Roman Khachatryan created FLINK-23276:
-----------------------------------------
Summary: Changelog backend not always updates delegating functions
Key: FLINK-23276
URL: https://issues.apache.org/jira/browse/FLINK-23276
Project: Flink
Issue Type: Bug
Components: Runtime / State Backends
Affects Versions: 1.14.0
Reporter: Roman Khachatryan
Assignee: Roman Khachatryan
Fix For: 1.14.0
(currently disabled in tests, so doesn't affect build stability)
E.g. org.apache.flink.table.planner.runtime.stream.table.GroupWindowITCase
{code}
2021-07-03T20:30:28.0384912Z Jul 03 20:30:28 Caused by:
java.lang.NullPointerException
*2021-07-03T20:30:28.0385566Z Jul 03 20:30:28 at
org.apache.flink.util.Preconditions.checkNotNull(Preconditions.java:59)
*2021-07-03T20:30:28.0386330Z Jul 03 20:30:28 at
org.apache.flink.state.changelog.restore.FunctionDelegationHelper$DelegatingReduceFunction.redu*ce(FunctionDelegationHelper.java:138)
*2021-07-03T20:30:28.0387147Z Jul 03 20:30:28 at
org.apache.flink.contrib.streaming.state.RocksDBReducingState.add(RocksDBReducingState.java:95)
*2021-07-03T20:30:28.0387892Z Jul 03 20:30:28 at
org.apache.flink.state.changelog.ChangelogReducingState.add(ChangelogReducingState.java:82)
*2021-07-03T20:30:28.0388677Z Jul 03 20:30:28 at
org.apache.flink.table.runtime.operators.window.triggers.ElementTriggers$CountElement.onElement*(ElementTriggers.java:124)
*2021-07-03T20:30:28.0389503Z Jul 03 20:30:28 at
org.apache.flink.table.runtime.operators.window.WindowOperator$TriggerContext.onElement(WindowO*perator.java:572)
*2021-07-03T20:30:28.0390296Z Jul 03 20:30:28 at
org.apache.flink.table.runtime.operators.window.WindowOperator.processElement(WindowOperator.ja*va:379)
*2021-07-03T20:30:28.0391107Z Jul 03 20:30:28 at
org.apache.flink.streaming.runtime.tasks.OneInputStreamTask$StreamTaskNetworkOutput.emitRecord(*OneInputStreamTask.java:228)
*2021-07-03T20:30:28.0391936Z Jul 03 20:30:28 at
org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.processElement(AbstractStr*eamTaskNetworkInput.java:134)
*2021-07-03T20:30:28.0392776Z Jul 03 20:30:28 at
org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.emitNext(AbstractStreamTas*kNetworkInput.java:105)
*2021-07-03T20:30:28.0393929Z Jul 03 20:30:28 at
org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProces*sor.java:66)
*2021-07-03T20:30:28.0394611Z Jul 03 20:30:28 at
org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:428)
*2021-07-03T20:30:28.0395288Z Jul 03 20:30:28 at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcess*or.java:204)
*2021-07-03T20:30:28.0395966Z Jul 03 20:30:28 at
org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:691)
*2021-07-03T20:30:28.0396892Z Jul 03 20:30:28 at
org.apache.flink.streaming.runtime.tasks.StreamTask.executeInvoke(StreamTask.java:646)
*2021-07-03T20:30:28.0397601Z Jul 03 20:30:28 at
org.apache.flink.streaming.runtime.tasks.StreamTask.runWithCleanUpOnFail(StreamTask.java:657)
*2021-07-03T20:30:28.0398398Z Jul 03 20:30:28 at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:630)
*2021-07-03T20:30:28.0399051Z Jul 03 20:30:28 at
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:779)
*2021-07-03T20:30:28.0399669Z Jul 03 20:30:28 at
org.apache.flink.runtime.taskmanager.Task.run(Task.java:566)
2021-07-03T20:30:28.0400238Z Jul 03 20:30:28 at
java.lang.Thread.run(Thread.java:748)
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
