Hello:
I was recently study the code about how the JobGraph generates. I noticed
in the constructor of StreamingJobGraphGenerator, it constructs a JobGraph. And
in the constructor of JobGraph, it called setExecutionConfig(new
ExecutionConfig()) which serialized a default ExecutionConfig. The comment said
"Further modification of the referenced ExecutionConfig object will not affect
this serialized copy".
While at the end of StreamingJobGraphGenerator#createJobGraph(), it called
jobGraph.setExecutionConfig(streamGraph.getExecutionConfig()) again, which sets
the ExecutionConfig contains the parameters we have changed. I think that does
the right thing.
So I wonder what the setExecutionConfig() in the constructor of JobGraph
for? It seems meaningless for me.
Best regards!