You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Shuyi Chen (Jira)" <ji...@apache.org> on 2026/03/09 06:25:00 UTC
[jira] [Created] (FLINK-39226) pemja.core.object.PyIterator ClassCastException
Shuyi Chen created FLINK-39226:
----------------------------------
Summary: 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
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)