Hi,
单机本地开发执行，遇到该问题，请问有人遇过并解决吗？
2023-09-23 13:52:03.989 INFO
[flink-akka.actor.default-dispatcher-9][Execution.java:1445] - Interval Join
(19/20)
(ff8e25fb94208d3c27f549a1e24757ea_e8388ada9c03cfdb1446bb3ccfbd461b_18_0)
switched from RUNNING to FAILED on d569c5db-6882-496b-9e92-8a40bb631784 @
localhost (dataPort=-1).
java.lang.NullPointerException: null
at
org.apache.flink.streaming.api.operators.TimerSerializer.serialize(TimerSerializer.java:149)
~[flink-streaming-java-1.17.1.jar:1.17.1]
at
org.apache.flink.streaming.api.operators.TimerSerializer.serialize(TimerSerializer.java:39)
~[flink-streaming-java-1.17.1.jar:1.17.1]
at
org.apache.flink.state.changelog.ChangelogKeyGroupedPriorityQueue.lambda$logRemoval$1(ChangelogKeyGroupedPriorityQueue.java:153)
~[flink-statebackend-changelog-1.17.1.jar:1.17.1]
at
org.apache.flink.state.changelog.AbstractStateChangeLogger.lambda$serialize$4(AbstractStateChangeLogger.java:184)
~[flink-statebackend-changelog-1.17.1.jar:1.17.1]
at
org.apache.flink.state.changelog.AbstractStateChangeLogger.serializeRaw(AbstractStateChangeLogger.java:193)
~[flink-statebackend-changelog-1.17.1.jar:1.17.1]
at
org.apache.flink.state.changelog.AbstractStateChangeLogger.serialize(AbstractStateChangeLogger.java:178)
~[flink-statebackend-changelog-1.17.1.jar:1.17.1]
at
org.apache.flink.state.changelog.AbstractStateChangeLogger.log(AbstractStateChangeLogger.java:151)
~[flink-statebackend-changelog-1.17.1.jar:1.17.1]
at
org.apache.flink.state.changelog.AbstractStateChangeLogger.valueElementRemoved(AbstractStateChangeLogger.java:125)
~[flink-statebackend-changelog-1.17.1.jar:1.17.1]
at
org.apache.flink.state.changelog.ChangelogKeyGroupedPriorityQueue.logRemoval(ChangelogKeyGroupedPriorityQueue.java:153)
~[flink-statebackend-changelog-1.17.1.jar:1.17.1]
at
org.apache.flink.state.changelog.ChangelogKeyGroupedPriorityQueue.poll(ChangelogKeyGroupedPriorityQueue.java:69)
~[flink-statebackend-changelog-1.17.1.jar:1.17.1]
at
org.apache.flink.streaming.api.operators.InternalTimerServiceImpl.advanceWatermark(InternalTimerServiceImpl.java:301)
~[flink-streaming-java-1.17.1.jar:1.17.1]
at
org.apache.flink.streaming.api.operators.InternalTimeServiceManagerImpl.advanceWatermark(InternalTimeServiceManagerImpl.java:180)
~[flink-streaming-java-1.17.1.jar:1.17.1]
at
org.apache.flink.streaming.api.operators.AbstractStreamOperator.processWatermark(AbstractStreamOperator.java:602)
~[flink-streaming-java-1.17.1.jar:1.17.1]
at
org.apache.flink.streaming.api.operators.AbstractStreamOperator.processWatermark(AbstractStreamOperator.java:609)
~[flink-streaming-java-1.17.1.jar:1.17.1]
at
org.apache.flink.streaming.api.operators.AbstractStreamOperator.processWatermark2(AbstractStreamOperator.java:618)
~[flink-streaming-java-1.17.1.jar:1.17.1]
at
org.apache.flink.streaming.runtime.io.StreamTwoInputProcessorFactory$StreamTaskNetworkOutput.emitWatermark(StreamTwoInputProcessorFactory.java:268)
~[flink-streaming-java-1.17.1.jar:1.17.1]
at
org.apache.flink.streaming.runtime.watermarkstatus.StatusWatermarkValve.findAndOutputNewMinWatermarkAcrossAlignedChannels(StatusWatermarkValve.java:200)
~[flink-streaming-java-1.17.1.jar:1.17.1]
at
org.apache.flink.streaming.runtime.watermarkstatus.StatusWatermarkValve.inputWatermark(StatusWatermarkValve.java:115)
~[flink-streaming-java-1.17.1.jar:1.17.1]
at
org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.processElement(AbstractStreamTaskNetworkInput.java:148)
~[flink-streaming-java-1.17.1.jar:1.17.1]
at
org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.emitNext(AbstractStreamTaskNetworkInput.java:110)
~[flink-streaming-java-1.17.1.jar:1.17.1]
at
org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65)
~[flink-streaming-java-1.17.1.jar:1.17.1]
at
org.apache.flink.streaming.runtime.io.StreamMultipleInputProcessor.processInput(StreamMultipleInputProcessor.java:85)
~[flink-streaming-java-1.17.1.jar:1.17.1]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:550)
~[flink-streaming-java-1.17.1.jar:1.17.1]
at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:231)
~[flink-streaming-java-1.17.1.jar:1.17.1]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:839)
~[flink-streaming-java-1.17.1.jar:1.17.1]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:788)
~[flink-streaming-java-1.17.1.jar:1.17.1]
at
org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:952)
~[flink-runtime-1.17.1.jar:1.17.1]
at
org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:931)
~[flink-runtime-1.17.1.jar:1.17.1]
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:745)
~[flink-runtime-1.17.1.jar:1.17.1]
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:562)
~[flink-runtime-1.17.1.jar:1.17.1]
at java.lang.Thread.run(Thread.java:829) ~[?:?]
