[GitHub] flink issue #2233: [FLINK-2125][streaming] Delimiter change from char to str...

2016-07-15 Thread delding
Github user delding commented on the issue: https://github.com/apache/flink/pull/2233 Hi @zentol , If you agree with @StephanEwen 's suggestion, I will update this PR in his way. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-2125) String delimiter for SocketTextStream

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

[jira] [Comment Edited] (FLINK-4194) KinesisDeserializationSchema.isEndOfStream() is never called

2016-07-15 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15378902#comment-15378902 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4194 at 7/15/16 7:07 AM: ---

[jira] [Comment Edited] (FLINK-4194) KinesisDeserializationSchema.isEndOfStream() is never called

2016-07-15 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15378902#comment-15378902 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4194 at 7/15/16 7:22 AM: ---

[jira] [Comment Edited] (FLINK-4194) KinesisDeserializationSchema.isEndOfStream() is never called

2016-07-15 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15378902#comment-15378902 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4194 at 7/15/16 7:24 AM: ---

[jira] [Comment Edited] (FLINK-4194) KinesisDeserializationSchema.isEndOfStream() is never called

2016-07-15 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15378902#comment-15378902 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4194 at 7/15/16 7:25 AM: ---

[jira] [Comment Edited] (FLINK-4194) KinesisDeserializationSchema.isEndOfStream() is never called

2016-07-15 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15378902#comment-15378902 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4194 at 7/15/16 7:27 AM: ---

[jira] [Comment Edited] (FLINK-4194) KinesisDeserializationSchema.isEndOfStream() is never called

2016-07-15 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15378902#comment-15378902 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4194 at 7/15/16 7:32 AM: ---

[GitHub] flink pull request #:

2016-07-15 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/commit/2477161352e12e75e2f0f85b5833ad04dc6d31f2#commitcomment-18257970 In flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTaskState.java: In flink-streaming-java/sr

[GitHub] flink pull request #2249: 4166 zookeeper namespaces

2016-07-15 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2249#discussion_r70935614 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java --- @@ -545,6 +551,19 @@ protected YarnClusterClient deployInterna

[GitHub] flink pull request #2249: 4166 zookeeper namespaces

2016-07-15 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2249#discussion_r70935698 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java --- @@ -545,6 +551,19 @@ protected YarnClusterClient deployInterna

[jira] [Commented] (FLINK-4211) Dynamic Properties not working for jobs submitted to Yarn session

2016-07-15 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15378999#comment-15378999 ] Stefan Richter commented on FLINK-4211: --- I see. I think unfortunately this is not re

[jira] [Commented] (FLINK-1502) Expose metrics to graphite, ganglia and JMX.

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

[GitHub] flink issue #1947: [FLINK-1502] [WIP] Basic Metric System

2016-07-15 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/1947 What do you mean by "Job writers"? --- 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 an

[jira] [Commented] (FLINK-4218) Sporadic "java.lang.RuntimeException: Error triggering a checkpoint..." causes task restarting

