luzongzhu opened a new issue, #5474: URL: https://github.com/apache/seatunnel/issues/5474
### Search before asking - [X] I had searched in the [issues](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues. ### What happened 执行 /hazelcast/rest/maps/submit-job 日志报错空指针，这里的sink iceberg是我自己从issue下载的源码调整了后重新打了一个connector的jar包上传到2.3.3的，使用 -local 执行是可以执行成功的。 ### SeaTunnel Version 2.3.3 ### SeaTunnel Config ```conf { "env": { "execution.parallelism": 2, "job.mode": "BATCH" }, "source": [ { "url": "jdbc:oracle:thin:@******:1521/WFLDBDEV", "driver": "oracle.jdbc.OracleDriver", "user": "biods", "password": "biods2020", "query": "SELECT MANDT, EBELN, EBELP, ZEKKN, LOEKZ, AEDAT, KFLAG, MENGE, VPROZ, NETWR, SAKTO, GSBER, KOSTL, PROJN, VBELN, VBELP, VETEN, KZBRB, ANLN1, ANLN2, AUFNR, WEMPF, ABLAD, KOKRS, XBKST, XBAUF, XBPRO, EREKZ, KSTRG, PAOBJNR, PRCTR, PS_PSP_PNR, NPLNR, AUFPL, IMKEY, APLZL, VPTNR, FIPOS, RECID, ZZFZH, ZZPTH, ZZICP, ZZBRAN1, FISTL, GEBER, FKBER, DABRZ, AUFPL_ORD, APLZL_ORD, MWSKZ, TXJCD, NAVNW, KBLNR, KBLPOS, LSTAR, PRZNR, GRANT_NBR, BUDGET_PD, FM_SPLIT_BATCH, FM_SPLIT_BEGRU, AA_FINAL_IND, AA_FINAL_REASON, AA_FINAL_QTY, EGRUP, VNAME, TCOBJNR, DATEOFSERVICE, NOTAXCORR, DIFFOPTRATE, HASDIFFOPTRATE, FMFGUS_KEY, AA_FINAL_QTY_F, MENGE_F,'2023-09-09 13:53:00' AS fdop_import_time FROM BIODS.EKKN" } ], "sink": [ { "catalog_name": "iceberg", "catalog_type": "hive", "uri": "thrift://*****:9083", "warehouse": "/user/hive/warehouse", "namespace": "ods", "table": "EKKN" } ] } ``` ### Running Command ```shell /hazelcast/rest/maps/submit-job ``` ### Error Exception ```log 2023-09-13 16:11:38,620 WARN org.apache.seatunnel.engine.server.log.Log4j2HttpPostCommandProcessor - [ddp2]:5801 [seatunnel] [5.1] An error occurred while handling request HttpCommand [HTTP_POST]{uri='/hazelcast/rest/maps/submit-job?jobId=1234&jobName=testJob&isStartWithSavePoint=false'}AbstractTextCommand[HTTP_POST]{requestId=0} java.lang.NullPointerException: null at org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery.findPluginJarPath(AbstractPluginDiscovery.java:341) ~[seatunnel-starter.jar:2.3.3] at java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1660) ~[?:1.8.0_221] at org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery.getPluginJarPath(AbstractPluginDiscovery.java:319) ~[seatunnel-starter.jar:2.3.3] at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) ~[?:1.8.0_221] at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1382) ~[?:1.8.0_221] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482) ~[?:1.8.0_221] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472) ~[?:1.8.0_221] at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708) ~[?:1.8.0_221] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:1.8.0_221] at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:499) ~[?:1.8.0_221] at org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery.getPluginJarPaths(AbstractPluginDiscovery.java:131) ~[seatunnel-starter.jar:2.3.3] at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.getConnectorJarList(MultipleTableJobConfigParser.java:227) ~[seatunnel-starter.jar:2.3.3] at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:160) ~[seatunnel-starter.jar:2.3.3] at org.apache.seatunnel.engine.core.job.AbstractJobEnvironment.getLogicalDag(AbstractJobEnvironment.java:109) ~[seatunnel-starter.jar:2.3.3] at org.apache.seatunnel.engine.server.job.JobImmutableInformationEnv.build(JobImmutableInformationEnv.java:76) ~[seatunnel-starter.jar:2.3.3] at org.apache.seatunnel.engine.server.rest.RestHttpPostCommandProcessor.handleSubmitJob(RestHttpPostCommandProcessor.java:112) ~[seatunnel-starter.jar:2.3.3] at org.apache.seatunnel.engine.server.rest.RestHttpPostCommandProcessor.handle(RestHttpPostCommandProcessor.java:68) ~[seatunnel-starter.jar:2.3.3] at org.apache.seatunnel.engine.server.rest.RestHttpPostCommandProcessor.handle(RestHttpPostCommandProcessor.java:47) ~[seatunnel-starter.jar:2.3.3] at com.hazelcast.internal.ascii.TextCommandServiceImpl$CommandExecutor.run(TextCommandServiceImpl.java:402) ~[seatunnel-starter.jar:2.3.3] at com.hazelcast.internal.util.executor.CachedExecutorServiceDelegate$Worker.run(CachedExecutorServiceDelegate.java:217) ~[seatunnel-starter.jar:2.3.3] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_221] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_221] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_221] at com.hazelcast.internal.util.executor.HazelcastManagedThread.executeRun(HazelcastManagedThread.java:76) ~[seatunnel-starter.jar:2.3.3] at com.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102) ~[seatunnel-starter.jar:2.3.3] 2023-09-13 16:12:07,487 INFO org.apache.seatunnel.engine.server.CoordinatorService - [ddp2]:5801 [seatunnel] [5.1] ``` ### Zeta or Flink or Spark Version _No response_ ### Java or Scala Version 1.8 ### Screenshots _No response_ ### Are you willing to submit PR? - [X] Yes I am willing to submit a PR! ### Code of Conduct - [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- 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]
