EricJoy2048 commented on issue #2501:
URL:
https://github.com/apache/incubator-seatunnel/issues/2501#issuecomment-1232732819
Another idea, I only set the `Data jobImmutableInformationData` to IMap, The
type of `jobImmutableInformationData` is `Data` and is send from client when
submit a job. And in the new active Master Node, I use
`jobImmutableInformationData` and new a `JobMaster`. Then do JobMaster `init`.
```
final Tuple2<PhysicalPlan, CheckpointPlan> planTuple =
PlanUtils.fromLogicalDAG(logicalDag,
nodeEngine,
jobImmutableInformation,
System.currentTimeMillis(),
executorService,
flakeIdGenerator);
```
generate physical plan will input initializationTimestamp
`System.currentTimeMillis()`, I think the `initializationTimestamp` must not
be changed when create JobMaster again, So finally a object contain
`jobImmutableInformationData` and `initializationTimestamp` will be set to the
IMap named `runningJobDataIMap`.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