2016-07-15 Thread Sergii Koshel (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15379007#comment-15379007 ] Sergii Koshel commented on FLINK-4218: -- AWS promised to have *read-after-write* consi

[GitHub] flink issue #2249: 4166 zookeeper namespaces

2016-07-15 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/2249 I addressed the valid comments and added some tests. --- 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 ha

[GitHub] flink issue #2254: [FLINK-3630] [docs] Little mistake in documentation

2016-07-15 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2254 Changes look good! Thanks --- 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,

[jira] [Commented] (FLINK-3630) Little mistake in documentation

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

[jira] [Created] (FLINK-4220) ClientTest fails after port conflict

2016-07-15 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-4220: -- Summary: ClientTest fails after port conflict Key: FLINK-4220 URL: https://issues.apache.org/jira/browse/FLINK-4220 Project: Flink Issue Type: Bug Comp

[jira] [Commented] (FLINK-3516) JobManagerHACheckpointRecoveryITCase testCheckpointedStreamingSumProgram fails

2016-07-15 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15379068#comment-15379068 ] Ufuk Celebi commented on FLINK-3516: https://travis-ci.org/apache/flink/builds/1448423

[GitHub] flink pull request #2252: [FLINK-3466] [runtime] Cancel state handled on sta...

2016-07-15 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/2252#discussion_r70943314 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractCloseableHandle.java --- @@ -0,0 +1,131 @@ +/* + * Licensed to the Apache So

[jira] [Assigned] (FLINK-4142) Recovery problem in HA on Hadoop Yarn 2.4.1

2016-07-15 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-4142: - Assignee: Robert Metzger > Recovery problem in HA on Hadoop Yarn 2.4.1 >

[jira] [Commented] (FLINK-3466) Job might get stuck in restoreState() from HDFS due to interrupt

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

[jira] [Commented] (FLINK-4142) Recovery problem in HA on Hadoop Yarn 2.4.1

2016-07-15 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15379079#comment-15379079 ] Robert Metzger commented on FLINK-4142: --- Thank you for posting a log as well. It se

[GitHub] flink pull request #2252: [FLINK-3466] [runtime] Cancel state handled on sta...

2016-07-15 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/2252#discussion_r70944104 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/AbstractFileStateHandle.java --- @@ -20,18 +20,21 @@ import org.apache

[jira] [Commented] (FLINK-3466) Job might get stuck in restoreState() from HDFS due to interrupt

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

[GitHub] flink pull request #2255: [FLINK-4142][docs] Add warning about YARN HA bug

2016-07-15 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/2255 [FLINK-4142][docs] Add warning about YARN HA bug There is a bug in YARN 2.4.0 preventing container starts from a re-started application master. This is how the updated documentation looks

[jira] [Commented] (FLINK-4142) Recovery problem in HA on Hadoop Yarn 2.4.1

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

[GitHub] flink pull request #2252: [FLINK-3466] [runtime] Cancel state handled on sta...

2016-07-15 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/2252#discussion_r70946219 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/InterruptSensitiveRestoreTest.java --- @@ -0,0 +1,223 @@ +/* + * Li

[jira] [Commented] (FLINK-3466) Job might get stuck in restoreState() from HDFS due to interrupt

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

[jira] [Commented] (FLINK-3466) Job might get stuck in restoreState() from HDFS due to interrupt

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

[GitHub] flink pull request #2252: [FLINK-3466] [runtime] Cancel state handled on sta...

2016-07-15 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/2252#discussion_r70946878 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/memory/AbstractMemStateSnapshot.java --- @@ -54,6 +56,8 @@ /** The serialized

[GitHub] flink issue #2252: [FLINK-3466] [runtime] Cancel state handled on state rest...

2016-07-15 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2252 Looks very good! The test failures seem unrelated: - ClientTest: https://issues.apache.org/jira/browse/FLINK-4220 (newly created) - JobManagerHACheckpointRecoveryITCase: https://issues.apach

[jira] [Commented] (FLINK-4142) Recovery problem in HA on Hadoop Yarn 2.4.1

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

[jira] [Commented] (FLINK-3466) Job might get stuck in restoreState() from HDFS due to interrupt

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

[GitHub] flink issue #2241: [FLINK-3666] Remove all remaining Nephele references

2016-07-15 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2241 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 #2246: [hotfix] [doc] fixed example

2016-07-15 Thread mjsax
Github user mjsax commented on the issue: https://github.com/apache/flink/pull/2246 @rmetzger yes --- 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

[GitHub] flink issue #2255: [FLINK-4142][docs] Add warning about YARN HA bug

2016-07-15 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2255 Nice! +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 t

[jira] [Commented] (FLINK-3666) Remove Nephele references

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

[GitHub] flink issue #2254: [FLINK-3630] [docs] Little mistake in documentation

2016-07-15 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2254 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-3630) Little mistake in documentation

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

[GitHub] flink issue #2243: [FLINK-4196] [runtime] Remove recovery timestamp from che...

2016-07-15 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2243 @StephanEwen Could you close the PR? --- 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

[jira] [Commented] (FLINK-4196) Remove "recoveryTimestamp"

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

[GitHub] flink pull request #2241: [FLINK-3666] Remove all remaining Nephele referenc...

2016-07-15 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/2241 --- 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-3666) Remove Nephele references

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

[jira] [Closed] (FLINK-3666) Remove Nephele references

2016-07-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-3666. --- Resolution: Fixed Fix Version/s: 1.1.0 Fixed in 273f54ba4357ccc4e4ade35b8967f0fa607a1ea

[GitHub] flink issue #2135: [hotfix] [metrics] Prevent log flooding from collisions

2016-07-15 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2135 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 pull request #2254: [FLINK-3630] [docs] Little mistake in documentatio...

2016-07-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2254 --- 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-3630) Little mistake in documentation

2016-07-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-3630. --- Resolution: Fixed Fix Version/s: 1.1.0 Fixed in 9a2057310eb22bae2601f2635b201e3a168a0fe

[jira] [Commented] (FLINK-3630) Little mistake in documentation

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

[jira] [Commented] (FLINK-4142) Recovery problem in HA on Hadoop Yarn 2.4.1

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

