[
https://issues.apache.org/jira/browse/FLINK-36065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897809#comment-17897809
]
Ammu Parvathy commented on FLINK-36065:
---------------------------------------
[~JunRuiLi] I assume that in this PR you updated the job submission code to
accept a stream graph. For the issue on checkpointing,
StreamingJobGraphGenerator.preValidate() method tries loading the UDF jar using
the Application class loader instead of FlinkUserCodeClassLoader which was the
root cause of failure. After verifying the master branch I could see that
StreamingJobGraphGenerator.preValidate() is now loading the UDF jars correctly
with FlinkUserCodeClassLoader and hence the issue is not reproduced. I might be
wrong but I guess this might be due to the recent updation to compile the
jobgraph from the stream graph within the Job manager.
> Support for submitting StreamGraph
> ----------------------------------
>
> Key: FLINK-36065
> URL: https://issues.apache.org/jira/browse/FLINK-36065
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Coordination
> Reporter: Junrui Li
> Assignee: Junrui Li
> Priority: Major
> Labels: pull-request-available
> Fix For: 2.0.0
>
>
> This ticket will encompass the following tasks:
> # Make StreamGraph serializable
> # Support the submission of StreamGraph, allowing the Dispatcher to receive
> a StreamGraph, which the JobManager will then use to execute the job.
> Note that this ticket will not modify the existing JobGraph submission path.
>
>
>
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
