[jira] [Commented] (FLINK-5720) Deprecate "Folding" in all of DataStream API

2017-07-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16079320#comment-16079320 ] ASF GitHub Bot commented on FLINK-5720: --- Github user caddac commented on the issue:

[GitHub] flink issue #3816: [FLINK-5720] Deprecate DataStream#fold()

2017-07-08 Thread caddac
Github user caddac commented on the issue: https://github.com/apache/flink/pull/3816 Sorry for commenting on this closed PR, but can you point me to documentation for what will replace fold? I'm starting a new project using 1.3 and don't want to use a deprecated API, but don't find

[GitHub] flink issue #4290: [FLINK-7133]Excluding optional asm dependencies from elas...

2017-07-08 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4290 yes --- 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

[jira] [Commented] (FLINK-7133) Fix Elasticsearch version interference

2017-07-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16079187#comment-16079187 ] ASF GitHub Bot commented on FLINK-7133: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #4290: [FLINK-7133]Excluding optional asm dependencies from elas...

2017-07-08 Thread Adebski
Github user Adebski commented on the issue: https://github.com/apache/flink/pull/4290 You mean in the pom.xml itself yes? --- 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

[jira] [Commented] (FLINK-7133) Fix Elasticsearch version interference

2017-07-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16079184#comment-16079184 ] ASF GitHub Bot commented on FLINK-7133: --- Github user Adebski commented on the issue:

[jira] [Commented] (FLINK-7133) Fix Elasticsearch version interference

2017-07-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16079182#comment-16079182 ] ASF GitHub Bot commented on FLINK-7133: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #4290: [FLINK-7133]Excluding optional asm dependencies from elas...

2017-07-08 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4290 Thanks for the PR @Adebski! Given that this was tested already for both local and cluster execution,+1 from me once Travis is green. Could you also include a comment, preferably referencing

[jira] [Commented] (FLINK-7133) Fix Elasticsearch version interference

2017-07-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16079178#comment-16079178 ] ASF GitHub Bot commented on FLINK-7133: --- GitHub user Adebski opened a pull request:

[GitHub] flink pull request #4290: [FLINK-7133]Excluding optional asm dependencies fr...

2017-07-08 Thread Adebski
GitHub user Adebski opened a pull request: https://github.com/apache/flink/pull/4290 [FLINK-7133]Excluding optional asm dependencies from elasticsearch You can merge this pull request into a Git repository by running: $ git pull https://github.com/Adebski/flink

[jira] [Commented] (FLINK-6998) Kafka connector needs to expose metrics for failed/successful offset commits in the Kafka Consumer callback

2017-07-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16079172#comment-16079172 ] ASF GitHub Bot commented on FLINK-6998: --- Github user GJL commented on a diff in the pull request:

[jira] [Commented] (FLINK-6998) Kafka connector needs to expose metrics for failed/successful offset commits in the Kafka Consumer callback

2017-07-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16079170#comment-16079170 ] ASF GitHub Bot commented on FLINK-6998: --- Github user GJL commented on a diff in the pull request:

[GitHub] flink pull request #4187: [FLINK-6998][Kafka Connector] Add kafka offset com...

2017-07-08 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/4187#discussion_r126283335 --- Diff: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java --- @@ -184,6

[GitHub] flink pull request #4187: [FLINK-6998][Kafka Connector] Add kafka offset com...

2017-07-08 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/4187#discussion_r126283316 --- Diff: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java --- @@ -104,7

[jira] [Commented] (FLINK-7133) Fix Elasticsearch version interference

2017-07-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16079168#comment-16079168 ] Chesnay Schepler commented on FLINK-7133: - For future reference, if yo want to provide a patch

[jira] [Commented] (FLINK-7133) Fix Elasticsearch version interference

2017-07-08 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16079165#comment-16079165 ] Tzu-Li (Gordon) Tai commented on FLINK-7133: [~Adebski] nice! I'm also in favor of excluding,

[jira] [Commented] (FLINK-7133) Fix Elasticsearch version interference

2017-07-08 Thread Adebski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16079156#comment-16079156 ] Adebski commented on FLINK-7133: I've changed ES configuration in pom to {noformat}

[jira] [Comment Edited] (FLINK-7133) Fix Elasticsearch version interference

2017-07-08 Thread Adebski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16079156#comment-16079156 ] Adebski edited comment on FLINK-7133 at 7/8/17 2:17 PM: I've changed ES

[jira] [Closed] (FLINK-6302) Documentation build error on ruby 2.4

2017-07-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6302. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: f21915b22604e435bf5189c61ef05a3ec6133529

[jira] [Closed] (FLINK-6822) Activate checkstyle for runtime/plugable

2017-07-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6822. --- Resolution: Fixed 1.4: 98eb2cff32c84b9a4f5c3136652040438f4cdd5d > Activate checkstyle for

[jira] [Commented] (FLINK-6825) Activate checkstyle for runtime/heartbeat

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

[jira] [Closed] (FLINK-6825) Activate checkstyle for runtime/heartbeat

2017-07-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6825. --- Resolution: Fixed 1.4: 73ab3175a071baa06b60e193e249343b98b7d9af > Activate checkstyle for

[jira] [Commented] (FLINK-6828) Activate checkstyle for runtime/deployment

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

[jira] [Commented] (FLINK-7069) Catch exceptions for each reporter separately

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

[jira] [Closed] (FLINK-6828) Activate checkstyle for runtime/deployment

2017-07-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6828. --- Resolution: Fixed 1.4: 1779a0ebe3c61073ca9860f3dc29528dd49e24c9 > Activate checkstyle for

[jira] [Commented] (FLINK-6822) Activate checkstyle for runtime/plugable

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

