[
https://issues.apache.org/jira/browse/FLINK-39226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18127709#comment-18127709
]
Dian Fu edited comment on FLINK-39226 at 10/16/26 5:14 AM:
-----------------------------------------------------------
Backport to release-2.2 via 1c9d4f9084efd73555380fed101083836ec652b6
was (Author: dianfu):
Backport to release-1.20 via 1c9d4f9084efd73555380fed101083836ec652b6
> pemja.core.object.PyIterator ClassCastException
> ------------------------------------------------
>
> Key: FLINK-39226
> URL: https://issues.apache.org/jira/browse/FLINK-39226
> Project: Flink
> Issue Type: Bug
> Components: API / Python
> Affects Versions: 1.19.1
> Reporter: Shuyi Chen
> Assignee: Bowen Li
> Priority: Major
> Labels: pull-request-available
> Fix For: 2.3.0, 1.20.6
>
>
> Exception details:
> org.apache.flink.runtime.taskmanager.AsynchronousException: Caught exception
> while processing timer.
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask$StreamTaskAsyncExceptionHandler.handleAsyncException(StreamTask.java:1642)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.handleAsyncException(StreamTask.java:1617)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invokeProcessingTimeCallback(StreamTask.java:1771)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$deferCallbackToMailbox$25(StreamTask.java:1760)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50)
> at
> org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90)
> at
> org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMail(MailboxProcessor.java:398)
> at
> org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMailsNonBlocking(MailboxProcessor.java:383)
> at
> org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:345)
> at
> org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:229)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:756)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:712)
> at
> org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958)
> at
> org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:927)
> at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:751)
> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:566)
> at java.base/java.lang.Thread.run(Unknown Source)
> Caused by: TimerException{java.lang.ClassCastException: class
> pemja.core.object.PyIterator cannot be cast to class
> pemja.core.object.PyIterator (pemja.core.object.PyIterator is in unnamed
> module of loader
> org.apache.flink.util.FlinkUserCodeClassLoaders$ParentFirstClassLoader
> @5153b89c; pemja.core.object.PyIterator is in unnamed module of loader
> org.apache.flink.util.FlinkUserCodeClassLoaders$ParentFirstClassLoader
> @815e4f9)}
> ... 15 more
> Caused by: java.lang.ClassCastException: class pemja.core.object.PyIterator
> cannot be cast to class pemja.core.object.PyIterator
> (pemja.core.object.PyIterator is in unnamed module of loader
> org.apache.flink.util.FlinkUserCodeClassLoaders$ParentFirstClassLoader
> @5153b89c; pemja.core.object.PyIterator is in unnamed module of loader
> org.apache.flink.util.FlinkUserCodeClassLoaders$ParentFirstClassLoader
> @815e4f9)
> at
> org.apache.flink.streaming.api.operators.python.embedded.EmbeddedPythonWindowOperator.invokeUserFunction(EmbeddedPythonWindowOperator.java:148)
> at
> org.apache.flink.streaming.api.operators.python.embedded.EmbeddedPythonWindowOperator.onProcessingTime(EmbeddedPythonWindowOperator.java:123)
> at
> org.apache.flink.streaming.api.operators.InternalTimerServiceImpl.onProcessingTime(InternalTimerServiceImpl.java:294)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invokeProcessingTimeCallback(StreamTask.java:1769)
> ... 14 more
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
