plaofchina opened a new issue, #8893: URL: https://github.com/apache/seatunnel/issues/8893
### 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 I created a job with Hocon config and there is a null value in Env, then I get the job info through Restapi `/job-info/{jobId}.` the result got is `{ "status": "fail", "message": null }` and Seatunnel print Exception logs like `[] 2025-03-04 15:48:29,226 ERROR org.apache.seatunnel.engine.server.rest.filter.ExceptionHandlingFilter - Error occurred while processing request java.lang.NullPointerException: null at com.hazelcast.internal.util.JsonUtil.toJsonObject(JsonUtil.java:308) ~[seatunnel-hazelcast-shade-2.3.10-SNAPSHOT.jar:2.3.10-SNAPSHOT] at org.apache.seatunnel.engine.server.rest.service.BaseService.convertToJson(BaseService.java:181) ~[classes/:?] at org.apache.seatunnel.engine.server.rest.service.JobInfoService.getJobInfoJson(JobInfoService.java:66) ~[classes/:?] at org.apache.seatunnel.engine.server.rest.servlet.JobInfoServlet.doGet(JobInfoServlet.java:52) ~[classes/:?] at javax.servlet.http.HttpServlet.service(HttpServlet.java:687) ~[javax.servlet-api-3.1.0.jar:3.1.0] at javax.servlet.http.HttpServlet.service(HttpServlet.java:790) ~[javax.servlet-api-3.1.0.jar:3.1.0]` ### SeaTunnel Version 2.3.9 ### SeaTunnel Config ```conf env { id=16838005946560 name=wqz-kafka description="测试kafka streaming模式报错" engine=SeaTunnel cron=null jobMode=STREAMING "job.name"=wqz-kafka "job.mode"=STREAMING } source { Kafka { "plugin_output"=Table16838010490304 "dag-parsing.mode"=MULTIPLEX topic="tyx_test01" // topic="wqz-001-topic" format_error_handle_way=fail commit_on_checkpoint=false schema { fields { name=string } } format=json "kafka.config" { "max.pool.recodes"=500 } "bootstrap.servers"="10.*.*.*:9092" } } transform { } sink { Console { "plugin_input"=Table16838010490304 "log.print.data"=true } } ``` ### Running Command ```shell ClientConfig clientConfig = ConfigProvider.locateAndGetClientConfig(); clientConfig.setClusterName(clientConfig.getClusterName()); SeaTunnelClient seaTunnelClient = new SeaTunnelClient(clientConfig); SeaTunnelConfig seaTunnelConfig = new YamlSeaTunnelConfigBuilder().build(); String filePath = "/test/kafka-streaming.conf"; JobConfig jobConfig = new JobConfig(); JobContext jobContext = new JobContext(); jobConfig.setJobContext(jobContext); ClientJobExecutionEnvironment jobExecutionEnv = seaTunnelClient.createExecutionContext(filePath, null, jobConfig, seaTunnelConfig, 1234568L); final ClientJobProxy clientJobProxy = jobExecutionEnv.execute(); long jobId = clientJobProxy.getJobId(); System.out.println("jobId:" + jobId); JobResult jobResultCache = clientJobProxy.getJobResultCache(); System.out.println("jobResultCache:" + jobResultCache); String runningJobMetrics = seaTunnelClient.getJobClient().getRunningJobMetrics(); System.out.println( "runningJobMetrics:" + runningJobMetrics); seaTunnelClient.close(); System.out.println("close:" + jobId); ``` ### Error Exception ```log 2025-03-04 15:48:29,226 ERROR org.apache.seatunnel.engine.server.rest.filter.ExceptionHandlingFilter - Error occurred while processing request java.lang.NullPointerException: null at com.hazelcast.internal.util.JsonUtil.toJsonObject(JsonUtil.java:308) ~[seatunnel-hazelcast-shade-2.3.10-SNAPSHOT.jar:2.3.10-SNAPSHOT] at org.apache.seatunnel.engine.server.rest.service.BaseService.convertToJson(BaseService.java:181) ~[classes/:?] at org.apache.seatunnel.engine.server.rest.service.JobInfoService.getJobInfoJson(JobInfoService.java:66) ~[classes/:?] at org.apache.seatunnel.engine.server.rest.servlet.JobInfoServlet.doGet(JobInfoServlet.java:52) ~[classes/:?] at javax.servlet.http.HttpServlet.service(HttpServlet.java:687) ~[javax.servlet-api-3.1.0.jar:3.1.0] at javax.servlet.http.HttpServlet.service(HttpServlet.java:790) ~[javax.servlet-api-3.1.0.jar:3.1.0] at org.apache.seatunnel.shade.org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:799) ~[seatunnel-jetty9-9.4.56.jar:2.3.10-SNAPSHOT] at org.apache.seatunnel.shade.org.eclipse.jetty.servlet.ServletHandler$ChainEnd.doFilter(ServletHandler.java:1656) ~[seatunnel-jetty9-9.4.56.jar:2.3.10-SNAPSHOT] at org.apache.seatunnel.engine.server.rest.filter.ExceptionHandlingFilter.doFilter(ExceptionHandlingFilter.java:50) ~[classes/:?] at org.apache.seatunnel.shade.org.eclipse.jetty.servlet.FilterHolder.doFilter(FilterHolder.java:193) ~[seatunnel-jetty9-9.4.56.jar:2.3.10-SNAPSHOT] at org.apache.seatunnel.shade.org.eclipse.jetty.servlet.ServletHandler$Chain.doFilter(ServletHandler.java:1626) ~[seatunnel-jetty9-9.4.56.jar:2.3.10-SNAPSHOT] at org.apache.seatunnel.shade.org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:552) ~[seatunnel-jetty9-9.4.56.jar:2.3.10-SNAPSHOT] at org.apache.seatunnel.shade.org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233) ~[seatunnel-jetty9-9.4.56.jar:2.3.10-SNAPSHOT] at org.apache.seatunnel.shade.org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:1624) ~[seatunnel-jetty9-9.4.56.jar:2.3.10-SNAPSHOT] at org.apache.seatunnel.shade.org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233) ~[seatunnel-jetty9-9.4.56.jar:2.3.10-SNAPSHOT] at org.apache.seatunnel.shade.org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1440) ~[seatunnel-jetty9-9.4.56.jar:2.3.10-SNAPSHOT] at org.apache.seatunnel.shade.org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:188) ~[seatunnel-jetty9-9.4.56.jar:2.3.10-SNAPSHOT] at org.apache.seatunnel.shade.org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:505) ~[seatunnel-jetty9-9.4.56.jar:2.3.10-SNAPSHOT] at org.apache.seatunnel.shade.org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:1594) ~[seatunnel-jetty9-9.4.56.jar:2.3.10-SNAPSHOT] at org.apache.seatunnel.shade.org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:186) ~[seatunnel-jetty9-9.4.56.jar:2.3.10-SNAPSHOT] at org.apache.seatunnel.shade.org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1355) ~[seatunnel-jetty9-9.4.56.jar:2.3.10-SNAPSHOT] at org.apache.seatunnel.shade.org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141) ~[seatunnel-jetty9-9.4.56.jar:2.3.10-SNAPSHOT] at org.apache.seatunnel.shade.org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127) ~[seatunnel-jetty9-9.4.56.jar:2.3.10-SNAPSHOT] at org.apache.seatunnel.shade.org.eclipse.jetty.server.Server.handle(Server.java:516) ~[seatunnel-jetty9-9.4.56.jar:2.3.10-SNAPSHOT] at org.apache.seatunnel.shade.org.eclipse.jetty.server.HttpChannel.lambda$handle$1(HttpChannel.java:487) ~[seatunnel-jetty9-9.4.56.jar:2.3.10-SNAPSHOT] at org.apache.seatunnel.shade.org.eclipse.jetty.server.HttpChannel.dispatch(HttpChannel.java:732) ~[seatunnel-jetty9-9.4.56.jar:2.3.10-SNAPSHOT] at org.apache.seatunnel.shade.org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:479) ~[seatunnel-jetty9-9.4.56.jar:2.3.10-SNAPSHOT] at org.apache.seatunnel.shade.org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:277) ~[seatunnel-jetty9-9.4.56.jar:2.3.10-SNAPSHOT] at org.apache.seatunnel.shade.org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:311) ~[seatunnel-jetty9-9.4.56.jar:2.3.10-SNAPSHOT] at org.apache.seatunnel.shade.org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:105) ~[seatunnel-jetty9-9.4.56.jar:2.3.10-SNAPSHOT] at org.apache.seatunnel.shade.org.eclipse.jetty.io.ChannelEndPoint$1.run(ChannelEndPoint.java:104) ~[seatunnel-jetty9-9.4.56.jar:2.3.10-SNAPSHOT] at org.apache.seatunnel.shade.org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.runTask(EatWhatYouKill.java:338) ~[seatunnel-jetty9-9.4.56.jar:2.3.10-SNAPSHOT] at org.apache.seatunnel.shade.org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.doProduce(EatWhatYouKill.java:315) ~[seatunnel-jetty9-9.4.56.jar:2.3.10-SNAPSHOT] at org.apache.seatunnel.shade.org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.tryProduce(EatWhatYouKill.java:173) ~[seatunnel-jetty9-9.4.56.jar:2.3.10-SNAPSHOT] at org.apache.seatunnel.shade.org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.produce(EatWhatYouKill.java:137) ~[seatunnel-jetty9-9.4.56.jar:2.3.10-SNAPSHOT] at org.apache.seatunnel.shade.org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:883) [seatunnel-jetty9-9.4.56.jar:2.3.10-SNAPSHOT] at org.apache.seatunnel.shade.org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:1034) [seatunnel-jetty9-9.4.56.jar:2.3.10-SNAPSHOT] at java.lang.Thread.run(Thread.java:829) [?:?] ``` ### Zeta or Flink or Spark Version _No response_ ### Java or Scala Version _No response_ ### 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: commits-unsubscr...@seatunnel.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
