EricJoy2048 commented on code in PR #2699:
URL:
https://github.com/apache/incubator-seatunnel/pull/2699#discussion_r971647477
##########
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/SeaTunnelServer.java:
##########
@@ -73,12 +81,52 @@ public class SeaTunnelServer implements ManagedService,
MembershipAwareService,
private final SeaTunnelConfig seaTunnelConfig;
+ /**
+ * IMap key is jobId and value is a Tuple2
+ * Tuple2 key is JobMaster init timestamp and value is the
jobImmutableInformation which is sent by client when submit job
+ * <p>
+ * This IMap is used to recovery runningJobInfoIMap in JobMaster when a
new master node active
+ */
+ private IMap<Long, RunningJobInfo> runningJobInfoIMap;
+
+ /**
+ * IMap key is one of jobId {@link
org.apache.seatunnel.engine.server.dag.physical.PipelineLocation} and
+ * {@link org.apache.seatunnel.engine.server.execution.TaskGroupLocation}
+ * <p>
+ * The value of IMap is one of {@link JobStatus} {@link
org.apache.seatunnel.engine.core.job.PipelineState}
+ * {@link org.apache.seatunnel.engine.server.execution.ExecutionState}
+ * <p>
+ * This IMap is used to recovery runningJobStateIMap in JobMaster when a
new master node active
+ */
+ IMap<Object, Object> runningJobStateIMap;
Review Comment:
> It's strange jobID map PipelineState, does JobStatus can't contains
PipelineState?
The key-value may be `jobId-JobStatus`, `PipelineLocaltion-PipelineState`,
`TaskGroupLocation-ExecutionState`.
--
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]
