visiontk opened a new issue, #7498: URL: https://github.com/apache/seatunnel/issues/7498
### 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 SLF4J: Class path contains multiple SLF4J bindings. SLF4J: Found binding in [jar:file:/home/clickhouse/seatunnel/backend/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class] SLF4J: Found binding in [jar:file:/home/clickhouse/seatunnel/backend/starter/seatunnel-starter.jar!/org/slf4j/impl/StaticLoggerBinder.class] SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. SLF4J: Actual binding is of type [ch.qos.logback.classic.util.ContextSelectorStaticBinder] 09:37:52.036 [main] WARN org.apache.seatunnel.core.starter.seatunnel.args.ClientCommandArgs$MasterTypeValidator - ****************************************************************************************** -e and --deploy-mode deprecated in 2.3.1, please use -m and --master instead of it ****************************************************************************************** Aug 26, 2024 9:37:52 AM com.hazelcast.internal.config.AbstractConfigLocator INFO: Loading configuration '/home/clickhouse/seatunnel/backend/config/seatunnel.yaml' from System property 'seatunnel.config' Aug 26, 2024 9:37:52 AM com.hazelcast.internal.config.AbstractConfigLocator INFO: Using configuration file at /home/clickhouse/seatunnel/backend/config/seatunnel.yaml Aug 26, 2024 9:37:52 AM org.apache.seatunnel.engine.common.config.SeaTunnelConfig INFO: seatunnel.home is /home/clickhouse/seatunnel/backend Aug 26, 2024 9:37:52 AM com.hazelcast.internal.config.AbstractConfigLocator INFO: Loading configuration '/home/clickhouse/seatunnel/backend/config/hazelcast.yaml' from System property 'hazelcast.config' Aug 26, 2024 9:37:52 AM com.hazelcast.internal.config.AbstractConfigLocator INFO: Using configuration file at /home/clickhouse/seatunnel/backend/config/hazelcast.yaml Aug 26, 2024 9:37:52 AM com.hazelcast.instance.impl.HazelcastInstanceFactory WARNING: WARNING: Classpath misconfiguration: found multiple META-INF/services/com.hazelcast.instance.impl.NodeExtension resources: jar:file:/home/clickhouse/seatunnel/backend/lib/hazelcast-5.1.jar!/META-INF/services/com.hazelcast.instance.impl.NodeExtension, jar:file:/home/clickhouse/seatunnel/backend/starter/seatunnel-starter.jar!/META-INF/services/com.hazelcast.instance.impl.NodeExtension 09:37:52.545 [main] INFO com.hazelcast.instance.AddressPicker - [LOCAL] [seatunnel-996597] [5.1] Interfaces is disabled, trying to pick one address from TCP-IP config addresses: [127.0.0.1] 09:37:52.552 [main] DEBUG com.hazelcast.instance.AddressPicker - [LOCAL] [seatunnel-996597] [5.1] Trying to bind inet socket address: 0.0.0.0/0.0.0.0:5801 09:37:52.552 [main] DEBUG com.hazelcast.instance.AddressPicker - [LOCAL] [seatunnel-996597] [5.1] Trying to bind inet socket address: 0.0.0.0/0.0.0.0:5802 09:37:52.553 [main] DEBUG com.hazelcast.instance.AddressPicker - [LOCAL] [seatunnel-996597] [5.1] Bind successful to inet socket address: /0:0:0:0:0:0:0:0:5802 09:37:52.553 [main] DEBUG com.hazelcast.instance.AddressPicker - [LOCAL] [seatunnel-996597] [5.1] Picked [127.0.0.1]:5802, using socket ServerSocket[addr=/0:0:0:0:0:0:0:0,localport=5802], bind any local is true 09:37:52.567 [main] INFO org.apache.seatunnel.engine.server.SeaTunnelServer - SeaTunnel server start... 09:37:52.568 [main] INFO com.hazelcast.system - [127.0.0.1]:5802 [seatunnel-996597] [5.1] Based on Hazelcast IMDG version: 5.1.0 (20220228 - 21f20e7) 09:37:52.568 [main] INFO com.hazelcast.system - [127.0.0.1]:5802 [seatunnel-996597] [5.1] Cluster name: seatunnel-996597 09:37:52.568 [main] DEBUG com.hazelcast.system - [127.0.0.1]:5802 [seatunnel-996597] [5.1] Configured Hazelcast Serialization version: 1 09:37:52.568 [main] INFO com.hazelcast.system - [127.0.0.1]:5802 [seatunnel-996597] [5.1] _____ _____ _ / ___| |_ _| | | \ `--. ___ __ _ | | _ _ _ __ _ __ ___ | | `--. \ / _ \ / _` | | | | | | || '_ \ | '_ \ / _ \| | /\__/ /| __/| (_| | | | | |_| || | | || | | || __/| | \____/ \___| \__,_| \_/ \__,_||_| |_||_| |_| \___||_| 09:37:52.568 [main] INFO com.hazelcast.system - [127.0.0.1]:5802 [seatunnel-996597] [5.1] Copyright © 2021-2022 The Apache Software Foundation. Apache SeaTunnel, SeaTunnel, and its feather logo are trademarks of The Apache Software Foundation. 09:37:52.568 [main] INFO com.hazelcast.system - [127.0.0.1]:5802 [seatunnel-996597] [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) 09:37:52.570 [main] INFO com.hazelcast.system - [127.0.0.1]:5802 [seatunnel-996597] [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) 09:37:52.710 [main] DEBUG com.hazelcast.internal.util.ServiceLoader - The class com.hazelcast.jet.impl.metrics.JetMetricsDataSerializerHook does not implement the expected interface com.hazelcast.nio.serialization.SerializerHook 09:37:52.712 [main] DEBUG com.hazelcast.internal.util.ServiceLoader - The class com.hazelcast.jet.impl.observer.JetObserverDataSerializerHook does not implement the expected interface com.hazelcast.nio.serialization.SerializerHook 09:37:52.721 [main] DEBUG com.hazelcast.internal.util.ServiceLoader - The class com.hazelcast.jet.impl.metrics.JetMetricsDataSerializerHook does not implement the expected interface com.hazelcast.nio.serialization.SerializerHook 09:37:52.721 [main] DEBUG com.hazelcast.internal.util.ServiceLoader - The class com.hazelcast.jet.impl.observer.JetObserverDataSerializerHook does not implement the expected interface com.hazelcast.nio.serialization.SerializerHook 09:37:52.725 [main] DEBUG com.hazelcast.internal.metrics.impl.MetricsConfigHelper - [127.0.0.1]:5802 [seatunnel-996597] [5.1] Collecting debug metrics and sending to diagnostics is disabled 09:37:52.739 [main] DEBUG com.hazelcast.spi.impl.operationservice.impl.BackpressureRegulator - [127.0.0.1]:5802 [seatunnel-996597] [5.1] Backpressure is disabled 09:37:52.747 [main] DEBUG com.hazelcast.spi.impl.operationservice.impl.InboundResponseHandlerSupplier - [127.0.0.1]:5802 [seatunnel-996597] [5.1] Running with 2 response threads 09:37:52.791 [main] DEBUG com.hazelcast.internal.server.tcp.LocalAddressRegistry - [127.0.0.1]:5802 [seatunnel-996597] [5.1] LinkedAddresses{primaryAddress=[127.0.0.1]:5802, allLinkedAddresses=[[fe80:0:0:0:505b:72ff:fe31:e6f3%vethe79b9b5]:5802, [fe80:0:0:0:250:56ff:fe86:b1ef]:5802, [fe80:0:0:0:3c4a:3eff:fe9a:9e52]:5802, [fe80:0:0:0:3c4a:3eff:fe9a:9e52%veth890101e]:5802, [fe80:0:0:0:505b:72ff:fe31:e6f3]:5802, [10.8.101.8]:5802, [172.19.0.1]:5802, [127.0.0.1]:5802, [0:0:0:0:0:0:0:1%lo]:5802, [fe80:0:0:0:42:26ff:fef5:2b3d]:5802, [fe80:0:0:0:42:26ff:fef5:2b3d%br-4d760021032b]:5802, [fe80:0:0:0:42:ff:fe0d:e371]:5802, [fe80:0:0:0:250:56ff:fe86:b1ef%ens33]:5802, [fe80:0:0:0:3031:d3ff:fee0:1cd3%vethc95de89]:5802, [0:0:0:0:0:0:0:1]:5802, [fe80:0:0:0:4499:89ff:feef:4eab%vethc8e27ed]:5802, [172.17.0.1]:5802, [fe80:0:0:0:3031:d3ff:fee0:1cd3]:5802, [fe80:0:0:0:42:ff:fe0d:e371%docker0]:5802, [fe80:0:0:0:4499:89ff:feef:4eab]:5802]} are registered for the local member with local uuid=d66b5e63-1cb 7-4089-a1ed-c42644e760b5 09:37:52.945 [main] DEBUG com.hazelcast.system.security - [127.0.0.1]:5802 [seatunnel-996597] [5.1] 🔒 Security recommendations and their status: ✅ Use a custom cluster name ✅ Disable member multicast discovery/join method ⚠️ Use advanced networking, separate client and member sockets ⚠️ Bind Server sockets to a single network interface (disable hazelcast.socket.server.bind.any) ✅ Disable scripting in the Management Center ✅ Disable console in the Management Center ⚠️ Enable Security (Enterprise) ⚠️ Use TLS communication protection (Enterprise) ⚠️ Enable auditlog (Enterprise) Check the hazelcast-security-hardened.xml/yaml example config file to find why and how to configure these security related settings. 09:37:53.004 [main] INFO com.hazelcast.instance.impl.Node - [127.0.0.1]:5802 [seatunnel-996597] [5.1] Using TCP/IP discovery 09:37:53.005 [main] WARN com.hazelcast.cp.CPSubsystem - [127.0.0.1]:5802 [seatunnel-996597] [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. Aug 26, 2024 9:37:53 AM com.hazelcast.internal.config.AbstractConfigLocator INFO: Loading configuration '/home/clickhouse/seatunnel/backend/config/seatunnel.yaml' from System property 'seatunnel.config' Aug 26, 2024 9:37:53 AM com.hazelcast.internal.config.AbstractConfigLocator INFO: Using configuration file at /home/clickhouse/seatunnel/backend/config/seatunnel.yaml Aug 26, 2024 9:37:53 AM com.hazelcast.internal.config.AbstractConfigLocator INFO: Loading configuration '/home/clickhouse/seatunnel/backend/config/hazelcast.yaml' from System property 'hazelcast.config' Aug 26, 2024 9:37:53 AM com.hazelcast.internal.config.AbstractConfigLocator INFO: Using configuration file at /home/clickhouse/seatunnel/backend/config/hazelcast.yaml 09:37:53.165 [main] INFO org.apache.seatunnel.engine.server.TaskExecutionService - [127.0.0.1]:5802 [seatunnel-996597] [5.1] Created new BusWork : 1491676195 09:37:53.165 [pool-2-thread-1] WARN org.apache.seatunnel.engine.server.TaskExecutionService - [127.0.0.1]:5802 [seatunnel-996597] [5.1] The Node is not ready yet, Node state STARTING,looking forward to the next scheduling 09:37:53.174 [hz.main.seaTunnel.slotService.thread] DEBUG org.apache.seatunnel.engine.server.service.slot.DefaultSlotService - start send heartbeat to resource manager, this address: [127.0.0.1]:5802 09:37:53.178 [hz.main.seaTunnel.slotService.thread] WARN org.apache.seatunnel.engine.server.service.slot.DefaultSlotService - failed send heartbeat to resource manager, will retry later. this address: [127.0.0.1]:5802 09:37:53.178 [pool-5-thread-1] INFO org.apache.seatunnel.engine.server.CoordinatorService - [127.0.0.1]:5802 [seatunnel-996597] [5.1] *********************************************** CoordinatorService Thread Pool Status *********************************************** activeCount : 0 corePoolSize : 0 maximumPoolSize : 2147483647 poolSize : 0 completedTaskCount : 0 taskCount : 0 *********************************************** 09:37:53.182 [pool-4-thread-1] DEBUG org.apache.seatunnel.common.utils.RetryUtils - Failed to execute due to java.lang.NullPointerException at org.apache.seatunnel.engine.server.SeaTunnelServer.lambda$isMasterNode$0(SeaTunnelServer.java:236) at org.apache.seatunnel.common.utils.RetryUtils.retryWithException(RetryUtils.java:48) at org.apache.seatunnel.engine.server.SeaTunnelServer.isMasterNode(SeaTunnelServer.java:235) at org.apache.seatunnel.engine.server.CoordinatorService.checkNewActiveMaster(CoordinatorService.java:369) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:750) . Retrying attempt (1/30) after backoff of 2000 ms 09:37:53.215 [main] DEBUG com.hazelcast.internal.metrics.impl.MetricsService - [127.0.0.1]:5802 [seatunnel-996597] [5.1] Configuring metrics collection, collection interval=5 seconds, retention=5 seconds, publishers=[Management Center Publisher, JMX Publisher] 09:37:53.232 [main] DEBUG com.hazelcast.spi.impl.operationexecutor.impl.OperationExecutorImpl - [127.0.0.1]:5802 [seatunnel-996597] [5.1] Starting 20 partition threads and 51 generic threads (1 dedicated for priority tasks) 09:37:53.244 [main] DEBUG com.hazelcast.sql.impl.SqlServiceImpl - [127.0.0.1]:5802 [seatunnel-996597] [5.1] Optimizer class "com.hazelcast.jet.sql.impl.CalciteSqlOptimizer" not found, falling back to com.hazelcast.sql.impl.optimizer.DisabledSqlOptimizer 09:37:53.250 [main] INFO com.hazelcast.internal.diagnostics.Diagnostics - [127.0.0.1]:5802 [seatunnel-996597] [5.1] Diagnostics disabled. To enable add -Dhazelcast.diagnostics.enabled=true to the JVM arguments. 09:37:53.258 [main] INFO com.hazelcast.core.LifecycleService - [127.0.0.1]:5802 [seatunnel-996597] [5.1] [127.0.0.1]:5802 is STARTING 09:37:53.259 [main] DEBUG com.hazelcast.internal.partition.InternalPartitionService - [127.0.0.1]:5802 [seatunnel-996597] [5.1] Adding Member [127.0.0.1]:5802 - d66b5e63-1cb7-4089-a1ed-c42644e760b5 this 09:37:53.267 [main] DEBUG com.hazelcast.internal.networking.nio.NioNetworking - [127.0.0.1]:5802 [seatunnel-996597] [5.1] TcpIpConnectionManager configured with Non Blocking IO-threading model: 4 input threads and 4 output threads 09:37:53.267 [main] DEBUG com.hazelcast.internal.networking.nio.NioNetworking - [127.0.0.1]:5802 [seatunnel-996597] [5.1] write through enabled:true 09:37:53.267 [main] DEBUG com.hazelcast.internal.networking.nio.NioNetworking - [127.0.0.1]:5802 [seatunnel-996597] [5.1] IO threads selector mode is SELECT 09:37:53.278 [main] DEBUG com.hazelcast.internal.cluster.ClusterService - [127.0.0.1]:5802 [seatunnel-996597] [5.1] Setting master address to null 09:37:53.279 [main] DEBUG com.hazelcast.internal.cluster.impl.TcpIpJoiner - [127.0.0.1]:5802 [seatunnel-996597] [5.1] [127.0.0.1]:5801 is local? false 09:37:53.281 [main] DEBUG com.hazelcast.internal.cluster.impl.TcpIpJoiner - [127.0.0.1]:5802 [seatunnel-996597] [5.1] NOT sending master question to blacklisted endpoints: {} 09:37:53.281 [main] DEBUG com.hazelcast.internal.cluster.impl.TcpIpJoiner - [127.0.0.1]:5802 [seatunnel-996597] [5.1] Sending master question to [127.0.0.1]:5814 09:37:53.287 [main] DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [127.0.0.1]:5802 [seatunnel-996597] [5.1] Connection to: [127.0.0.1]:5814 streamId:-1 is not yet in progress 09:37:53.297 [hz.main.cached.thread-7] INFO com.hazelcast.internal.cluster.impl.TcpIpJoiner - [127.0.0.1]:5802 [seatunnel-996597] [5.1] [127.0.0.1]:5810 is added to the blacklist. 09:37:53.299 [hz.main.cached.thread-15] DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [127.0.0.1]:5802 [seatunnel-996597] [5.1] Established socket connection between /127.0.0.1:47379 and /127.0.0.1:5801 09:37:53.304 [hz.main.IO.thread-in-3] INFO com.hazelcast.internal.server.tcp.TcpServerConnection - [127.0.0.1]:5802 [seatunnel-996597] [5.1] Initialized new cluster connection between /127.0.0.1:47379 and /127.0.0.1:5801 09:37:53.388 [hz.main.TcpServer.thread-1] DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [127.0.0.1]:5802 [seatunnel-996597] [5.1] Connection to: [127.0.0.1]:5814 streamId:-1 is not yet in progress 09:37:53.397 [hz.main.priority-generic-operation.thread-0] INFO com.hazelcast.internal.server.tcp.TcpServerConnection - [127.0.0.1]:5802 [seatunnel-996597] [5.1] Connection[id=1, /127.0.0.1:47379->/127.0.0.1:5801, qualifier=null, endpoint=[127.0.0.1]:5801, remoteUuid=7517603b-05e5-4f43-adde-fbd3ca56cc8d, alive=false, connectionType=MEMBER, planeIndex=0] closed. Reason: Node could not join cluster at node: [127.0.0.1]:5801 Cause: the target cluster has a different cluster-name 09:37:53.398 [hz.main.priority-generic-operation.thread-0] DEBUG com.hazelcast.internal.server.tcp.LocalAddressRegistry - [127.0.0.1]:5802 [seatunnel-996597] [5.1] LinkedAddresses{primaryAddress=[127.0.0.1]:5801, allLinkedAddresses=[[127.0.0.1]:5801]} previously registered for the instance uuid=7517603b-05e5-4f43-adde-fbd3ca56cc8d are removed from the registry 09:37:53.399 [hz.main.priority-generic-operation.thread-0] WARN com.hazelcast.cluster - [127.0.0.1]:5802 [seatunnel-996597] [5.1] Node could not join cluster at node: [127.0.0.1]:5801 Cause: the target cluster has a different cluster-name 09:37:53.399 [hz.main.event-2] DEBUG com.hazelcast.internal.cluster.ClusterService - [127.0.0.1]:5802 [seatunnel-996597] [5.1] Removed connection to [127.0.0.1]:5801 09:37:53.399 [hz.main.priority-generic-operation.thread-0] INFO com.hazelcast.internal.cluster.impl.TcpIpJoiner - [127.0.0.1]:5802 [seatunnel-996597] [5.1] [127.0.0.1]:5801 is permanently added to the blacklist. 09:37:54.298 [main] DEBUG com.hazelcast.internal.cluster.impl.TcpIpJoiner - [127.0.0.1]:5802 [seatunnel-996597] [5.1] [127.0.0.1]:5814 is local? false 09:37:54.298 [main] DEBUG com.hazelcast.internal.cluster.impl.TcpIpJoiner - [127.0.0.1]:5802 [seatunnel-996597] [5.1] [127.0.0.1]:5816 is local? false 09:37:54.298 [hz.main.TcpServer.thread-3] DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [127.0.0.1]:5802 [seatunnel-996597] [5.1] Connection to: [127.0.0.1]:5828 streamId:-1 is not yet in progress 09:37:54.298 [main] DEBUG com.hazelcast.internal.cluster.impl.TcpIpJoiner - [127.0.0.1]:5802 [seatunnel-996597] [5.1] [127.0.0.1]:5818 is local? false 09:37:54.301 [main] DEBUG com.hazelcast.internal.cluster.impl.TcpIpJoiner - [127.0.0.1]:5802 [seatunnel-996597] [5.1] This node will assume master role since none of the possible members accepted join request. 09:37:54.301 [main] DEBUG com.hazelcast.internal.cluster.ClusterService - [127.0.0.1]:5802 [seatunnel-996597] [5.1] Setting master address to [127.0.0.1]:5802 09:37:54.301 [main] DEBUG com.hazelcast.internal.cluster.impl.MembershipManager - [127.0.0.1]:5802 [seatunnel-996597] [5.1] Local member list join version is set to 1 09:37:54.301 [main] DEBUG com.hazelcast.internal.cluster.impl.TcpIpJoiner - [127.0.0.1]:5802 [seatunnel-996597] [5.1] PostJoin master: [127.0.0.1]:5802, isMaster: true 09:37:54.301 [main] INFO com.hazelcast.internal.cluster.ClusterService - [127.0.0.1]:5802 [seatunnel-996597] [5.1] Members {size:1, ver:1} [ Member [127.0.0.1]:5802 - d66b5e63-1cb7-4089-a1ed-c42644e760b5 this ] 09:37:54.301 [main] WARN com.hazelcast.instance.impl.Node - [127.0.0.1]:5802 [seatunnel-996597] [5.1] Config seed port is 5801 and cluster size is 1. Some of the ports seem occupied! 09:37:54.312 [main] INFO com.hazelcast.core.LifecycleService - [127.0.0.1]:5802 [seatunnel-996597] [5.1] [127.0.0.1]:5802 is STARTED Aug 26, 2024 9:37:54 AM com.hazelcast.internal.config.AbstractConfigLocator INFO: Loading configuration '/home/clickhouse/seatunnel/backend/config/hazelcast-client.yaml' from System property 'hazelcast.client.config' Aug 26, 2024 9:37:54 AM com.hazelcast.internal.config.AbstractConfigLocator INFO: Using configuration file at /home/clickhouse/seatunnel/backend/config/hazelcast-client.yaml 09:37:54.336 [main] DEBUG com.hazelcast.internal.metrics.impl.MetricsConfigHelper - hz.client_1 [seatunnel-996597] [5.1] Collecting debug metrics and sending to diagnostics is disabled 09:37:54.339 [main] DEBUG com.hazelcast.internal.util.ServiceLoader - The class com.hazelcast.jet.impl.metrics.JetMetricsDataSerializerHook does not implement the expected interface com.hazelcast.nio.serialization.SerializerHook 09:37:54.339 [main] DEBUG com.hazelcast.internal.util.ServiceLoader - The class com.hazelcast.jet.impl.observer.JetObserverDataSerializerHook does not implement the expected interface com.hazelcast.nio.serialization.SerializerHook 09:37:54.349 [main] INFO com.hazelcast.client.impl.spi.ClientInvocationService - hz.client_1 [seatunnel-996597] [5.1] Running with 2 response threads, dynamic=true 09:37:54.357 [main] INFO com.hazelcast.core.LifecycleService - hz.client_1 [seatunnel-996597] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is STARTING 09:37:54.358 [main] INFO com.hazelcast.core.LifecycleService - hz.client_1 [seatunnel-996597] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is STARTED 09:37:54.360 [main] DEBUG com.hazelcast.internal.networking.nio.NioNetworking - hz.client_1 [seatunnel-996597] [5.1] TcpIpConnectionManager configured with Non Blocking IO-threading model: 1 input threads and 1 output threads 09:37:54.360 [main] DEBUG com.hazelcast.internal.networking.nio.NioNetworking - hz.client_1 [seatunnel-996597] [5.1] write through enabled:true 09:37:54.360 [main] DEBUG com.hazelcast.internal.networking.nio.NioNetworking - hz.client_1 [seatunnel-996597] [5.1] IO threads selector mode is SELECT 09:37:54.362 [main] INFO com.hazelcast.client.impl.connection.ClientConnectionManager - hz.client_1 [seatunnel-996597] [5.1] Trying to connect to cluster: seatunnel-996597 09:37:54.363 [main] INFO com.hazelcast.client.impl.connection.ClientConnectionManager - hz.client_1 [seatunnel-996597] [5.1] Trying to connect to [127.0.0.1]:5801 09:37:54.371 [main] WARN com.hazelcast.client.impl.connection.tcp.TcpClientConnection - hz.client_1 [seatunnel-996597] [5.1] ClientConnection{alive=false, connectionId=1, channel=NioChannel{/127.0.0.1:52525->/127.0.0.1:5801}, remoteAddress=null, lastReadTime=2024-08-26 09:37:54.369, lastWriteTime=2024-08-26 09:37:54.368, closedTime=2024-08-26 09:37:54.370, connected server version=null} closed. Reason: Failed to authenticate connection com.hazelcast.client.AuthenticationException: Authentication failed. The configured cluster name on the client (see ClientConfig.setClusterName()) does not match the one configured in the cluster or the credentials set in the Client security config could not be authenticated at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.checkAuthenticationResponse(TcpClientConnectionManager.java:995) at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.onAuthenticated(TcpClientConnectionManager.java:898) at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.getOrConnectToAddress(TcpClientConnectionManager.java:615) at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.lambda$doConnectToCandidateCluster$3(TcpClientConnectionManager.java:505) at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.connect(TcpClientConnectionManager.java:459) at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.doConnectToCandidateCluster(TcpClientConnectionManager.java:505) at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.doConnectToCluster(TcpClientConnectionManager.java:411) at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.connectToCluster(TcpClientConnectionManager.java:372) at com.hazelcast.client.impl.clientside.HazelcastClientInstanceImpl.start(HazelcastClientInstanceImpl.java:381) at com.hazelcast.client.HazelcastClient.constructHazelcastClient(HazelcastClient.java:460) at com.hazelcast.client.HazelcastClient.newHazelcastClientInternal(HazelcastClient.java:416) at com.hazelcast.client.HazelcastClient.newHazelcastClient(HazelcastClient.java:136) at org.apache.seatunnel.engine.client.SeaTunnelHazelcastClient.<init>(SeaTunnelHazelcastClient.java:53) at org.apache.seatunnel.engine.client.SeaTunnelClient.<init>(SeaTunnelClient.java:46) at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:96) at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) at org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34) 09:37:54.372 [main] WARN com.hazelcast.client.impl.connection.ClientConnectionManager - hz.client_1 [seatunnel-996597] [5.1] Exception during initial connection to [127.0.0.1]:5801: com.hazelcast.client.AuthenticationException: Authentication failed. The configured cluster name on the client (see ClientConfig.setClusterName()) does not match the one configured in the cluster or the credentials set in the Client security config could not be authenticated 09:37:54.372 [main] WARN com.hazelcast.client.impl.connection.ClientConnectionManager - hz.client_1 [seatunnel-996597] [5.1] Unable to get live cluster connection, retry in 1000 ms, attempt: 1, cluster connect timeout: 3000 ms, max backoff: 30000 ms 09:37:55.184 [pool-4-thread-1] INFO org.apache.seatunnel.engine.server.CoordinatorService - [127.0.0.1]:5802 [seatunnel-996597] [5.1] This node become a new active master node, begin init coordinator service 09:37:55.371 [pool-4-thread-1] INFO com.hazelcast.internal.partition.impl.PartitionStateManager - [127.0.0.1]:5802 [seatunnel-996597] [5.1] Initializing cluster partition table arrangement... 09:37:55.372 [main] INFO com.hazelcast.client.impl.connection.ClientConnectionManager - hz.client_1 [seatunnel-996597] [5.1] Trying to connect to [127.0.0.1]:5801 09:37:55.377 [main] WARN com.hazelcast.client.impl.connection.tcp.TcpClientConnection - hz.client_1 [seatunnel-996597] [5.1] ClientConnection{alive=false, connectionId=2, channel=NioChannel{/127.0.0.1:33345->/127.0.0.1:5801}, remoteAddress=null, lastReadTime=2024-08-26 09:37:55.375, lastWriteTime=2024-08-26 09:37:55.374, closedTime=2024-08-26 09:37:55.376, connected server version=null} closed. Reason: Failed to authenticate connection com.hazelcast.client.AuthenticationException: Authentication failed. The configured cluster name on the client (see ClientConfig.setClusterName()) does not match the one configured in the cluster or the credentials set in the Client security config could not be authenticated at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.checkAuthenticationResponse(TcpClientConnectionManager.java:995) at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.onAuthenticated(TcpClientConnectionManager.java:898) at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.getOrConnectToAddress(TcpClientConnectionManager.java:615) at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.lambda$doConnectToCandidateCluster$3(TcpClientConnectionManager.java:505) at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.connect(TcpClientConnectionManager.java:459) at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.doConnectToCandidateCluster(TcpClientConnectionManager.java:505) at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.doConnectToCluster(TcpClientConnectionManager.java:411) at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.connectToCluster(TcpClientConnectionManager.java:372) at com.hazelcast.client.impl.clientside.HazelcastClientInstanceImpl.start(HazelcastClientInstanceImpl.java:381) at com.hazelcast.client.HazelcastClient.constructHazelcastClient(HazelcastClient.java:460) at com.hazelcast.client.HazelcastClient.newHazelcastClientInternal(HazelcastClient.java:416) at com.hazelcast.client.HazelcastClient.newHazelcastClient(HazelcastClient.java:136) at org.apache.seatunnel.engine.client.SeaTunnelHazelcastClient.<init>(SeaTunnelHazelcastClient.java:53) at org.apache.seatunnel.engine.client.SeaTunnelClient.<init>(SeaTunnelClient.java:46) at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:96) at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) at org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34) 09:37:55.378 [main] WARN com.hazelcast.client.impl.connection.ClientConnectionManager - hz.client_1 [seatunnel-996597] [5.1] Exception during initial connection to [127.0.0.1]:5801: com.hazelcast.client.AuthenticationException: Authentication failed. The configured cluster name on the client (see ClientConfig.setClusterName()) does not match the one configured in the cluster or the credentials set in the Client security config could not be authenticated 09:37:55.378 [main] WARN com.hazelcast.client.impl.connection.ClientConnectionManager - hz.client_1 [seatunnel-996597] [5.1] Unable to get live cluster connection, retry in 1050 ms, attempt: 2, cluster connect timeout: 3000 ms, max backoff: 30000 ms 09:37:55.384 [pool-4-thread-1] DEBUG com.hazelcast.internal.partition.InternalPartitionService - [127.0.0.1]:5802 [seatunnel-996597] [5.1] Publishing partition state, stamp: -8661523421455686299 09:37:56.428 [main] INFO com.hazelcast.client.impl.connection.ClientConnectionManager - hz.client_1 [seatunnel-996597] [5.1] Trying to connect to [127.0.0.1]:5801 09:37:56.434 [main] WARN com.hazelcast.client.impl.connection.tcp.TcpClientConnection - hz.client_1 [seatunnel-996597] [5.1] ClientConnection{alive=false, connectionId=3, channel=NioChannel{/127.0.0.1:59325->/127.0.0.1:5801}, remoteAddress=null, lastReadTime=2024-08-26 09:37:56.433, lastWriteTime=2024-08-26 09:37:56.432, closedTime=2024-08-26 09:37:56.433, connected server version=null} closed. Reason: Failed to authenticate connection com.hazelcast.client.AuthenticationException: Authentication failed. The configured cluster name on the client (see ClientConfig.setClusterName()) does not match the one configured in the cluster or the credentials set in the Client security config could not be authenticated at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.checkAuthenticationResponse(TcpClientConnectionManager.java:995) at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.onAuthenticated(TcpClientConnectionManager.java:898) at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.getOrConnectToAddress(TcpClientConnectionManager.java:615) at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.lambda$doConnectToCandidateCluster$3(TcpClientConnectionManager.java:505) at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.connect(TcpClientConnectionManager.java:459) at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.doConnectToCandidateCluster(TcpClientConnectionManager.java:505) at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.doConnectToCluster(TcpClientConnectionManager.java:411) at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.connectToCluster(TcpClientConnectionManager.java:372) at com.hazelcast.client.impl.clientside.HazelcastClientInstanceImpl.start(HazelcastClientInstanceImpl.java:381) at com.hazelcast.client.HazelcastClient.constructHazelcastClient(HazelcastClient.java:460) at com.hazelcast.client.HazelcastClient.newHazelcastClientInternal(HazelcastClient.java:416) at com.hazelcast.client.HazelcastClient.newHazelcastClient(HazelcastClient.java:136) at org.apache.seatunnel.engine.client.SeaTunnelHazelcastClient.<init>(SeaTunnelHazelcastClient.java:53) at org.apache.seatunnel.engine.client.SeaTunnelClient.<init>(SeaTunnelClient.java:46) at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:96) at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) at org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34) 09:37:56.435 [main] WARN com.hazelcast.client.impl.connection.ClientConnectionManager - hz.client_1 [seatunnel-996597] [5.1] Exception during initial connection to [127.0.0.1]:5801: com.hazelcast.client.AuthenticationException: Authentication failed. The configured cluster name on the client (see ClientConfig.setClusterName()) does not match the one configured in the cluster or the credentials set in the Client security config could not be authenticated 09:37:56.435 [main] WARN com.hazelcast.client.impl.connection.ClientConnectionManager - hz.client_1 [seatunnel-996597] [5.1] Unable to get live cluster connection, retry in 927 ms, attempt: 3, cluster connect timeout: 3000 ms, max backoff: 30000 ms 09:37:57.362 [main] INFO com.hazelcast.client.impl.connection.ClientConnectionManager - hz.client_1 [seatunnel-996597] [5.1] Trying to connect to [127.0.0.1]:5801 09:37:57.368 [main] WARN com.hazelcast.client.impl.connection.tcp.TcpClientConnection - hz.client_1 [seatunnel-996597] [5.1] ClientConnection{alive=false, connectionId=4, channel=NioChannel{/127.0.0.1:45889->/127.0.0.1:5801}, remoteAddress=null, lastReadTime=2024-08-26 09:37:57.367, lastWriteTime=2024-08-26 09:37:57.366, closedTime=2024-08-26 09:37:57.367, connected server version=null} closed. Reason: Failed to authenticate connection com.hazelcast.client.AuthenticationException: Authentication failed. The configured cluster name on the client (see ClientConfig.setClusterName()) does not match the one configured in the cluster or the credentials set in the Client security config could not be authenticated at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.checkAuthenticationResponse(TcpClientConnectionManager.java:995) at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.onAuthenticated(TcpClientConnectionManager.java:898) at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.getOrConnectToAddress(TcpClientConnectionManager.java:615) at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.lambda$doConnectToCandidateCluster$3(TcpClientConnectionManager.java:505) at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.connect(TcpClientConnectionManager.java:459) at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.doConnectToCandidateCluster(TcpClientConnectionManager.java:505) at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.doConnectToCluster(TcpClientConnectionManager.java:411) at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.connectToCluster(TcpClientConnectionManager.java:372) at com.hazelcast.client.impl.clientside.HazelcastClientInstanceImpl.start(HazelcastClientInstanceImpl.java:381) at com.hazelcast.client.HazelcastClient.constructHazelcastClient(HazelcastClient.java:460) at com.hazelcast.client.HazelcastClient.newHazelcastClientInternal(HazelcastClient.java:416) at com.hazelcast.client.HazelcastClient.newHazelcastClient(HazelcastClient.java:136) at org.apache.seatunnel.engine.client.SeaTunnelHazelcastClient.<init>(SeaTunnelHazelcastClient.java:53) at org.apache.seatunnel.engine.client.SeaTunnelClient.<init>(SeaTunnelClient.java:46) at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:96) at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) at org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34) 09:37:57.369 [main] WARN com.hazelcast.client.impl.connection.ClientConnectionManager - hz.client_1 [seatunnel-996597] [5.1] Exception during initial connection to [127.0.0.1]:5801: 、 09:37:59.083 [main] ERROR org.apache.seatunnel.core.starter.SeaTunnel - =============================================================================== 09:37:59.083 [main] ERROR org.apache.seatunnel.core.starter.SeaTunnel - Fatal Error, 09:37:59.083 [main] ERROR org.apache.seatunnel.core.starter.SeaTunnel - Please submit bug report in https://github.com/apache/seatunnel/issues 09:37:59.083 [main] ERROR org.apache.seatunnel.core.starter.SeaTunnel - Reason:SeaTunnel job executed failed 09:37:59.085 [main] ERROR org.apache.seatunnel.core.starter.SeaTunnel - 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:191) 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: java.lang.IllegalStateException: Unable to connect to any cluster. at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.doConnectToCluster(TcpClientConnectionManager.java:433) at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.connectToCluster(TcpClientConnectionManager.java:372) at com.hazelcast.client.impl.clientside.HazelcastClientInstanceImpl.start(HazelcastClientInstanceImpl.java:381) at com.hazelcast.client.HazelcastClient.constructHazelcastClient(HazelcastClient.java:460) at com.hazelcast.client.HazelcastClient.newHazelcastClientInternal(HazelcastClient.java:416) at com.hazelcast.client.HazelcastClient.newHazelcastClient(HazelcastClient.java:136) at org.apache.seatunnel.engine.client.SeaTunnelHazelcastClient.<init>(SeaTunnelHazelcastClient.java:53) at org.apache.seatunnel.engine.client.SeaTunnelClient.<init>(SeaTunnelClient.java:46) at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:96) ... 2 more 09:37:59.085 [main] ERROR org.apache.seatunnel.core.starter.SeaTunnel - =============================================================================== 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:191) 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: java.lang.IllegalStateException: Unable to connect to any cluster. at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.doConnectToCluster(TcpClientConnectionManager.java:433) at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.connectToCluster(TcpClientConnectionManager.java:372) at com.hazelcast.client.impl.clientside.HazelcastClientInstanceImpl.start(HazelcastClientInstanceImpl.java:381) at com.hazelcast.client.HazelcastClient.constructHazelcastClient(HazelcastClient.java:460) at com.hazelcast.client.HazelcastClient.newHazelcastClientInternal(HazelcastClient.java:416) at com.hazelcast.client.HazelcastClient.newHazelcastClient(HazelcastClient.java:136) at org.apache.seatunnel.engine.client.SeaTunnelHazelcastClient.<init>(SeaTunnelHazelcastClient.java:53) at org.apache.seatunnel.engine.client.SeaTunnelClient.<init>(SeaTunnelClient.java:46) at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:96) ... 2 more ### SeaTunnel Version 2.3.3 ### SeaTunnel Config ```conf env { execution.parallelism = 2 job.mode = "STREAMING" checkpoint.interval = 5000 } source { SqlServer-CDC { exactly_once=true result_table_name = "customers" username = "test" password = "123456" startup.mode="latest" database-names = ["test"] table-names = ["test.dbo.test1"] base-url = "jdbc:sqlserver://localhost:1433;databaseName=test" } } transform { } sink { console { source_table_name = "customers" } ``` ### Running Command ```shell bash ./bin/seatunnel.sh --config ./config/v2.streaming.sqlserver.conf.template -e local ``` ### Error Exception ```log 09:37:59.085 [main] ERROR org.apache.seatunnel.core.starter.SeaTunnel - 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:191) 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: java.lang.IllegalStateException: Unable to connect to any cluster. at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.doConnectToCluster(TcpClientConnectionManager.java:433) at com.hazelcast.client.impl.connection.tcp.TcpClientConnectionManager.connectToCluster(TcpClientConnectionManager.java:372) at com.hazelcast.client.impl.clientside.HazelcastClientInstanceImpl.start(HazelcastClientInstanceImpl.java:381) at com.hazelcast.client.HazelcastClient.constructHazelcastClient(HazelcastClient.java:460) at com.hazelcast.client.HazelcastClient.newHazelcastClientInternal(HazelcastClient.java:416) at com.hazelcast.client.HazelcastClient.newHazelcastClient(HazelcastClient.java:136) at org.apache.seatunnel.engine.client.SeaTunnelHazelcastClient.<init>(SeaTunnelHazelcastClient.java:53) at org.apache.seatunnel.engine.client.SeaTunnelClient.<init>(SeaTunnelClient.java:46) at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:96) ``` ### Zeta or Flink or Spark Version _No response_ ### Java or Scala Version _No response_ ### Screenshots _No response_ ### Are you willing to submit PR? - [X] Yes I am willing to submit a PR! ### Code of Conduct - [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