[GitHub] flink pull request #2135: [hotfix] [metrics] Prevent log flooding from colli...

2016-07-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2135 --- 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

[GitHub] flink issue #2255: [FLINK-4142][docs] Add warning about YARN HA bug

2016-07-15 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2255 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-4142) Recovery problem in HA on Hadoop Yarn 2.4.1

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

[GitHub] flink pull request #2255: [FLINK-4142][docs] Add warning about YARN HA bug

2016-07-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2255 --- 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

[GitHub] flink issue #2186: [licenses] Remove not included dependency from LICENSE

2016-07-15 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2186 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 pull request #2186: [licenses] Remove not included dependency from LIC...

2016-07-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2186 --- 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

[GitHub] flink issue #2233: [FLINK-2125][streaming] Delimiter change from char to str...

2016-07-15 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2233 Yes, `@PublicEvolving` allows us to change things, but it is still nice for users if we give them a smooth transition :-) --- If your project is set up for it, you can reply to this email and ha

[GitHub] flink issue #2128: [FLINK-4053] Return value from Connection should be check...

2016-07-15 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2128 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-4053) Return value from Connection should be checked against null

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

[jira] [Commented] (FLINK-2125) String delimiter for SocketTextStream

2016-07-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15379171#comment-15379171 ] ASF GitHub Bot commented on FLINK-2125: --- Github user StephanEwen commented on the is

[GitHub] flink pull request #2243: [FLINK-4196] [runtime] Remove recovery timestamp f...

2016-07-15 Thread StephanEwen
Github user StephanEwen closed the pull request at: https://github.com/apache/flink/pull/2243 --- 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

[GitHub] flink issue #2243: [FLINK-4196] [runtime] Remove recovery timestamp from che...

2016-07-15 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2243 Yes, thanks! Manually merged in de6a3d33ecfa689fd0da1ef661bbf6edb68e9d0b --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. I

[jira] [Commented] (FLINK-4196) Remove "recoveryTimestamp"

2016-07-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15379175#comment-15379175 ] ASF GitHub Bot commented on FLINK-4196: --- Github user StephanEwen closed the pull req

[jira] [Commented] (FLINK-4196) Remove "recoveryTimestamp"

2016-07-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15379174#comment-15379174 ] ASF GitHub Bot commented on FLINK-4196: --- Github user StephanEwen commented on the is

[GitHub] flink pull request #2128: [FLINK-4053] Return value from Connection should b...

2016-07-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2128 --- 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-4053) Return value from Connection should be checked against null

2016-07-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4053. --- Resolution: Fixed Fix Version/s: 1.1.0 Fixed in a0c3b879b25b5e935e9540422b50bbc031a2073

[jira] [Commented] (FLINK-4017) [py] Add Aggregation support to Python API

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

[GitHub] flink issue #2115: [FLINK-4017] [py] Add Aggregation support to Python API

2016-07-15 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2115 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-4053) Return value from Connection should be checked against null

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

[jira] [Closed] (FLINK-4017) [py] Add Aggregation support to Python API

2016-07-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4017. --- Resolution: Fixed Fix Version/s: 1.1.0 Implemented in 2218cb4c1f21479704ff51b1841d8f1ff

[jira] [Commented] (FLINK-4017) [py] Add Aggregation support to Python API

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

[GitHub] flink pull request #2115: [FLINK-4017] [py] Add Aggregation support to Pytho...

2016-07-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2115 --- 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

[GitHub] flink issue #2233: [FLINK-2125][streaming] Delimiter change from char to str...

2016-07-15 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2233 ok, go ahead then. --- 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

[jira] [Commented] (FLINK-2125) String delimiter for SocketTextStream

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

[jira] [Created] (FLINK-4221) Show metrics in WebFrontend

2016-07-15 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-4221: --- Summary: Show metrics in WebFrontend Key: FLINK-4221 URL: https://issues.apache.org/jira/browse/FLINK-4221 Project: Flink Issue Type: Sub-task

[GitHub] flink issue #2248: [FLINK-4213] [gelly] Provide CombineHint in Gelly algorit...

2016-07-15 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2248 Depends how much faster we can make sorting in the `NormalizedKeySorter` :) I'll keep working on a comparison, I've been running into the deadlock in FLINK-4163. --- If your project is se

[jira] [Commented] (FLINK-4213) Provide CombineHint in Gelly algorithms

2016-07-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15379210#comment-15379210 ] ASF GitHub Bot commented on FLINK-4213: --- Github user greghogan commented on the issu

[GitHub] flink issue #2128: [FLINK-4053] Return value from Connection should be check...

2016-07-15 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2128 Thank you @zentol ! --- 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,

