You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/02/23 07:16:00 UTC
[jira] [Created] (FLINK-21449)
Kafka011ProducerExactlyOnceITCase>KafkaProducerTestBase.testExactlyOnceRegularSink
fails on azure
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)