[
https://issues.apache.org/jira/browse/FLINK-37084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37084:
-----------------------------------
Labels: pull-request-available (was: )
> 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
> Assignee: Shuyi Chen
> Priority: Major
> Labels: pull-request-available
>
> {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)
