[
https://issues.apache.org/jira/browse/FLINK-21449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-21449.
------------------------------------
Resolution: Duplicate
> 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
> Priority: Major
> Labels: test-stability
>
> 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)
