[GitHub] flink pull request #2834: [docs] Fix broken links and incorrect examples

GitHub user mindprince opened a pull request: https://github.com/apache/flink/pull/2834 [docs] Fix broken links and incorrect examples You can merge this pull request into a Git repository by running: $ git pull https://github.com/mindprince/flink docs-fix Alternatively you c

[jira] [Commented] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()"

[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15679034#comment-15679034 ] Kostas Kloudas commented on FLINK-2646: --- By the way the {{RichFunction}} is annotate

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15679052#comment-15679052 ] Andrey Melentyev commented on FLINK-2821: - [~mxm] I think getting rid of "bind" pa

[jira] [Commented] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()"

[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15679122#comment-15679122 ] Chesnay Schepler commented on FLINK-2646: - could you post how you defined the meth

[GitHub] flink pull request #2792: [FLINK-4937] [Table] Add incremental group window ...

Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/2792#discussion_r88778110 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/IncrementalAggregateReduceFunction.scala --- @@ -0,0 +1,69

[jira] [Commented] (FLINK-4937) Add incremental group window aggregation for streaming Table API

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

[GitHub] flink pull request #2792: [FLINK-4937] [Table] Add incremental group window ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2792#discussion_r88778828 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/IncrementalAggregateReduceFunction.scala --- @@ -0,0 +1,69

[jira] [Commented] (FLINK-4937) Add incremental group window aggregation for streaming Table API

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

[GitHub] flink issue #2467: [FLINK-3719][web frontend] Moving the barrier between gra...

Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2467 @iampeter Is there anything else that I should change? --- 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-5090) Expose optionally detailed metrics about network queue lengths

[ https://issues.apache.org/jira/browse/FLINK-5090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15679596#comment-15679596 ] Xiaogang Shi commented on FLINK-5090: - In flink, the performance bottlenecks are usual

[jira] [Commented] (FLINK-3719) WebInterface: Moving the barrier between graph and stats

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

[jira] [Created] (FLINK-5104) Implement BipartiteGraph validator

Ivan Mushketyk created FLINK-5104: - Summary: Implement BipartiteGraph validator Key: FLINK-5104 URL: https://issues.apache.org/jira/browse/FLINK-5104 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-3719) WebInterface: Moving the barrier between graph and stats

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

[GitHub] flink issue #2467: [FLINK-3719][web frontend] Moving the barrier between gra...

Github user iampeter commented on the issue: https://github.com/apache/flink/pull/2467 @mushketyk do make sure that the generated files are up-to-date (if they're not) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If y

[jira] [Commented] (FLINK-4905) Kafka test instability IllegalStateException: Client is not started

[ https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15680307#comment-15680307 ] Andrew Efimov commented on FLINK-4905: -- I have started investigation the issue and wh

[jira] [Comment Edited] (FLINK-4905) Kafka test instability IllegalStateException: Client is not started

[ https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15680307#comment-15680307 ] Andrew Efimov edited comment on FLINK-4905 at 11/20/16 3:01 AM: