[
https://issues.apache.org/jira/browse/FLINK-39226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuyi Chen updated FLINK-39226:
-------------------------------
Description:
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
was:
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}}|
> 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
> Priority: Major
>
> 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)
