[FLINK-12916] KeyedComplexChainTest.testMigrationAndRestore failed on Travis

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 1.9.0
• Fix Version/s: 1.9.0
• Component/s: Runtime / Checkpointing, Tests
• Labels: pull-request-available test-stability
• Assignee: Yun Tang
• Reporter: Till Rohrmann
• Created: 20/Jun/19 16:32
• Updated: 19/Jul/19 09:44
• Resolved: 19/Jul/19 09:44

Description

The test case KeyedComplexChainTest.testMigrationAndRestore failed on Travis because a Task received the cancellation from one of its inputs

Caused by: org.apache.flink.runtime.checkpoint.CheckpointException: Task received cancellation from one of its inputs
	at org.apache.flink.streaming.runtime.io.BarrierBuffer.notifyAbortOnCancellationBarrier(BarrierBuffer.java:428)
	at org.apache.flink.streaming.runtime.io.BarrierBuffer.processCancellationBarrier(BarrierBuffer.java:327)
	at org.apache.flink.streaming.runtime.io.BarrierBuffer.pollNext(BarrierBuffer.java:208)
	at org.apache.flink.streaming.runtime.io.StreamTaskNetworkInput.pollNextNullable(StreamTaskNetworkInput.java:102)
	at org.apache.flink.streaming.runtime.io.StreamTaskNetworkInput.pollNextNullable(StreamTaskNetworkInput.java:47)
	at org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:128)
	at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.performDefaultAction(OneInputStreamTask.java:101)
	at org.apache.flink.streaming.runtime.tasks.StreamTask.run(StreamTask.java:268)
	at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:376)
	at org.apache.flink.runtime.taskmanager.Task.run(Task.java:676)
	... 1 more

https://api.travis-ci.org/v3/job/548181384/log.txt

Issue Links

• is duplicated by: FLINK-11440 ChainLengthIncreaseTest failed on Travis
• is duplicated by: FLINK-13014 ChainBreakTest failed on Travis
• is duplicated by: FLINK-13212 Unstable ChainLengthIncreaseTest
• links to: GitHub Pull Request #8820