[jira] [Commented] (FLINK-6302) Documentation build error on ruby 2.4

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

[GitHub] flink pull request #3720: [FLINK-6302] Documentation build error on ruby 2.4

2017-07-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3720 --- 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 pull request #4064: [FLINK-6822] Activate checkstyle for runtime/pluga...

2017-07-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4064 --- 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 pull request #4067: [FLINK-6825] Activate checkstyle for runtime/heart...

2017-07-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4067 --- 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 pull request #4066: [FLINK-6828] Activate checkstyle for runtime/deplo...

2017-07-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4066 --- 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 pull request #4248: [FLINK-7069] [metrics] Granular exception catching...

2017-07-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4248 --- 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] [Commented] (FLINK-7092) Shutdown ResourceManager components properly

2017-07-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16079133#comment-16079133 ] ASF GitHub Bot commented on FLINK-7092: --- GitHub user zhangminglei opened a pull request:

[GitHub] flink pull request #4289: [FLINK-7092] [mesos] Shutdown ResourceManager comp...

2017-07-08 Thread zhangminglei
GitHub user zhangminglei opened a pull request: https://github.com/apache/flink/pull/4289 [FLINK-7092] [mesos] Shutdown ResourceManager components properly (FL… The MesosResourceManager starts internally a TaskMonitor, LaunchCoordinator, ConnectionMonitor and a

[jira] [Commented] (FLINK-7139) Refine currentTimeMillis to nanoTime

2017-07-08 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16079084#comment-16079084 ] mingleizhang commented on FLINK-7139: - Hello, [~Zentol] What do you think ? > Refine

[jira] [Created] (FLINK-7139) Refine currentTimeMillis to nanoTime

2017-07-08 Thread mingleizhang (JIRA)
mingleizhang created FLINK-7139: --- Summary: Refine currentTimeMillis to nanoTime Key: FLINK-7139 URL: https://issues.apache.org/jira/browse/FLINK-7139 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-7133) Fix Elasticsearch version interference

2017-07-08 Thread Adebski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16079011#comment-16079011 ] Adebski commented on FLINK-7133: [~tzulitai] I didn't, I will try it and report back. [~Zentol] I think

[jira] [Commented] (FLINK-6822) Activate checkstyle for runtime/plugable

2017-07-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16078998#comment-16078998 ] ASF GitHub Bot commented on FLINK-6822: --- Github user zentol commented on the issue:

[GitHub] flink issue #4064: [FLINK-6822] Activate checkstyle for runtime/plugable

2017-07-08 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4064 merging. --- 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

[jira] [Commented] (FLINK-7111) flink-scala-shell fails on mvn verify

2017-07-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16078997#comment-16078997 ] ASF GitHub Bot commented on FLINK-7111: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #4288: [FLINK-7111] [scala-shell] Disable external jar te...

2017-07-08 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4288 [FLINK-7111] [scala-shell] Disable external jar test @aljoscha What do you think? You can merge this pull request into a Git repository by running: $ git pull https://github.com/zentol/flink

[jira] [Assigned] (FLINK-7111) flink-scala-shell fails on mvn verify

2017-07-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-7111: --- Assignee: Chesnay Schepler > flink-scala-shell fails on mvn verify >

[jira] [Commented] (FLINK-6903) Activate checkstyle for runtime/akka

2017-07-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16078988#comment-16078988 ] ASF GitHub Bot commented on FLINK-6903: --- Github user zentol commented on the issue:

[GitHub] flink issue #4114: [FLINK-6903] [runtime] Activate checkstyle for runtime/ak...

2017-07-08 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4114 +1 to merge. --- 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

[jira] [Commented] (FLINK-7131) Streaming wordcount jar does not contain WordCountData

2017-07-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16078979#comment-16078979 ] ASF GitHub Bot commented on FLINK-7131: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #4287: [FLINK-7131][FLINK-7138] Include WordCountData in ...

2017-07-08 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4287 [FLINK-7131][FLINK-7138] Include WordCountData in example jars You can merge this pull request into a Git repository by running: $ git pull https://github.com/zentol/flink 7131 Alternatively

[jira] [Created] (FLINK-7138) Storm example jars do not contain WordCountData

2017-07-08 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-7138: --- Summary: Storm example jars do not contain WordCountData Key: FLINK-7138 URL: https://issues.apache.org/jira/browse/FLINK-7138 Project: Flink Issue

[jira] [Assigned] (FLINK-7131) Streaming wordcount jar does not contain WordCountData

2017-07-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-7131: --- Assignee: Chesnay Schepler > Streaming wordcount jar does not contain WordCountData

[jira] [Commented] (FLINK-6940) Clarify the effect of configuring per-job state backend

2017-07-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16078976#comment-16078976 ] ASF GitHub Bot commented on FLINK-6940: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #4136: [FLINK-6940][docs] Clarify the effect of configuri...

2017-07-08 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4136#discussion_r126275617 --- Diff: docs/ops/state_backends.md --- @@ -124,7 +124,7 @@ RocksDBStateBackend is currently the only backend that offers incremental checkp ##

[jira] [Commented] (FLINK-7135) Pass in proper Configuration to Dispatcher component

2017-07-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16078975#comment-16078975 ] ASF GitHub Bot commented on FLINK-7135: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-7133) Fix Elasticsearch version interference

2017-07-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16078974#comment-16078974 ] Chesnay Schepler commented on FLINK-7133: - Could we not just shade the ES asm dependency to a

[GitHub] flink pull request #4286: [FLINK-7135] [flip6] Pass in proper configuration ...

2017-07-08 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4286#discussion_r126275600 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobManagerRunner.java --- @@ -228,6 +228,7 @@ public JobManagerRunner(