Jetiaime opened a new issue, #9155: URL: https://github.com/apache/seatunnel/issues/9155
### 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 的配置： ```hocon env { parallelism = 1 job.mode = "BATCH" } source { Hivesource { table_name = "default.test_table" metastore_uri = "thrift://host116:9083" plugin_output = hive_source } } sink { Console { plugin_input = hive_source } } ``` 但是运行的时候报错： ```java 2025-04-11 16:08:57,437 INFO [c.h.i.c.AbstractConfigLocator ] [main] - Loading configuration '/wdp_data1/apache-seatunnel-2.3.10/config/seatunnel.yaml' from System property 'seatunnel.config' 2025-04-11 16:08:57,442 INFO [c.h.i.c.AbstractConfigLocator ] [main] - Using configuration file at /wdp_data1/apache-seatunnel-2.3.10/config/seatunnel.yaml 2025-04-11 16:08:57,445 INFO [o.a.s.e.c.c.SeaTunnelConfig ] [main] - seatunnel.home is /wdp_data1/apache-seatunnel-2.3.10 2025-04-11 16:08:57,576 WARN [amlSeaTunnelDomConfigProcessor] [main] - Unrecognized element: log 2025-04-11 16:08:57,576 INFO [amlSeaTunnelDomConfigProcessor] [main] - Dynamic slot is enabled, the schedule strategy is set to REJECT 2025-04-11 16:08:57,577 INFO [c.h.i.c.AbstractConfigLocator ] [main] - Loading configuration '/wdp_data1/apache-seatunnel-2.3.10/config/hazelcast.yaml' from System property 'hazelcast.config' 2025-04-11 16:08:57,577 INFO [c.h.i.c.AbstractConfigLocator ] [main] - Using configuration file at /wdp_data1/apache-seatunnel-2.3.10/config/hazelcast.yaml 2025-04-11 16:08:58,051 INFO [c.h.i.c.AbstractConfigLocator ] [main] - Loading configuration '/wdp_data1/apache-seatunnel-2.3.10/config/hazelcast-client.yaml' from System property 'hazelcast.client.config' 2025-04-11 16:08:58,051 INFO [c.h.i.c.AbstractConfigLocator ] [main] - Using configuration file at /wdp_data1/apache-seatunnel-2.3.10/config/hazelcast-client.yaml 2025-04-11 16:08:58,118 WARN [c.h.i.AddressPicker ] [main] - [LOCAL] [seatunnel-661079] [5.1] You configured your member address as host name. Please be aware of that your dns can be spoofed. Make sure that your dns configurations are correct. 2025-04-11 16:08:58,118 INFO [c.h.i.AddressPicker ] [main] - [LOCAL] [seatunnel-661079] [5.1] Resolving domain name 'localhost' to address(es): [127.0.0.1, 0:0:0:0:0:0:0:1] 2025-04-11 16:08:58,119 INFO [c.h.i.AddressPicker ] [main] - [LOCAL] [seatunnel-661079] [5.1] Interfaces is disabled, trying to pick one address from TCP-IP config addresses: [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] 2025-04-11 16:08:58,145 INFO [o.a.s.e.s.SeaTunnelServer ] [main] - SeaTunnel server start... 2025-04-11 16:08:58,149 INFO [c.h.system ] [main] - [localhost]:5801 [seatunnel-661079] [5.1] Based on Hazelcast IMDG version: 5.1.0 (20220228 - 21f20e7) 2025-04-11 16:08:58,149 INFO [c.h.system ] [main] - [localhost]:5801 [seatunnel-661079] [5.1] Cluster name: seatunnel-661079 2025-04-11 16:08:58,149 INFO [c.h.system ] [main] - [localhost]:5801 [seatunnel-661079] [5.1] _____ _____ _ / ___| |_ _| | | \ `--. ___ __ _ | | _ _ _ __ _ __ ___ | | `--. \ / _ \ / _` | | | | | | || '_ \ | '_ \ / _ \| | /\__/ /| __/| (_| | | | | |_| || | | || | | || __/| | \____/ \___| \__,_| \_/ \__,_||_| |_||_| |_| \___||_| 2025-04-11 16:08:58,149 INFO [c.h.system ] [main] - [localhost]:5801 [seatunnel-661079] [5.1] Copyright © 2021-2024 The Apache Software Foundation. Apache SeaTunnel, SeaTunnel, and its feather logo are trademarks of The Apache Software Foundation. 2025-04-11 16:08:58,149 INFO [c.h.system ] [main] - [localhost]:5801 [seatunnel-661079] [5.1] Integrity Checker is disabled. Fail-fast on corrupted executables will not be performed. To enable integrity checker do one of the following: - Change member config using Java API: config.setIntegrityCheckerEnabled(true); - Change XML/YAML configuration property: Set hazelcast.integrity-checker.enabled to true - Add system property: -Dhz.integritychecker.enabled=true (for Hazelcast embedded, works only when loading config via Config.load) - Add environment variable: HZ_INTEGRITYCHECKER_ENABLED=true (recommended when running container image. For Hazelcast embedded, works only when loading config via Config.load) 2025-04-11 16:08:58,152 INFO [c.h.system ] [main] - [localhost]:5801 [seatunnel-661079] [5.1] The Jet engine is disabled. To enable the Jet engine on the members, do one of the following: - Change member config using Java API: config.getJetConfig().setEnabled(true) - Change XML/YAML configuration property: Set hazelcast.jet.enabled to true - Add system property: -Dhz.jet.enabled=true (for Hazelcast embedded, works only when loading config via Config.load) - Add environment variable: HZ_JET_ENABLED=true (recommended when running container image. For Hazelcast embedded, works only when loading config via Config.load) 2025-04-11 16:08:58,655 INFO [c.h.s.security ] [main] - [localhost]:5801 [seatunnel-661079] [5.1] Enable DEBUG/FINE log level for log category com.hazelcast.system.security or use -Dhazelcast.security.recommendations system property to see 🔒 security recommendations and the status of current config. 2025-04-11 16:08:58,734 INFO [o.a.s.e.s.SeaTunnelNodeContext] [main] - Using LiteNodeDropOutTcpIpJoiner TCP/IP discovery 2025-04-11 16:08:58,736 WARN [c.h.c.CPSubsystem ] [main] - [localhost]:5801 [seatunnel-661079] [5.1] CP Subsystem is not enabled. CP data structures will operate in UNSAFE mode! Please note that UNSAFE mode will not provide strong consistency guarantees. 2025-04-11 16:08:58,907 INFO [.c.c.DefaultClassLoaderService] [main] - start classloader service with cache mode 2025-04-11 16:08:58,915 INFO [c.h.i.c.AbstractConfigLocator ] [main] - Loading configuration '/wdp_data1/apache-seatunnel-2.3.10/config/seatunnel.yaml' from System property 'seatunnel.config' 2025-04-11 16:08:58,916 INFO [c.h.i.c.AbstractConfigLocator ] [main] - Using configuration file at /wdp_data1/apache-seatunnel-2.3.10/config/seatunnel.yaml 2025-04-11 16:08:58,922 WARN [amlSeaTunnelDomConfigProcessor] [main] - Unrecognized element: log 2025-04-11 16:08:58,922 INFO [amlSeaTunnelDomConfigProcessor] [main] - Dynamic slot is enabled, the schedule strategy is set to REJECT 2025-04-11 16:08:58,922 INFO [c.h.i.c.AbstractConfigLocator ] [main] - Loading configuration '/wdp_data1/apache-seatunnel-2.3.10/config/hazelcast.yaml' from System property 'hazelcast.config' 2025-04-11 16:08:58,922 INFO [c.h.i.c.AbstractConfigLocator ] [main] - Using configuration file at /wdp_data1/apache-seatunnel-2.3.10/config/hazelcast.yaml 2025-04-11 16:08:58,934 WARN [o.a.s.e.s.TaskExecutionService] [pool-3-thread-1] - [localhost]:5801 [seatunnel-661079] [5.1] The Node is not ready yet, Node state STARTING,looking forward to the next scheduling 2025-04-11 16:08:58,935 INFO [o.a.s.e.s.TaskExecutionService] [main] - [localhost]:5801 [seatunnel-661079] [5.1] Created new BusWork : 1029148906 2025-04-11 16:08:58,947 WARN [a.s.e.s.s.s.DefaultSlotService] [hz.main.seaTunnel.slotService.thread] - failed send heartbeat to resource manager, will retry later. this address: [localhost]:5801 2025-04-11 16:08:58,949 INFO [o.a.s.e.s.CoordinatorService ] [main] - [localhost]:5801 [seatunnel-661079] [5.1] Start pending job schedule thread 2025-04-11 16:08:59,208 WARN [o.a.h.u.NativeCodeLoader ] [main] - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable 2025-04-11 16:08:59,368 INFO [o.a.s.e.s.CoordinatorService ] [pool-7-thread-1] - [localhost]:5801 [seatunnel-661079] [5.1] *********************************************** CoordinatorService Thread Pool Status *********************************************** activeCount : 1 corePoolSize : 10 maximumPoolSize : 2147483647 poolSize : 1 completedTaskCount : 0 taskCount : 1 *********************************************** 2025-04-11 16:08:59,375 INFO [o.a.s.e.s.JettyService ] [main] - SeaTunnel REST service will start on port 8080 2025-04-11 16:08:59,391 INFO [o.a.s.s.o.e.j.u.log ] [main] - Logging initialized @2679ms to org.apache.seatunnel.shade.org.eclipse.jetty.util.log.Slf4jLog 2025-04-11 16:08:59,465 WARN [a.s.s.o.e.j.s.h.ContextHandler] [main] - Empty contextPath 2025-04-11 16:08:59,487 INFO [o.a.s.s.o.e.j.s.Server ] [main] - jetty-9.4.56.v20240826; built: 2024-08-26T17:15:05.868Z; git: ec6782ff5ead824dabdcf47fa98f90a4aedff401; jvm 1.8.0_351-b10 2025-04-11 16:08:59,527 INFO [o.a.s.s.o.e.j.s.session ] [main] - DefaultSessionIdManager workerName=node0 2025-04-11 16:08:59,527 INFO [o.a.s.s.o.e.j.s.session ] [main] - No SessionScavenger set, using defaults 2025-04-11 16:08:59,529 INFO [o.a.s.s.o.e.j.s.session ] [main] - node0 Scavenging every 660000ms 2025-04-11 16:08:59,696 INFO [a.s.s.o.e.j.s.h.ContextHandler] [main] - Started o.a.s.s.o.e.j.s.ServletContextHandler@68b366e2{/,null,AVAILABLE} 2025-04-11 16:08:59,712 INFO [.s.s.o.e.j.s.AbstractConnector] [main] - Started ServerConnector@6abdec0e{HTTP/1.1, (http/1.1)}{0.0.0.0:8080} 2025-04-11 16:08:59,712 INFO [o.a.s.s.o.e.j.s.Server ] [main] - Started @3001ms 2025-04-11 16:08:59,761 INFO [c.h.i.d.Diagnostics ] [main] - [localhost]:5801 [seatunnel-661079] [5.1] Diagnostics disabled. To enable add -Dhazelcast.diagnostics.enabled=true to the JVM arguments. 2025-04-11 16:08:59,767 INFO [c.h.c.LifecycleService ] [main] - [localhost]:5801 [seatunnel-661079] [5.1] [localhost]:5801 is STARTING 2025-04-11 16:08:59,812 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-6] - [localhost]:5801 [seatunnel-661079] [5.1] [localhost]:5813 is added to the blacklist. 2025-04-11 16:08:59,812 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-2] - [localhost]:5801 [seatunnel-661079] [5.1] [localhost]:5821 is added to the blacklist. 2025-04-11 16:08:59,812 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-15] - [localhost]:5801 [seatunnel-661079] [5.1] [localhost]:5822 is added to the blacklist. 2025-04-11 16:08:59,812 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-16] - [localhost]:5801 [seatunnel-661079] [5.1] [localhost]:5820 is added to the blacklist. 2025-04-11 16:08:59,813 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-14] - [localhost]:5801 [seatunnel-661079] [5.1] [localhost]:5802 is added to the blacklist. 2025-04-11 16:08:59,813 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-12] - [localhost]:5801 [seatunnel-661079] [5.1] [localhost]:5808 is added to the blacklist. 2025-04-11 16:08:59,813 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-13] - [localhost]:5801 [seatunnel-661079] [5.1] [localhost]:5829 is added to the blacklist. 2025-04-11 16:08:59,813 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-10] - [localhost]:5801 [seatunnel-661079] [5.1] [localhost]:5804 is added to the blacklist. 2025-04-11 16:08:59,813 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-2] - [localhost]:5801 [seatunnel-661079] [5.1] [localhost]:5824 is added to the blacklist. 2025-04-11 16:08:59,813 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-14] - [localhost]:5801 [seatunnel-661079] [5.1] [localhost]:5812 is added to the blacklist. 2025-04-11 16:08:59,813 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-15] - [localhost]:5801 [seatunnel-661079] [5.1] [localhost]:5814 is added to the blacklist. 2025-04-11 16:08:59,812 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-5] - [localhost]:5801 [seatunnel-661079] [5.1] [localhost]:5815 is added to the blacklist. 2025-04-11 16:08:59,813 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-13] - [localhost]:5801 [seatunnel-661079] [5.1] [localhost]:5816 is added to the blacklist. 2025-04-11 16:08:59,813 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-2] - [localhost]:5801 [seatunnel-661079] [5.1] [localhost]:5805 is added to the blacklist. 2025-04-11 16:08:59,813 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-12] - [localhost]:5801 [seatunnel-661079] [5.1] [localhost]:5818 is added to the blacklist. 2025-04-11 16:08:59,813 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-10] - [localhost]:5801 [seatunnel-661079] [5.1] [localhost]:5807 is added to the blacklist. 2025-04-11 16:08:59,814 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-14] - [localhost]:5801 [seatunnel-661079] [5.1] [localhost]:5811 is added to the blacklist. 2025-04-11 16:08:59,813 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-8] - [localhost]:5801 [seatunnel-661079] [5.1] [localhost]:5817 is added to the blacklist. 2025-04-11 16:08:59,812 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-3] - [localhost]:5801 [seatunnel-661079] [5.1] [localhost]:5823 is added to the blacklist. 2025-04-11 16:08:59,814 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-15] - [localhost]:5801 [seatunnel-661079] [5.1] [localhost]:5809 is added to the blacklist. 2025-04-11 16:08:59,814 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-13] - [localhost]:5801 [seatunnel-661079] [5.1] [localhost]:5828 is added to the blacklist. 2025-04-11 16:08:59,813 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-11] - [localhost]:5801 [seatunnel-661079] [5.1] [localhost]:5810 is added to the blacklist. 2025-04-11 16:08:59,812 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-1] - [localhost]:5801 [seatunnel-661079] [5.1] [localhost]:5827 is added to the blacklist. 2025-04-11 16:08:59,813 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-4] - [localhost]:5801 [seatunnel-661079] [5.1] [localhost]:5825 is added to the blacklist. 2025-04-11 16:08:59,814 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-6] - [localhost]:5801 [seatunnel-661079] [5.1] [localhost]:5826 is added to the blacklist. 2025-04-11 16:08:59,814 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-5] - [localhost]:5801 [seatunnel-661079] [5.1] [localhost]:5830 is added to the blacklist. 2025-04-11 16:08:59,814 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-2] - [localhost]:5801 [seatunnel-661079] [5.1] [localhost]:5803 is added to the blacklist. 2025-04-11 16:08:59,812 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-7] - [localhost]:5801 [seatunnel-661079] [5.1] [localhost]:5819 is added to the blacklist. 2025-04-11 16:08:59,813 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-9] - [localhost]:5801 [seatunnel-661079] [5.1] [localhost]:5806 is added to the blacklist. 2025-04-11 16:09:00,814 INFO [c.h.i.c.ClusterService ] [main] - [localhost]:5801 [seatunnel-661079] [5.1] Members {size:1, ver:1} [ Member [localhost]:5801 - 168c715b-ad55-4575-a3c5-2a7a854776d0 [master node] [active master] this ] 2025-04-11 16:09:00,827 INFO [c.h.c.LifecycleService ] [main] - [localhost]:5801 [seatunnel-661079] [5.1] [localhost]:5801 is STARTED 2025-04-11 16:09:00,849 INFO [o.a.s.e.s.CoordinatorService ] [pool-5-thread-1] - [localhost]:5801 [seatunnel-661079] [5.1] This node become a new active master node, begin init coordinator service 2025-04-11 16:09:00,878 INFO [.c.i.s.ClientInvocationService] [main] - hz.client_1 [seatunnel-661079] [5.1] Running with 2 response threads, dynamic=true 2025-04-11 16:09:00,892 INFO [o.a.s.e.s.CoordinatorService ] [pool-5-thread-1] - [localhost]:5801 [seatunnel-661079] [5.1] Loaded event handlers: [org.apache.seatunnel.api.event.LoggingEventHandler@f747324] 2025-04-11 16:09:00,896 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel-661079] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is STARTING 2025-04-11 16:09:00,896 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel-661079] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is STARTED 2025-04-11 16:09:00,905 INFO [.c.i.c.ClientConnectionManager] [main] - hz.client_1 [seatunnel-661079] [5.1] Trying to connect to cluster: seatunnel-661079 2025-04-11 16:09:00,907 INFO [.c.i.c.ClientConnectionManager] [main] - hz.client_1 [seatunnel-661079] [5.1] Trying to connect to [localhost]:5801 2025-04-11 16:09:00,916 INFO [.h.i.p.i.PartitionStateManager] [seatunnel-coordinator-service-1] - [localhost]:5801 [seatunnel-661079] [5.1] Initializing cluster partition table arrangement... 2025-04-11 16:09:00,932 INFO [.p.t.AuthenticationMessageTask] [hz.main.priority-generic-operation.thread-0] - [localhost]:5801 [seatunnel-661079] [5.1] Received auth from Connection[id=1, /127.0.0.1:5801->/127.0.0.1:43062, qualifier=null, endpoint=[127.0.0.1]:43062, remoteUuid=2050336c-52f5-420f-939d-e01b752f9f6a, alive=true, connectionType=JVM, planeIndex=-1], successfully authenticated, clientUuid: 2050336c-52f5-420f-939d-e01b752f9f6a, client name: hz.client_1, client version: 5.1 2025-04-11 16:09:00,937 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel-661079] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is CLIENT_CONNECTED 2025-04-11 16:09:00,937 INFO [.c.i.c.ClientConnectionManager] [main] - hz.client_1 [seatunnel-661079] [5.1] Authenticated with server [localhost]:5801:168c715b-ad55-4575-a3c5-2a7a854776d0, server version: 5.1, local address: /127.0.0.1:43062 2025-04-11 16:09:00,939 INFO [c.h.i.d.Diagnostics ] [main] - hz.client_1 [seatunnel-661079] [5.1] Diagnostics disabled. To enable add -Dhazelcast.diagnostics.enabled=true to the JVM arguments. 2025-04-11 16:09:00,953 INFO [c.h.c.i.s.ClientClusterService] [hz.client_1.event-6] - hz.client_1 [seatunnel-661079] [5.1] Members [1] { Member [localhost]:5801 - 168c715b-ad55-4575-a3c5-2a7a854776d0 [master node] } 2025-04-11 16:09:00,986 INFO [.c.i.s.ClientStatisticsService] [main] - Client statistics is enabled with period 5 seconds. 2025-04-11 16:09:01,057 INFO [o.a.s.c.s.u.ConfigBuilder ] [main] - Loading config file from path: ./jobs/hive_single_table.conf 2025-04-11 16:09:01,181 INFO [o.a.s.c.s.u.ConfigShadeUtils ] [main] - Load config shade spi: [base64] 2025-04-11 16:09:01,231 INFO [o.a.s.c.s.u.ConfigBuilder ] [main] - Parsed config file: { "env" : { "parallelism" : 1, "job.mode" : "BATCH" }, "source" : [ { "table_name" : "default.test_table", "metastore_uri" : "thrift://host116:9083", "plugin_output" : "hive_source", "plugin_name" : "Hivesource" } ], "sink" : [ { "plugin_input" : "hive_source", "plugin_name" : "Console" } ] } 2025-04-11 16:09:01,241 INFO [p.MultipleTableJobConfigParser] [main] - add common jar in plugins :[] 2025-04-11 16:09:01,268 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load SeaTunnelSink Plugin from /wdp_data1/apache-seatunnel-2.3.10/connectors 2025-04-11 16:09:01,280 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load SeaTunnelSink Plugin from /wdp_data1/apache-seatunnel-2.3.10/connectors 2025-04-11 16:09:01,286 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load SeaTunnelSink Plugin from /wdp_data1/apache-seatunnel-2.3.10/connectors 2025-04-11 16:09:01,288 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Discovery plugin jar for: PluginIdentifier{engineType='seatunnel', pluginType='sink', pluginName='Console'} at: file:/wdp_data1/apache-seatunnel-2.3.10/connectors/connector-console-2.3.10.jar 2025-04-11 16:09:01,292 WARN [o.a.s.a.c.u.ConfigUtil ] [main] - Option 'plugin_input' is a List, and it is recommended to configure it as ["string1","string2"]; we will only use ',' to split the String into a list. 2025-04-11 16:09:01,293 INFO [p.MultipleTableJobConfigParser] [main] - start generating all sources. 2025-04-11 16:09:01,308 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load SeaTunnelSource Plugin from /wdp_data1/apache-seatunnel-2.3.10/connectors 2025-04-11 16:09:01,311 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel-661079] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is SHUTTING_DOWN 2025-04-11 16:09:01,315 INFO [c.h.i.s.t.TcpServerConnection ] [hz.main.IO.thread-in-1] - [localhost]:5801 [seatunnel-661079] [5.1] Connection[id=1, /127.0.0.1:5801->/127.0.0.1:43062, qualifier=null, endpoint=[127.0.0.1]:43062, remoteUuid=2050336c-52f5-420f-939d-e01b752f9f6a, alive=false, connectionType=JVM, planeIndex=-1] closed. Reason: Connection closed by the other side 2025-04-11 16:09:01,317 INFO [.c.i.c.ClientConnectionManager] [main] - hz.client_1 [seatunnel-661079] [5.1] Removed connection to endpoint: [localhost]:5801:168c715b-ad55-4575-a3c5-2a7a854776d0, connection: ClientConnection{alive=false, connectionId=1, channel=NioChannel{/127.0.0.1:43062->localhost/127.0.0.1:5801}, remoteAddress=[localhost]:5801, lastReadTime=2025-04-11 16:09:01.051, lastWriteTime=2025-04-11 16:09:01.048, closedTime=2025-04-11 16:09:01.313, connected server version=5.1} 2025-04-11 16:09:01,317 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel-661079] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is CLIENT_DISCONNECTED 2025-04-11 16:09:01,324 INFO [c.h.c.i.ClientEndpointManager ] [hz.main.event-3] - [localhost]:5801 [seatunnel-661079] [5.1] Destroying ClientEndpoint{connection=Connection[id=1, /127.0.0.1:5801->/127.0.0.1:43062, qualifier=null, endpoint=[127.0.0.1]:43062, remoteUuid=2050336c-52f5-420f-939d-e01b752f9f6a, alive=false, connectionType=JVM, planeIndex=-1], clientUuid=2050336c-52f5-420f-939d-e01b752f9f6a, clientName=hz.client_1, authenticated=true, clientVersion=5.1, creationTime=1744358940928, latest clientAttributes=lastStatisticsCollectionTime=1744358940984,enterprise=false,clientType=JVM,clientVersion=5.1,clusterConnectionTimestamp=1744358940909,clientAddress=127.0.0.1,clientName=hz.client_1,credentials.principal=null,os.committedVirtualMemorySize=17252737024,os.freePhysicalMemorySize=2767990784,os.freeSwapSpaceSize=8589930496,os.maxFileDescriptorCount=65536,os.openFileDescriptorCount=96,os.processCpuTime=12430000000,os.systemLoadAverage=2.63,os.totalPhysicalMemorySize=10119939686 4,os.totalSwapSpaceSize=8589930496,runtime.availableProcessors=32,runtime.freeMemory=211759320,runtime.maxMemory=477626368,runtime.totalMemory=324534272,runtime.uptime=4324,runtime.usedMemory=112774952, labels=[]} 2025-04-11 16:09:01,327 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel-661079] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is SHUTDOWN 2025-04-11 16:09:01,328 INFO [s.c.s.s.c.ClientExecuteCommand] [main] - Closed SeaTunnel client...... 2025-04-11 16:09:01,328 INFO [c.h.c.LifecycleService ] [main] - [localhost]:5801 [seatunnel-661079] [5.1] [localhost]:5801 is SHUTTING_DOWN 2025-04-11 16:09:01,333 INFO [c.h.i.p.i.MigrationManager ] [hz.main.cached.thread-14] - [localhost]:5801 [seatunnel-661079] [5.1] Shutdown request of Member [localhost]:5801 - 168c715b-ad55-4575-a3c5-2a7a854776d0 [master node] [active master] this is handled 2025-04-11 16:09:01,339 INFO [c.h.i.i.Node ] [main] - [localhost]:5801 [seatunnel-661079] [5.1] Shutting down connection manager... 2025-04-11 16:09:01,340 INFO [c.h.i.i.Node ] [main] - [localhost]:5801 [seatunnel-661079] [5.1] Shutting down node engine... 2025-04-11 16:09:01,349 INFO [o.a.s.e.s.CoordinatorService ] [pool-5-thread-1] - [localhost]:5801 [seatunnel-661079] [5.1] This node become leave active master node, begin clear coordinator service 2025-04-11 16:09:01,361 INFO [.s.s.o.e.j.s.AbstractConnector] [main] - Stopped ServerConnector@6abdec0e{HTTP/1.1, (http/1.1)}{0.0.0.0:8080} 2025-04-11 16:09:01,361 INFO [o.a.s.s.o.e.j.s.session ] [main] - node0 Stopped scavenging 2025-04-11 16:09:01,362 INFO [a.s.s.o.e.j.s.h.ContextHandler] [main] - Stopped o.a.s.s.o.e.j.s.ServletContextHandler@68b366e2{/,null,STOPPED} 2025-04-11 16:09:01,365 INFO [.c.c.DefaultClassLoaderService] [main] - close classloader service 2025-04-11 16:09:01,367 INFO [o.a.s.e.s.EventService ] [event-forwarder-0] - Event forward thread interrupted 2025-04-11 16:09:04,399 INFO [c.h.i.i.NodeExtension ] [main] - [localhost]:5801 [seatunnel-661079] [5.1] Destroying node NodeExtension. 2025-04-11 16:09:04,399 INFO [c.h.i.i.Node ] [main] - [localhost]:5801 [seatunnel-661079] [5.1] Hazelcast Shutdown is completed in 3067 ms. 2025-04-11 16:09:04,400 INFO [c.h.c.LifecycleService ] [main] - [localhost]:5801 [seatunnel-661079] [5.1] [localhost]:5801 is SHUTDOWN 2025-04-11 16:09:04,400 INFO [s.c.s.s.c.ClientExecuteCommand] [main] - Closed HazelcastInstance ...... 2025-04-11 16:09:04,400 ERROR [o.a.s.c.s.SeaTunnel ] [main] - =============================================================================== 2025-04-11 16:09:04,400 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Fatal Error, 2025-04-11 16:09:04,400 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Please submit bug report in https://github.com/apache/seatunnel/issues 2025-04-11 16:09:04,400 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Reason:SeaTunnel job executed failed 2025-04-11 16:09:04,402 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Exception StackTrace:org.apache.seatunnel.core.starter.exception.CommandExecuteException: SeaTunnel job executed failed at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:228) at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) at org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34) Caused by: org.apache.seatunnel.api.table.factory.FactoryException: ErrorCode:[API-06], ErrorDescription:[Factory initialize failed] - Unable to create a source for identifier 'Hivesource'. at org.apache.seatunnel.api.table.factory.FactoryUtil.restoreAndPrepareSource(FactoryUtil.java:168) at org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:86) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSource(MultipleTableJobConfigParser.java:376) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:227) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.getLogicalDag(ClientJobExecutionEnvironment.java:123) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.execute(ClientJobExecutionEnvironment.java:191) at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:165) ... 2 more Caused by: java.lang.RuntimeException: Plugin PluginIdentifier{engineType='seatunnel', pluginType='source', pluginName='Hivesource'} not found. at org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery.createPluginInstance(AbstractPluginDiscovery.java:242) at org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery.createPluginInstance(AbstractPluginDiscovery.java:182) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.lambda$parseSource$3(MultipleTableJobConfigParser.java:359) at org.apache.seatunnel.api.table.factory.FactoryUtil.restoreAndPrepareSource(FactoryUtil.java:113) ... 8 more 2025-04-11 16:09:04,403 ERROR [o.a.s.c.s.SeaTunnel ] [main] - =============================================================================== Exception in thread "main" org.apache.seatunnel.core.starter.exception.CommandExecuteException: SeaTunnel job executed failed at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:228) at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) at org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34) Caused by: org.apache.seatunnel.api.table.factory.FactoryException: ErrorCode:[API-06], ErrorDescription:[Factory initialize failed] - Unable to create a source for identifier 'Hivesource'. at org.apache.seatunnel.api.table.factory.FactoryUtil.restoreAndPrepareSource(FactoryUtil.java:168) at org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:86) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSource(MultipleTableJobConfigParser.java:376) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:227) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.getLogicalDag(ClientJobExecutionEnvironment.java:123) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.execute(ClientJobExecutionEnvironment.java:191) at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:165) ... 2 more Caused by: java.lang.RuntimeException: Plugin PluginIdentifier{engineType='seatunnel', pluginType='source', pluginName='Hivesource'} not found. at org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery.createPluginInstance(AbstractPluginDiscovery.java:242) at org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery.createPluginInstance(AbstractPluginDiscovery.java:182) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.lambda$parseSource$3(MultipleTableJobConfigParser.java:359) at org.apache.seatunnel.api.table.factory.FactoryUtil.restoreAndPrepareSource(FactoryUtil.java:113) ... 8 more ``` ### SeaTunnel Version 2.3.10 ### SeaTunnel Config ```conf seatunnel: engine: classloader-cache-mode: true history-job-expire-minutes: 1440 backup-count: 1 queue-type: blockingqueue print-execution-info-interval: 60 print-job-metrics-info-interval: 60 slot-service: dynamic-slot: true checkpoint: interval: 10000 timeout: 60000 storage: type: hdfs max-retained: 3 plugin-config: namespace: /tmp/seatunnel/checkpoint_snapshot storage.type: hdfs fs.defaultFS: file:///tmp/ # Ensure that the directory has written permission telemetry: metric: enabled: false log: scheduled-deletion-enable: true http: enable-http: true port: 8080 enable-dynamic-port: false ``` ### Running Command ```shell ./bin/seatunnel.sh --config ./jobs/hive_single_table.conf -m local ``` ### Error Exception ```log 2025-04-11 16:09:04,403 ERROR [o.a.s.c.s.SeaTunnel ] [main] - =============================================================================== Exception in thread "main" org.apache.seatunnel.core.starter.exception.CommandExecuteException: SeaTunnel job executed failed at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:228) at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) at org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34) Caused by: org.apache.seatunnel.api.table.factory.FactoryException: ErrorCode:[API-06], ErrorDescription:[Factory initialize failed] - Unable to create a source for identifier 'Hivesource'. at org.apache.seatunnel.api.table.factory.FactoryUtil.restoreAndPrepareSource(FactoryUtil.java:168) at org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:86) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSource(MultipleTableJobConfigParser.java:376) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:227) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.getLogicalDag(ClientJobExecutionEnvironment.java:123) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.execute(ClientJobExecutionEnvironment.java:191) at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:165) ... 2 more Caused by: java.lang.RuntimeException: Plugin PluginIdentifier{engineType='seatunnel', pluginType='source', pluginName='Hivesource'} not found. at org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery.createPluginInstance(AbstractPluginDiscovery.java:242) at org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery.createPluginInstance(AbstractPluginDiscovery.java:182) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.lambda$parseSource$3(MultipleTableJobConfigParser.java:359) at org.apache.seatunnel.api.table.factory.FactoryUtil.restoreAndPrepareSource(FactoryUtil.java:113) ... 8 more ``` ### Zeta or Flink or Spark Version Zeta ### Java or Scala Version 1.8 ### 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: commits-unsubscr...@seatunnel.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
