[jira] [Commented] (FLINK-6312) Update curator version to 2.12.0

[ https://issues.apache.org/jira/browse/FLINK-6312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970749#comment-15970749 ] ASF GitHub Bot commented on FLINK-6312: --- GitHub user WangTaoTheTonic opened a pull r

[GitHub] flink pull request #3727: [FLINK-6312]update curator version to 2.12.0 to av...

GitHub user WangTaoTheTonic opened a pull request: https://github.com/apache/flink/pull/3727 [FLINK-6312]update curator version to 2.12.0 to avoid potential block As there's a Major bug([CURATOR-344](https://issues.apache.org/jira/browse/CURATOR-344)) in curator release used by fli

[jira] [Created] (FLINK-6312) Update curator version to 2.12.0

Tao Wang created FLINK-6312: --- Summary: Update curator version to 2.12.0 Key: FLINK-6312 URL: https://issues.apache.org/jira/browse/FLINK-6312 Project: Flink Issue Type: Bug Components: Jo

[jira] [Updated] (FLINK-6312) Update curator version to 2.12.0

[ https://issues.apache.org/jira/browse/FLINK-6312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tao Wang updated FLINK-6312: Description: As there's a Major bug(https://issues.apache.org/jira/browse/CURATOR-344) in curator release us

[jira] [Commented] (FLINK-6301) Flink KafkaConnector09 leaks memory on reading compressed messages due to a Kafka consumer bug

[ https://issues.apache.org/jira/browse/FLINK-6301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970740#comment-15970740 ] Rahul Yadav commented on FLINK-6301: Sure. My pleasure. :) Sent the email. Will assign

[jira] [Comment Edited] (FLINK-5697) Add per-shard watermarks for FlinkKinesisConsumer

[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970738#comment-15970738 ] Tzu-Li (Gordon) Tai edited comment on FLINK-5697 at 4/17/17 6:40 AM: ---

[jira] [Comment Edited] (FLINK-5697) Add per-shard watermarks for FlinkKinesisConsumer

[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970738#comment-15970738 ] Tzu-Li (Gordon) Tai edited comment on FLINK-5697 at 4/17/17 6:40 AM: ---

[jira] [Commented] (FLINK-5697) Add per-shard watermarks for FlinkKinesisConsumer

[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970738#comment-15970738 ] Tzu-Li (Gordon) Tai commented on FLINK-5697: I'd say it still makes sense. If

[jira] [Comment Edited] (FLINK-5611) Add QueryableStateException type

[ https://issues.apache.org/jira/browse/FLINK-5611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970729#comment-15970729 ] mingleizhang edited comment on FLINK-5611 at 4/17/17 6:35 AM: --

[jira] [Comment Edited] (FLINK-5611) Add QueryableStateException type

[ https://issues.apache.org/jira/browse/FLINK-5611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970729#comment-15970729 ] mingleizhang edited comment on FLINK-5611 at 4/17/17 6:34 AM: --

[jira] [Commented] (FLINK-6301) Flink KafkaConnector09 leaks memory on reading compressed messages due to a Kafka consumer bug

[ https://issues.apache.org/jira/browse/FLINK-6301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970730#comment-15970730 ] Tzu-Li (Gordon) Tai commented on FLINK-6301: Yes, absolutely! Assign the issue

[jira] [Commented] (FLINK-5611) Add QueryableStateException type

[ https://issues.apache.org/jira/browse/FLINK-5611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970729#comment-15970729 ] mingleizhang commented on FLINK-5611: - [~uce] Hi, How do you think of this ? It is un

[jira] [Updated] (FLINK-6301) Flink KafkaConnector09 leaks memory on reading compressed messages due to a Kafka consumer bug

[ https://issues.apache.org/jira/browse/FLINK-6301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rahul Yadav updated FLINK-6301: --- Attachment: POSTFIX.jeprof.14880.4129.i4129.heap.svg POSTFIX.jeprof.14880.1944.i1944.he

[jira] [Commented] (FLINK-6301) Flink KafkaConnector09 leaks memory on reading compressed messages due to a Kafka consumer bug

[ https://issues.apache.org/jira/browse/FLINK-6301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970725#comment-15970725 ] Rahul Yadav commented on FLINK-6301: BTW, I wanted to start contributing to the Flink

[jira] [Comment Edited] (FLINK-6301) Flink KafkaConnector09 leaks memory on reading compressed messages due to a Kafka consumer bug

[ https://issues.apache.org/jira/browse/FLINK-6301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970723#comment-15970723 ] Rahul Yadav edited comment on FLINK-6301 at 4/17/17 6:18 AM: -

[jira] [Commented] (FLINK-6301) Flink KafkaConnector09 leaks memory on reading compressed messages due to a Kafka consumer bug

[ https://issues.apache.org/jira/browse/FLINK-6301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970723#comment-15970723 ] Rahul Yadav commented on FLINK-6301: Thanx for the update and sure, makes sense! Few

[jira] [Commented] (FLINK-6301) Flink KafkaConnector09 leaks memory on reading compressed messages due to a Kafka consumer bug

[ https://issues.apache.org/jira/browse/FLINK-6301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970699#comment-15970699 ] Tzu-Li (Gordon) Tai commented on FLINK-6301: Thanks a lot for looking into thi

[jira] [Commented] (FLINK-6306) Sink for eventually consistent file systems

[ https://issues.apache.org/jira/browse/FLINK-6306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970683#comment-15970683 ] Tzu-Li (Gordon) Tai commented on FLINK-6306: This definitely needs a closer lo

[jira] [Created] (FLINK-6311) NPE in FlinkKinesisConsumer if source was closed before run

Tzu-Li (Gordon) Tai created FLINK-6311: -- Summary: NPE in FlinkKinesisConsumer if source was closed before run Key: FLINK-6311 URL: https://issues.apache.org/jira/browse/FLINK-6311 Project: Flink

[jira] [Commented] (FLINK-6130) Consider calling resourceManager#getTerminationFuture() with lock held

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

[GitHub] flink issue #3726: [FLINK-6130] [yarn] Fix Consider calling resourceManager#...

Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/3726 @tedyu @zentol It seems there is a problem with travis-ci test if no output within 5 mins then it will print the stacktrace and then kill the watchdog , please help to review and checkout how to

[jira] [Assigned] (FLINK-6309) Memory consumer weights should be calculated in job vertex level

[ https://issues.apache.org/jira/browse/FLINK-6309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Pingyong reassigned FLINK-6309: -- Assignee: Xu Pingyong > Memory consumer weights should be calculated in job vertex level >

[jira] [Commented] (FLINK-6130) Consider calling resourceManager#getTerminationFuture() with lock held

[ https://issues.apache.org/jira/browse/FLINK-6130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970608#comment-15970608 ] ASF GitHub Bot commented on FLINK-6130: --- GitHub user zhangminglei opened a pull requ

[GitHub] flink pull request #3726: [FLINK-6130] [yarn] Fix Consider calling resourceM...

GitHub user zhangminglei opened a pull request: https://github.com/apache/flink/pull/3726 [FLINK-6130] [yarn] Fix Consider calling resourceManager#getTerminati… …onFuture() with lock held. Thanks for contributing to Apache Flink. Before you open your pull request, pleas

[jira] [Commented] (FLINK-6130) Consider calling resourceManager#getTerminationFuture() with lock held

[ https://issues.apache.org/jira/browse/FLINK-6130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970602#comment-15970602 ] mingleizhang commented on FLINK-6130: - [~tedyu] Thanks and appreciate it again. If the

[jira] [Commented] (FLINK-6130) Consider calling resourceManager#getTerminationFuture() with lock held

[ https://issues.apache.org/jira/browse/FLINK-6130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970599#comment-15970599 ] Ted Yu commented on FLINK-6130: --- lgtm > Consider calling resourceManager#getTerminationFutu

[jira] [Commented] (FLINK-6130) Consider calling resourceManager#getTerminationFuture() with lock held

[ https://issues.apache.org/jira/browse/FLINK-6130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970598#comment-15970598 ] mingleizhang commented on FLINK-6130: - [~tedyu] Yep. And the code like below, how do y

[jira] [Created] (FLINK-6310) LocalExecutor#endSession() uses wrong lock for synchronization

Ted Yu created FLINK-6310: - Summary: LocalExecutor#endSession() uses wrong lock for synchronization Key: FLINK-6310 URL: https://issues.apache.org/jira/browse/FLINK-6310 Project: Flink Issue Type: B

[jira] [Commented] (FLINK-5752) Support push down projections for HBaseTableSource

[ https://issues.apache.org/jira/browse/FLINK-5752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970592#comment-15970592 ] ramkrishna.s.vasudevan commented on FLINK-5752: --- I completed the patch relat

[jira] [Commented] (FLINK-6130) Consider calling resourceManager#getTerminationFuture() with lock held

[ https://issues.apache.org/jira/browse/FLINK-6130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970590#comment-15970590 ] Ted Yu commented on FLINK-6130: --- You don't need to create another synchronized (lock) block.

[jira] [Commented] (FLINK-6130) Consider calling resourceManager#getTerminationFuture() with lock held

[ https://issues.apache.org/jira/browse/FLINK-6130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970588#comment-15970588 ] mingleizhang commented on FLINK-6130: - [~tedyu] Thanks and appreciate it. I will give

[jira] [Commented] (FLINK-6130) Consider calling resourceManager#getTerminationFuture() with lock held

[ https://issues.apache.org/jira/browse/FLINK-6130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970587#comment-15970587 ] Ted Yu commented on FLINK-6130: --- lgtm > Consider calling resourceManager#getTerminationFutu

[jira] [Comment Edited] (FLINK-6130) Consider calling resourceManager#getTerminationFuture() with lock held

[ https://issues.apache.org/jira/browse/FLINK-6130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970586#comment-15970586 ] mingleizhang edited comment on FLINK-6130 at 4/17/17 1:51 AM: --

[jira] [Commented] (FLINK-6130) Consider calling resourceManager#getTerminationFuture() with lock held

[ https://issues.apache.org/jira/browse/FLINK-6130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970586#comment-15970586 ] mingleizhang commented on FLINK-6130: - [~tedyu] Could you please help review the code

[jira] [Created] (FLINK-6309) Memory consumer weights should be calculated in job vertex level

Kurt Young created FLINK-6309: - Summary: Memory consumer weights should be calculated in job vertex level Key: FLINK-6309 URL: https://issues.apache.org/jira/browse/FLINK-6309 Project: Flink Iss

[jira] [Commented] (FLINK-2032) Migrate integration tests from temp output files to collect()

[ https://issues.apache.org/jira/browse/FLINK-2032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970524#comment-15970524 ] Pattarawat Chormai commented on FLINK-2032: --- Hi all, I have searched on Github

[jira] [Commented] (FLINK-4548) Refactor ContinuousFileMonitoringTest to use OneShotLatch

[ https://issues.apache.org/jira/browse/FLINK-4548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970516#comment-15970516 ] Pattarawat Chormai commented on FLINK-4548: --- The test was removed already by ht

[jira] [Closed] (FLINK-4548) Refactor ContinuousFileMonitoringTest to use OneShotLatch

[ https://issues.apache.org/jira/browse/FLINK-4548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pattarawat Chormai closed FLINK-4548. - Resolution: Fixed > Refactor ContinuousFileMonitoringTest to use OneShotLatch > --

[jira] [Updated] (FLINK-6308) Task managers are not attaching to job manager on macos

[ https://issues.apache.org/jira/browse/FLINK-6308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mateusz Zakarczemny updated FLINK-6308: --- Description: I'm using flink 1.2.0. On macOS task managers were not joining cluster. I

[jira] [Created] (FLINK-6308) Task managers are not attaching to job manager on macos

Mateusz Zakarczemny created FLINK-6308: -- Summary: Task managers are not attaching to job manager on macos Key: FLINK-6308 URL: https://issues.apache.org/jira/browse/FLINK-6308 Project: Flink

[jira] [Commented] (FLINK-6130) Consider calling resourceManager#getTerminationFuture() with lock held

[ https://issues.apache.org/jira/browse/FLINK-6130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970408#comment-15970408 ] Ted Yu commented on FLINK-6130: --- You can store the return value from getTerminationFuture in

[jira] [Commented] (FLINK-5611) Add QueryableStateException type

[ https://issues.apache.org/jira/browse/FLINK-5611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970385#comment-15970385 ] mingleizhang commented on FLINK-5611: - [~uce]Hi, I will work on this soon. Thanks ~ >

[jira] [Assigned] (FLINK-5611) Add QueryableStateException type

[ https://issues.apache.org/jira/browse/FLINK-5611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-5611: --- Assignee: mingleizhang > Add QueryableStateException type >

[jira] [Commented] (FLINK-6104) Resource leak in ListViaRangeSpeedMiniBenchmark

[ https://issues.apache.org/jira/browse/FLINK-6104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970358#comment-15970358 ] ASF GitHub Bot commented on FLINK-6104: --- GitHub user zhangminglei opened a pull requ

[GitHub] flink pull request #3725: [FLINK-6104] Fix resource leak in ListViaRangeSpee...

GitHub user zhangminglei opened a pull request: https://github.com/apache/flink/pull/3725 [FLINK-6104] Fix resource leak in ListViaRangeSpeedMiniBenchmark. Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into considera

[jira] [Commented] (FLINK-6286) hbase command not found error

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

[GitHub] flink issue #3711: [FLINK-6286] [script] Fix the hbase command not found err...

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3711 @lingjinjiang thanks for your contribution! 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

[jira] [Assigned] (FLINK-6104) Resource leak in ListViaRangeSpeedMiniBenchmark

[ https://issues.apache.org/jira/browse/FLINK-6104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-6104: --- Assignee: mingleizhang > Resource leak in ListViaRangeSpeedMiniBenchmark > --

[jira] [Commented] (FLINK-6104) Resource leak in ListViaRangeSpeedMiniBenchmark

[ https://issues.apache.org/jira/browse/FLINK-6104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970341#comment-15970341 ] mingleizhang commented on FLINK-6104: - I will give a pr to this jira soon. > Resource

[jira] [Assigned] (FLINK-6130) Consider calling resourceManager#getTerminationFuture() with lock held

[ https://issues.apache.org/jira/browse/FLINK-6130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-6130: --- Assignee: mingleizhang > Consider calling resourceManager#getTerminationFuture() with lock he

[jira] [Commented] (FLINK-6130) Consider calling resourceManager#getTerminationFuture() with lock held

[ https://issues.apache.org/jira/browse/FLINK-6130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970332#comment-15970332 ] mingleizhang commented on FLINK-6130: - [~tedyu] Thanks. I would ask how to use those r

[GitHub] flink issue #3348: [FLINK-5090] [network] Add metrics for details about inbo...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3348 Did @StephanEwen provide the initial implementation, or why is the first commit by him? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[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=15970314#comment-15970314 ] ASF GitHub Bot commented on FLINK-5090: --- Github user zentol commented on the issue:

[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=15970311#comment-15970311 ] ASF GitHub Bot commented on FLINK-5090: --- Github user zentol commented on the issue:

[GitHub] flink issue #3348: [FLINK-5090] [network] Add metrics for details about inbo...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3348 Will try merging this now. --- 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

[jira] [Commented] (FLINK-6195) Move gelly-examples jar from opt to examples

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

[GitHub] flink issue #3691: [FLINK-6195] [build] Move gelly-examples jar from opt to ...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3691 Changes to the build and docs look good. I would propose moving the changes to the EdgeList/AsmTestBase into a separate commit though. --- If your project is set up for it, you can reply to this emai

[jira] [Commented] (FLINK-6257) Post-pass OVER windows

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

[GitHub] flink issue #3697: [FLINK-6257][table]Optimize test cases

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3697 Please provide some description as to the changes that you made, it's a 2000+ line diff after all. --- If your project is set up for it, you can reply to this email and have your reply appear on GitH

[jira] [Commented] (FLINK-6295) use LoadingCache instead of WeakHashMap to lower latency

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

[GitHub] flink issue #3709: [FLINK-6295]use LoadingCache instead of WeakHashMap to lo...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3709 It shouldn't matter for the display in the web-frontend in which data structure the cached ExecutionGraphs are being held. We are caching the actual ExecutionGraph that the JobManager works with and n