[jira] [Commented] (FLINK-5679) Refactor *CheckpointedITCase tests to speed up

[ https://issues.apache.org/jira/browse/FLINK-5679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15847924#comment-15847924 ] Andrew Efimov commented on FLINK-5679: -- Described above idea accompanies current task, it is not main

[jira] [Commented] (FLINK-5679) Refactor *CheckpointedITCase tests to speed up

[ https://issues.apache.org/jira/browse/FLINK-5679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15858852#comment-15858852 ] Andrew Efimov commented on FLINK-5679: -- Current status: I am collected all tests related to testing

[jira] [Comment Edited] (FLINK-5679) Refactor *CheckpointedITCase tests to speed up

[ https://issues.apache.org/jira/browse/FLINK-5679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15858852#comment-15858852 ] Andrew Efimov edited comment on FLINK-5679 at 2/9/17 1:59 AM: -- Current

[jira] (FLINK-5679) Refactor *CheckpointedITCase tests to speed up

[ https://issues.apache.org/jira/browse/FLINK-5679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15847551#comment-15847551 ] Andrew Efimov commented on FLINK-5679: -- I agree. Recently, I checked approach that allows to reuse

[jira] [Commented] (FLINK-2671) Instable Test StreamCheckpointNotifierITCase

[ https://issues.apache.org/jira/browse/FLINK-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15839859#comment-15839859 ] Andrew Efimov commented on FLINK-2671: -- Hi team, [~StephanEwen] Do we still have issue with this

[jira] [Updated] (FLINK-2671) Instable Test StreamCheckpointNotifierITCase

[ https://issues.apache.org/jira/browse/FLINK-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Efimov updated FLINK-2671: - Labels: test test-stability (was: test-stability) > Instable Test StreamCheckpointNotifierITCase

[jira] [Commented] (FLINK-2671) Instable Test StreamCheckpointNotifierITCase

[ https://issues.apache.org/jira/browse/FLINK-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15839993#comment-15839993 ] Andrew Efimov commented on FLINK-2671: -- [~StephanEwen] Ok. I am looking at the listed tests. You can

[jira] [Closed] (FLINK-4905) Kafka test instability IllegalStateException: Client is not started

[ https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Efimov closed FLINK-4905. Resolution: Fixed Fix Version/s: 1.3.0 Fixed by Stephan Ewen > Kafka test instability

[jira] [Created] (FLINK-5679) Refactor *CheckpointedITCase tests to speed up

Andrew Efimov created FLINK-5679: Summary: Refactor *CheckpointedITCase tests to speed up Key: FLINK-5679 URL: https://issues.apache.org/jira/browse/FLINK-5679 Project: Flink Issue Type:

[jira] [Comment Edited] (FLINK-2671) Instable Test StreamCheckpointNotifierITCase

[ https://issues.apache.org/jira/browse/FLINK-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15839993#comment-15839993 ] Andrew Efimov edited comment on FLINK-2671 at 1/27/17 4:03 PM: ---

[jira] [Comment Edited] (FLINK-2671) Instable Test StreamCheckpointNotifierITCase

[ https://issues.apache.org/jira/browse/FLINK-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15839993#comment-15839993 ] Andrew Efimov edited comment on FLINK-2671 at 1/27/17 4:03 PM: ---

[jira] [Comment Edited] (FLINK-4905) Kafka test instability IllegalStateException: Client is not started

[ https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15680307#comment-15680307 ] Andrew Efimov edited comment on FLINK-4905 at 11/20/16 3:01 AM: I have

[jira] [Commented] (FLINK-4905) Kafka test instability IllegalStateException: Client is not started

[ https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15683063#comment-15683063 ] Andrew Efimov commented on FLINK-4905: -- I would suggest the following solution: - not only set null

[jira] [Commented] (FLINK-4905) Kafka test instability IllegalStateException: Client is not started

[ https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15754286#comment-15754286 ] Andrew Efimov commented on FLINK-4905: -- Hi team, Thanks for replay. Sorry, I had a hard work of this

[jira] [Commented] (FLINK-4905) Kafka test instability IllegalStateException: Client is not started

[ https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708105#comment-15708105 ] Andrew Efimov commented on FLINK-4905: -- Hi [~tzulitai] Thanks for reply. It is very difficult to

[jira] [Updated] (FLINK-4905) Kafka test instability IllegalStateException: Client is not started

[ https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Efimov updated FLINK-4905: - Attachment: Kafka08Fetcher.png > Kafka test instability IllegalStateException: Client is not

[jira] [Comment Edited] (FLINK-4905) Kafka test instability IllegalStateException: Client is not started

[ https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708105#comment-15708105 ] Andrew Efimov edited comment on FLINK-4905 at 11/30/16 10:38 AM: - Hi

[jira] [Comment Edited] (FLINK-4905) Kafka test instability IllegalStateException: Client is not started

[ https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708105#comment-15708105 ] Andrew Efimov edited comment on FLINK-4905 at 11/30/16 10:34 AM: - Hi

[jira] [Commented] (FLINK-5108) Remove ClientShutdownHook during job execution

[ https://issues.apache.org/jira/browse/FLINK-5108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15722400#comment-15722400 ] Andrew Efimov commented on FLINK-5108: -- Hi team, I thought that in this issue we should implement: 1.

[jira] [Assigned] (FLINK-4714) Set task state to RUNNING after state has been restored

[ https://issues.apache.org/jira/browse/FLINK-4714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Efimov reassigned FLINK-4714: Assignee: Wei-Che Wei (was: Andrew Efimov) > Set task state to RUNNING after state has

[jira] [Closed] (FLINK-5679) Refactor *CheckpointedITCase tests to speed up

[ https://issues.apache.org/jira/browse/FLINK-5679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Efimov closed FLINK-5679. Resolution: Incomplete > Refactor *CheckpointedITCase tests to speed up >

[jira] [Assigned] (FLINK-5679) Refactor *CheckpointedITCase tests to speed up

[ https://issues.apache.org/jira/browse/FLINK-5679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Efimov reassigned FLINK-5679: Assignee: (was: Andrew Efimov) > Refactor *CheckpointedITCase tests to speed up >