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

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

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

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

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

[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=15836398#comment-15836398 ] ASF GitHub Bot commented on FLINK-4905: --- Github user asfgit closed the pull request at:

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

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

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

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

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

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

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

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

[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=15765735#comment-15765735 ] ASF GitHub Bot commented on FLINK-4905: --- GitHub user BrainLogic opened a pull request:

[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=15751146#comment-15751146 ] Stephan Ewen commented on FLINK-4905: - I saw the issue happening again:

[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=15728171#comment-15728171 ] Tzu-Li (Gordon) Tai commented on FLINK-4905: Hi [~Andrew Efimov], Sorry for the very late

[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] [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=15686881#comment-15686881 ] Tzu-Li (Gordon) Tai commented on FLINK-4905: Hi [~Andrew Efimov], Thanks for looking at 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=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=15607498#comment-15607498 ] Tzu-Li (Gordon) Tai commented on FLINK-4905: Had a quick look at this. The only place we're