[jira] [Commented] (FLINK-6143) Unprotected access to this.flink in LocalExecutor#endSession()

[ https://issues.apache.org/jira/browse/FLINK-6143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15964530#comment-15964530 ] mingleizhang commented on FLINK-6143: - [~Zentol] Thanks for your help and the pr is ready now. Could

[jira] [Assigned] (FLINK-6275) Unprotected access to resourceManager in YarnFlinkApplicationMasterRunner#runApplicationMaster

[ https://issues.apache.org/jira/browse/FLINK-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-6275: --- Assignee: mingleizhang > Unprotected access to resourceManager in >

[jira] [Comment Edited] (FLINK-6275) Unprotected access to resourceManager in YarnFlinkApplicationMasterRunner#runApplicationMaster

[ https://issues.apache.org/jira/browse/FLINK-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15963873#comment-15963873 ] mingleizhang edited comment on FLINK-6275 at 4/11/17 7:03 AM: -- Let me inside

[jira] [Commented] (FLINK-6275) Unprotected access to resourceManager in YarnFlinkApplicationMasterRunner#runApplicationMaster

[ https://issues.apache.org/jira/browse/FLINK-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15963873#comment-15963873 ] mingleizhang commented on FLINK-6275: - Let me inside it what happened. > Unprotected access to

[jira] [Comment Edited] (FLINK-6275) Unprotected access to resourceManager in YarnFlinkApplicationMasterRunner#runApplicationMaster

[ https://issues.apache.org/jira/browse/FLINK-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15963873#comment-15963873 ] mingleizhang edited comment on FLINK-6275 at 4/11/17 9:43 AM: -- [~tedyu] Could

[jira] [Commented] (FLINK-6245) Fix late side output documentation in Window documents.

[ https://issues.apache.org/jira/browse/FLINK-6245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15964067#comment-15964067 ] mingleizhang commented on FLINK-6245: - [~kkl0u] Could you please specify information of where the

[jira] [Comment Edited] (FLINK-6143) Unprotected access to this.flink in LocalExecutor#endSession()

[ https://issues.apache.org/jira/browse/FLINK-6143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15964153#comment-15964153 ] mingleizhang edited comment on FLINK-6143 at 4/11/17 10:37 AM: --- [~tedyu] Hi,

[jira] [Commented] (FLINK-6143) Unprotected access to this.flink in LocalExecutor#endSession()

[ https://issues.apache.org/jira/browse/FLINK-6143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15964153#comment-15964153 ] mingleizhang commented on FLINK-6143: - [~tedyu] Hi, Could you please assgin this jira to me ? I will

[jira] [Commented] (FLINK-6143) Unprotected access to this.flink in LocalExecutor#endSession()

[ https://issues.apache.org/jira/browse/FLINK-6143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15966974#comment-15966974 ] mingleizhang commented on FLINK-6143: - [~StephanEwen] , Hi, Could you please take some time review

[jira] [Commented] (FLINK-6275) Unprotected access to resourceManager in YarnFlinkApplicationMasterRunner#runApplicationMaster

[ https://issues.apache.org/jira/browse/FLINK-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15966977#comment-15966977 ] mingleizhang commented on FLINK-6275: - [~StephanEwen] Hi, Could you please take some time review this

[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=15970586#comment-15970586 ] mingleizhang edited comment on FLINK-6130 at 4/17/17 1:51 AM: -- [~tedyu] Could

[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=15970586#comment-15970586 ] mingleizhang commented on FLINK-6130: - [~tedyu] Could you please help review the code ? How do you

[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=15970598#comment-15970598 ] mingleizhang commented on FLINK-6130: - [~tedyu] Yep. And the code like below, how do you think of this

[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=15970602#comment-15970602 ] mingleizhang commented on FLINK-6130: - [~tedyu] Thanks and appreciate it again. If there is no more

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

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

[jira] [Assigned] (FLINK-5943) Unprotected access to haServices in YarnFlinkApplicationMasterRunner#shutdown()

[ https://issues.apache.org/jira/browse/FLINK-5943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-5943: --- Assignee: mingleizhang > Unprotected access to haServices in >

[jira] [Commented] (FLINK-5943) Unprotected access to haServices in YarnFlinkApplicationMasterRunner#shutdown()

[ https://issues.apache.org/jira/browse/FLINK-5943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15970759#comment-15970759 ] mingleizhang commented on FLINK-5943: - [~tedyu] Hi, Ted, How do you think of this ? I have put what

[jira] [Created] (FLINK-6313) Some words was spelled wrong and incorrect LOG.error without print

mingleizhang created FLINK-6313: --- Summary: Some words was spelled wrong and incorrect LOG.error without print Key: FLINK-6313 URL: https://issues.apache.org/jira/browse/FLINK-6313 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=15970588#comment-15970588 ] mingleizhang commented on FLINK-6130: - [~tedyu] Thanks and appreciate it. I will give a PR to this

[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=15970729#comment-15970729 ] mingleizhang edited comment on FLINK-5611 at 4/17/17 6:35 AM: -- [~uce] Hi,

[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=15970729#comment-15970729 ] mingleizhang edited comment on FLINK-5611 at 4/17/17 6:34 AM: -- [~uce] Hi,

[jira] [Updated] (FLINK-6351) Refactoring YarnFlinkApplicationMasterRunner by combining AbstractYarnFlinkApplicationMasterRunner in one class

[ https://issues.apache.org/jira/browse/FLINK-6351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-6351: Priority: Major (was: Minor) > Refactoring YarnFlinkApplicationMasterRunner by combining >

[jira] [Updated] (FLINK-6351) Refactoring YarnFlinkApplicationMasterRunner by combining AbstractYarnFlinkApplicationMasterRunner in one class

[ https://issues.apache.org/jira/browse/FLINK-6351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-6351: Description: The currently YarnFlinkApplicationMasterRunner inherits from

[jira] [Comment Edited] (FLINK-6351) Refactoring YarnFlinkApplicationMasterRunner by combining AbstractYarnFlinkApplicationMasterRunner in one class

[ https://issues.apache.org/jira/browse/FLINK-6351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15977998#comment-15977998 ] mingleizhang edited comment on FLINK-6351 at 4/21/17 3:10 AM: --

[jira] [Created] (FLINK-6351) Refactoring YarnFlinkApplicationMasterRunner by combining AbstractYarnFlinkApplicationMasterRunner in one class

mingleizhang created FLINK-6351: --- Summary: Refactoring YarnFlinkApplicationMasterRunner by combining AbstractYarnFlinkApplicationMasterRunner in one class Key: FLINK-6351 URL:

[jira] [Commented] (FLINK-6351) Refactoring YarnFlinkApplicationMasterRunner by combining AbstractYarnFlinkApplicationMasterRunner in one class

[ https://issues.apache.org/jira/browse/FLINK-6351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15977998#comment-15977998 ] mingleizhang commented on FLINK-6351: - [~till.rohrmann] Hi, Till. Please check it out and how do you

[jira] [Assigned] (FLINK-6345) Migrate from Java serialization for ContinuousFileReaderOperator's state

[ https://issues.apache.org/jira/browse/FLINK-6345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-6345: --- Assignee: mingleizhang > Migrate from Java serialization for ContinuousFileReaderOperator's

[jira] [Commented] (FLINK-6345) Migrate from Java serialization for ContinuousFileReaderOperator's state

[ https://issues.apache.org/jira/browse/FLINK-6345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15978559#comment-15978559 ] mingleizhang commented on FLINK-6345: - I will try to solve this issue. > Migrate from Java

[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

[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=15970332#comment-15970332 ] mingleizhang commented on FLINK-6130: - [~tedyu] Thanks. I would ask how to use those return value that

[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=15970341#comment-15970341 ] mingleizhang commented on FLINK-6104: - I will give a pr to this jira soon. > Resource leak in

[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-5611) Add QueryableStateException type

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

[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=15972736#comment-15972736 ] mingleizhang commented on FLINK-6130: - [~till.rohrmann] Void ? I see. I would think

[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=15972736#comment-15972736 ] mingleizhang edited comment on FLINK-6130 at 4/18/17 2:10 PM: --

[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=15972656#comment-15972656 ] mingleizhang commented on FLINK-6130: - [~till.rohrmann] Thanks for review, and except for [~Zentol]

[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=15972690#comment-15972690 ] mingleizhang commented on FLINK-6130: - [~Zentol] Doesn't it return the result of the status of YARN

[jira] [Commented] (FLINK-6264) Kafka consumer fails if can't find leader for partition

[ https://issues.apache.org/jira/browse/FLINK-6264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15976012#comment-15976012 ] mingleizhang commented on FLINK-6264: - Hi, I would not think it is a bug when brokers failer and

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

[ https://issues.apache.org/jira/browse/FLINK-6311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15974207#comment-15974207 ] mingleizhang edited comment on FLINK-6311 at 4/19/17 7:13 AM: -- [~tzulitai]

[jira] [Commented] (FLINK-6319) Add timeout when shutting SystemProcessingTimeService down

[ https://issues.apache.org/jira/browse/FLINK-6319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979854#comment-15979854 ] mingleizhang commented on FLINK-6319: - +1 I have to say, the method of {code}shutdownNow{code}has it's

[jira] [Commented] (FLINK-5855) Unprotected access to pendingFilesPerCheckpoint in BucketingSink

[ https://issues.apache.org/jira/browse/FLINK-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15980624#comment-15980624 ] mingleizhang commented on FLINK-5855: - [~tedyu] Hi, Ted. I would ask if

[jira] [Assigned] (FLINK-5855) Unprotected access to pendingFilesPerCheckpoint in BucketingSink

[ https://issues.apache.org/jira/browse/FLINK-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-5855: --- Assignee: mingleizhang > Unprotected access to pendingFilesPerCheckpoint in BucketingSink >

[jira] [Comment Edited] (FLINK-5855) Unprotected access to pendingFilesPerCheckpoint in BucketingSink

[ https://issues.apache.org/jira/browse/FLINK-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15980624#comment-15980624 ] mingleizhang edited comment on FLINK-5855 at 4/24/17 1:50 AM: -- [~tedyu] Hi,

[jira] [Comment Edited] (FLINK-5855) Unprotected access to pendingFilesPerCheckpoint in BucketingSink

[ https://issues.apache.org/jira/browse/FLINK-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15980664#comment-15980664 ] mingleizhang edited comment on FLINK-5855 at 4/24/17 2:57 AM: -- Yep. That is

[jira] [Commented] (FLINK-5855) Unprotected access to pendingFilesPerCheckpoint in BucketingSink

[ https://issues.apache.org/jira/browse/FLINK-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15980664#comment-15980664 ] mingleizhang commented on FLINK-5855: - @Ted Yu, Yep. That is right. So, follow your suggestion. I

[jira] [Comment Edited] (FLINK-5855) Unprotected access to pendingFilesPerCheckpoint in BucketingSink

[ https://issues.apache.org/jira/browse/FLINK-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15980664#comment-15980664 ] mingleizhang edited comment on FLINK-5855 at 4/24/17 2:57 AM: -- Yep. That is

[jira] [Issue Comment Deleted] (FLINK-5855) Unprotected access to pendingFilesPerCheckpoint in BucketingSink

[ https://issues.apache.org/jira/browse/FLINK-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-5855: Comment: was deleted (was: Yep. That is right. So, follow your suggestion. I would write the code

[jira] [Commented] (FLINK-5855) Unprotected access to pendingFilesPerCheckpoint in BucketingSink

[ https://issues.apache.org/jira/browse/FLINK-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15980668#comment-15980668 ] mingleizhang commented on FLINK-5855: - I think the code snippet would follow your suggestion. How do

[jira] [Commented] (FLINK-5855) Unprotected access to pendingFilesPerCheckpoint in BucketingSink

[ https://issues.apache.org/jira/browse/FLINK-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15980671#comment-15980671 ] mingleizhang commented on FLINK-5855: - Okay, thanks. I will give a PR to this. I dont know really, why

[jira] [Commented] (FLINK-5943) Unprotected access to haServices in YarnFlinkApplicationMasterRunner#shutdown()

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

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

[ https://issues.apache.org/jira/browse/FLINK-6311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15974207#comment-15974207 ] mingleizhang edited comment on FLINK-6311 at 4/19/17 7:14 AM: -- [~tzulitai]

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

[ https://issues.apache.org/jira/browse/FLINK-6311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15974012#comment-15974012 ] mingleizhang commented on FLINK-6311: - [~tzulitai] I just watch FlinkKinesisConsumer which under the

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

[ https://issues.apache.org/jira/browse/FLINK-6311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15974207#comment-15974207 ] mingleizhang commented on FLINK-6311: - [~tzulitai] Hi, here is the sample code I put here, please

[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=15973937#comment-15973937 ] mingleizhang edited comment on FLINK-6130 at 4/19/17 2:36 AM: -- [~Zentol]

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

[ https://issues.apache.org/jira/browse/FLINK-6311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-6311: --- Assignee: mingleizhang > NPE in FlinkKinesisConsumer if source was closed before run >

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

[ https://issues.apache.org/jira/browse/FLINK-6311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15974124#comment-15974124 ] mingleizhang commented on FLINK-6311: - [~tzulitai] Thanks for telling me so useful information. I 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=15973937#comment-15973937 ] mingleizhang commented on FLINK-6130: - [~Zentol] [~till.rohrmann] That makes sense to me now. So, I

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

[ https://issues.apache.org/jira/browse/FLINK-6311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15974385#comment-15974385 ] mingleizhang commented on FLINK-6311: - [~tzulitai] Thanks and I will give a PR to this jira soon

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

[ https://issues.apache.org/jira/browse/FLINK-6311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15974012#comment-15974012 ] mingleizhang edited comment on FLINK-6311 at 4/19/17 10:02 AM: --- [~tzulitai]

[jira] [Updated] (FLINK-7302) Failed to run CorrelateITCase class under windows environment

[ https://issues.apache.org/jira/browse/FLINK-7302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-7302: Description: Error:(220, 5) reference to UserDefinedFunctionTestUtils is ambiguous; it is imported

[jira] [Created] (FLINK-7302) Failed to run CorrelateITCase class under windows environment

mingleizhang created FLINK-7302: --- Summary: Failed to run CorrelateITCase class under windows environment Key: FLINK-7302 URL: https://issues.apache.org/jira/browse/FLINK-7302 Project: Flink

[jira] [Commented] (FLINK-7297) Instable Kafka09ProducerITCase.testCustomPartitioning test case

[ https://issues.apache.org/jira/browse/FLINK-7297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107062#comment-16107062 ] mingleizhang commented on FLINK-7297: - Every time, I dont know why It would take me several hours to

[jira] [Comment Edited] (FLINK-7297) Instable Kafka09ProducerITCase.testCustomPartitioning test case

[ https://issues.apache.org/jira/browse/FLINK-7297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107062#comment-16107062 ] mingleizhang edited comment on FLINK-7297 at 7/31/17 9:56 AM: -- Every time, I

[jira] [Commented] (FLINK-7297) Instable Kafka09ProducerITCase.testCustomPartitioning test case

[ https://issues.apache.org/jira/browse/FLINK-7297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107059#comment-16107059 ] mingleizhang commented on FLINK-7297: - It is just a XML instead. > Instable

[jira] [Commented] (FLINK-7092) Shutdown ResourceManager components properly

[ https://issues.apache.org/jira/browse/FLINK-7092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16106216#comment-16106216 ] mingleizhang commented on FLINK-7092: - Thanks to Till. I back to my home these days. :) Shy I am. >

[jira] [Resolved] (FLINK-7302) Failed to run CorrelateITCase class under windows environment

[ https://issues.apache.org/jira/browse/FLINK-7302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang resolved FLINK-7302. - Resolution: Won't Fix > Failed to run CorrelateITCase class under windows environment >

[jira] [Commented] (FLINK-6995) Add a warning to outdated documentation

[ https://issues.apache.org/jira/browse/FLINK-6995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16114213#comment-16114213 ] mingleizhang commented on FLINK-6995: - Ahhha. I see. Thanks ~ > Add a warning to outdated

[jira] [Commented] (FLINK-6995) Add a warning to outdated documentation

[ https://issues.apache.org/jira/browse/FLINK-6995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16114134#comment-16114134 ] mingleizhang commented on FLINK-6995: - I am planning checkout a new branch based on {{release-1.2

[jira] [Commented] (FLINK-6995) Add a warning to outdated documentation

[ https://issues.apache.org/jira/browse/FLINK-6995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16114184#comment-16114184 ] mingleizhang commented on FLINK-6995: - Hi, [~alpinegizmo] What you said : We have to be enabled by

[jira] [Created] (FLINK-7162) Tests should not write outside 'target' directory.

mingleizhang created FLINK-7162: --- Summary: Tests should not write outside 'target' directory. Key: FLINK-7162 URL: https://issues.apache.org/jira/browse/FLINK-7162 Project: Flink Issue Type:

[jira] [Updated] (FLINK-7162) Tests should not write outside 'target' directory.

[ https://issues.apache.org/jira/browse/FLINK-7162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-7162: Issue Type: Improvement (was: Bug) > Tests should not write outside 'target' directory. >

[jira] [Updated] (FLINK-7162) Tests should not write outside 'target' directory.

[ https://issues.apache.org/jira/browse/FLINK-7162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-7162: Description: A few tests use Files.createTempDir() from Guava package, but do not set

[jira] [Updated] (FLINK-6934) Consider moving LRUCache and it's test classes

[ https://issues.apache.org/jira/browse/FLINK-6934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-6934: Summary: Consider moving LRUCache and it's test classes (was: Consider moving LRUCache class) >

[jira] [Commented] (FLINK-6378) Implement FLIP-6 Flink-on-Mesos

[ https://issues.apache.org/jira/browse/FLINK-6378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081702#comment-16081702 ] mingleizhang commented on FLINK-6378: - Why are we going to remove akka dependency ? > Implement

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

[ 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

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] [Created] (FLINK-7134) Remove hadoop1.x code in mapreduce.utils.HadoopUtils

mingleizhang created FLINK-7134: --- Summary: Remove hadoop1.x code in mapreduce.utils.HadoopUtils Key: FLINK-7134 URL: https://issues.apache.org/jira/browse/FLINK-7134 Project: Flink Issue Type:

[jira] [Commented] (FLINK-7121) Remove the hardcoded way in core

[ https://issues.apache.org/jira/browse/FLINK-7121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16078189#comment-16078189 ] mingleizhang commented on FLINK-7121: - OK. > Remove the hardcoded way in core >

[jira] [Commented] (FLINK-6493) Ineffective null check in RegisteredOperatorBackendStateMetaInfo#equals()

[ https://issues.apache.org/jira/browse/FLINK-6493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16085030#comment-16085030 ] mingleizhang commented on FLINK-6493: - Thanks Ted. {{partitionStateSerializerConfigSnapshot.equals()}}

[jira] [Comment Edited] (FLINK-6493) Ineffective null check in RegisteredOperatorBackendStateMetaInfo#equals()

[ https://issues.apache.org/jira/browse/FLINK-6493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16085054#comment-16085054 ] mingleizhang edited comment on FLINK-6493 at 7/13/17 2:29 AM: -- Actually,

[jira] [Assigned] (FLINK-6493) Ineffective null check in RegisteredOperatorBackendStateMetaInfo#equals()

[ https://issues.apache.org/jira/browse/FLINK-6493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-6493: --- Assignee: mingleizhang > Ineffective null check in

[jira] [Commented] (FLINK-5541) Missing null check for localJar in FlinkSubmitter#submitTopology()

[ https://issues.apache.org/jira/browse/FLINK-5541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16085159#comment-16085159 ] mingleizhang commented on FLINK-5541: - Thanks Ted report this, I wil take a look. > Missing null

[jira] [Commented] (FLINK-6493) Ineffective null check in RegisteredOperatorBackendStateMetaInfo#equals()

[ https://issues.apache.org/jira/browse/FLINK-6493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16085054#comment-16085054 ] mingleizhang commented on FLINK-6493: - Actually, Sorry. I dont think null check is ineffective, as it

[jira] [Assigned] (FLINK-6105) Properly handle InterruptedException in HadoopInputFormatBase

[ https://issues.apache.org/jira/browse/FLINK-6105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-6105: --- Assignee: mingleizhang > Properly handle InterruptedException in HadoopInputFormatBase >

[jira] [Assigned] (FLINK-5541) Missing null check for localJar in FlinkSubmitter#submitTopology()

[ https://issues.apache.org/jira/browse/FLINK-5541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-5541: --- Assignee: mingleizhang > Missing null check for localJar in FlinkSubmitter#submitTopology()

[jira] [Assigned] (FLINK-5987) Upgrade zookeeper dependency to 3.4.10

[ https://issues.apache.org/jira/browse/FLINK-5987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-5987: --- Assignee: mingleizhang > Upgrade zookeeper dependency to 3.4.10 >

[jira] [Assigned] (FLINK-5486) Lack of synchronization in BucketingSink#handleRestoredBucketState()

[ https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-5486: --- Assignee: mingleizhang > Lack of synchronization in

[jira] [Updated] (FLINK-7118) Remove hadoop1.x code in HadoopUtils

[ https://issues.apache.org/jira/browse/FLINK-7118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-7118: Description: Since flink no longer support hadoop 1.x version, we should remove it. Below code

[jira] [Commented] (FLINK-7114) Remove the hardcoded way like classpath is written by a string

[ https://issues.apache.org/jira/browse/FLINK-7114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16078199#comment-16078199 ] mingleizhang commented on FLINK-7114: - Thanks. Chesnay. Makes sense better. > Remove the hardcoded

[jira] [Commented] (FLINK-7134) Remove hadoop1.x code in mapreduce.utils.HadoopUtils

[ https://issues.apache.org/jira/browse/FLINK-7134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16092465#comment-16092465 ] mingleizhang commented on FLINK-7134: - I will work on this soon enough. > Remove hadoop1.x code in

[jira] [Commented] (FLINK-7225) Cutoff exception message in StateDescriptor

[ https://issues.apache.org/jira/browse/FLINK-7225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16094600#comment-16094600 ] mingleizhang commented on FLINK-7225: - [~StephanEwen] Sorry, I dont understand what you exactly mean.

[jira] [Commented] (FLINK-4421) Make clocks and time measurements monotonous

[ https://issues.apache.org/jira/browse/FLINK-4421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16095699#comment-16095699 ] mingleizhang commented on FLINK-4421: - Hi, Stephan. Thanks for reporting this. I would like to know,

[jira] [Comment Edited] (FLINK-4421) Make clocks and time measurements monotonous

[ https://issues.apache.org/jira/browse/FLINK-4421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16095699#comment-16095699 ] mingleizhang edited comment on FLINK-4421 at 7/21/17 2:46 AM: -- Hi,

[jira] [Issue Comment Deleted] (FLINK-4421) Make clocks and time measurements monotonous

[ https://issues.apache.org/jira/browse/FLINK-4421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-4421: Comment: was deleted (was: Hi, [~StephanEwen]. Thanks for reporting this. I would like to know,

[jira] [Commented] (FLINK-4423) Introduce a Clock utility for monotonous system timestamps

[ https://issues.apache.org/jira/browse/FLINK-4423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16095743#comment-16095743 ] mingleizhang commented on FLINK-4423: - [~StephanEwen] This is a very interesting topic indeed . One

[jira] [Commented] (FLINK-5130) Remove Deprecated Methods from WindowedStream

[ https://issues.apache.org/jira/browse/FLINK-5130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16096110#comment-16096110 ] mingleizhang commented on FLINK-5130: - If agree, I wont do it until 2.0.0 begin. > Remove Deprecated

[jira] [Commented] (FLINK-3992) Remove Key interface

[ https://issues.apache.org/jira/browse/FLINK-3992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16096123#comment-16096123 ] mingleizhang commented on FLINK-3992: - Could you please add more message here ? [~Zentol] Thanks. :)

[jira] [Commented] (FLINK-4048) Remove Hadoop dependencies from ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-4048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16096120#comment-16096120 ] mingleizhang commented on FLINK-4048: - I would like work on it when 2.0.0 should comes. Now, I wont.

[jira] [Updated] (FLINK-5789) Make Bucketing Sink independent of Hadoop's FileSystem

[ https://issues.apache.org/jira/browse/FLINK-5789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-5789: Summary: Make Bucketing Sink independent of Hadoop's FileSystem (was: Make Bucketing Sink

  1   2   3   4   5   6   >