[
https://issues.apache.org/jira/browse/FLINK-25444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17475383#comment-17475383
]
Chesnay Schepler commented on FLINK-25444:
------------------------------------------
Note that plain Java serialization still works for the ExecutionConfig, it is
just the ClojureCleaner that rejects it because it does very strict checks
w.r.t. serializability.
As such, the underlying problem could be that the clojure of the map function
in the post is larger than expected; I don't know what the
SiddhiOperatorContext contains.
> ClosureCleaner rejects ExecutionConfig as not be Serializable due to
> TextElement
> --------------------------------------------------------------------------------
>
> Key: FLINK-25444
> URL: https://issues.apache.org/jira/browse/FLINK-25444
> Project: Flink
> Issue Type: Bug
> Components: API / Core
> Affects Versions: 1.14.0
> Reporter: Wen Zhou
> Assignee: Chesnay Schepler
> Priority: Major
> Fix For: 1.15.0, 1.14.4
>
>
> This should be a bug introduced by the latest flink commit of file
> [flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java|https://github.com/apache/flink/commit/9e0e0929b86c372c9243daad9d654af9e7718708#diff-7a439abdf207cf6da8aa6c147b38c1346820fe786afbf652bc614fc377cdf238]
> Diff the file, we can find TextElement is used here where ClosureCleanerLevel
> is is used as a memeber of Serializable ExecutionConfig.
> [TextElement in ClosureCleanerLevel|https://i.stack.imgur.com/ky3d8.png]
> The simplest way to verify the problem is running code as followings in flink
> 1.13.5 and 1.14.x, the exception is reproduced in 1.14.x . And the diff
> between 1.13.5 and 1.14.x is only lates commit
>
> @Test
> public void testExecutionConfigSerializable() throws Exception {
> ExecutionConfig config = new ExecutionConfig();
> ClosureCleaner.clean(config, ExecutionConfig.ClosureCleanerLevel.RECURSIVE,
> true);
> }
>
> The problem can be found here
> [https://stackoverflow.com/questions/70443743/flink-blockelement-exception-when-updating-to-version-1-14-2/70468925?noredirect=1#comment124597510_70468925]
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
