[
https://issues.apache.org/jira/browse/FLINK-21446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-21446:
-----------------------------------
Labels: auto-deprioritized-major stale-minor test-stability (was:
auto-deprioritized-major test-stability)
I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help
the community manage its development. I see this issues has been marked as
Minor but is unassigned and neither itself nor its Sub-Tasks have been updated
for 180 days. I have gone ahead and marked it "stale-minor". If this ticket is
still Minor, please either assign yourself or give an update. Afterwards,
please remove the label or in 7 days the issue will be deprioritized.
> KafkaProducerTestBase.testExactlyOnce Fail
> ------------------------------------------
>
> Key: FLINK-21446
> URL: https://issues.apache.org/jira/browse/FLINK-21446
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka
> Affects Versions: 1.11.3
> Reporter: Guowei Ma
> Priority: Minor
> Labels: auto-deprioritized-major, stale-minor, test-stability
>
> [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=13612&view=logs&j=d44f43ce-542c-597d-bf94-b0718c71e5e8&t=34f486e1-e1e4-5dd2-9c06-bfdd9b9c74a8]
>
> {code:java}
> 22:52:12,032 [ Checkpoint Timer] INFO
> org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Checkpoint 18
> of job 84164b7efcb41ca524cc7076030d1f91 expired before completing.
> 22:52:12,033 [ Checkpoint Timer] INFO
> org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Triggering
> checkpoint 19 (type=CHECKPOINT) @ 1614034332033 for job
> 84164b7efcb41ca524cc7076030d1f91. 22:52:12,036 [Source: Custom Source -> Map
> -> Sink: Unnamed (1/1)] INFO
> org.apache.flink.streaming.connectors.kafka.internal.FlinkKafkaProducer [] -
> Flushing new partitions 22:52:12,036
> [flink-akka.actor.default-dispatcher-172] INFO
> org.apache.flink.runtime.jobmaster.JobMaster [] - Trying to recover from a
> global failure. org.apache.flink.util.FlinkRuntimeException: Exceeded
> checkpoint tolerable failure threshold. at
> org.apache.flink.runtime.checkpoint.CheckpointFailureManager.handleJobLevelCheckpointException(CheckpointFailureManager.java:68)
> ~[flink-runtime_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT] at
> org.apache.flink.runtime.checkpoint.CheckpointCoordinator.abortPendingCheckpoint(CheckpointCoordinator.java:1892)
> ~[flink-runtime_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT] at
> org.apache.flink.runtime.checkpoint.CheckpointCoordinator.abortPendingCheckpoint(CheckpointCoordinator.java:1869)
> ~[flink-runtime_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT] at
> org.apache.flink.runtime.checkpoint.CheckpointCoordinator.access$600(CheckpointCoordinator.java:93)
> ~[flink-runtime_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT] at
> org.apache.flink.runtime.checkpoint.CheckpointCoordinator$CheckpointCanceller.run(CheckpointCoordinator.java:2006)
> ~[flink-runtime_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT] at
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
> ~[?:1.8.0_275] at java.util.concurrent.FutureTask.run(FutureTask.java:266)
> ~[?:1.8.0_275] at
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
> ~[?:1.8.0_275] at
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
> ~[?:1.8.0_275] at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> ~[?:1.8.0_275] at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> ~[?:1.8.0_275] at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_275]
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
