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

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

[GitHub] flink pull request #2726: Flink 4883

2016-10-29 Thread Renkai
GitHub user Renkai opened a pull request: https://github.com/apache/flink/pull/2726 Flink 4883 Ideas and code structure are basically copied from `org.apache.flink.api.java.ClosureCleaner` You can merge this pull request into a Git repository by running: $ git pull https://git

[jira] [Created] (FLINK-4964) FlinkML - Add StringIndexer

2016-10-29 Thread Thomas FOURNIER (JIRA)
Thomas FOURNIER created FLINK-4964: -- Summary: FlinkML - Add StringIndexer Key: FLINK-4964 URL: https://issues.apache.org/jira/browse/FLINK-4964 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-4880) FlinkML - Implement Feature hashing (Data pre-processing)

2016-10-29 Thread Thomas FOURNIER (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas FOURNIER updated FLINK-4880: --- Description: I'm going to work on feature hashing, as it is a point mentioned on the FlinkML

[jira] [Commented] (FLINK-4888) instantiated job manager metrics missing important job statistics

2016-10-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15618451#comment-15618451 ] ASF GitHub Bot commented on FLINK-4888: --- Github user philippbussche commented on a d

[GitHub] flink pull request #2683: [FLINK-4888][metrics] instantiated job manager met...

2016-10-29 Thread philippbussche
Github user philippbussche commented on a diff in the pull request: https://github.com/apache/flink/pull/2683#discussion_r85644418 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -1828,6 +1828,33 @@ class JobManager( jobM

[GitHub] flink issue #2706: [FLINK-4945] KafkaConsumer logs wrong warning about confi...

2016-10-29 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/2706 At least at on the first checkpoint was the only time I ever observed it. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If you

[jira] [Commented] (FLINK-4945) KafkaConsumer logs wrong warning about confirmation for unknown checkpoint

2016-10-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15617895#comment-15617895 ] ASF GitHub Bot commented on FLINK-4945: --- Github user StefanRRichter commented on the

[jira] [Commented] (FLINK-4155) Get Kafka producer partition info in open method instead of constructor

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

[GitHub] flink issue #2681: [FLINK-4155] [kafka] Move partition list fetching to open...

2016-10-29 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2681 @StephanEwen I think it makes sense to convert the table sink / source tests to unit tests that simply check they are using the Kafka consumer / producers correctly. Will include as part of this PR.

[GitHub] flink issue #2706: [FLINK-4945] KafkaConsumer logs wrong warning about confi...

2016-10-29 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2706 So does the misleading warning only pop up on the first checkpoint notification after startup? If that's the case, then this looks good to me. --- If your project is set up for it, you can repl

[jira] [Commented] (FLINK-4945) KafkaConsumer logs wrong warning about confirmation for unknown checkpoint

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

[jira] [Comment Edited] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources

2016-10-29 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15617827#comment-15617827 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4576 at 10/29/16 9:46 AM: --

[jira] [Commented] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources

2016-10-29 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15617827#comment-15617827 ] Tzu-Li (Gordon) Tai commented on FLINK-4576: Hi [~aljoscha], Thanks a lot for