Dian Fu created FLINK-37084:
-------------------------------
Summary: NullPointerException occurs during handling timer of
window in PyFlink
Key: FLINK-37084
URL: https://issues.apache.org/jira/browse/FLINK-37084
Project: Flink
Issue Type: Bug
Components: API / Python
Reporter: Dian Fu
{code}
2025-01-08 15:30:00,098 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] -
TumblingProcessingTimeWindows (62/256)
(43af0f7269e3fc5bd5edf3f23e94e07e_9dd63673dd41ea021b896d5203f3ba7c_61_14)
switched from RUNNING to FAILED on flink-load-generator2-taskmanager-1-96 @
10.0.65.119 (dataPort=36047).
org.apache.flink.runtime.taskmanager.AsynchronousException: Caught exception
while processing timer. at
org.apache.flink.streaming.runtime.tasks.StreamTask$StreamTaskAsyncExceptionHandler.handleAsyncException(StreamTask.java:1642)
~[flink-dist-1.19.1.jar:1.19.1] at
org.apache.flink.streaming.runtime.tasks.StreamTask.handleAsyncException(StreamTask.java:1617)
~[flink-dist-1.19.1.jar:1.19.1] at
org.apache.flink.streaming.runtime.tasks.StreamTask.invokeProcessingTimeCallback(StreamTask.java:1771)
~[flink-dist-1.19.1.jar:1.19.1] at
org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$null$25(StreamTask.java:1760)
~[flink-dist-1.19.1.jar:1.19.1] at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50)
~[flink-dist-1.19.1.jar:1.19.1] at
org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90)
~[flink-dist-1.19.1.jar:1.19.1] at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMail(MailboxProcessor.java:398)
~[flink-dist-1.19.1.jar:1.19.1] at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMailsWhenDefaultActionUnavailable(MailboxProcessor.java:367)
~[flink-dist-1.19.1.jar:1.19.1] at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:352)
~[flink-dist-1.19.1.jar:1.19.1] at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:229)
~[flink-dist-1.19.1.jar:1.19.1] at
org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:909)
~[flink-dist-1.19.1.jar:1.19.1] at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:858)
~[flink-dist-1.19.1.jar:1.19.1] at
org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958)
~[flink-dist-1.19.1.jar:1.19.1] at
org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:937)
~[flink-dist-1.19.1.jar:1.19.1] at
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:751)
~[flink-dist-1.19.1.jar:1.19.1] at
org.apache.flink.runtime.taskmanager.Task.run(Task.java:566)
~[flink-dist-1.19.1.jar:1.19.1] at java.lang.Thread.run(Unknown Source) ~[?:?]
Caused by: org.apache.flink.streaming.runtime.tasks.TimerException:
java.lang.NullPointerException ... 15 more Caused by:
java.lang.NullPointerException at
org.apache.flink.runtime.state.heap.AbstractHeapPriorityQueue.moveElementToIdx(AbstractHeapPriorityQueue.java:166)
~[flink-dist-1.19.1.jar:1.19.1] at
org.apache.flink.runtime.state.heap.HeapPriorityQueue.removeInternal(HeapPriorityQueue.java:96)
~[flink-dist-1.19.1.jar:1.19.1] at
org.apache.flink.runtime.state.heap.AbstractHeapPriorityQueue.poll(AbstractHeapPriorityQueue.java:59)
~[flink-dist-1.19.1.jar:1.19.1] at
org.apache.flink.runtime.state.heap.HeapPriorityQueueSet.poll(HeapPriorityQueueSet.java:107)
~[flink-dist-1.19.1.jar:1.19.1] at
org.apache.flink.runtime.state.heap.HeapPriorityQueueSet.poll(HeapPriorityQueueSet.java:53)
~[flink-dist-1.19.1.jar:1.19.1] at
org.apache.flink.streaming.api.operators.InternalTimerServiceImpl.onProcessingTime(InternalTimerServiceImpl.java:293)
~[flink-dist-1.19.1.jar:1.19.1] at
org.apache.flink.streaming.runtime.tasks.StreamTask.invokeProcessingTimeCallback(StreamTask.java:1769)
~[flink-dist-1.19.1.jar:1.19.1]
{code}
Reported in slack channel:
https://apache-flink.slack.com/archives/C065944F9M2/p1736236759968739
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
