[
https://issues.apache.org/jira/browse/FLINK-40883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-40883:
-----------------------------------
Labels: pull-request-available (was: )
> Accumulator corruption in NonTimeRowsUnboundedPrecedingFunction
> ---------------------------------------------------------------
>
> Key: FLINK-40883
> URL: https://issues.apache.org/jira/browse/FLINK-40883
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Runtime
> Affects Versions: 2.2.0, 2.3.0, 2.2.1
> Reporter: Bonnie Varghese
> Assignee: Bonnie Varghese
> Priority: Major
> Labels: pull-request-available
>
> {code:java}
> java.lang.ClassCastException: class
> org.apache.flink.table.data.binary.BinaryStringData cannot be cast to class
> org.apache.flink.table.data.RowData
> (org.apache.flink.table.data.binary.BinaryStringData and
> org.apache.flink.table.data.RowData are in unnamed module of loader 'app')
> at
> org.apache.flink.table.data.GenericRowData.getRow(GenericRowData.java:206)
> at
> org.apache.flink.table.data.RowData.lambda$createFieldGetter$1547cee5$1(RowData.java:278)
> at
> org.apache.flink.table.data.RowData.lambda$createFieldGetter$25774257$1(RowData.java:301)
> at
> org.apache.flink.table.runtime.typeutils.RowDataSerializer.toBinaryRow(RowDataSerializer.java:207)
> at
> org.apache.flink.table.runtime.typeutils.RowDataSerializer.serialize(RowDataSerializer.java:103)
> at
> org.apache.flink.table.runtime.typeutils.RowDataSerializer.serialize(RowDataSerializer.java:48)
> at
> org.apache.flink.state.rocksdb.AbstractRocksDBState.serializeValueNullSensitive(AbstractRocksDBState.java:176)
> at
> org.apache.flink.state.rocksdb.RocksDBMapState.put(RocksDBMapState.java:138)
> at
> org.apache.flink.runtime.state.metrics.MetricsTrackingMapState.put(MetricsTrackingMapState.java:142)
> at
> org.apache.flink.runtime.state.UserFacingMapState.put(UserFacingMapState.java:53)
> at
> org.apache.flink.table.runtime.operators.over.NonTimeRowsUnboundedPrecedingFunction.processRemainingElements(NonTimeRowsUnboundedPrecedingFunction.java:290)
> at
> org.apache.flink.table.runtime.operators.over.NonTimeRowsUnboundedPrecedingFunction.insertIntoSortedList(NonTimeRowsUnboundedPrecedingFunction.java:172)
> at
> org.apache.flink.table.runtime.operators.over.AbstractNonTimeUnboundedPrecedingOver.processElement(AbstractNonTimeUnboundedPrecedingOver.java:269)
> at
> org.apache.flink.table.runtime.operators.over.AbstractNonTimeUnboundedPrecedingOver.processElement(AbstractNonTimeUnboundedPrecedingOver.java:97)
> at
> org.apache.flink.streaming.api.operators.KeyedProcessOperator.processElement(KeyedProcessOperator.java:87)
> at
> org.apache.flink.streaming.runtime.io.RecordProcessorUtils.lambda$getRecordProcessor$0(RecordProcessorUtils.java:64)
> at
> org.apache.flink.streaming.runtime.tasks.OneInputStreamTask$StreamTaskNetworkOutput.emitRecord(OneInputStreamTask.java:271)
> at
> org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.processElement(AbstractStreamTaskNetworkInput.java:206)
> at
> org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.emitNext(AbstractStreamTaskNetworkInput.java:163)
> at
> org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:674)
> at
> org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:231)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:1051)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:988)
> at
> org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:1152)
> at
> org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:1134)
> at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:927)
> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:722)
> at java.base/java.lang.Thread.run(Thread.java:1583) {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
