[jira] [Created] (FLINK-22085) KafkaSourceLegacyITCase hangs on azure

[Shang Yuanchun (Jira)]

Dawid Wysakowicz created FLINK-22085:
----------------------------------------

             Summary: KafkaSourceLegacyITCase hangs 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
             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)