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)
