You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/05/22 06:17:00 UTC
[jira] [Comment Edited] (FLINK-17805) InputProcessorUtil doesn't
handle indexes for multiple inputs operators correctly
[ https://issues.apache.org/jira/browse/FLINK-17805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113472#comment-17113472 ]
Piotr Nowojski edited comment on FLINK-17805 at 5/22/20, 6:16 AM:
------------------------------------------------------------------
merged to master as c9fd502c5a^ and c9fd502c5a
merged to release-1.11 as f3268aa8fa^ and f3268aa8fa
was (Author: pnowojski):
merged to master as c9fd502c5a^ and c9fd502c5a
merged to release-1.11 as d0451b7738^ and d0451b7738
> InputProcessorUtil doesn't handle indexes for multiple inputs operators correctly
> ---------------------------------------------------------------------------------
>
> Key: FLINK-17805
> URL: https://issues.apache.org/jira/browse/FLINK-17805
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Network
> Reporter: Piotr Nowojski
> Assignee: Piotr Nowojski
> Priority: Critical
> Labels: pull-request-available
> Fix For: 1.11.0
>
>
> This can cause {{ArrayIndexOutOfBound}} exception when input gates passed to {{InputProcessorUtil#createCheckpointedInputGatePair}} have lower IDs in the second input compared to input gates from the first one.
> {noformat}
> Caused by: java.lang.ArrayIndexOutOfBoundsException: 7
> at org.apache.flink.streaming.runtime.io.CheckpointBarrierUnaligner$ThreadSafeUnaligner.notifyBufferReceived(CheckpointBarrierUnaligner.java:328)
> at org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannel.getNextBuffer(LocalInputChannel.java:218)
> at org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.waitAndGetNextData(SingleInputGate.java:637)
> at org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:615)
> at org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.pollNext(SingleInputGate.java:603)
> at org.apache.flink.runtime.taskmanager.InputGateWithMetrics.pollNext(InputGateWithMetrics.java:105)
> at org.apache.flink.streaming.runtime.io.CheckpointedInputGate.pollNext(CheckpointedInputGate.java:110)
> at org.apache.flink.streaming.runtime.io.StreamTaskNetworkInput.emitNext(StreamTaskNetworkInput.java:136)
> at org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor.processInput(StreamTwoInputProcessor.java:178)
> at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:341)
> at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxStep(MailboxProcessor.java:206)
> at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:196)
> at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:553)
> at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:526)
> at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:713)
> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:539)
> at java.lang.Thread.run(Thread.java:748)
> {noformat}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)