[
https://issues.apache.org/jira/browse/FLINK-20199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237087#comment-17237087
]
Shuiqiang Chen edited comment on FLINK-20199 at 11/23/20, 3:38 AM:
-------------------------------------------------------------------
[~hxbks2ks] Thank you for reporting this issue. It seems that it failed to stop
the Kafka process after the DataStream job finished. I'll keep an eye on this
problem.
was (Author: csq):
[~hxbks2ks] Thank you for reporting this issue. It is because the testing
environment's instability that it fail to stop the Kafka process after the
DataStream job finished.
> PyFlink e2e DataStream test failed during stopping kafka services
> -----------------------------------------------------------------
>
> Key: FLINK-20199
> URL: https://issues.apache.org/jira/browse/FLINK-20199
> Project: Flink
> Issue Type: Bug
> Components: API / Python
> Reporter: Huang Xingbo
> Priority: Major
> Fix For: 1.12.0
>
>
> [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=9667&view=logs&j=c88eea3b-64a0-564d-0031-9fdcd7b8abee&t=ff888d9b-cd34-53cc-d90f-3e446d355529]
>
> {code}
> Nov 17 06:04:35 Reading kafka messages...
> Nov 17 06:05:17 Cancelling job 55acfb14436b24b9c6fb0f47d7297f83.
> Nov 17 06:05:17 Cancelled job 55acfb14436b24b9c6fb0f47d7297f83.
> Nov 17 06:05:18 Stopping taskexecutor daemon (pid: 110438) on host
> fv-az598-520.
> Nov 17 06:05:24 Stopping standalonesession daemon (pid: 110130) on host
> fv-az598-520.
> Nov 17 06:05:25 Waiting till process is stopped: pid = 123127 pattern =
> 'kafka'
> Nov 17 06:05:26 Waiting till process is stopped: pid = 123717 pattern =
> 'kafka'
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
