[
https://issues.apache.org/jira/browse/FLINK-36349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883886#comment-17883886
]
xuhuang commented on FLINK-36349:
---------------------------------
Hi, [~mapohl]
Thank for your reminder. I think the failure of the _ClosureCleanerITCase_ in
the AdaptiveScheduler test profile is not due to the absence of
_FlinkScalaKryoInstantiator_ class.
In pull request [25324|https://github.com/apache/flink/pull/25324], the
_ClosureCleanerITCase_ was updated to use Java language and the DataStream API.
This test case employs the _fullWindowPartition_ operator while running in
streaming job mode.
The _fullWindowPartition_ operator will sets jobEdge blocking, which leads the
_AdaptiveScheduler_ fail to check whether the job edge can be pipelined
(org.apache.flink.runtime.scheduler.adaptive.AdaptiveScheduler#assertPreconditions).
I have correct the _ClosureCleanerITCase_ in pull request
[25378|https://github.com/apache/flink/pull/25378], modifing the test case in
ClosureCleanerITCase to run in batch mode.
> ClassNotFoundException due to
> org.apache.flink.runtime.types.FlinkScalaKryoInstantiator missing
> -----------------------------------------------------------------------------------------------
>
> Key: FLINK-36349
> URL: https://issues.apache.org/jira/browse/FLINK-36349
> Project: Flink
> Issue Type: Bug
> Components: API / Type Serialization System
> Affects Versions: 2.0-preview
> Reporter: Matthias Pohl
> Priority: Blocker
> Labels: pull-request-available, test-stability
>
> This is most likely caused by FLINK-29741 which was recently merged.
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=62359&view=logs&j=8fd9202e-fd17-5b26-353c-ac1ff76c8f28&t=ea7cf968-e585-52cb-e0fc-f48de023a7ca&l=17558
> {code}
> Sep 23 01:58:51 01:58:50,533 12326 [AsyncOperations-thread-1] INFO
> org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer [] - Kryo
> serializer scala extensions are not available.
> Sep 23 01:58:51 java.lang.ClassNotFoundException:
> org.apache.flink.runtime.types.FlinkScalaKryoInstantiator
> Sep 23 01:58:51 at
> java.net.URLClassLoader.findClass(URLClassLoader.java:382) ~[?:1.8.0_292]
> Sep 23 01:58:51 at
> java.lang.ClassLoader.loadClass(ClassLoader.java:418) ~[?:1.8.0_292]
> Sep 23 01:58:51 at
> sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:352) ~[?:1.8.0_292]
> Sep 23 01:58:51 at
> java.lang.ClassLoader.loadClass(ClassLoader.java:351) ~[?:1.8.0_292]
> Sep 23 01:58:51 at java.lang.Class.forName0(Native Method)
> ~[?:1.8.0_292]
> Sep 23 01:58:51 at java.lang.Class.forName(Class.java:264)
> ~[?:1.8.0_292]
> [...]
> {code}
> It causes ClosureCleanerITCase to fail in the AdaptiveScheduler test profile.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
