sunjunwei2020 opened a new issue, #6257: URL: https://github.com/apache/seatunnel/issues/6257
### 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 hive版本为3.1.0，通过jdbc访问hive，使用connector-jdbc-2.3.3.jar执行时，异常信息：Could not find any jdbc dialect factory that can handle url 'jdbc:hive2://server1:10000' that implements 'org.apache.seatunnel.connectors.seatunnel.jdbc.internal.dialect.JdbcDialectFactory' in the classpath. 将connector-jdbc-2.3.4.jar编译后执行时，异常信息为 ：2024-01-19 00:13:23,484 WARN org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSource - get row type info exception java.sql.SQLFeatureNotSupportedException: Method not supported at org.apache.hive.jdbc.HivePreparedStatement.getMetaData(HivePreparedStatement.java:201) ~[hive-jdbc-3.1.0.3.1.5.0-152.jar:3.1.0.3.1.5.0-152] at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.dialect.JdbcDialect.getResultSetMetaData(JdbcDialect.java:216) ~[connector-cdc-mysql-2.3.3.jar:2.3.3] at org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSource.initTableField(JdbcSource.java:174) [connector-cdc-mysql-2.3.3.jar:2.3.3] at org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSource.prepare(JdbcSource.java:108) [connector-cdc-mysql-2.3.3.jar:2.3.3] at org.apache.seatunnel.engine.core.parse.JobConfigParser.parseSource(JobConfigParser.java:85) [seatunnel-starter.jar:2.3.3] at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSource(MultipleTableJobConfigParser.java:317) [seatunnel-starter.jar:2.3.3] at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:179) [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.client.job.JobExecutionEnvironment.execute(JobExecutionEnvironment.java:73) [seatunnel-starter.jar:2.3.3] at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:143) [seatunnel-starter.jar:2.3.3] at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) [seatunnel-starter.jar:2.3.3] at org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34) [seatunnel-starter.jar:2.3.3] 请问我该如何解决它？ hive version 3.1.0, when accessing hive via jdbc, using connective-jdbc-2.3.3.jar, gives an exception: Could not find any jdbc dialect factory that can handle url 'jdbc:hive2://server1:10000' that implements 'org.apache.seatunnel.connectors.seatunnel.jdbc.internal.dialect.JdbcDialectFactory' in the classpath. When the connector-jdbc-2.3.4.jar is compiled and executed, the exception message is: The 2024-01-19 00:13:23, 484 WARN org. Apache. Seatunnel. Connectors. Seatunnel. JDBC. Source. JdbcSource - get a row type info exception java.sql.SQLFeatureNotSupportedException: Method not supported at org.apache.hive.jdbc.HivePreparedStatement.getMetaData(HivePreparedStatement.java:201) ~ [hive - JDBC - 3.1.0.3.1.5.0-152. The jar: 3.1.0.3.1.5.0-152] at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.dialect.JdbcDialect.getResultSetMetaData(JdbcDialect.java:216) ~ [connector - CDC - mysql - 2.3.3. Jar: 2.3.3] at org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSource.initTableField(JdbcSource.java:174) [connector - CDC - mysql - 2.3.3. Jar: 2.3.3] at org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSource.prepare(JdbcSource.java:108) [connector - CDC - mysql - 2.3.3. Jar: 2.3.3] at org.apache.seatunnel.engine.core.parse.JobConfigParser.parseSource(JobConfigParser.java:85) [seatunnel - starter. Jar: 2.3.3] at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSource(MultipleTableJobConfigParser.java:317) [seatunnel - starter. Jar: 2.3.3] at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:179) [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.client.job.JobExecutionEnvironment.execute(JobExecutionEnvironment.java:73) [seatunnel - starter. Jar: 2.3.3] at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:143) [seatunnel - starter. Jar: 2.3.3] At org. Apache. Seatunnel. Core. The starter. Seatunnel. Run (seatunnel. Java: 40) [seatunnel - starter. Jar: 2.3.3] at org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34) [seatunnel - starter. Jar: 2.3.3] How can I fix it? ### SeaTunnel Version 2.3.3 ### SeaTunnel Config ```conf env { job.mode = "BATCH" parallelism = 2 } source { Jdbc { url = "jdbc:hive2://server1:10000" driver = "org.apache.hive.jdbc.HiveDriver" user = "hive" password = "hive" query = "select * from demo.attr_key" result_table_name = "demo" } } sink { Console { source_table_name = "demo" } } ``` ### Running Command ```shell bin/seatunnel.sh -e local -c config/conf/read-hive-jdbc.conf ``` ### Error Exception ```log 2024-01-19 00:13:22,929 INFO org.apache.seatunnel.api.configuration.ReadonlyConfig - Config uses fallback configuration key 'plugin_name' instead of key 'factory' 2024-01-19 00:13:22,930 INFO org.apache.seatunnel.api.configuration.ReadonlyConfig - Config uses fallback configuration key 'plugin_name' instead of key 'factory' 2024-01-19 00:13:22,936 INFO org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Load SeaTunnelSink Plugin from /opt/soft/seatunnel-2.3.3/backend/apache-seatunnel-2.3.3/connectors/seatunnel 2024-01-19 00:13:22,943 INFO org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Discovery plugin jar: Jdbc at: file:/opt/soft/seatunnel-2.3.3/backend/apache-seatunnel-2.3.3/connectors/seatunnel/connector-jdbc-2.3.3.jar 2024-01-19 00:13:22,948 WARN org.apache.seatunnel.api.configuration.util.ConfigUtil - Option 'source_table_name' is a List, and it is recommended to configure it as ["string1","string2"]; we will only use ',' to split the String into a list. 2024-01-19 00:13:22,949 INFO org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser - start generating all sources. 2024-01-19 00:13:22,950 INFO org.apache.seatunnel.api.configuration.ReadonlyConfig - Config uses fallback configuration key 'plugin_name' instead of key 'factory' 2024-01-19 00:13:23,032 INFO org.apache.seatunnel.api.configuration.ReadonlyConfig - Config uses fallback configuration key 'plugin_name' instead of key 'factory' 2024-01-19 00:13:23,048 INFO org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Load SeaTunnelSource Plugin from /opt/soft/seatunnel-2.3.3/backend/apache-seatunnel-2.3.3/connectors/seatunnel 2024-01-19 00:13:23,056 INFO org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Discovery plugin jar: Jdbc at: file:/opt/soft/seatunnel-2.3.3/backend/apache-seatunnel-2.3.3/connectors/seatunnel/connector-jdbc-2.3.3.jar 2024-01-19 00:13:23,063 INFO org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Load plugin: PluginIdentifier{engineType='seatunnel', pluginType='source', pluginName='Jdbc'} from classpath 2024-01-19 00:13:23,262 INFO org.apache.seatunnel.engine.server.CoordinatorService - [server1]:5801 [seatunnel-525719] [5.1] This node become a new active master node, begin init coordinator service 2024-01-19 00:13:23,317 INFO com.hazelcast.internal.partition.impl.PartitionStateManager - [server1]:5801 [seatunnel-525719] [5.1] Initializing cluster partition table arrangement... 2024-01-19 00:13:23,484 WARN org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSource - get row type info exception java.sql.SQLFeatureNotSupportedException: Method not supported at org.apache.hive.jdbc.HivePreparedStatement.getMetaData(HivePreparedStatement.java:201) ~[hive-jdbc-3.1.0.3.1.5.0-152.jar:3.1.0.3.1.5.0-152] at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.dialect.JdbcDialect.getResultSetMetaData(JdbcDialect.java:216) ~[connector-cdc-mysql-2.3.3.jar:2.3.3] at org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSource.initTableField(JdbcSource.java:174) [connector-cdc-mysql-2.3.3.jar:2.3.3] at org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSource.prepare(JdbcSource.java:108) [connector-cdc-mysql-2.3.3.jar:2.3.3] at org.apache.seatunnel.engine.core.parse.JobConfigParser.parseSource(JobConfigParser.java:85) [seatunnel-starter.jar:2.3.3] at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSource(MultipleTableJobConfigParser.java:317) [seatunnel-starter.jar:2.3.3] at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:179) [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.client.job.JobExecutionEnvironment.execute(JobExecutionEnvironment.java:73) [seatunnel-starter.jar:2.3.3] at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:143) [seatunnel-starter.jar:2.3.3] at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) [seatunnel-starter.jar:2.3.3] at org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34) [seatunnel-starter.jar:2.3.3] 2024-01-19 00:13:23,497 INFO org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSource - The partition_column parameter is not configured, and the source parallelism is set to 1 2024-01-19 00:13:23,530 INFO org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser - start generating all transforms. 2024-01-19 00:13:23,530 INFO org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser - start generating all sinks. 2024-01-19 00:13:23,530 INFO org.apache.seatunnel.api.configuration.ReadonlyConfig - Config uses fallback configuration key 'plugin_name' instead of key 'factory' 2024-01-19 00:13:23,531 WARN org.apache.seatunnel.api.configuration.util.ConfigUtil - Option 'source_table_name' is a List, and it is recommended to configure it as ["string1","string2"]; we will only use ',' to split the String into a list. 2024-01-19 00:13:23,540 INFO org.apache.seatunnel.api.configuration.ReadonlyConfig - Config uses fallback configuration key 'plugin_name' instead of key 'factory' 2024-01-19 00:13:23,598 INFO org.apache.seatunnel.engine.client.job.ClientJobProxy - Start submit job, job id: 800593659660599297, with plugin jar [file:/opt/soft/seatunnel-2.3.3/backend/apache-seatunnel-2.3.3/plugins/jdbc/lib/mysql-connector-java-8.0.25.jar, file:/opt/soft/seatunnel-2.3.3/backend/apache-seatunnel-2.3.3/plugins/jdbc/lib/hive-exec-3.1.0.3.1.5.0-152.jar, file:/opt/soft/seatunnel-2.3.3/backend/apache-seatunnel-2.3.3/plugins/jdbc/lib/connector-jdbc-2.3.4.jar, file:/opt/soft/seatunnel-2.3.3/backend/apache-seatunnel-2.3.3/plugins/jdbc/lib/hive-service-3.1.0.3.1.5.0-152.jar, file:/opt/soft/seatunnel-2.3.3/backend/apache-seatunnel-2.3.3/plugins/jdbc/lib/hive-common-3.1.0.3.1.5.0-152.jar, file:/opt/soft/seatunnel-2.3.3/backend/apache-seatunnel-2.3.3/plugins/jdbc/lib/libthrift-0.9.3-1.jar, file:/opt/soft/seatunnel-2.3.3/backend/apache-seatunnel-2.3.3/plugins/jdbc/lib/hive-jdbc-3.1.0.3.1.5.0-152.jar, file:/opt/soft/seatunnel-2.3.3/backend/apache-seatunnel-2.3.3/plugins/jdbc /lib/hive-service-rpc-3.1.0.3.1.5.0-152.jar, file:/opt/soft/seatunnel-2.3.3/backend/apache-seatunnel-2.3.3/lib/connector-console-2.3.3.jar, file:/opt/soft/seatunnel-2.3.3/backend/apache-seatunnel-2.3.3/connectors/seatunnel/connector-jdbc-2.3.3.jar] 2024-01-19 00:13:23,612 INFO org.apache.seatunnel.engine.server.resourcemanager.AbstractResourceManager - Init ResourceManager 2024-01-19 00:13:23,613 INFO org.apache.seatunnel.engine.server.resourcemanager.AbstractResourceManager - initWorker... 2024-01-19 00:13:23,613 INFO org.apache.seatunnel.engine.server.resourcemanager.AbstractResourceManager - initWorker live nodes: [[server1]:5801] 2024-01-19 00:13:23,615 INFO org.apache.seatunnel.engine.server.resourcemanager.AbstractResourceManager - registerWorker: {[server1]:5801=WorkerProfile(address=[server1]:5801, profile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=1029177344}}, unassignedResource=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=1029177344}}, assignedSlots=[], unassignedSlots=[])} 2024-01-19 00:13:23,636 INFO org.apache.seatunnel.engine.server.master.JobMaster - Init JobMaster for Job read-hive-jdbc (800593659660599297) 2024-01-19 00:13:23,637 INFO org.apache.seatunnel.engine.server.master.JobMaster - Job read-hive-jdbc (800593659660599297) needed jar urls [file:/opt/soft/seatunnel-2.3.3/backend/apache-seatunnel-2.3.3/plugins/jdbc/lib/mysql-connector-java-8.0.25.jar, file:/opt/soft/seatunnel-2.3.3/backend/apache-seatunnel-2.3.3/plugins/jdbc/lib/hive-exec-3.1.0.3.1.5.0-152.jar, file:/opt/soft/seatunnel-2.3.3/backend/apache-seatunnel-2.3.3/plugins/jdbc/lib/connector-jdbc-2.3.4.jar, file:/opt/soft/seatunnel-2.3.3/backend/apache-seatunnel-2.3.3/plugins/jdbc/lib/hive-service-3.1.0.3.1.5.0-152.jar, file:/opt/soft/seatunnel-2.3.3/backend/apache-seatunnel-2.3.3/plugins/jdbc/lib/hive-common-3.1.0.3.1.5.0-152.jar, file:/opt/soft/seatunnel-2.3.3/backend/apache-seatunnel-2.3.3/plugins/jdbc/lib/libthrift-0.9.3-1.jar, file:/opt/soft/seatunnel-2.3.3/backend/apache-seatunnel-2.3.3/plugins/jdbc/lib/hive-jdbc-3.1.0.3.1.5.0-152.jar, file:/opt/soft/seatunnel-2.3.3/backend/apache-seatunnel-2.3.3/plugins/jdbc/lib/hiv e-service-rpc-3.1.0.3.1.5.0-152.jar, file:/opt/soft/seatunnel-2.3.3/backend/apache-seatunnel-2.3.3/lib/connector-console-2.3.3.jar, file:/opt/soft/seatunnel-2.3.3/backend/apache-seatunnel-2.3.3/connectors/seatunnel/connector-jdbc-2.3.3.jar] 2024-01-19 00:13:23,924 WARN org.apache.hadoop.util.NativeCodeLoader - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable 2024-01-19 00:13:24,046 WARN org.apache.hadoop.fs.FileSystem - Cannot load filesystem: java.util.ServiceConfigurationError: org.apache.hadoop.fs.FileSystem: Provider org.apache.hadoop.fs.s3native.NativeS3FileSystem not found 2024-01-19 00:13:24,051 WARN org.apache.hadoop.fs.FileSystem - Cannot load filesystem: java.util.ServiceConfigurationError: org.apache.hadoop.fs.FileSystem: Provider org.apache.hadoop.fs.s3native.NativeS3FileSystem not found 2024-01-19 00:13:24,573 INFO org.apache.seatunnel.engine.checkpoint.storage.hdfs.HdfsStorage - Path /tmp/seatunnel/checkpoint_snapshot/800593659660599297 is not a directory 2024-01-19 00:13:24,573 INFO org.apache.seatunnel.engine.checkpoint.storage.hdfs.HdfsStorage - No checkpoint found for job, job id is: 800593659660599297 2024-01-19 00:13:24,577 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job read-hive-jdbc (800593659660599297), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-demo]-SourceTask (1/2)] is in state CREATED when init state future 2024-01-19 00:13:24,578 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job read-hive-jdbc (800593659660599297), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-demo]-SourceTask (2/2)] is in state CREATED when init state future 2024-01-19 00:13:24,578 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job read-hive-jdbc (800593659660599297), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-demo]-SplitEnumerator (1/1)] is in state CREATED when init state future 2024-01-19 00:13:24,580 INFO org.apache.seatunnel.engine.client.job.ClientJobProxy - Submit job finished, job id: 800593659660599297, job name: SeaTunnel 2024-01-19 00:13:24,583 INFO org.apache.seatunnel.engine.server.master.JobMaster - Job Job read-hive-jdbc (800593659660599297) waiting for scheduler finished 2024-01-19 00:13:24,584 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan - Job read-hive-jdbc (800593659660599297) turn from state CREATED to SCHEDULED. 2024-01-19 00:13:24,588 INFO org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job read-hive-jdbc (800593659660599297), Pipeline: [(1/1)] turn from state CREATED to SCHEDULED. 2024-01-19 00:13:24,591 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job read-hive-jdbc (800593659660599297), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-demo]-SplitEnumerator (1/1)] state from CREATED to SCHEDULED 2024-01-19 00:13:24,593 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job read-hive-jdbc (800593659660599297), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-demo]-SplitEnumerator (1/1)] turn from state CREATED to SCHEDULED. 2024-01-19 00:13:24,599 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job read-hive-jdbc (800593659660599297), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-demo]-SourceTask (1/2)] state from CREATED to SCHEDULED 2024-01-19 00:13:24,600 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job read-hive-jdbc (800593659660599297), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-demo]-SourceTask (1/2)] turn from state CREATED to SCHEDULED. 2024-01-19 00:13:24,601 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job read-hive-jdbc (800593659660599297), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-demo]-SourceTask (2/2)] state from CREATED to SCHEDULED 2024-01-19 00:13:24,602 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job read-hive-jdbc (800593659660599297), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-demo]-SourceTask (2/2)] turn from state CREATED to SCHEDULED. 2024-01-19 00:13:24,610 INFO org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job read-hive-jdbc (800593659660599297), Pipeline: [(1/1)] turn from state SCHEDULED to DEPLOYING. 2024-01-19 00:13:24,612 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job read-hive-jdbc (800593659660599297), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-demo]-SplitEnumerator (1/1)] state from SCHEDULED to DEPLOYING 2024-01-19 00:13:24,613 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job read-hive-jdbc (800593659660599297), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-demo]-SplitEnumerator (1/1)] turn from state SCHEDULED to DEPLOYING. 2024-01-19 00:13:24,614 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job read-hive-jdbc (800593659660599297), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-demo]-SourceTask (1/2)] state from SCHEDULED to DEPLOYING 2024-01-19 00:13:24,615 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job read-hive-jdbc (800593659660599297), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-demo]-SourceTask (1/2)] turn from state SCHEDULED to DEPLOYING. 2024-01-19 00:13:24,616 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job read-hive-jdbc (800593659660599297), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-demo]-SourceTask (2/2)] state from SCHEDULED to DEPLOYING 2024-01-19 00:13:24,618 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job read-hive-jdbc (800593659660599297), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-demo]-SourceTask (2/2)] turn from state SCHEDULED to DEPLOYING. 2024-01-19 00:13:24,620 WARN org.apache.seatunnel.engine.client.job.JobMetricsRunner - Failed to get job metrics summary, it maybe first-run 2024-01-19 00:13:24,625 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [server1]:5801 [seatunnel-525719] [5.1] received deploying task executionId [800593667378118657] 2024-01-19 00:13:24,629 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [server1]:5801 [seatunnel-525719] [5.1] deploying task TaskGroupLocation{jobId=800593659660599297, pipelineId=1, taskGroupId=1}, executionId [800593667378118657] 2024-01-19 00:13:24,629 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [server1]:5801 [seatunnel-525719] [5.1] deploying TaskGroup TaskGroupLocation{jobId=800593659660599297, pipelineId=1, taskGroupId=1} init success 2024-01-19 00:13:24,636 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [server1]:5801 [seatunnel-525719] [5.1] deploying TaskGroup TaskGroupLocation{jobId=800593659660599297, pipelineId=1, taskGroupId=1} success 2024-01-19 00:13:24,636 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [server1]:5801 [seatunnel-525719] [5.1] received deploying task executionId [800593667378184193] 2024-01-19 00:13:24,636 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [server1]:5801 [seatunnel-525719] [5.1] received deploying task executionId [800593667378249729] 2024-01-19 00:13:24,638 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job read-hive-jdbc (800593659660599297), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-demo]-SplitEnumerator (1/1)] state from DEPLOYING to RUNNING 2024-01-19 00:13:24,639 INFO org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask - starting seatunnel source split enumerator task, source name: pipeline-1 [Source[0]-Jdbc-demo] 2024-01-19 00:13:24,640 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job read-hive-jdbc (800593659660599297), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-demo]-SplitEnumerator (1/1)] turn from state DEPLOYING to RUNNING. 2024-01-19 00:13:24,646 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [server1]:5801 [seatunnel-525719] [5.1] deploying task TaskGroupLocation{jobId=800593659660599297, pipelineId=1, taskGroupId=30001}, executionId [800593667378249729] 2024-01-19 00:13:24,647 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [server1]:5801 [seatunnel-525719] [5.1] deploying TaskGroup TaskGroupLocation{jobId=800593659660599297, pipelineId=1, taskGroupId=30001} init success 2024-01-19 00:13:24,647 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [server1]:5801 [seatunnel-525719] [5.1] deploying task TaskGroupLocation{jobId=800593659660599297, pipelineId=1, taskGroupId=30000}, executionId [800593667378184193] 2024-01-19 00:13:24,648 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [server1]:5801 [seatunnel-525719] [5.1] deploying TaskGroup TaskGroupLocation{jobId=800593659660599297, pipelineId=1, taskGroupId=30001} success 2024-01-19 00:13:24,649 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job read-hive-jdbc (800593659660599297), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-demo]-SourceTask (2/2)] state from DEPLOYING to RUNNING 2024-01-19 00:13:24,650 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job read-hive-jdbc (800593659660599297), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-demo]-SourceTask (2/2)] turn from state DEPLOYING to RUNNING. 2024-01-19 00:13:24,650 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [server1]:5801 [seatunnel-525719] [5.1] deploying TaskGroup TaskGroupLocation{jobId=800593659660599297, pipelineId=1, taskGroupId=30000} init success 2024-01-19 00:13:24,652 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [server1]:5801 [seatunnel-525719] [5.1] deploying TaskGroup TaskGroupLocation{jobId=800593659660599297, pipelineId=1, taskGroupId=30000} success 2024-01-19 00:13:24,652 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job read-hive-jdbc (800593659660599297), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-demo]-SourceTask (1/2)] state from DEPLOYING to RUNNING 2024-01-19 00:13:24,653 INFO org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask - starting seatunnel transform task, index 1 2024-01-19 00:13:24,653 INFO org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask - starting seatunnel transform task, index 0 2024-01-19 00:13:24,653 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job read-hive-jdbc (800593659660599297), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-demo]-SourceTask (1/2)] turn from state DEPLOYING to RUNNING. 2024-01-19 00:13:24,654 INFO org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job read-hive-jdbc (800593659660599297), Pipeline: [(1/1)] turn from state DEPLOYING to RUNNING. 2024-01-19 00:13:24,655 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan - Job read-hive-jdbc (800593659660599297) turn from state SCHEDULED to RUNNING. 2024-01-19 00:13:24,656 INFO org.apache.seatunnel.engine.server.master.JobMaster - Job read-hive-jdbc (800593659660599297) scheduler finished 2024-01-19 00:13:24,657 INFO org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask - starting seatunnel source task, index 1 2024-01-19 00:13:24,657 INFO org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask - starting seatunnel source task, index 0 2024-01-19 00:13:24,662 INFO org.apache.seatunnel.connectors.seatunnel.console.sink.ConsoleSinkWriter - output rowType: 2024-01-19 00:13:24,662 INFO org.apache.seatunnel.connectors.seatunnel.console.sink.ConsoleSinkWriter - output rowType: 2024-01-19 00:13:25,134 INFO org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask - received reader register, readerID: TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=800593659660599297, pipelineId=1, taskGroupId=30000}, taskID=40000, index=0} 2024-01-19 00:13:25,289 INFO org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask - received reader register, readerID: TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=800593659660599297, pipelineId=1, taskGroupId=30001}, taskID=40001, index=1} 2024-01-19 00:13:25,346 INFO org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask - received enough reader, starting enumerator... 2024-01-19 00:13:25,347 INFO org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceSplitEnumerator - Starting to calculate splits. 2024-01-19 00:13:25,347 INFO org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceSplitEnumerator - Assigning JdbcSourceSplit(parameterValues=null, splitId=0) to 0 reader. 2024-01-19 00:13:25,347 INFO org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceSplitEnumerator - Assign splits [JdbcSourceSplit(parameterValues=null, splitId=0)] to reader 0 2024-01-19 00:13:25,390 INFO org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceReader - Closed the bounded jdbc source 2024-01-19 00:13:26,785 INFO org.apache.seatunnel.connectors.seatunnel.console.sink.ConsoleSinkWriter - subtaskIndex=0 rowIndex=1: SeaTunnelRow#tableId= SeaTunnelRow#kind=INSERT : 2024-01-19 00:13:26,785 INFO org.apache.seatunnel.connectors.seatunnel.console.sink.ConsoleSinkWriter - subtaskIndex=0 rowIndex=2: SeaTunnelRow#tableId= SeaTunnelRow#kind=INSERT : 2024-01-19 00:13:26,785 INFO org.apache.seatunnel.connectors.seatunnel.console.sink.ConsoleSinkWriter - subtaskIndex=0 rowIndex=3: SeaTunnelRow#tableId= SeaTunnelRow#kind=INSERT : 2024-01-19 00:13:26,785 INFO org.apache.seatunnel.connectors.seatunnel.console.sink.ConsoleSinkWriter - subtaskIndex=0 rowIndex=4: SeaTunnelRow#tableId= SeaTunnelRow#kind=INSERT : 2024-01-19 00:13:26,786 INFO org.apache.seatunnel.connectors.seatunnel.console.sink.ConsoleSinkWriter - subtaskIndex=0 rowIndex=5: SeaTunnelRow#tableId= SeaTunnelRow#kind=INSERT : 2024-01-19 00:13:26,786 INFO org.apache.seatunnel.connectors.seatunnel.console.sink.ConsoleSinkWriter - subtaskIndex=0 rowIndex=6: SeaTunnelRow#tableId= SeaTunnelRow#kind=INSERT : 2024-01-19 00:13:26,786 INFO org.apache.seatunnel.connectors.seatunnel.console.sink.ConsoleSinkWriter - subtaskIndex=0 rowIndex=7: SeaTunnelRow#tableId= SeaTunnelRow#kind=INSERT : 2024-01-19 00:13:26,786 INFO org.apache.seatunnel.connectors.seatunnel.console.sink.ConsoleSinkWriter - subtaskIndex=0 rowIndex=8: SeaTunnelRow#tableId= SeaTunnelRow#kind=INSERT : 2024-01-19 00:13:26,786 INFO org.apache.seatunnel.connectors.seatunnel.console.sink.ConsoleSinkWriter - subtaskIndex=0 rowIndex=9: SeaTunnelRow#tableId= SeaTunnelRow#kind=INSERT : 2024-01-19 00:13:26,786 INFO org.apache.seatunnel.connectors.seatunnel.console.sink.ConsoleSinkWriter - subtaskIndex=0 rowIndex=10: SeaTunnelRow#tableId= SeaTunnelRow#kind=INSERT : 2024-01-19 00:13:26,786 INFO org.apache.seatunnel.connectors.seatunnel.console.sink.ConsoleSinkWriter - subtaskIndex=0 rowIndex=11: SeaTunnelRow#tableId= SeaTunnelRow#kind=INSERT : 2024-01-19 00:13:26,786 INFO org.apache.seatunnel.connectors.seatunnel.console.sink.ConsoleSinkWriter - subtaskIndex=0 rowIndex=12: SeaTunnelRow#tableId= SeaTunnelRow#kind=INSERT : 2024-01-19 00:13:26,786 INFO org.apache.seatunnel.connectors.seatunnel.console.sink.ConsoleSinkWriter - subtaskIndex=0 rowIndex=13: SeaTunnelRow#tableId= SeaTunnelRow#kind=INSERT : 2024-01-19 00:13:26,786 INFO org.apache.seatunnel.connectors.seatunnel.console.sink.ConsoleSinkWriter - subtaskIndex=0 rowIndex=14: SeaTunnelRow#tableId= SeaTunnelRow#kind=INSERT : 2024-01-19 00:13:26,814 INFO org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceReader - Closed the bounded jdbc source 2024-01-19 00:13:26,866 INFO org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - wait checkpoint completed: 9223372036854775807 2024-01-19 00:13:27,224 INFO org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - pending checkpoint(9223372036854775807/1@800593659660599297) notify finished! 2024-01-19 00:13:27,224 INFO org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - start notify checkpoint completed, checkpoint:org.apache.seatunnel.engine.server.checkpoint.CompletedCheckpoint@60ef8f12 2024-01-19 00:13:27,232 INFO org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - start clean pending checkpoint cause CheckpointCoordinator completed. 2024-01-19 00:13:27,234 INFO org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - Turn checkpoint_state_800593659660599297_1 state from null to FINISHED 2024-01-19 00:13:27,258 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [server1]:5801 [seatunnel-525719] [5.1] taskDone, taskId = 20000, taskGroup = TaskGroupLocation{jobId=800593659660599297, pipelineId=1, taskGroupId=1} 2024-01-19 00:13:27,259 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [server1]:5801 [seatunnel-525719] [5.1] Task TaskGroupLocation{jobId=800593659660599297, pipelineId=1, taskGroupId=1} complete with state FINISHED 2024-01-19 00:13:27,259 INFO org.apache.seatunnel.engine.server.CoordinatorService - [server1]:5801 [seatunnel-525719] [5.1] Received task end from execution TaskGroupLocation{jobId=800593659660599297, pipelineId=1, taskGroupId=1}, state FINISHED 2024-01-19 00:13:27,262 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job read-hive-jdbc (800593659660599297), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-demo]-SplitEnumerator (1/1)] turn to end state FINISHED. 2024-01-19 00:13:27,262 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job read-hive-jdbc (800593659660599297), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-demo]-SplitEnumerator (1/1)] end with state FINISHED 2024-01-19 00:13:27,283 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [server1]:5801 [seatunnel-525719] [5.1] taskDone, taskId = 50001, taskGroup = TaskGroupLocation{jobId=800593659660599297, pipelineId=1, taskGroupId=30001} 2024-01-19 00:13:27,283 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [server1]:5801 [seatunnel-525719] [5.1] taskDone, taskId = 50000, taskGroup = TaskGroupLocation{jobId=800593659660599297, pipelineId=1, taskGroupId=30000} 2024-01-19 00:13:27,325 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [server1]:5801 [seatunnel-525719] [5.1] taskDone, taskId = 40001, taskGroup = TaskGroupLocation{jobId=800593659660599297, pipelineId=1, taskGroupId=30001} 2024-01-19 00:13:27,326 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [server1]:5801 [seatunnel-525719] [5.1] Task TaskGroupLocation{jobId=800593659660599297, pipelineId=1, taskGroupId=30001} complete with state FINISHED 2024-01-19 00:13:27,326 INFO org.apache.seatunnel.engine.server.CoordinatorService - [server1]:5801 [seatunnel-525719] [5.1] Received task end from execution TaskGroupLocation{jobId=800593659660599297, pipelineId=1, taskGroupId=30001}, state FINISHED 2024-01-19 00:13:27,327 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job read-hive-jdbc (800593659660599297), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-demo]-SourceTask (2/2)] turn to end state FINISHED. 2024-01-19 00:13:27,328 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job read-hive-jdbc (800593659660599297), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-demo]-SourceTask (2/2)] end with state FINISHED 2024-01-19 00:13:27,336 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [server1]:5801 [seatunnel-525719] [5.1] taskDone, taskId = 40000, taskGroup = TaskGroupLocation{jobId=800593659660599297, pipelineId=1, taskGroupId=30000} 2024-01-19 00:13:27,336 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [server1]:5801 [seatunnel-525719] [5.1] Task TaskGroupLocation{jobId=800593659660599297, pipelineId=1, taskGroupId=30000} complete with state FINISHED 2024-01-19 00:13:27,337 INFO org.apache.seatunnel.engine.server.CoordinatorService - [server1]:5801 [seatunnel-525719] [5.1] Received task end from execution TaskGroupLocation{jobId=800593659660599297, pipelineId=1, taskGroupId=30000}, state FINISHED 2024-01-19 00:13:27,337 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job read-hive-jdbc (800593659660599297), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-demo]-SourceTask (1/2)] turn to end state FINISHED. 2024-01-19 00:13:27,338 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job read-hive-jdbc (800593659660599297), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-demo]-SourceTask (1/2)] end with state FINISHED 2024-01-19 00:13:27,338 INFO org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job read-hive-jdbc (800593659660599297), Pipeline: [(1/1)] end with state FINISHED 2024-01-19 00:13:27,371 INFO org.apache.seatunnel.engine.server.master.JobMaster - release the pipeline Job read-hive-jdbc (800593659660599297), Pipeline: [(1/1)] resource 2024-01-19 00:13:27,372 INFO org.apache.seatunnel.engine.server.service.slot.DefaultSlotService - received slot release request, jobID: 800593659660599297, slot: SlotProfile{worker=[server1]:5801, slotID=2, ownerJobID=800593659660599297, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='4b43f996-446e-45ca-804c-6364c23ee367'} 2024-01-19 00:13:27,373 INFO org.apache.seatunnel.engine.server.service.slot.DefaultSlotService - received slot release request, jobID: 800593659660599297, slot: SlotProfile{worker=[server1]:5801, slotID=3, ownerJobID=800593659660599297, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='4b43f996-446e-45ca-804c-6364c23ee367'} 2024-01-19 00:13:27,373 INFO org.apache.seatunnel.engine.server.service.slot.DefaultSlotService - received slot release request, jobID: 800593659660599297, slot: SlotProfile{worker=[server1]:5801, slotID=1, ownerJobID=800593659660599297, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='4b43f996-446e-45ca-804c-6364c23ee367'} 2024-01-19 00:13:27,377 INFO org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job read-hive-jdbc (800593659660599297), Pipeline: [(1/1)] turn to end state FINISHED. 2024-01-19 00:13:27,395 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan - Job read-hive-jdbc (800593659660599297) end with state FINISHED 2024-01-19 00:13:27,417 INFO org.apache.seatunnel.engine.client.job.ClientJobProxy - Job (800593659660599297) end with state FINISHED 2024-01-19 00:13:27,456 INFO org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand - *********************************************** Job Statistic Information *********************************************** Start Time : 2024-01-19 00:13:22 End Time : 2024-01-19 00:13:27 Total Time(s) : 4 Total Read Count : 14 Total Write Count : 14 Total Failed Count : 0 *********************************************** 2024-01-19 00:13:27,457 INFO com.hazelcast.core.LifecycleService - hz.client_1 [seatunnel-525719] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is SHUTTING_DOWN 2024-01-19 00:13:27,460 INFO com.hazelcast.internal.server.tcp.TcpServerConnection - [server1]:5801 [seatunnel-525719] [5.1] Connection[id=1, /192.168.0.148:5801->/192.168.0.148:40030, qualifier=null, endpoint=[192.168.0.148]:40030, remoteUuid=0471965d-16e8-45b3-9b20-1f34218a98e6, alive=false, connectionType=JVM, planeIndex=-1] closed. Reason: Connection closed by the other side 2024-01-19 00:13:27,461 INFO com.hazelcast.client.impl.connection.ClientConnectionManager - hz.client_1 [seatunnel-525719] [5.1] Removed connection to endpoint: [server1]:5801:0426eeda-157e-4566-8055-64500c975abb, connection: ClientConnection{alive=false, connectionId=1, channel=NioChannel{/192.168.0.148:40030->server1/192.168.0.148:5801}, remoteAddress=[server1]:5801, lastReadTime=2024-01-19 00:13:27.453, lastWriteTime=2024-01-19 00:13:27.417, closedTime=2024-01-19 00:13:27.458, connected server version=5.1} 2024-01-19 00:13:27,461 INFO com.hazelcast.core.LifecycleService - hz.client_1 [seatunnel-525719] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is CLIENT_DISCONNECTED 2024-01-19 00:13:27,462 INFO com.hazelcast.client.impl.ClientEndpointManager - [server1]:5801 [seatunnel-525719] [5.1] Destroying ClientEndpoint{connection=Connection[id=1, /192.168.0.148:5801->/192.168.0.148:40030, qualifier=null, endpoint=[192.168.0.148]:40030, remoteUuid=0471965d-16e8-45b3-9b20-1f34218a98e6, alive=false, connectionType=JVM, planeIndex=-1], clientUuid=0471965d-16e8-45b3-9b20-1f34218a98e6, clientName=hz.client_1, authenticated=true, clientVersion=5.1, creationTime=1705641202543, latest clientAttributes=lastStatisticsCollectionTime=1705641202584,enterprise=false,clientType=JVM,clientVersion=5.1,clusterConnectionTimestamp=1705641202531,clientAddress=192.168.0.148,clientName=hz.client_1,credentials.principal=null,os.committedVirtualMemorySize=11465359360,os.freePhysicalMemorySize=339169280,os.freeSwapSpaceSize=7564857344,os.maxFileDescriptorCount=65536,os.openFileDescriptorCount=108,os.processCpuTime=10860000000,os.systemLoadAverage=0.95,os.totalPhysicalMemorySize= 16542617600,os.totalSwapSpaceSize=8388603904,runtime.availableProcessors=16,runtime.freeMemory=973575440,runtime.maxMemory=1029177344,runtime.totalMemory=1029177344,runtime.uptime=3784,runtime.usedMemory=55601904, labels=[]} 2024-01-19 00:13:27,464 INFO com.hazelcast.core.LifecycleService - hz.client_1 [seatunnel-525719] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is SHUTDOWN 2024-01-19 00:13:27,464 INFO org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand - Closed SeaTunnel client...... 2024-01-19 00:13:27,464 INFO com.hazelcast.core.LifecycleService - [server1]:5801 [seatunnel-525719] [5.1] [server1]:5801 is SHUTTING_DOWN 2024-01-19 00:13:27,468 INFO com.hazelcast.internal.partition.impl.MigrationManager - [server1]:5801 [seatunnel-525719] [5.1] Shutdown request of Member [server1]:5801 - 0426eeda-157e-4566-8055-64500c975abb this is handled 2024-01-19 00:13:27,474 INFO com.hazelcast.instance.impl.Node - [server1]:5801 [seatunnel-525719] [5.1] Shutting down connection manager... 2024-01-19 00:13:27,476 INFO com.hazelcast.instance.impl.Node - [server1]:5801 [seatunnel-525719] [5.1] Shutting down node engine... 2024-01-19 00:13:27,831 INFO com.hazelcast.instance.impl.NodeExtension - [server1]:5801 [seatunnel-525719] [5.1] Destroying node NodeExtension. 2024-01-19 00:13:27,831 INFO com.hazelcast.instance.impl.Node - [server1]:5801 [seatunnel-525719] [5.1] Hazelcast Shutdown is completed in 364 ms. 2024-01-19 00:13:27,832 INFO com.hazelcast.core.LifecycleService - [server1]:5801 [seatunnel-525719] [5.1] [server1]:5801 is SHUTDOWN 2024-01-19 00:13:27,832 INFO org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand - Closed HazelcastInstance ...... 2024-01-19 00:13:27,832 INFO org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand - Closed metrics executor service ...... 2024-01-19 00:13:27,834 INFO org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand - run shutdown hook because get close signal ``` ### Zeta or Flink or Spark Version _No response_ ### Java or Scala Version openjdk version "1.8.0_392" OpenJDK Runtime Environment (build 1.8.0_392-b08) OpenJDK 64-Bit Server VM (build 25.392-b08, mixed mode) ### Screenshots    ### 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]
