Bonnie Varghese created FLINK-40883:
---------------------------------------
Summary: 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
Reporter: Bonnie Varghese
Assignee: Bonnie Varghese
{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)
