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

[ https://issues.apache.org/jira/browse/FLINK-3297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350807#comment-15350807 ] Robert Metzger edited comment on FLINK-3297 at 6/27/16 11:22 AM: ---

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

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2156 Good fix @greghogan. We should definitely include it in the upcoming release. Would it be possible to write a test to guard the fix from future changes? --- If your project is set up for it, y

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

[ https://issues.apache.org/jira/browse/FLINK-4113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350810#comment-15350810 ] ASF GitHub Bot commented on FLINK-4113: --- Github user tillrohrmann commented on the i

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

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2131#discussion_r68560835 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardDiscoverer.java ---

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

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

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350822#comment-15350822 ] ASF GitHub Bot commented on FLINK-4116: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68561771 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68561851 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68561918 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350824#comment-15350824 ] ASF GitHub Bot commented on FLINK-4116: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350825#comment-15350825 ] ASF GitHub Bot commented on FLINK-4116: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68562012 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68562169 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68562093 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350826#comment-15350826 ] ASF GitHub Bot commented on FLINK-4116: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350827#comment-15350827 ] ASF GitHub Bot commented on FLINK-4116: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68562298 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350830#comment-15350830 ] ASF GitHub Bot commented on FLINK-4116: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68562330 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350834#comment-15350834 ] ASF GitHub Bot commented on FLINK-4116: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350836#comment-15350836 ] ASF GitHub Bot commented on FLINK-4116: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68562801 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350843#comment-15350843 ] ASF GitHub Bot commented on FLINK-4116: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68562924 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350845#comment-15350845 ] ASF GitHub Bot commented on FLINK-4116: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350848#comment-15350848 ] ASF GitHub Bot commented on FLINK-4116: --- Github user tillrohrmann commented on a dif

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

[ https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350850#comment-15350850 ] 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...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2131#discussion_r68562955 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java ---

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68562873 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68563031 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68562986 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68563067 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350853#comment-15350853 ] ASF GitHub Bot commented on FLINK-4116: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350854#comment-15350854 ] ASF GitHub Bot commented on FLINK-4116: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68563125 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350852#comment-15350852 ] ASF GitHub Bot commented on FLINK-4116: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350855#comment-15350855 ] ASF GitHub Bot commented on FLINK-4116: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68563243 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350857#comment-15350857 ] ASF GitHub Bot commented on FLINK-4116: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350859#comment-15350859 ] ASF GitHub Bot commented on FLINK-4116: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68563199 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68563419 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68563569 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350863#comment-15350863 ] ASF GitHub Bot commented on FLINK-4116: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350864#comment-15350864 ] ASF GitHub Bot commented on FLINK-4116: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68563676 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68563758 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350867#comment-15350867 ] ASF GitHub Bot commented on FLINK-4116: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68563783 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350866#comment-15350866 ] ASF GitHub Bot commented on FLINK-4116: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350868#comment-15350868 ] ASF GitHub Bot commented on FLINK-4116: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68563905 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350871#comment-15350871 ] ASF GitHub Bot commented on FLINK-4116: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68564011 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68564061 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350873#comment-15350873 ] ASF GitHub Bot commented on FLINK-4116: --- Github user tillrohrmann commented on a dif

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

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2131#discussion_r68564082 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java ---

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350876#comment-15350876 ] ASF GitHub Bot commented on FLINK-4116: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68564101 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the

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

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

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350874#comment-15350874 ] ASF GitHub Bot commented on FLINK-4116: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68564162 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68564218 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350881#comment-15350881 ] ASF GitHub Bot commented on FLINK-4116: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350878#comment-15350878 ] ASF GitHub Bot commented on FLINK-4116: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68564233 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350879#comment-15350879 ] ASF GitHub Bot commented on FLINK-4116: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68564208 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68564324 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350882#comment-15350882 ] ASF GitHub Bot commented on FLINK-4116: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350884#comment-15350884 ] ASF GitHub Bot commented on FLINK-4116: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68564604 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350886#comment-15350886 ] ASF GitHub Bot commented on FLINK-4116: --- Github user tillrohrmann commented on a dif

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

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2131#discussion_r68564678 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardDiscoverer.java ---

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

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

[GitHub] flink issue #2158: [FLINK-4116] Metrics documentation

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2158 Good first draft of the metrics documentation @zentol. I think the documentation should be a bit more verbose containing more explanations and code examples. This will help the user to quickly g

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350890#comment-15350890 ] ASF GitHub Bot commented on FLINK-4116: --- Github user tillrohrmann commented on the i

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-4113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350900#comment-15350900 ] ASF GitHub Bot commented on FLINK-4113: --- Github user greghogan commented on a diff i

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

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

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68567416 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the execu

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

[ https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350910#comment-15350910 ] ASF GitHub Bot commented on FLINK-4084: --- Github user alkagin commented on a diff in

[jira] [Commented] (FLINK-4110) Provide testing skeleton in quickstarts

[ https://issues.apache.org/jira/browse/FLINK-4110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350914#comment-15350914 ] ASF GitHub Bot commented on FLINK-4110: --- Github user tillrohrmann commented on the i

[GitHub] flink issue #2153: [FLINK-4110] Add testing skeleton to quickstart

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2153 I think these tests are far too specific for the quickstarts. Why starting your own Flink cluster when the local execution environment would do the same? People using the quickstarts should not

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350911#comment-15350911 ] ASF GitHub Bot commented on FLINK-4116: --- Github user zentol commented on a diff in t

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

Github user alkagin commented on a diff in the pull request: https://github.com/apache/flink/pull/2149#discussion_r68568030 --- Diff: flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java --- @@ -132,9 +132,9 @@ - private final Configuration c

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

[ https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350919#comment-15350919 ] ASF GitHub Bot commented on FLINK-4084: --- Github user alkagin commented on a diff in

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r68571093 --- Diff: docs/apis/common/index.md --- @@ -1350,3 +1350,211 @@ You may specify program arguments before the job is executed. The plan visualiza the execu

[jira] [Commented] (FLINK-4116) Document metrics

[ https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350944#comment-15350944 ] ASF GitHub Bot commented on FLINK-4116: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #2083: [FLINK-3713] [clients, runtime] Use user code clas...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2083#discussion_r68571489 --- Diff: docs/apis/cli.md --- @@ -279,13 +289,27 @@ guarantees for a stop request. Action "savepoint" triggers savepoints for a running job or

[jira] [Commented] (FLINK-3713) DisposeSavepoint message uses system classloader to discard state

[ https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350947#comment-15350947 ] ASF GitHub Bot commented on FLINK-3713: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2150: [FLINK-3580] [table] Reintroduce Date/Time and imp...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2150#discussion_r68571843 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/sql/ExpressionsITCase.scala --- @@ -120,4 +122,26 @@ class Expressions

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

[ https://issues.apache.org/jira/browse/FLINK-3580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350950#comment-15350950 ] ASF GitHub Bot commented on FLINK-3580: --- Github user aljoscha commented on a diff in

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

[ https://issues.apache.org/jira/browse/FLINK-3675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350951#comment-15350951 ] Maximilian Michels commented on FLINK-3675: --- Do we want to ship the /lib folder

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

[ https://issues.apache.org/jira/browse/FLINK-3675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350953#comment-15350953 ] Maximilian Michels commented on FLINK-3675: --- Option 1 is easiest but might be un

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

[ https://issues.apache.org/jira/browse/FLINK-3675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350951#comment-15350951 ] Maximilian Michels edited comment on FLINK-3675 at 6/27/16 1:04 PM:

[GitHub] flink pull request #2083: [FLINK-3713] [clients, runtime] Use user code clas...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2083#discussion_r68572931 --- Diff: flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java --- @@ -305,6 +307,11 @@ public static void printHelpForSavepoi

[jira] [Commented] (FLINK-3713) DisposeSavepoint message uses system classloader to discard state

[ https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350959#comment-15350959 ] ASF GitHub Bot commented on FLINK-3713: --- Github user tillrohrmann commented on a dif

[GitHub] flink issue #2168: [FLINK-3964] add hint to job submission timeout exception...

Github user gyfora commented on the issue: https://github.com/apache/flink/pull/2168 I think it is often the case that the timeout is caused by some failure. For instance the savepoint restore failes due to something, then you get this timeout in the command line. Maybe it's

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

[ https://issues.apache.org/jira/browse/FLINK-3964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350969#comment-15350969 ] ASF GitHub Bot commented on FLINK-3964: --- Github user gyfora commented on the issue:

<    1   2   3   4   >