[
https://issues.apache.org/jira/browse/FLINK-20199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-20199.
---------------------------
Fix Version/s: (was: 1.14.0)
Resolution: Cannot Reproduce
Closing this ticket for now as it has not occurred for almost one year.
> 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: Minor
> Labels: auto-deprioritized-major
>
> [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)
