prscsl opened a new issue, #9199: URL: https://github.com/apache/seatunnel/issues/9199
### 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 First of all, thank you for your great work on the project. We're encountering an intermittent issue when running a job that transfers data from 6 tables. The job is triggered every 1 minute. Occasionally, the job seems to fail internally but remains stuck in the "running" state instead of transitioning to "failed", which prevents automatic retries from being triggered as expected. Upon checking the logs, we found that a NullPointerException is being thrown during this time. This suggests that the job may be encountering an unhandled NPE, which causes it to hang rather than fail gracefully. This issue did not occur when we tested with version 2.3.8, but it started happening intermittently in version 2.3.9 and later. Could you help us understand what might be causing this behavior? Any insights or suggestions would be greatly appreciated. Thank you! ### SeaTunnel Version 2.3.9, 2.3.10 ### SeaTunnel Config ```conf "env": { "job.mode": "BATCH" }, "source" : [ { "plugin_name" : "Jdbc", "driver" : "org.postgresql.Driver", "url" : "jdbc:postgresql://10.10.10.10:5432/data", "user" : "dat", "password" : "*******", "query" : "SELECT * FROM public.test_data_1", "result_table_name" : "8b2ac913-91bf-3469-8de7-455bf4e010ab_test_data_1", }, { "plugin_name" : "Jdbc", "driver" : "org.postgresql.Driver", "url" : "jdbc:postgresql://10.10.10.10:5432/data", "user" : "dat", "password" : "*******", "query" : "SELECT * FROM public.test_data_2", "result_table_name" : "8b2ac913-91bf-3469-8de7-455bf4e010ab_test_data_2", }, { "plugin_name" : "Jdbc", "driver" : "org.postgresql.Driver", "url" : "jdbc:postgresql://10.10.10.10:5432/data", "user" : "dat", "password" : "*******", "query" : "SELECT * FROM public.test_data_3", "result_table_name" : "8b2ac913-91bf-3469-8de7-455bf4e010ab_test_data_3", }, { "plugin_name" : "Jdbc", "driver" : "org.postgresql.Driver", "url" : "jdbc:postgresql://10.10.10.10:5432/data", "user" : "dat", "password" : "*******", "query" : "SELECT * FROM public.test_data_4", "result_table_name" : "8b2ac913-91bf-3469-8de7-455bf4e010ab_test_data_4", }, { "plugin_name" : "Jdbc", "driver" : "org.postgresql.Driver", "url" : "jdbc:postgresql://10.10.10.10:5432/data", "user" : "dat", "password" : "*******", "query" : "SELECT * FROM public.test_data_5", "result_table_name" : "8b2ac913-91bf-3469-8de7-455bf4e010ab_test_data_5", }, { "plugin_name" : "Jdbc", "driver" : "org.postgresql.Driver", "url" : "jdbc:postgresql://10.10.10.10:5432/data", "user" : "dat", "password" : "*******", "query" : "SELECT * FROM public.test_data_6", "result_table_name" : "8b2ac913-91bf-3469-8de7-455bf4e010ab_test_data_6", } ], "sink" : [ { "plugin_name" : "S3File", "file_format_type" : "parquet", "path" : "/10051/24/8b2ac913-91bf-3469-8de7-455bf4e010ab/test_data_1", "tmp_path" : "/tmp", "custom_filename" : true, "filename_time_format" : "yyyy.mm.dd", "file_name_expression" : "${transactionId}_24_${now}", "batch_size" : 2100000000, "compress_codec" : "none", "bucket" : "s3a://data", "fs.s3a.endpoint" : "http://10.10.10.10:9020";, "fs.s3a.aws.credentials.provider" : "org.apache.hadoop.fs.s3a.SimpleAWSCredentialsProvider", "access_key" : "*******", "secret_key" : "*******", "hadoop_s3_properties" : { "fs.s3a.signing-algorithm" : "S3SignerType", "fs.s3a.path.style.access" : "true" }, "schema_save_mode" : "CREATE_SCHEMA_WHEN_NOT_EXIST", "data_save_mode" : "APPEND_DATA", "source_table_name" : "8b2ac913-91bf-3469-8de7-455bf4e010ab_test_data_1" }, { "plugin_name" : "S3File", "file_format_type" : "parquet", "path" : "/10051/24/8b2ac913-91bf-3469-8de7-455bf4e010ab/test_data_2", "tmp_path" : "/tmp", "custom_filename" : true, "filename_time_format" : "yyyy.mm.dd", "file_name_expression" : "${transactionId}_24_${now}", "batch_size" : 2100000000, "compress_codec" : "none", "bucket" : "s3a://data", "fs.s3a.endpoint" : "http://10.10.10.10:9020";, "fs.s3a.aws.credentials.provider" : "org.apache.hadoop.fs.s3a.SimpleAWSCredentialsProvider", "access_key" : "*******", "secret_key" : "*******", "hadoop_s3_properties" : { "fs.s3a.signing-algorithm" : "S3SignerType", "fs.s3a.path.style.access" : "true" }, "schema_save_mode" : "CREATE_SCHEMA_WHEN_NOT_EXIST", "data_save_mode" : "APPEND_DATA", "source_table_name" : "8b2ac913-91bf-3469-8de7-455bf4e010ab_test_data_2" }, { "plugin_name" : "S3File", "file_format_type" : "parquet", "path" : "/10051/24/8b2ac913-91bf-3469-8de7-455bf4e010ab/test_data_3", "tmp_path" : "/tmp", "custom_filename" : true, "filename_time_format" : "yyyy.mm.dd", "file_name_expression" : "${transactionId}_24_${now}", "batch_size" : 2100000000, "compress_codec" : "none", "bucket" : "s3a://data", "fs.s3a.endpoint" : "http://10.10.10.10:9020";, "fs.s3a.aws.credentials.provider" : "org.apache.hadoop.fs.s3a.SimpleAWSCredentialsProvider", "access_key" : "*******", "secret_key" : "*******", "hadoop_s3_properties" : { "fs.s3a.signing-algorithm" : "S3SignerType", "fs.s3a.path.style.access" : "true" }, "schema_save_mode" : "CREATE_SCHEMA_WHEN_NOT_EXIST", "data_save_mode" : "APPEND_DATA", "source_table_name" : "8b2ac913-91bf-3469-8de7-455bf4e010ab_test_data_3" }, { "plugin_name" : "S3File", "file_format_type" : "parquet", "path" : "/10051/24/8b2ac913-91bf-3469-8de7-455bf4e010ab/test_data_4", "tmp_path" : "/tmp", "custom_filename" : true, "filename_time_format" : "yyyy.mm.dd", "file_name_expression" : "${transactionId}_24_${now}", "batch_size" : 2100000000, "compress_codec" : "none", "bucket" : "s3a://data", "fs.s3a.endpoint" : "http://10.10.10.10:9020";, "fs.s3a.aws.credentials.provider" : "org.apache.hadoop.fs.s3a.SimpleAWSCredentialsProvider", "access_key" : "*******", "secret_key" : "*******", "hadoop_s3_properties" : { "fs.s3a.signing-algorithm" : "S3SignerType", "fs.s3a.path.style.access" : "true" }, "schema_save_mode" : "CREATE_SCHEMA_WHEN_NOT_EXIST", "data_save_mode" : "APPEND_DATA", "source_table_name" : "8b2ac913-91bf-3469-8de7-455bf4e010ab_test_data_4" }, { "plugin_name" : "S3File", "file_format_type" : "parquet", "path" : "/10051/24/8b2ac913-91bf-3469-8de7-455bf4e010ab/test_data_5", "tmp_path" : "/tmp", "custom_filename" : true, "filename_time_format" : "yyyy.mm.dd", "file_name_expression" : "${transactionId}_24_${now}", "batch_size" : 2100000000, "compress_codec" : "none", "bucket" : "s3a://data", "fs.s3a.endpoint" : "http://10.10.10.10:9020";, "fs.s3a.aws.credentials.provider" : "org.apache.hadoop.fs.s3a.SimpleAWSCredentialsProvider", "access_key" : "*******", "secret_key" : "*******", "hadoop_s3_properties" : { "fs.s3a.signing-algorithm" : "S3SignerType", "fs.s3a.path.style.access" : "true" }, "schema_save_mode" : "CREATE_SCHEMA_WHEN_NOT_EXIST", "data_save_mode" : "APPEND_DATA", "source_table_name" : "8b2ac913-91bf-3469-8de7-455bf4e010ab_test_data_5" }, { "plugin_name" : "S3File", "file_format_type" : "parquet", "path" : "/10051/24/8b2ac913-91bf-3469-8de7-455bf4e010ab/test_data_6", "tmp_path" : "/tmp", "custom_filename" : true, "filename_time_format" : "yyyy.mm.dd", "file_name_expression" : "${transactionId}_24_${now}", "batch_size" : 2100000000, "compress_codec" : "none", "bucket" : "s3a://data", "fs.s3a.endpoint" : "http://10.10.10.10:9020";, "fs.s3a.aws.credentials.provider" : "org.apache.hadoop.fs.s3a.SimpleAWSCredentialsProvider", "access_key" : "*******", "secret_key" : "*******", "hadoop_s3_properties" : { "fs.s3a.signing-algorithm" : "S3SignerType", "fs.s3a.path.style.access" : "true" }, "schema_save_mode" : "CREATE_SCHEMA_WHEN_NOT_EXIST", "data_save_mode" : "APPEND_DATA", "source_table_name" : "8b2ac913-91bf-3469-8de7-455bf4e010ab_test_data_6" } ] }' ``` ### Running Command ```shell curl --http1.1 --location --request POST 'http://localhost:5801/hazelcast/rest/maps/submit-job' \ --header 'Content-Type: application/json' \ --header 'Expect:' \ --data-raw '{ "env": { "job.mode": "BATCH" }, "source" : [ { "plugin_name" : "Jdbc", "driver" : "org.postgresql.Driver", "url" : "jdbc:postgresql://10.10.10.10:5432/data", "user" : "dat", "password" : "*******", "query" : "SELECT * FROM public.test_data_1", "result_table_name" : "8b2ac913-91bf-3469-8de7-455bf4e010ab_test_data_1", }, { "plugin_name" : "Jdbc", "driver" : "org.postgresql.Driver", "url" : "jdbc:postgresql://10.10.10.10:5432/data", "user" : "dat", "password" : "*******", "query" : "SELECT * FROM public.test_data_2", "result_table_name" : "8b2ac913-91bf-3469-8de7-455bf4e010ab_test_data_2", }, { "plugin_name" : "Jdbc", "driver" : "org.postgresql.Driver", "url" : "jdbc:postgresql://10.10.10.10:5432/data", "user" : "dat", "password" : "*******", "query" : "SELECT * FROM public.test_data_3", "result_table_name" : "8b2ac913-91bf-3469-8de7-455bf4e010ab_test_data_3", }, { "plugin_name" : "Jdbc", "driver" : "org.postgresql.Driver", "url" : "jdbc:postgresql://10.10.10.10:5432/data", "user" : "dat", "password" : "*******", "query" : "SELECT * FROM public.test_data_4", "result_table_name" : "8b2ac913-91bf-3469-8de7-455bf4e010ab_test_data_4", }, { "plugin_name" : "Jdbc", "driver" : "org.postgresql.Driver", "url" : "jdbc:postgresql://10.10.10.10:5432/data", "user" : "dat", "password" : "*******", "query" : "SELECT * FROM public.test_data_5", "result_table_name" : "8b2ac913-91bf-3469-8de7-455bf4e010ab_test_data_5", }, { "plugin_name" : "Jdbc", "driver" : "org.postgresql.Driver", "url" : "jdbc:postgresql://10.10.10.10:5432/data", "user" : "dat", "password" : "*******", "query" : "SELECT * FROM public.test_data_6", "result_table_name" : "8b2ac913-91bf-3469-8de7-455bf4e010ab_test_data_6", } ], "sink" : [ { "plugin_name" : "S3File", "file_format_type" : "parquet", "path" : "/10051/24/8b2ac913-91bf-3469-8de7-455bf4e010ab/test_data_1", "tmp_path" : "/tmp", "custom_filename" : true, "filename_time_format" : "yyyy.mm.dd", "file_name_expression" : "${transactionId}_24_${now}", "batch_size" : 2100000000, "compress_codec" : "none", "bucket" : "s3a://data", "fs.s3a.endpoint" : "http://10.10.10.10:9020";, "fs.s3a.aws.credentials.provider" : "org.apache.hadoop.fs.s3a.SimpleAWSCredentialsProvider", "access_key" : "*******", "secret_key" : "*******", "hadoop_s3_properties" : { "fs.s3a.signing-algorithm" : "S3SignerType", "fs.s3a.path.style.access" : "true" }, "schema_save_mode" : "CREATE_SCHEMA_WHEN_NOT_EXIST", "data_save_mode" : "APPEND_DATA", "source_table_name" : "8b2ac913-91bf-3469-8de7-455bf4e010ab_test_data_1" }, { "plugin_name" : "S3File", "file_format_type" : "parquet", "path" : "/10051/24/8b2ac913-91bf-3469-8de7-455bf4e010ab/test_data_2", "tmp_path" : "/tmp", "custom_filename" : true, "filename_time_format" : "yyyy.mm.dd", "file_name_expression" : "${transactionId}_24_${now}", "batch_size" : 2100000000, "compress_codec" : "none", "bucket" : "s3a://data", "fs.s3a.endpoint" : "http://10.10.10.10:9020";, "fs.s3a.aws.credentials.provider" : "org.apache.hadoop.fs.s3a.SimpleAWSCredentialsProvider", "access_key" : "*******", "secret_key" : "*******", "hadoop_s3_properties" : { "fs.s3a.signing-algorithm" : "S3SignerType", "fs.s3a.path.style.access" : "true" }, "schema_save_mode" : "CREATE_SCHEMA_WHEN_NOT_EXIST", "data_save_mode" : "APPEND_DATA", "source_table_name" : "8b2ac913-91bf-3469-8de7-455bf4e010ab_test_data_2" }, { "plugin_name" : "S3File", "file_format_type" : "parquet", "path" : "/10051/24/8b2ac913-91bf-3469-8de7-455bf4e010ab/test_data_3", "tmp_path" : "/tmp", "custom_filename" : true, "filename_time_format" : "yyyy.mm.dd", "file_name_expression" : "${transactionId}_24_${now}", "batch_size" : 2100000000, "compress_codec" : "none", "bucket" : "s3a://data", "fs.s3a.endpoint" : "http://10.10.10.10:9020";, "fs.s3a.aws.credentials.provider" : "org.apache.hadoop.fs.s3a.SimpleAWSCredentialsProvider", "access_key" : "*******", "secret_key" : "*******", "hadoop_s3_properties" : { "fs.s3a.signing-algorithm" : "S3SignerType", "fs.s3a.path.style.access" : "true" }, "schema_save_mode" : "CREATE_SCHEMA_WHEN_NOT_EXIST", "data_save_mode" : "APPEND_DATA", "source_table_name" : "8b2ac913-91bf-3469-8de7-455bf4e010ab_test_data_3" }, { "plugin_name" : "S3File", "file_format_type" : "parquet", "path" : "/10051/24/8b2ac913-91bf-3469-8de7-455bf4e010ab/test_data_4", "tmp_path" : "/tmp", "custom_filename" : true, "filename_time_format" : "yyyy.mm.dd", "file_name_expression" : "${transactionId}_24_${now}", "batch_size" : 2100000000, "compress_codec" : "none", "bucket" : "s3a://data", "fs.s3a.endpoint" : "http://10.10.10.10:9020";, "fs.s3a.aws.credentials.provider" : "org.apache.hadoop.fs.s3a.SimpleAWSCredentialsProvider", "access_key" : "*******", "secret_key" : "*******", "hadoop_s3_properties" : { "fs.s3a.signing-algorithm" : "S3SignerType", "fs.s3a.path.style.access" : "true" }, "schema_save_mode" : "CREATE_SCHEMA_WHEN_NOT_EXIST", "data_save_mode" : "APPEND_DATA", "source_table_name" : "8b2ac913-91bf-3469-8de7-455bf4e010ab_test_data_4" }, { "plugin_name" : "S3File", "file_format_type" : "parquet", "path" : "/10051/24/8b2ac913-91bf-3469-8de7-455bf4e010ab/test_data_5", "tmp_path" : "/tmp", "custom_filename" : true, "filename_time_format" : "yyyy.mm.dd", "file_name_expression" : "${transactionId}_24_${now}", "batch_size" : 2100000000, "compress_codec" : "none", "bucket" : "s3a://data", "fs.s3a.endpoint" : "http://10.10.10.10:9020";, "fs.s3a.aws.credentials.provider" : "org.apache.hadoop.fs.s3a.SimpleAWSCredentialsProvider", "access_key" : "*******", "secret_key" : "*******", "hadoop_s3_properties" : { "fs.s3a.signing-algorithm" : "S3SignerType", "fs.s3a.path.style.access" : "true" }, "schema_save_mode" : "CREATE_SCHEMA_WHEN_NOT_EXIST", "data_save_mode" : "APPEND_DATA", "source_table_name" : "8b2ac913-91bf-3469-8de7-455bf4e010ab_test_data_5" }, { "plugin_name" : "S3File", "file_format_type" : "parquet", "path" : "/10051/24/8b2ac913-91bf-3469-8de7-455bf4e010ab/test_data_6", "tmp_path" : "/tmp", "custom_filename" : true, "filename_time_format" : "yyyy.mm.dd", "file_name_expression" : "${transactionId}_24_${now}", "batch_size" : 2100000000, "compress_codec" : "none", "bucket" : "s3a://data", "fs.s3a.endpoint" : "http://10.10.10.10:9020";, "fs.s3a.aws.credentials.provider" : "org.apache.hadoop.fs.s3a.SimpleAWSCredentialsProvider", "access_key" : "*******", "secret_key" : "*******", "hadoop_s3_properties" : { "fs.s3a.signing-algorithm" : "S3SignerType", "fs.s3a.path.style.access" : "true" }, "schema_save_mode" : "CREATE_SCHEMA_WHEN_NOT_EXIST", "data_save_mode" : "APPEND_DATA", "source_table_name" : "8b2ac913-91bf-3469-8de7-455bf4e010ab_test_data_6" } ] }' ``` ### Error Exception ```log [965508252030926849] 2025-04-18 16:05:09,673 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [hz.main.seaTunnel.task.thread-196] - Job 1D (965508252030926849), Pipeline: [(1/6)], task: [pipeline-1 [Source[0]-Jdbc]-SplitEnumerator (1/1)] turned from state CANCELING to CANCELED. [965508252030926849] 2025-04-18 16:05:09,673 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [hz.main.seaTunnel.task.thread-196] - Job 1D (965508252030926849), Pipeline: [(1/6)], task: [pipeline-1 [Source[0]-Jdbc]-SplitEnumerator (1/1)] state process is stopped [965508252030926849] 2025-04-18 16:05:09,673 INFO [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-69] - Job 1D (965508252030926849), Pipeline: [(1/6)], task: [pipeline-1 [Source[0]-Jdbc]-SplitEnumerator (1/1)] future complete with state CANCELED [965508252030926849] 2025-04-18 16:05:09,673 ERROR [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-68] - java.lang.NullPointerException at org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex.cancel(PhysicalVertex.java:413) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.lambda$stateProcess$21(SubPlan.java:663) at java.base/java.util.ArrayList.forEach(ArrayList.java:1541) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.stateProcess(SubPlan.java:660) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.updatePipelineState(SubPlan.java:383) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.makePipelineFailing(SubPlan.java:699) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.updatePipelineState(SubPlan.java:387) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.stateProcess(SubPlan.java:633) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.updatePipelineState(SubPlan.java:383) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.stateProcess(SubPlan.java:624) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.startSubPlanStateProcess(SubPlan.java:608) at org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan.lambda$stateProcess$3(PhysicalPlan.java:320) at java.base/java.util.ArrayList.forEach(ArrayList.java:1541) at org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan.stateProcess(PhysicalPlan.java:316) at org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan.updateJobState(PhysicalPlan.java:267) at org.apache.seatunnel.engine.server.CoordinatorService.lambda$submitJob$6(CoordinatorService.java:660) at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:829) [965508252030926849] 2025-04-18 16:05:09,673 INFO [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-68] - Job 1D (965508252030926849), Pipeline: [(2/6)] state process is start [965508252030926849] 2025-04-18 16:05:09,673 INFO [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-68] - Job 1D (965508252030926849), Pipeline: [(2/6)] turned from state CREATED to SCHEDULED. [965508252030926849] 2025-04-18 16:05:09,674 INFO [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-68] - Job 1D (965508252030926849), Pipeline: [(2/6)] turned from state SCHEDULED to DEPLOYING. [965508252030926849] 2025-04-18 16:05:09,674 ERROR [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-68] - java.lang.NullPointerException at org.apache.seatunnel.engine.server.dag.physical.SubPlan.lambda$stateProcess$19(SubPlan.java:641) at java.base/java.util.ArrayList.forEach(ArrayList.java:1541) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.stateProcess(SubPlan.java:639) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.updatePipelineState(SubPlan.java:383) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.stateProcess(SubPlan.java:633) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.updatePipelineState(SubPlan.java:383) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.stateProcess(SubPlan.java:624) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.startSubPlanStateProcess(SubPlan.java:608) at org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan.lambda$stateProcess$3(PhysicalPlan.java:320) at java.base/java.util.ArrayList.forEach(ArrayList.java:1541) at org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan.stateProcess(PhysicalPlan.java:316) at org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan.updateJobState(PhysicalPlan.java:267) at org.apache.seatunnel.engine.server.CoordinatorService.lambda$submitJob$6(CoordinatorService.java:660) at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:829) ``` ### Zeta or Flink or Spark Version _No response_ ### Java or Scala Version java 11 ### Screenshots _No response_ ### Are you willing to submit PR? - [ ] 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]
