[Bug] [Module Name]Unable to connect to any cluster.

[cxy878977hb]

Search before asking

• [X] I had searched in the issues and found no similar issues.

What happened

seatunnel 2.3.3 is this problem when i uee 2.3.7 its ok why?

SeaTunnel Version

2.3.3

SeaTunnel Config

#
# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements.  See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License.  You may obtain a copy of the License at
#
#    http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#
######
###### This config file is a demonstration of streaming processing in SeaTunnel config
######

env {
  # You can set SeaTunnel environment configuration here
  parallelism = 2
  job.mode = "STREAMING"
  checkpoint.interval = 2000
}

source {
  # This is a example source plugin **only for test and demonstrate the feature source plugin**
  MySQL-CDC {
    result_table_name = "fake1"
    base-url = "jdbc:mysql://192**:3306/gmall?rewriteBatchedStatements=true&useUnicode=true&characterEncoding=UTF8&serverTimezone=Asia/Shanghai&useSSL=false&verifyServerCertificate=false&autoReconnect=true&failOverReadOnly=false"
    username = "**"
    password = "**"
    table-names = ["gmall.psql"]

    startup.mode = "latest"
  }
  # If you would like to get more information about how to configure SeaTunnel and see full list of source plugins,
  # please go to https://seatunnel.apache.org/docs/category/source-v2
}

transform {
  Sql {
    source_table_name = "fake"
    result_table_name = "fake1"
    query = "select id,aslarm as alarm_code ,user AS user_id,cha AS channel,opint AS operator,re AS remark,cr AS create_time ,up AS update_time from fake"
  }
}

sink {
  StarRocks {
    source_table_name = "fake"
    nodeUrls = ["**"]
    base-url = "**"
    username = **
    password = "**@2023"
    database = "**"
    table = "**"
    batch_max_rows = 10
    schema_save_mode = "ERROR_WHEN_SCHEMA_NOT_EXIST"
    data_save_mode = "APPEND_DATA"
    starrocks.config = {
      format = "JSON"
      strip_outer_array = true
    }
  }
  # If you would like to get more information about how to configure SeaTunnel and see full list of sink plugins,
  # please go to https://seatunnel.apache.org/docs/category/sink-v2
}

Running Command

sh seatunnel.sh --config ../config/v2.streaming.conf.template.senpeng -e local

Error Exception

2024-09-20 11:23:10,434 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)

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

[cxy878977hb]

2024-09-20 11:23:10,234 WARN com.hazelcast.client.impl.connection.tcp.TcpClientConnection - hz.client_1 [seatunnel-515393] [5.1] ClientConnection{alive=false, connectionId=4, channel=NioChannel{/127.0.0.1:44353->localhost/127.0.0.1:5801}, remoteAddress=null, lastReadTime=2024-09-20 11:23:10.232, lastWriteTime=2024-09-20 11:23:10.228, closedTime=2024-09-20 11:23:10.232, connected server version=null} closed. Reason: Failed to authenticate connection