search

apache / seatunnel

SeaTunnel is a next-generation super high-performance, distributed, massive data integration tool.
https://seatunnel.apache.org/
Apache License 2.0
8.03k stars 1.82k forks source link

Failed to authenticate connection com.hazelcast.client.AuthenticationException #7498

Closed visiontk closed 1 month ago

visiontk commented 2 months ago

Search before asking

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:

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.(SeaTunnelHazelcastClient.java:53) at org.apache.seatunnel.engine.client.SeaTunnelClient.(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.(SeaTunnelHazelcastClient.java:53) at org.apache.seatunnel.engine.client.SeaTunnelClient.(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.(SeaTunnelHazelcastClient.java:53) at org.apache.seatunnel.engine.client.SeaTunnelClient.(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.(SeaTunnelHazelcastClient.java:53) at org.apache.seatunnel.engine.client.SeaTunnelClient.(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.(SeaTunnelHazelcastClient.java:53) at org.apache.seatunnel.engine.client.SeaTunnelClient.(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.(SeaTunnelHazelcastClient.java:53) at org.apache.seatunnel.engine.client.SeaTunnelClient.(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

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

bash ./bin/seatunnel.sh --config ./config/v2.streaming.sqlserver.conf.template -e local

Error Exception

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?

Code of Conduct

github-actions[bot] commented 1 month ago

This issue has been automatically marked as stale because it has not had recent activity for 30 days. It will be closed in next 7 days if no further activity occurs.

github-actions[bot] commented 1 month ago

This issue has been closed because it has not received response for too long time. You could reopen it if you encountered similar problems in the future.