[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318658#comment-17318658
]
Guowei Ma commented on FLINK-22085:
-----------------------------------
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=16311&view=logs&j=c5f0071e-1851-543e-9a45-9ac140befc32&t=1fb1a56f-e8b5-5a82-00a0-a2db7757b4f5&l=6862
> KafkaSourceLegacyITCase hangs/fails on azure
> --------------------------------------------
>
> Key: FLINK-22085
> URL: https://issues.apache.org/jira/browse/FLINK-22085
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka
> Affects Versions: 1.13.0
> Reporter: Dawid Wysakowicz
> Priority: Blocker
> Labels: test-stability
> Fix For: 1.13.0
>
>
> {code}
> 2021-04-01T00:25:10.1501093Z [INFO] Running
> org.apache.flink.connector.kafka.source.KafkaSourceLegacyITCase
> 2021-04-01T00:25:12.6833522Z 00:25:12,681 [ main] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] -
> -------------------------------------------------------------------------
> 2021-04-01T00:25:12.6835433Z 00:25:12,682 [ main] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] -
> Starting KafkaTestBase
> 2021-04-01T00:25:12.6837371Z 00:25:12,682 [ main] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] -
> -------------------------------------------------------------------------
> 2021-04-01T00:25:12.6864448Z 00:25:12,685 [ main] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Starting
> KafkaTestBase.prepare() for Kafka 2.0
> 2021-04-01T00:25:13.8482126Z 00:25:13,847 [ main] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl [] -
> Starting Zookeeper with zookeeperConnectionString: 127.0.0.1:37140
> 2021-04-01T00:25:13.8483503Z 00:25:13,847 [ main] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl [] -
> Starting KafkaServer
> 2021-04-01T00:25:16.3558946Z 00:25:16,354 [ main] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl [] - ZK
> and KafkaServer started.
> 2021-04-01T00:25:16.3733096Z 00:25:16,372 [ Time-limited test] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl [] -
> Creating topic cancelingOnEmptyInputTopic
> 2021-04-01T00:25:19.1825798Z 00:25:19,181 [program runner thread] ERROR
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Job Runner
> failed with exception
> 2021-04-01T00:25:19.1826635Z
> org.apache.flink.runtime.client.JobCancellationException: Job was cancelled.
> 2021-04-01T00:25:19.1827475Z at
> org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:146)
> ~[flink-runtime_2.11-1.13-SNAPSHOT.jar:1.13-SNAPSHOT]
> 2021-04-01T00:25:19.1828360Z at
> org.apache.flink.test.util.TestUtils.submitJobAndWaitForResult(TestUtils.java:63)
> ~[flink-tests-1.13-SNAPSHOT-tests.jar:1.13-SNAPSHOT]
> 2021-04-01T00:25:19.1829375Z at
> org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase.lambda$runCancelingOnEmptyInputTest$2(KafkaConsumerTestBase.java:1217)
> ~[test-classes/:?]
> 2021-04-01T00:25:19.1829920Z at java.lang.Thread.run(Thread.java:748)
> [?:1.8.0_282]
> 2021-04-01T00:25:19.1871303Z 00:25:19,186 [ Time-limited test] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl [] -
> Deleting topic cancelingOnEmptyInputTopic
> 2021-04-01T00:25:19.2990861Z 00:25:19,297 [ Time-limited test] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl [] -
> Creating topic alldeletestest
> 2021-04-01T00:25:19.4938211Z 00:25:19,492 [ Time-limited test] WARN
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer [] - Property
> [transaction.timeout.ms] not specified. Setting it to 3600000 ms
> 2021-04-01T00:25:19.5826317Z 00:25:19,580 [Source: Custom Source -> Sink:
> Unnamed (1/1)#0] WARN
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer [] - Using
> AT_LEAST_ONCE semantic, but checkpointing is not enabled. Switching to NONE
> semantic.
> 2021-04-01T00:25:19.9535621Z 00:25:19,952 [Source: Custom Source -> Sink:
> Unnamed (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer [] - Starting
> FlinkKafkaInternalProducer (1/1) to produce into default topic alldeletestest
> 2021-04-01T00:25:20.3024529Z 00:25:20,300 [ Time-limited test] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl [] -
> Deleting topic alldeletestest
> 2021-04-01T00:25:20.3649416Z 00:25:20,363 [ Time-limited test] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] -
> 2021-04-01T00:25:20.3650188Z ===================================
> 2021-04-01T00:25:20.3650741Z == Writing sequence of 50 into
> testStartFromEarliestOffsetsTopic with p=3
> 2021-04-01T00:25:20.3651195Z ===================================
> 2021-04-01T00:25:20.3672261Z 00:25:20,366 [ Time-limited test] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Writing
> attempt #1
> 2021-04-01T00:25:20.3700506Z 00:25:20,366 [ Time-limited test] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl [] -
> Creating topic testStartFromEarliestOffsetsTopic-1
> 2021-04-01T00:25:20.4594288Z 00:25:20,458 [ Time-limited test] WARN
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer [] - Property
> [transaction.timeout.ms] not specified. Setting it to 3600000 ms
> 2021-04-01T00:25:20.4969968Z 00:25:20,495 [Source: Custom Source -> Sink:
> Unnamed (1/3)#0] WARN
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer [] - Using
> AT_LEAST_ONCE semantic, but checkpointing is not enabled. Switching to NONE
> semantic.
> 2021-04-01T00:25:20.4983179Z 00:25:20,497 [Source: Custom Source -> Sink:
> Unnamed (2/3)#0] WARN
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer [] - Using
> AT_LEAST_ONCE semantic, but checkpointing is not enabled. Switching to NONE
> semantic.
> 2021-04-01T00:25:20.5041701Z 00:25:20,503 [Source: Custom Source -> Sink:
> Unnamed (1/3)#0] INFO
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer [] - Starting
> FlinkKafkaInternalProducer (1/3) to produce into default topic
> testStartFromEarliestOffsetsTopic-1
> 2021-04-01T00:25:20.5123124Z 00:25:20,509 [Source: Custom Source -> Sink:
> Unnamed (2/3)#0] INFO
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer [] - Starting
> FlinkKafkaInternalProducer (2/3) to produce into default topic
> testStartFromEarliestOffsetsTopic-1
> 2021-04-01T00:25:20.5175121Z 00:25:20,516 [Source: Custom Source -> Sink:
> Unnamed (3/3)#0] WARN
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer [] - Using
> AT_LEAST_ONCE semantic, but checkpointing is not enabled. Switching to NONE
> semantic.
> 2021-04-01T00:25:20.5202713Z 00:25:20,519 [Source: Custom Source -> Sink:
> Unnamed (3/3)#0] INFO
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer [] - Starting
> FlinkKafkaInternalProducer (3/3) to produce into default topic
> testStartFromEarliestOffsetsTopic-1
> 2021-04-01T00:25:20.6043145Z 00:25:20,603 [ Time-limited test] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Finished
> writing sequence
> 2021-04-01T00:25:20.6044769Z 00:25:20,603 [ Time-limited test] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Validating
> sequence
> 2021-04-01T00:25:22.5503698Z 00:25:22,549 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,0), total 1 messages
> 2021-04-01T00:25:22.5505507Z 00:25:22,549 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,1), total 2 messages
> 2021-04-01T00:25:22.5651055Z 00:25:22,564 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,0), total 3 messages
> 2021-04-01T00:25:22.5652753Z 00:25:22,564 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,1), total 4 messages
> 2021-04-01T00:25:22.5654174Z 00:25:22,564 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,2), total 5 messages
> 2021-04-01T00:25:22.6501990Z 00:25:22,649 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,2), total 6 messages
> 2021-04-01T00:25:22.6503209Z 00:25:22,649 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,3), total 7 messages
> 2021-04-01T00:25:22.6504388Z 00:25:22,649 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,4), total 8 messages
> 2021-04-01T00:25:22.6505217Z 00:25:22,649 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,5), total 9 messages
> 2021-04-01T00:25:22.6506034Z 00:25:22,649 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,6), total 10 messages
> 2021-04-01T00:25:22.6655007Z 00:25:22,664 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,3), total 11 messages
> 2021-04-01T00:25:22.6656120Z 00:25:22,664 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,4), total 12 messages
> 2021-04-01T00:25:22.6657238Z 00:25:22,664 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,5), total 13 messages
> 2021-04-01T00:25:22.6658058Z 00:25:22,664 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,6), total 14 messages
> 2021-04-01T00:25:22.6658990Z 00:25:22,664 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,7), total 15 messages
> 2021-04-01T00:25:22.7503400Z 00:25:22,749 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,7), total 16 messages
> 2021-04-01T00:25:22.7504453Z 00:25:22,749 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,8), total 17 messages
> 2021-04-01T00:25:22.7505488Z 00:25:22,749 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,9), total 18 messages
> 2021-04-01T00:25:22.7506317Z 00:25:22,749 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,10), total 19 messages
> 2021-04-01T00:25:22.7507120Z 00:25:22,749 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,11), total 20 messages
> 2021-04-01T00:25:22.7652157Z 00:25:22,764 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,8), total 21 messages
> 2021-04-01T00:25:22.7653215Z 00:25:22,764 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,9), total 22 messages
> 2021-04-01T00:25:22.7654011Z 00:25:22,764 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,10), total 23 messages
> 2021-04-01T00:25:22.7654879Z 00:25:22,764 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,11), total 24 messages
> 2021-04-01T00:25:22.8504704Z 00:25:22,849 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,12), total 25 messages
> 2021-04-01T00:25:22.8505796Z 00:25:22,849 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,13), total 26 messages
> 2021-04-01T00:25:22.8506746Z 00:25:22,849 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,14), total 27 messages
> 2021-04-01T00:25:22.8507568Z 00:25:22,849 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,15), total 28 messages
> 2021-04-01T00:25:22.8508393Z 00:25:22,849 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,16), total 29 messages
> 2021-04-01T00:25:22.8722216Z 00:25:22,871 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,12), total 30 messages
> 2021-04-01T00:25:22.8723734Z 00:25:22,871 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,13), total 31 messages
> 2021-04-01T00:25:22.8724642Z 00:25:22,871 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,14), total 32 messages
> 2021-04-01T00:25:22.8725459Z 00:25:22,871 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,15), total 33 messages
> 2021-04-01T00:25:22.8726259Z 00:25:22,871 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,16), total 34 messages
> 2021-04-01T00:25:22.8727074Z 00:25:22,871 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,17), total 35 messages
> 2021-04-01T00:25:22.9506523Z 00:25:22,949 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,17), total 36 messages
> 2021-04-01T00:25:22.9507626Z 00:25:22,949 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,18), total 37 messages
> 2021-04-01T00:25:22.9508469Z 00:25:22,949 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,19), total 38 messages
> 2021-04-01T00:25:22.9509353Z 00:25:22,949 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,20), total 39 messages
> 2021-04-01T00:25:22.9722763Z 00:25:22,971 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,18), total 40 messages
> 2021-04-01T00:25:22.9724081Z 00:25:22,971 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,19), total 41 messages
> 2021-04-01T00:25:22.9724969Z 00:25:22,971 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,20), total 42 messages
> 2021-04-01T00:25:22.9725784Z 00:25:22,971 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,21), total 43 messages
> 2021-04-01T00:25:23.0507440Z 00:25:23,049 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,21), total 44 messages
> 2021-04-01T00:25:23.0508505Z 00:25:23,050 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,22), total 45 messages
> 2021-04-01T00:25:23.0509462Z 00:25:23,050 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,23), total 46 messages
> 2021-04-01T00:25:23.0510298Z 00:25:23,050 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,24), total 47 messages
> 2021-04-01T00:25:23.0511183Z 00:25:23,050 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,25), total 48 messages
> 2021-04-01T00:25:23.0735035Z 00:25:23,071 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,22), total 49 messages
> 2021-04-01T00:25:23.0735998Z 00:25:23,071 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,23), total 50 messages
> 2021-04-01T00:25:23.0736807Z 00:25:23,071 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,24), total 51 messages
> 2021-04-01T00:25:23.0737615Z 00:25:23,071 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,25), total 52 messages
> 2021-04-01T00:25:23.0738441Z 00:25:23,072 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,26), total 53 messages
> 2021-04-01T00:25:23.1507987Z 00:25:23,150 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,26), total 54 messages
> 2021-04-01T00:25:23.1509152Z 00:25:23,150 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,27), total 55 messages
> 2021-04-01T00:25:23.1510017Z 00:25:23,150 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,28), total 56 messages
> 2021-04-01T00:25:23.1510992Z 00:25:23,150 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,29), total 57 messages
> 2021-04-01T00:25:23.1512064Z 00:25:23,150 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,30), total 58 messages
> 2021-04-01T00:25:23.1725066Z 00:25:23,171 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,27), total 59 messages
> 2021-04-01T00:25:23.1725942Z 00:25:23,171 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,28), total 60 messages
> 2021-04-01T00:25:23.1726758Z 00:25:23,172 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,29), total 61 messages
> 2021-04-01T00:25:23.1727554Z 00:25:23,172 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,30), total 62 messages
> 2021-04-01T00:25:23.1728359Z 00:25:23,172 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,31), total 63 messages
> 2021-04-01T00:25:23.2507865Z 00:25:23,250 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,31), total 64 messages
> 2021-04-01T00:25:23.2508948Z 00:25:23,250 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,32), total 65 messages
> 2021-04-01T00:25:23.2509809Z 00:25:23,250 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,33), total 66 messages
> 2021-04-01T00:25:23.2510794Z 00:25:23,250 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,34), total 67 messages
> 2021-04-01T00:25:23.2511612Z 00:25:23,250 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,35), total 68 messages
> 2021-04-01T00:25:23.2725124Z 00:25:23,271 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,32), total 69 messages
> 2021-04-01T00:25:23.2725983Z 00:25:23,272 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,33), total 70 messages
> 2021-04-01T00:25:23.2726847Z 00:25:23,272 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,34), total 71 messages
> 2021-04-01T00:25:23.2727660Z 00:25:23,272 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,35), total 72 messages
> 2021-04-01T00:25:23.2728447Z 00:25:23,272 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,36), total 73 messages
> 2021-04-01T00:25:23.3509837Z 00:25:23,350 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,36), total 74 messages
> 2021-04-01T00:25:23.3510858Z 00:25:23,350 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,37), total 75 messages
> 2021-04-01T00:25:23.3511670Z 00:25:23,350 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,38), total 76 messages
> 2021-04-01T00:25:23.3512874Z 00:25:23,350 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,39), total 77 messages
> 2021-04-01T00:25:23.3513695Z 00:25:23,350 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,40), total 78 messages
> 2021-04-01T00:25:23.3729063Z 00:25:23,372 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,37), total 79 messages
> 2021-04-01T00:25:23.3732609Z 00:25:23,372 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,38), total 80 messages
> 2021-04-01T00:25:23.3733820Z 00:25:23,372 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,39), total 81 messages
> 2021-04-01T00:25:23.3734744Z 00:25:23,372 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,40), total 82 messages
> 2021-04-01T00:25:23.3735580Z 00:25:23,372 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,41), total 83 messages
> 2021-04-01T00:25:23.4512917Z 00:25:23,450 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,41), total 84 messages
> 2021-04-01T00:25:23.4513948Z 00:25:23,450 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,42), total 85 messages
> 2021-04-01T00:25:23.4514761Z 00:25:23,450 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,43), total 86 messages
> 2021-04-01T00:25:23.4515602Z 00:25:23,450 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,44), total 87 messages
> 2021-04-01T00:25:23.4516415Z 00:25:23,450 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,45), total 88 messages
> 2021-04-01T00:25:23.4730050Z 00:25:23,472 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,42), total 89 messages
> 2021-04-01T00:25:23.4730983Z 00:25:23,472 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,43), total 90 messages
> 2021-04-01T00:25:23.4731824Z 00:25:23,472 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,44), total 91 messages
> 2021-04-01T00:25:23.4732783Z 00:25:23,472 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,45), total 92 messages
> 2021-04-01T00:25:23.4733780Z 00:25:23,472 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,46), total 93 messages
> 2021-04-01T00:25:23.5513009Z 00:25:23,550 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,46), total 94 messages
> 2021-04-01T00:25:23.5514065Z 00:25:23,550 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,47), total 95 messages
> 2021-04-01T00:25:23.5514945Z 00:25:23,550 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,48), total 96 messages
> 2021-04-01T00:25:23.5515833Z 00:25:23,550 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (0,49), total 97 messages
> 2021-04-01T00:25:23.5730281Z 00:25:23,572 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,47), total 98 messages
> 2021-04-01T00:25:23.5731516Z 00:25:23,572 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,48), total 99 messages
> 2021-04-01T00:25:23.5732398Z 00:25:23,572 [ Flat Map (1/1)#0] INFO
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Received
> message (1,49), total 100 messages
> {code}
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=15939&view=logs&j=c5f0071e-1851-543e-9a45-9ac140befc32&t=1fb1a56f-e8b5-5a82-00a0-a2db7757b4f5&l=8219
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
