W-dragan commented on code in PR #6492:
URL: https://github.com/apache/seatunnel/pull/6492#discussion_r1521120137
##########
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/rest/RestHttpPostCommandProcessor.java:
##########
@@ -124,7 +124,7 @@ private void handleSubmitJob(HttpPostCommand
httpPostCommand, String uri)
boolean startWithSavePoint =
Boolean.parseBoolean(requestParams.get(RestConstant.IS_START_WITH_SAVE_POINT));
- SeaTunnelServer seaTunnelServer = getSeaTunnelServer();
+ SeaTunnelServer seaTunnelServer = getSeaTunnelServer(false);
RestJobExecutionEnvironment restJobExecutionEnvironment =
new RestJobExecutionEnvironment(
seaTunnelServer,
Review Comment:
I noticed that you rolled back to the first version of the code. I just
tried using this version of the code, but I modified an additional line of
code, which is 135 lines
hold
`If (seaTunnelServer==null){`
Changed to
`if (! SeaTunnelServer. isMasterNode()){`
Currently, using HTTP to repeatedly submit the same task in cluster mode has
not reported any errors, and the classLoader has not been added
--
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]
