[jira] [Commented] (FLINK-3942) Add support for INTERSECT

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350520#comment-15350520 ] ASF GitHub Bot commented on FLINK-3942: --- Github user wuchong commented on the issue:

[GitHub] flink issue #2159: [FLINK-3942] [tableAPI] Add support for INTERSECT

2016-06-27 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/2159 Hi @fhueske, that's a good idea to use CoGroup instead of Join. I updated the PR according to your advice. Meanwhile, I updated the document too (correct me if I describe wrong). NOTE:

[jira] [Commented] (FLINK-4119) Null checks in close() for Cassandra Input/Output Formats, checking arguments via Flink Preconditions

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350532#comment-15350532 ] ASF GitHub Bot commented on FLINK-4119: --- Github user rmetzger commented on the issue

[GitHub] flink issue #2163: [FLINK-4119] Null checks in close() for Cassandra Input/O...

2016-06-27 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2163 +1 to merge --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if th

[jira] [Comment Edited] (FLINK-2144) Incremental count, average, and variance for windows

2016-06-27 Thread Wenlong Lyu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350396#comment-15350396 ] Wenlong Lyu edited comment on FLINK-2144 at 6/27/16 7:57 AM: -

[GitHub] flink issue #2110: [FLINK-3974] Fix object reuse with multi-chaining

2016-06-27 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2110 Aw man, I already hat "rename to Test" in my commit but forgot to add that ... 😅 Thanks again, @tillrohrmann, I'll make the changes and merge. --- If your project is set up for it, you

[jira] [Commented] (FLINK-3974) enableObjectReuse fails when an operator chains to multiple downstream operators

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350557#comment-15350557 ] ASF GitHub Bot commented on FLINK-3974: --- Github user aljoscha commented on the issue

[jira] [Commented] (FLINK-4120) Lightweight fault tolerance through recomputing lost state

2016-06-27 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350565#comment-15350565 ] Gyula Fora commented on FLINK-4120: --- Hi, Thanks for the interesting proposal. I have se

[jira] [Updated] (FLINK-4120) Lightweight fault tolerance through recomputing lost state

2016-06-27 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-4120: -- Priority: Minor (was: Major) > Lightweight fault tolerance through recomputing lost state > ---

[jira] [Updated] (FLINK-4120) Lightweight fault tolerance through recomputing lost state

2016-06-27 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-4120: -- Component/s: (was: Core) State Backends, Checkpointing > Lightweight fault toleranc

[GitHub] flink issue #1813: [FLINK-3034] Redis Sink Connector

2016-06-27 Thread subhankarb
Github user subhankarb commented on the issue: https://github.com/apache/flink/pull/1813 @tzulitai, @mjsax thank you very much for your valuable feedback. 1) `additionalKey` was supposed to one time declaration for `SORTED_SET` and `HASH`. For `HASH` it is the value of hash na

[GitHub] flink issue #2150: [FLINK-3580] [table] Reintroduce Date/Time and implement ...

2016-06-27 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2150 @fhueske I have updated the PR. If there are no objections, I would merge it soon. So that it will be contained in the next release. --- If your project is set up for it, you can reply to this email

[jira] [Commented] (FLINK-3580) Reintroduce Date/Time and implement scalar functions for it

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350645#comment-15350645 ] ASF GitHub Bot commented on FLINK-3580: --- Github user twalthr commented on the issue:

[jira] [Commented] (FLINK-3034) Redis SInk Connector

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350646#comment-15350646 ] ASF GitHub Bot commented on FLINK-3034: --- Github user subhankarb commented on the iss

[GitHub] flink issue #1813: [FLINK-3034] Redis Sink Connector

2016-06-27 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/1813 Hi @subhankarb, Sorry, I just read the code and didn't realize you were using the `additionalKey` as the `setName` for `SORTED_SET`. I think this might be quite confusing for Redis

[jira] [Commented] (FLINK-3034) Redis SInk Connector

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350673#comment-15350673 ] ASF GitHub Bot commented on FLINK-3034: --- Github user tzulitai commented on the issue

[jira] [Commented] (FLINK-3951) Add Histogram Metric Type

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350675#comment-15350675 ] ASF GitHub Bot commented on FLINK-3951: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-4093) Expose metric interfaces

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350674#comment-15350674 ] ASF GitHub Bot commented on FLINK-4093: --- Github user zentol commented on the issue:

[GitHub] flink issue #2112: [FLINK-3951] Add histogram metric type

2016-06-27 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2112 merging --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feat

[GitHub] flink issue #2134: [FLINK-4093] Expose metric interfaces

