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

2016-11-19 Thread Andrew Efimov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15680307#comment-15680307 ] Andrew Efimov edited comment on FLINK-4905 at 11/20/16 3:01 AM: I have

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

2016-11-19 Thread iampeter
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

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

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

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

2016-11-19 Thread Ivan Mushketyk (JIRA)
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-5090) Expose optionally detailed metrics about network queue lengths

2016-11-19 Thread Xiaogang Shi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15679596#comment-15679596 ] Xiaogang Shi commented on FLINK-5090: - In flink, the performance bottlenecks are usually caused by 1.

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

2016-11-19 Thread mushketyk
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-4937) Add incremental group window aggregation for streaming Table API

2016-11-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15679212#comment-15679212 ] ASF GitHub Bot commented on FLINK-4937: --- Github user fhueske commented on a diff in the pull

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

2016-11-19 Thread fhueske
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

2016-11-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15679133#comment-15679133 ] ASF GitHub Bot commented on FLINK-4937: --- Github user wuchong commented on a diff in the pull

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

2016-11-19 Thread wuchong
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-2646) Rich functions should provide a method "closeAfterFailure()"

2016-11-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15679122#comment-15679122 ] Chesnay Schepler commented on FLINK-2646: - could you post how you defined the method? > Rich

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

2016-11-19 Thread Andrey Melentyev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15679052#comment-15679052 ] Andrey Melentyev commented on FLINK-2821: - [~mxm] I think getting rid of "bind" params is a good

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

2016-11-19 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15679034#comment-15679034 ] Kostas Kloudas commented on FLINK-2646: --- By the way the {{RichFunction}} is annotated as {{Public}}

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

2016-11-19 Thread mindprince
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