[
https://issues.apache.org/jira/browse/FLINK-15403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17006758#comment-17006758
]
Piotr Nowojski edited comment on FLINK-15403 at 1/2/20 12:28 PM:
-----------------------------------------------------------------
Yes, indeed this is caused by FLINK-15317. I will prepare a fix for that.
The issue is that here, {{CancelTaskException}} is originating from a
{{LocalInputChannel}}, from upstream task task, that was already cancelled,
while the downstream task has been (yet?) cancelled.
In FLINK-15317 we made an assumption that {{CancelTaskException}} can not occur
in the stack trace of the task, before task was cancelled. Clearly that was
wrong assumption.
Code fix will be trivial, it might be more difficult to add a test coverage.
was (Author: pnowojski):
Yes, indeed this is caused by FLINK-15317. I will prepare a fix for that.
> 'State Migration end-to-end test from 1.6' is unstable on travis.
> -----------------------------------------------------------------
>
> Key: FLINK-15403
> URL: https://issues.apache.org/jira/browse/FLINK-15403
> Project: Flink
> Issue Type: Bug
> Components: Tests
> Affects Versions: 1.10.0
> Reporter: Xintong Song
> Assignee: Piotr Nowojski
> Priority: Blocker
> Labels: test-stability
> Fix For: 1.10.0
>
>
> -api.travis-ci.org/v3/job/629576631/log.txt-
> https://api.travis-ci.org/v3/job/631346939/log.txt
> The test case fails because the log contains the following error message.
> {code}
> 2019-12-26 09:19:35,537 ERROR
> org.apache.flink.streaming.runtime.tasks.StreamTask - Received
> CancelTaskException while we are not canceled. This is a bug and should be
> reported
> org.apache.flink.runtime.execution.CancelTaskException: Consumed partition
> PipelinedSubpartitionView(index: 0) of ResultPartition
> 3886657fb8cc980139fac67e32d6e380@8cfcbe851fe3bb3fa00e9afc370bd963 has been
> released.
> at
> org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannel.getNextBuffer(LocalInputChannel.java:190)
> at
> org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.waitAndGetNextData(SingleInputGate.java:509)
> at
> org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:487)
> at
> org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.pollNext(SingleInputGate.java:475)
> at
> org.apache.flink.runtime.taskmanager.InputGateWithMetrics.pollNext(InputGateWithMetrics.java:75)
> at
> org.apache.flink.streaming.runtime.io.CheckpointedInputGate.pollNext(CheckpointedInputGate.java:125)
> at
> org.apache.flink.streaming.runtime.io.StreamTaskNetworkInput.emitNext(StreamTaskNetworkInput.java:133)
> at
> org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:69)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:311)
> at
> org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:187)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:488)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:470)
> at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:702)
> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:527)
> at java.lang.Thread.run(Thread.java:748)
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
