seatunnel icon indicating copy to clipboard operation
seatunnel copied to clipboard

[ST-Engine][JobSubmit] Design of Job Submit

Open EricJoy2048 opened this issue 2 years ago • 0 comments

Search before asking

  • [X] I had searched in the feature and found no similar feature requirement.

Description

image

From https://github.com/apache/incubator-seatunnel/issues/2272 we know we will create LogicalDag in SeaTunnel Client and then submit it to SeaTunnel Server.

JobImmutableInformation

JobImmutableInformation is the Object that Client submit to Server .

public class JobImmutableInformation implements IdentifiedDataSerializable {
    private long jobId;

    private long createTime;

    private Data logicalDag;

    private JobConfig jobConfig;

    private List<URL> pluginJarsUrls;
}

Why logicalDag's type is Data

Because the deserialization of LogicalDag depends on the connector plugin jar be loaded into the classpath. So we add pluginJarsUrls to JobImmutableInformation. When SeaTunnel Server received the submitJob request,It will deserialization JobImmutableInformation first and then get the pluginJarsUrls from JobImmutableInformation. Then use a URLClassLoader load the jars so the logicalDag can be deserialized.

Usage Scenario

No response

Related issues

No response

Are you willing to submit a PR?

  • [X] Yes I am willing to submit a PR!

Code of Conduct

EricJoy2048 avatar Aug 02 '22 06:08 EricJoy2048