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)
