You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Kenny Ma (Jira)" <ji...@apache.org> on 2022/04/21 19:07:00 UTC
[jira] [Comment Edited] (FLINK-27055) java.lang.ArrayIndexOutOfBoundsException in BinarySegmentUtils
[ https://issues.apache.org/jira/browse/FLINK-27055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17525948#comment-17525948 ]
Kenny Ma edited comment on FLINK-27055 at 4/21/22 7:06 PM:
-----------------------------------------------------------
The problem seems to be caused by our custom UDF that handles the data from the collect() function is not using MultisetTypeInfo. Closing this ticket.
was (Author: JIRAUSER280080):
The problem seems to be caused by our custom UDF that handles the data from the collect() function is not implementing MultisetTypeInfo. Closing this ticket.
> java.lang.ArrayIndexOutOfBoundsException in BinarySegmentUtils
> --------------------------------------------------------------
>
> Key: FLINK-27055
> URL: https://issues.apache.org/jira/browse/FLINK-27055
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Runtime
> Affects Versions: 1.12.0
> Reporter: Kenny Ma
> Priority: Major
>
> I am using SQL for my streaming job and the job keeps failing with the java.lang.ArrayIndexOutOfBoundsException thrown in BinarySegmentUtils.
> Stacktrace:
>
> {code:java}
> java.lang.ArrayIndexOutOfBoundsException: Index 1 out of bounds for length 1
> at org.apache.flink.table.data.binary.BinarySegmentUtils.getLongSlowly(BinarySegmentUtils.java:773)
> at org.apache.flink.table.data.binary.BinarySegmentUtils.getLongMultiSegments(BinarySegmentUtils.java:763)
> at org.apache.flink.table.data.binary.BinarySegmentUtils.getLong(BinarySegmentUtils.java:751)
> at org.apache.flink.table.data.binary.BinaryArrayData.getString(BinaryArrayData.java:210)
> at org.apache.flink.table.data.ArrayData.lambda$createElementGetter$95d74a6c$1(ArrayData.java:250)
> at org.apache.flink.table.data.conversion.MapMapConverter.toExternal(MapMapConverter.java:79)
> at StreamExecCalc$11860.processElement(Unknown Source)
> at org.apache.flink.streaming.runtime.tasks.ChainingOutput.pushToOperator(ChainingOutput.java:112)
> at org.apache.flink.streaming.runtime.tasks.ChainingOutput.collect(ChainingOutput.java:93)
> at org.apache.flink.streaming.runtime.tasks.ChainingOutput.collect(ChainingOutput.java:39)
> at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:52)
> at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:30)
> at org.apache.flink.streaming.api.operators.TimestampedCollector.collect(TimestampedCollector.java:53)
> at org.apache.flink.table.runtime.operators.window.AggregateWindowOperator.collect(AggregateWindowOperator.java:183)
> at org.apache.flink.table.runtime.operators.window.AggregateWindowOperator.emitWindowResult(AggregateWindowOperator.java:176)
> at org.apache.flink.table.runtime.operators.window.WindowOperator.onEventTime(WindowOperator.java:384)
> at org.apache.flink.streaming.api.operators.InternalTimerServiceImpl.advanceWatermark(InternalTimerServiceImpl.java:276)
> at org.apache.flink.streaming.api.operators.InternalTimeServiceManagerImpl.advanceWatermark(InternalTimeServiceManagerImpl.java:183)
> at org.apache.flink.streaming.api.operators.AbstractStreamOperator.processWatermark(AbstractStreamOperator.java:600)
> at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask$StreamTaskNetworkOutput.emitWatermark(OneInputStreamTask.java:199)
> at org.apache.flink.streaming.runtime.streamstatus.StatusWatermarkValve.findAndOutputNewMinWatermarkAcrossAlignedChannels(StatusWatermarkValve.java:173)
> at org.apache.flink.streaming.runtime.streamstatus.StatusWatermarkValve.inputWatermark(StatusWatermarkValve.java:95)
> at org.apache.flink.streaming.runtime.io.StreamTaskNetworkInput.processElement(StreamTaskNetworkInput.java:181)
> at org.apache.flink.streaming.runtime.io.StreamTaskNetworkInput.emitNext(StreamTaskNetworkInput.java:152)
> at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:67)
> at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:372)
> at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:186)
> at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:575)
> at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:539)
> at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:722)
> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:547)
> {code}
>
--
This message was sent by Atlassian Jira
(v8.20.7#820007)