2016-06-27 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2134 merging --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feat

[GitHub] flink issue #2157: [FLINK-4115] FsStateBackend filesystem verification can c...

2016-06-27 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2157 Thanks for the PR! I'll have a look and try and figure out if it's the right way to go. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as we

[jira] [Commented] (FLINK-4115) FsStateBackend filesystem verification can cause classpath exceptions

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350678#comment-15350678 ] ASF GitHub Bot commented on FLINK-4115: --- Github user aljoscha commented on the issue

[jira] [Commented] (FLINK-3034) Redis SInk Connector

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350685#comment-15350685 ] ASF GitHub Bot commented on FLINK-3034: --- Github user tzulitai commented on a diff in

[GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector

2016-06-27 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/1813#discussion_r68545039 --- Diff: flink-streaming-connectors/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisContainer.java ---

[jira] [Created] (FLINK-4121) Add timeunit (ms) to docs for timestamps and watermarks

2016-06-27 Thread Jonas Traub (JIRA)
Jonas Traub created FLINK-4121: -- Summary: Add timeunit (ms) to docs for timestamps and watermarks Key: FLINK-4121 URL: https://issues.apache.org/jira/browse/FLINK-4121 Project: Flink Issue Type:

[GitHub] flink issue #2163: [FLINK-4119] Null checks in close() for Cassandra Input/O...

2016-06-27 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2163 merging --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feat

[jira] [Commented] (FLINK-4119) Null checks in close() for Cassandra Input/Output Formats, checking arguments via Flink Preconditions

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350692#comment-15350692 ] ASF GitHub Bot commented on FLINK-4119: --- Github user zentol commented on the issue:

[GitHub] flink issue #2151: [hotfix][docs] Add warning to Cassandra documentation

2016-06-27 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2151 merging --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feat

[jira] [Commented] (FLINK-3034) Redis SInk Connector

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350696#comment-15350696 ] ASF GitHub Bot commented on FLINK-3034: --- Github user tzulitai commented on a diff in

[GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector

2016-06-27 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/1813#discussion_r68546159 --- Diff: flink-streaming-connectors/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisContainer.java ---

[GitHub] flink pull request #2165: [FLINK-4121] Add timeunit (ms) to docs for timesta...

2016-06-27 Thread powibol
GitHub user powibol opened a pull request: https://github.com/apache/flink/pull/2165 [FLINK-4121] Add timeunit (ms) to docs for timestamps and watermarks This PR inserts an explicit specification of the timeunit used in watermarks and timestamps in the documentation. (According to F

[jira] [Commented] (FLINK-4121) Add timeunit (ms) to docs for timestamps and watermarks

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350699#comment-15350699 ] ASF GitHub Bot commented on FLINK-4121: --- GitHub user powibol opened a pull request:

[jira] [Commented] (FLINK-4109) Change the name of ternary condition operator 'eval' to '?'

2016-06-27 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350709#comment-15350709 ] Aljoscha Krettek commented on FLINK-4109: - I think "?" is better than eval() since

[jira] [Assigned] (FLINK-4099) CliFrontendYarnAddressConfigurationTest fails

2016-06-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-4099: - Assignee: Robert Metzger > CliFrontendYarnAddressConfigurationTest fails > --

[jira] [Updated] (FLINK-4099) CliFrontendYarnAddressConfigurationTest fails

2016-06-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4099: -- Labels: test-stability (was: ) > CliFrontendYarnAddressConfigurationTest fails > --

[jira] [Commented] (FLINK-2144) Incremental count, average, and variance for windows

2016-06-27 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350714#comment-15350714 ] Aljoscha Krettek commented on FLINK-2144: - Hi, did you make any progress? I haven'

[GitHub] flink issue #2165: [FLINK-4121] Add timeunit (ms) to docs for timestamps and...

2016-06-27 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2165 I think it would be better to only have one place in the doc where we say that timestamps/watermarks are in milliseconds (with a red warning box, so it's visible). I can change it while merging --

[jira] [Commented] (FLINK-4121) Add timeunit (ms) to docs for timestamps and watermarks

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350720#comment-15350720 ] ASF GitHub Bot commented on FLINK-4121: --- Github user aljoscha commented on the issue

[GitHub] flink pull request #2166: [FLINK-4099] Fix CliFrontendYarnAddressConfigurati...

2016-06-27 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/2166 [FLINK-4099] Fix CliFrontendYarnAddressConfigurationTest failures You can merge this pull request into a Git repository by running: $ git pull https://github.com/rmetzger/flink flink4099 Alt

[jira] [Commented] (FLINK-4099) CliFrontendYarnAddressConfigurationTest fails

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350721#comment-15350721 ] ASF GitHub Bot commented on FLINK-4099: --- GitHub user rmetzger opened a pull request:

[GitHub] flink pull request #2149: [FLINK-4084] Add configDir parameter to CliFronten...

2016-06-27 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2149#discussion_r68550160 --- Diff: docs/apis/cli.md --- @@ -187,6 +187,8 @@ Action "run" compiles and runs a program. java.net.URLClassLoader

[jira] [Commented] (FLINK-4084) Add configDir parameter to CliFrontend and flink shell script

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350724#comment-15350724 ] ASF GitHub Bot commented on FLINK-4084: --- Github user mxm commented on a diff in the

[jira] [Commented] (FLINK-4084) Add configDir parameter to CliFrontend and flink shell script

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350722#comment-15350722 ] ASF GitHub Bot commented on FLINK-4084: --- Github user mxm commented on a diff in the

[GitHub] flink pull request #2149: [FLINK-4084] Add configDir parameter to CliFronten...

2016-06-27 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2149#discussion_r68550234 --- Diff: flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java --- @@ -132,9 +132,9 @@ - private final Configuration confi

[GitHub] flink pull request #2149: [FLINK-4084] Add configDir parameter to CliFronten...

2016-06-27 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2149#discussion_r68550224 --- Diff: flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java --- @@ -132,9 +132,9 @@ - private final Configuration confi

[jira] [Commented] (FLINK-4084) Add configDir parameter to CliFrontend and flink shell script

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350723#comment-15350723 ] ASF GitHub Bot commented on FLINK-4084: --- Github user mxm commented on a diff in the

[GitHub] flink pull request #2149: [FLINK-4084] Add configDir parameter to CliFronten...

2016-06-27 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2149#discussion_r68550677 --- Diff: flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java --- @@ -76,6 +76,9 @@ static final Option SAVEPOINT_DISPOSE_OPTI

[jira] [Commented] (FLINK-4084) Add configDir parameter to CliFrontend and flink shell script

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350727#comment-15350727 ] ASF GitHub Bot commented on FLINK-4084: --- Github user mxm commented on a diff in the

[GitHub] flink pull request #2149: [FLINK-4084] Add configDir parameter to CliFronten...

2016-06-27 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2149#discussion_r68550807 --- Diff: flink-clients/src/test/java/org/apache/flink/client/CliFrontendRunTest.java --- @@ -98,6 +98,12 @@ public void testRun() {

[jira] [Commented] (FLINK-4084) Add configDir parameter to CliFrontend and flink shell script

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350730#comment-15350730 ] ASF GitHub Bot commented on FLINK-4084: --- Github user mxm commented on a diff in the

[GitHub] flink pull request #2149: [FLINK-4084] Add configDir parameter to CliFronten...

2016-06-27 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2149#discussion_r68551023 --- Diff: flink-dist/src/main/flink-bin/bin/flink --- @@ -17,6 +17,20 @@ # limitations under the License. ##

[jira] [Commented] (FLINK-4084) Add configDir parameter to CliFrontend and flink shell script

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350731#comment-15350731 ] ASF GitHub Bot commented on FLINK-4084: --- Github user mxm commented on a diff in the

[GitHub] flink pull request #2149: [FLINK-4084] Add configDir parameter to CliFronten...

2016-06-27 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2149#discussion_r68551210 --- Diff: flink-dist/src/main/flink-bin/bin/flink --- @@ -33,6 +47,22 @@ while [ -L "$target" ]; do iteration=$((iteration + 1)) done +

[jira] [Commented] (FLINK-4084) Add configDir parameter to CliFrontend and flink shell script

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350732#comment-15350732 ] ASF GitHub Bot commented on FLINK-4084: --- Github user mxm commented on a diff in the

[GitHub] flink issue #2149: [FLINK-4084] Add configDir parameter to CliFrontend and f...

2016-06-27 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2149 Thanks for the pull request! I've made some comments. The pull requests also needs to be rebased against the latest master. --- If your project is set up for it, you can reply to this email and have you

[jira] [Commented] (FLINK-4084) Add configDir parameter to CliFrontend and flink shell script

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350735#comment-15350735 ] ASF GitHub Bot commented on FLINK-4084: --- Github user mxm commented on the issue:

[GitHub] flink pull request #2166: [FLINK-4099] Fix CliFrontendYarnAddressConfigurati...

2016-06-27 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2166#discussion_r68551820 --- Diff: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java --- @@ -593,7 +593,12 @@ public void sendStop() { //

[jira] [Commented] (FLINK-4099) CliFrontendYarnAddressConfigurationTest fails

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350739#comment-15350739 ] ASF GitHub Bot commented on FLINK-4099: --- Github user mxm commented on a diff in the

[GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector

2016-06-27 Thread subhankarb
Github user subhankarb commented on a diff in the pull request: https://github.com/apache/flink/pull/1813#discussion_r68551999 --- Diff: flink-streaming-connectors/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisContainer.java ---

[jira] [Commented] (FLINK-3034) Redis SInk Connector

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350742#comment-15350742 ] ASF GitHub Bot commented on FLINK-3034: --- Github user subhankarb commented on a diff

[GitHub] flink pull request #2165: [FLINK-4121] Add timeunit (ms) to docs for timesta...

2016-06-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2165 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (FLINK-4121) Add timeunit (ms) to docs for timestamps and watermarks

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350743#comment-15350743 ] ASF GitHub Bot commented on FLINK-4121: --- Github user asfgit closed the pull request

[jira] [Resolved] (FLINK-4121) Add timeunit (ms) to docs for timestamps and watermarks

2016-06-27 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-4121. - Resolution: Fixed Fix Version/s: 1.1.0 Added in https://github.com/apache/flink/co

[GitHub] flink issue #2151: [hotfix][docs] Add warning to Cassandra documentation

2016-06-27 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2151 Forgot to add the close message, can you close this PR manually @rmetzger ? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your proj

[GitHub] flink pull request #2151: [hotfix][docs] Add warning to Cassandra documentat...

2016-06-27 Thread rmetzger
Github user rmetzger closed the pull request at: https://github.com/apache/flink/pull/2151 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is en

[GitHub] flink issue #2151: [hotfix][docs] Add warning to Cassandra documentation

2016-06-27 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2151 Sure. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feat

[jira] [Commented] (FLINK-4087) JMXReporter can't handle port conflicts

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350753#comment-15350753 ] ASF GitHub Bot commented on FLINK-4087: --- Github user tillrohrmann commented on the i

[GitHub] flink issue #2145: [FLINK-4087] [metrics] Improved JMX port handling

2016-06-27 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2145 Excellent @zentol :-) +1 for merging. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[GitHub] flink pull request #2163: [FLINK-4119] Null checks in close() for Cassandra ...

2016-06-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2163 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (FLINK-4119) Null checks in close() for Cassandra Input/Output Formats, checking arguments via Flink Preconditions

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350755#comment-15350755 ] ASF GitHub Bot commented on FLINK-4119: --- Github user asfgit closed the pull request

[GitHub] flink issue #2105: [FLINK-4074] Make metric reporters less blocking

2016-06-27 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2105 Very good work @zentol. +1 for merging. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have thi

[jira] [Commented] (FLINK-4074) Reporter can block TaskManager shutdown

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350757#comment-15350757 ] ASF GitHub Bot commented on FLINK-4074: --- Github user tillrohrmann commented on the i

[jira] [Closed] (FLINK-4119) Null checks in close() for Cassandra Input/Output Formats, checking arguments via Flink Preconditions

2016-06-27 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4119. --- Resolution: Fixed Implemented in 9487fcbfbae85caf82729e0dda5403fab2fb7d84 > Null checks in cl

[jira] [Created] (FLINK-4122) Cassandra jar contains 2 guava versions

2016-06-27 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-4122: --- Summary: Cassandra jar contains 2 guava versions Key: FLINK-4122 URL: https://issues.apache.org/jira/browse/FLINK-4122 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-3964) Job submission times out with recursive.file.enumeration

2016-06-27 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350759#comment-15350759 ] Maximilian Michels commented on FLINK-3964: --- I see where you're going. That's cu

[GitHub] flink pull request #2167: [FLINK-4122] Disable root shading in Cassandra jar

2016-06-27 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/2167 [FLINK-4122] Disable root shading in Cassandra jar This PR overrides the root pom's guava shading configuration, so that the JAR does not contain both shaded versions of guava. You can merge this pu

[jira] [Commented] (FLINK-4122) Cassandra jar contains 2 guava versions

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350762#comment-15350762 ] ASF GitHub Bot commented on FLINK-4122: --- GitHub user zentol opened a pull request:

[jira] [Created] (FLINK-4123) CassandraWriteAheadSink can hang on cassandra failure

2016-06-27 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-4123: --- Summary: CassandraWriteAheadSink can hang on cassandra failure Key: FLINK-4123 URL: https://issues.apache.org/jira/browse/FLINK-4123 Project: Flink Iss

[GitHub] flink pull request #2168: [FLINK-3964] add hint to job submission timeout ex...

2016-06-27 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/2168 [FLINK-3964] add hint to job submission timeout exception message You can merge this pull request into a Git repository by running: $ git pull https://github.com/mxm/flink FLINK-3964 Alternative

[jira] [Commented] (FLINK-3964) Job submission times out with recursive.file.enumeration

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350768#comment-15350768 ] ASF GitHub Bot commented on FLINK-3964: --- GitHub user mxm opened a pull request:

[jira] [Updated] (FLINK-3710) ScalaDocs for org.apache.flink.streaming.scala are missing from the web site

2016-06-27 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3710: -- Fix Version/s: 1.0.4 > ScalaDocs for org.apache.flink.streaming.scala are missing from t

[jira] [Updated] (FLINK-3710) ScalaDocs for org.apache.flink.streaming.scala are missing from the web site

2016-06-27 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3710: -- Fix Version/s: 1.1.0 > ScalaDocs for org.apache.flink.streaming.scala are missing from t

[jira] [Commented] (FLINK-3710) ScalaDocs for org.apache.flink.streaming.scala are missing from the web site

2016-06-27 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350783#comment-15350783 ] Maximilian Michels commented on FLINK-3710: --- Thanks for reporting! We need to in

[GitHub] flink issue #2105: [FLINK-4074] Make metric reporters less blocking

2016-06-27 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2105 merging --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feat

[jira] [Commented] (FLINK-4087) JMXReporter can't handle port conflicts

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350791#comment-15350791 ] ASF GitHub Bot commented on FLINK-4087: --- Github user zentol commented on the issue:

[GitHub] flink issue #2145: [FLINK-4087] [metrics] Improved JMX port handling

2016-06-27 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2145 merging --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feat

[jira] [Commented] (FLINK-4074) Reporter can block TaskManager shutdown

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350790#comment-15350790 ] ASF GitHub Bot commented on FLINK-4074: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-3231) Handle Kinesis-side resharding in Kinesis streaming consumer

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350793#comment-15350793 ] ASF GitHub Bot commented on FLINK-3231: --- Github user rmetzger commented on a diff in

[GitHub] flink pull request #2131: [FLINK-3231][streaming-connectors] FlinkKinesisCon...

2016-06-27 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2131#discussion_r68558779 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxyInterface.java ---

[jira] [Closed] (FLINK-4074) Reporter can block TaskManager shutdown

2016-06-27 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4074. --- Resolution: Fixed Fixed in 56cdec7d81a53f9ea9578ca274c149f9758b5ffd > Reporter can block Task

[jira] [Commented] (FLINK-4074) Reporter can block TaskManager shutdown

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350795#comment-15350795 ] ASF GitHub Bot commented on FLINK-4074: --- Github user asfgit closed the pull request

[GitHub] flink pull request #2105: [FLINK-4074] Make metric reporters less blocking

2016-06-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2105 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (FLINK-3297) Streaming connector for ZeroMQ

2016-06-27 Thread Omar Alvarez (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350796#comment-15350796 ] Omar Alvarez commented on FLINK-3297: - I have started work on this on: https://github

[GitHub] flink pull request #2145: [FLINK-4087] [metrics] Improved JMX port handling

2016-06-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2145 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Closed] (FLINK-4087) JMXReporter can't handle port conflicts

2016-06-27 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4087. --- Resolution: Fixed Fixed in 62cb954d989e3ed36f6d9ab7daeff93cda64adbb > JMXReporter can't handl

[jira] [Commented] (FLINK-4087) JMXReporter can't handle port conflicts

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350800#comment-15350800 ] ASF GitHub Bot commented on FLINK-4087: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-4113) Always copy first value in ChainedAllReduceDriver

2016-06-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350808#comment-15350808 ] ASF GitHub Bot commented on FLINK-4113: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2156: [FLINK-4113] [runtime] Always copy first value in ...

2016-06-27 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2156#discussion_r68560241 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/operators/chaining/ChainedAllReduceDriver.java --- @@ -89,7 +89,7 @@ public void collect(

[jira] [Assigned] (FLINK-3675) YARN ship folder incosistent behavior

2016-06-27 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-3675: - Assignee: Maximilian Michels > YARN ship folder incosistent behavior > --

[jira] [Commented] (FLINK-3297) Streaming connector for ZeroMQ

2016-06-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350807#comment-15350807 ] Robert Metzger commented on FLINK-3297: --- Thanks a lot for starting to work on this.

  1   2   3   4   >