[jira] [Commented] (FLINK-4053) Return value from Connection should be checked against null

2016-07-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15379216#comment-15379216 ] ASF GitHub Bot commented on FLINK-4053: --- Github user mushketyk commented on the issu

[jira] [Commented] (FLINK-4192) Move Metrics API to separate module

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

[GitHub] flink issue #2226: [FLINK-4192] - Move Metrics API to separate module

2016-07-15 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2226 @StephanEwen I've changed the `MetricConfig`to extend `Properties` and remove the `setString()` method. I've kept the other methods for now. --- If your project is set up for it, you can reply to thi

[GitHub] flink pull request #2252: [FLINK-3466] [runtime] Cancel state handled on sta...

2016-07-15 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2252#discussion_r70956526 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/memory/AbstractMemStateSnapshot.java --- @@ -54,6 +56,8 @@ /** The ser

[jira] [Commented] (FLINK-3466) Job might get stuck in restoreState() from HDFS due to interrupt

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

[jira] [Commented] (FLINK-3466) Job might get stuck in restoreState() from HDFS due to interrupt

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

[jira] [Commented] (FLINK-3466) Job might get stuck in restoreState() from HDFS due to interrupt

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

[GitHub] flink pull request #2252: [FLINK-3466] [runtime] Cancel state handled on sta...

2016-07-15 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2252#discussion_r70956828 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractCloseableHandle.java --- @@ -0,0 +1,131 @@ +/* + * Licensed to the A

[GitHub] flink pull request #2252: [FLINK-3466] [runtime] Cancel state handled on sta...

2016-07-15 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2252#discussion_r70956861 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/AbstractFileStateHandle.java --- @@ -20,18 +20,21 @@ import or

[GitHub] flink pull request #2252: [FLINK-3466] [runtime] Cancel state handled on sta...

2016-07-15 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2252#discussion_r70956813 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/InterruptSensitiveRestoreTest.java --- @@ -0,0 +1,223 @@ +/*

[jira] [Commented] (FLINK-3466) Job might get stuck in restoreState() from HDFS due to interrupt

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

[jira] [Commented] (FLINK-4218) Sporadic "java.lang.RuntimeException: Error triggering a checkpoint..." causes task restarting

2016-07-15 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15379254#comment-15379254 ] Stephan Ewen commented on FLINK-4218: - The read-after-write consistency seems to hold

[jira] [Commented] (FLINK-4210) Move close()/isClosed() out of MetricGroup interface

2016-07-15 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15379258#comment-15379258 ] Stephan Ewen commented on FLINK-4210: - So, the Flink runtime metrics for an operator a

[jira] [Commented] (FLINK-3397) Failed streaming jobs should fall back to the most recent checkpoint/savepoint

2016-07-15 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15379266#comment-15379266 ] ramkrishna.s.vasudevan commented on FLINK-3397: --- [~uce] Just a gentle remind

[GitHub] flink issue #2252: [FLINK-3466] [runtime] Cancel state handled on state rest...

2016-07-15 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2252 Thanks, I'll address your comments and merge this... --- 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

[jira] [Commented] (FLINK-3466) Job might get stuck in restoreState() from HDFS due to interrupt

2016-07-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15379270#comment-15379270 ] ASF GitHub Bot commented on FLINK-3466: --- Github user StephanEwen commented on the is

[jira] [Commented] (FLINK-4210) Move close()/isClosed() out of MetricGroup interface

2016-07-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15379276#comment-15379276 ] Chesnay Schepler commented on FLINK-4210: - initially there was a separate group fo

[GitHub] flink issue #2251: [FLINK-4212] [scripts] Lock PID file when starting daemon...

2016-07-15 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2251 Is the `flock` command available by default on the common UNIX-style OSs? Ubuntu has it by default, what about MacOS? --- If your project is set up for it, you can reply to this email an

[jira] [Commented] (FLINK-4212) Lock PID file when starting daemons

2016-07-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15379288#comment-15379288 ] ASF GitHub Bot commented on FLINK-4212: --- Github user StephanEwen commented on the is

[jira] [Commented] (FLINK-4212) Lock PID file when starting daemons

2016-07-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15379313#comment-15379313 ] ASF GitHub Bot commented on FLINK-4212: --- Github user greghogan commented on the issu

[GitHub] flink issue #2251: [FLINK-4212] [scripts] Lock PID file when starting daemon...

2016-07-15 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2251 Looks like it is available in Linux and BSD but not MacOS. We can skip locking if `flock` is not available. The race condition only manifests when starting duplicate managers on the same system in

  1   2   >