Dawid Wysakowicz created FLINK-21449: ----------------------------------------
Summary: Kafka011ProducerExactlyOnceITCase>KafkaProducerTestBase.testExactlyOnceRegularSink fails on azure Key: FLINK-21449 URL: https://issues.apache.org/jira/browse/FLINK-21449 Project: Flink Issue Type: Bug Components: Connectors / Kafka Affects Versions: 1.11.3 Reporter: Dawid Wysakowicz https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=13612&view=logs&s=ae4f8708-9994-57d3-c2d7-b892156e7812&j=d44f43ce-542c-597d-bf94-b0718c71e5e8 {code} 2021-02-22T22:53:30.4664077Z 22:53:30,464 [Kafka 0.10 Fetcher for Source: Custom Source -> Sink: Unnamed (3/3)] DEBUG org.apache.flink.streaming.connectors.kafka.internal.Kafka010Fetcher [] - Sending async offset commit request to Kafka broker 2021-02-22T22:53:30.5659222Z 22:53:30,565 [Kafka 0.10 Fetcher for Source: Custom Source -> Sink: Unnamed (1/3)] DEBUG org.apache.flink.streaming.connectors.kafka.internal.Kafka010Fetcher [] - Sending async offset commit request to Kafka broker 2021-02-22T22:53:30.5660797Z 22:53:30,565 [Kafka 0.10 Fetcher for Source: Custom Source -> Sink: Unnamed (1/3)] DEBUG org.apache.flink.streaming.connectors.kafka.internal.Kafka010Fetcher [] - Sending async offset commit request to Kafka broker 2021-02-22T22:53:30.5662001Z 22:53:30,565 [Kafka 0.10 Fetcher for Source: Custom Source -> Sink: Unnamed (2/3)] DEBUG org.apache.flink.streaming.connectors.kafka.internal.Kafka010Fetcher [] - Sending async offset commit request to Kafka broker 2021-02-22T22:53:30.5663175Z 22:53:30,565 [Kafka 0.10 Fetcher for Source: Custom Source -> Sink: Unnamed (2/3)] DEBUG org.apache.flink.streaming.connectors.kafka.internal.Kafka010Fetcher [] - Sending async offset commit request to Kafka broker 2021-02-22T22:53:30.5673806Z 22:53:30,566 [Kafka 0.10 Fetcher for Source: Custom Source -> Sink: Unnamed (3/3)] DEBUG org.apache.flink.streaming.connectors.kafka.internal.Kafka010Fetcher [] - Sending async offset commit request to Kafka broker 2021-02-22T22:53:30.5675137Z 22:53:30,566 [Kafka 0.10 Fetcher for Source: Custom Source -> Sink: Unnamed (3/3)] DEBUG org.apache.flink.streaming.connectors.kafka.internal.Kafka010Fetcher [] - Sending async offset commit request to Kafka broker 2021-02-22T22:53:30.7785928Z 22:53:30,767 [program runner thread] ERROR org.apache.flink.streaming.connectors.kafka.KafkaTestBase [] - Job Runner failed with exception 2021-02-22T22:53:30.7787195Z org.apache.flink.client.program.ProgramInvocationException: Job failed (JobID: 5488f1249d451a6f8e5d479342959c8b) 2021-02-22T22:53:30.7789060Z at org.apache.flink.client.ClientUtils.submitJobAndWaitForResult(ClientUtils.java:111) ~[flink-clients_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT] 2021-02-22T22:53:30.7791173Z at org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase.lambda$runCancelingOnEmptyInputTest$2(KafkaConsumerTestBase.java:1205) ~[flink-connector-kafka-base_2.11-1.11-SNAPSHOT-tests.jar:?] 2021-02-22T22:53:30.7792255Z at java.lang.Thread.run(Thread.java:748) [?:1.8.0_275] 2021-02-22T22:53:30.7792963Z Caused by: org.apache.flink.runtime.client.JobCancellationException: Job was cancelled. 2021-02-22T22:53:30.7794413Z at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:146) ~[flink-runtime_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT] 2021-02-22T22:53:30.7796019Z at org.apache.flink.client.ClientUtils.submitJobAndWaitForResult(ClientUtils.java:109) ~[flink-clients_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT] 2021-02-22T22:53:30.7796808Z ... 2 more {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)