[GitHub] flink pull request #2727: [FLINK-4923] [Metrics] Initializes patch for Expos...

2016-10-30 Thread zhuhaifengleon
GitHub user zhuhaifengleon opened a pull request: https://github.com/apache/flink/pull/2727 [FLINK-4923] [Metrics] Initializes patch for Expose input/output queue length and bufferPool usage as a metric Initializes all task's gauge metrics in one method of TaskIOMetricGroup for

[jira] [Commented] (FLINK-3930) Implement Service-Level Authorization

2016-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15620793#comment-15620793 ] ASF GitHub Bot commented on FLINK-3930: --- Github user vijikarthi commented on the issue:

[GitHub] flink issue #2425: FLINK-3930 Added shared secret based authorization for Fl...

2016-10-30 Thread vijikarthi
Github user vijikarthi commented on the issue: https://github.com/apache/flink/pull/2425 Addressed multiple application support/Yarn configuration file changes as part of FLINK-4950 patch. --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Created] (FLINK-4968) Replace direct JobManager ActorGateways by JobManagerGateway

2016-10-30 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-4968: Summary: Replace direct JobManager ActorGateways by JobManagerGateway Key: FLINK-4968 URL: https://issues.apache.org/jira/browse/FLINK-4968 Project: Flink

[jira] [Updated] (FLINK-4967) RockDB state backend fails on Windows

2016-10-30 Thread Yassine Marzougui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yassine Marzougui updated FLINK-4967: - Labels: (was: easyfix) > RockDB state backend fails on Windows >

[jira] [Created] (FLINK-4967) RockDB state backend fails on Windows

2016-10-30 Thread Yassine Marzougui (JIRA)
Yassine Marzougui created FLINK-4967: Summary: RockDB state backend fails on Windows Key: FLINK-4967 URL: https://issues.apache.org/jira/browse/FLINK-4967 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-4923) Expose input/output buffers and bufferPool usage as a metric for a Task

2016-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15620210#comment-15620210 ] ASF GitHub Bot commented on FLINK-4923: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #2693: [FLINK-4923] [Metrics] Expose input/output buffers...

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

[jira] [Created] (FLINK-4966) BetweennessCentrality

2016-10-30 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-4966: - Summary: BetweennessCentrality Key: FLINK-4966 URL: https://issues.apache.org/jira/browse/FLINK-4966 Project: Flink Issue Type: New Feature Components:

[jira] [Created] (FLINK-4965) AllPairsShortestPaths

2016-10-30 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-4965: - Summary: AllPairsShortestPaths Key: FLINK-4965 URL: https://issues.apache.org/jira/browse/FLINK-4965 Project: Flink Issue Type: New Feature Components:

[jira] [Commented] (FLINK-4883) Prevent UDFs implementations through Scala singleton objects

2016-10-30 Thread Renkai Ge (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15619663#comment-15619663 ] Renkai Ge commented on FLINK-4883: -- I tried to implement it in module flink-scala and

[jira] [Comment Edited] (FLINK-3551) Sync Scala and Java Streaming Examples

2016-10-30 Thread Lim Chee Hau (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15619447#comment-15619447 ] Lim Chee Hau edited comment on FLINK-3551 at 10/30/16 9:43 AM: --- Hi, I'm

[jira] [Commented] (FLINK-4883) Prevent UDFs implementations through Scala singleton objects

2016-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15619645#comment-15619645 ] ASF GitHub Bot commented on FLINK-4883: --- Github user Renkai closed the pull request at:

[jira] [Commented] (FLINK-4883) Prevent UDFs implementations through Scala singleton objects

2016-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15619646#comment-15619646 ] ASF GitHub Bot commented on FLINK-4883: --- Github user Renkai commented on the issue:

[GitHub] flink pull request #2726: [FLINK-4883]Prevent UDFs implementations through S...

2016-10-30 Thread Renkai
Github user Renkai closed the pull request at: https://github.com/apache/flink/pull/2726 --- 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 #2726: [FLINK-4883]Prevent UDFs implementations through Scala si...

2016-10-30 Thread Renkai
Github user Renkai commented on the issue: https://github.com/apache/flink/pull/2726 Not prepared yet --- 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-4600) Support min/max aggregations for Date/Time/Timestamp/Intervals

2016-10-30 Thread Leo Deng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15619525#comment-15619525 ] Leo Deng commented on FLINK-4600: - Yeah, I am still working on it. > Support min/max aggregations for

[jira] [Commented] (FLINK-3551) Sync Scala and Java Streaming Examples

2016-10-30 Thread Lim Chee Hau (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15619447#comment-15619447 ] Lim Chee Hau commented on FLINK-3551: - Hi, I'm pretty new to Apache Flink, *flink-example* is