[
https://issues.apache.org/jira/browse/FLINK-19951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233190#comment-17233190
]
Shuiqiang Chen commented on FLINK-19951:
----------------------------------------
Hi [~dian.fu] it's because that the Kafka consumer could not read the expected
number of messages(15), so it would stuck here. The root cause might be the
Flink job is not running normally. Maybe we could printing out the log of JM on
exiting the test.
> PyFlink end-to-end test stuck in "Reading kafka messages"
> ---------------------------------------------------------
>
> Key: FLINK-19951
> URL: https://issues.apache.org/jira/browse/FLINK-19951
> Project: Flink
> Issue Type: Bug
> Components: API / Python
> Affects Versions: 1.12.0
> Reporter: Robert Metzger
> Priority: Critical
> Labels: test-stability
> Fix For: 1.12.0
>
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=8837&view=logs&j=c88eea3b-64a0-564d-0031-9fdcd7b8abee&t=ff888d9b-cd34-53cc-d90f-3e446d355529
> {code}
> 2020-11-03T08:18:10.2935249Z Nov 03 08:18:10 Test PyFlink DataStream job:
> 2020-11-03T08:18:10.2936216Z Nov 03 08:18:10 Preparing Kafka...
> 2020-11-03T08:18:10.2948091Z Nov 03 08:18:10 Downloading Kafka from
> https://archive.apache.org/dist/kafka/2.2.0/kafka_2.12-2.2.0.tgz
> 2020-11-03T08:18:10.3024006Z % Total % Received % Xferd Average Speed
> Time Time Time Current
> 2020-11-03T08:18:10.3024610Z Dload Upload
> Total Spent Left Speed
> 2020-11-03T08:18:10.3024891Z
> 2020-11-03T08:18:10.6563956Z 0 0 0 0 0 0 0 0
> --:--:-- --:--:-- --:--:-- 0
> 2020-11-03T08:18:11.6568328Z 0 54.3M 0 32768 0 0 92275 0
> 0:10:18 --:--:-- 0:10:18 92044
> 2020-11-03T08:18:12.6540430Z 11 54.3M 11 6272k 0 0 4626k 0
> 0:00:12 0:00:01 0:00:11 4625k
> 2020-11-03T08:18:13.6585146Z 23 54.3M 23 12.6M 0 0 5521k 0
> 0:00:10 0:00:02 0:00:08 5521k
> 2020-11-03T08:18:14.6558377Z 36 54.3M 36 19.7M 0 0 6018k 0
> 0:00:09 0:00:03 0:00:06 6017k
> 2020-11-03T08:18:15.6593118Z 49 54.3M 49 26.7M 0 0 6297k 0
> 0:00:08 0:00:04 0:00:04 6297k
> 2020-11-03T08:18:16.6534444Z 62 54.3M 62 34.0M 0 0 6515k 0
> 0:00:08 0:00:05 0:00:03 6973k
> 2020-11-03T08:18:17.6544951Z 76 54.3M 76 41.8M 0 0 6747k 0
> 0:00:08 0:00:06 0:00:02 7322k
> 2020-11-03T08:18:18.2448109Z 91 54.3M 91 49.7M 0 0 6923k 0
> 0:00:08 0:00:07 0:00:01 7584k
> 2020-11-03T08:18:18.2450531Z 100 54.3M 100 54.3M 0 0 7010k 0
> 0:00:07 0:00:07 --:--:-- 7737k
> 2020-11-03T08:18:20.2751451Z Nov 03 08:18:20 Zookeeper Server has been
> started ...
> 2020-11-03T08:18:22.0064118Z Nov 03 08:18:22 Waiting for broker...
> 2020-11-03T08:18:25.4758082Z Nov 03 08:18:25 Created topic
> test-python-data-stream-source.
> 2020-11-03T08:18:25.8324767Z Nov 03 08:18:25 Sending messages to Kafka...
> 2020-11-03T08:18:35.2954788Z Nov 03 08:18:35 >>>>>>>>>>Created topic
> test-python-data-stream-sink.
> 2020-11-03T08:18:54.8314099Z Nov 03 08:18:54 Job has been submitted with
> JobID 1b0c317b47c69ee600937e1715ad9cce
> 2020-11-03T08:18:54.8348757Z Nov 03 08:18:54 Reading kafka messages...
> 2020-11-03T08:53:10.5246998Z
> ==========================================================================================
> 2020-11-03T08:53:10.5249381Z === WARNING: This E2E Run took already 80% of
> the allocated time budget of 250 minutes ===
> 2020-11-03T08:53:10.5251343Z
> ==========================================================================================
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
