kulame opened a new issue, #6295: URL: https://github.com/apache/seatunnel/issues/6295
### 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 MySQL-CDC cannot connect to mysql database ### SeaTunnel Version 2.3.3 ### SeaTunnel Config ```conf env { # You can set flink configuration here execution.parallelism = 2 job.mode = "STREAMING" checkpoint.interval = 2000 #execution.checkpoint.interval = 10000 #execution.checkpoint.data-uri = "hdfs://localhost:9000/checkpoint" } source { MySQL-CDC { base-url = "jdbc:mysql://xxx.xxx.xxx.xxx:3306/xxx" username = "xxx" password = "xxx" table-names = ["xxx"] startup.mode = "initial" } } sink { TDengine { url : "jdbc:TAOS-RS://localhost:6030/" username : "root" password : "taosdata" database : "stock" stable : "meters2" timezone: UTC } } ``` ### Running Command ```shell bin/seatunnel.sh --config config/tdengine.conf -e local ``` ### Error Exception ```log 2024-01-28 14:05:37,088 INFO org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog - Catalog mysql established connection to jdbc:mysql://xxxx:3306/xxxx 2024-01-28 14:05:37,090 INFO org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog - Catalog mysql closing 2024-01-28 14:05:37,090 INFO com.hazelcast.core.LifecycleService - hz.client_1 [seatunnel-350594] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is SHUTTING_DOWN 2024-01-28 14:05:37,092 INFO com.hazelcast.internal.server.tcp.TcpServerConnection - [192.168.31.131]:5801 [seatunnel-350594] [5.1] Connection[id=1, /127.0.0.1:5801->/127.0.0.1:60825, qualifier=null, endpoint=[127.0.0.1]:60825, remoteUuid=52344932-24fa-4f77-b2fa-d5ef3397c357, alive=false, connectionType=JVM, planeIndex=-1] closed. Reason: Connection closed by the other side 2024-01-28 14:05:37,092 INFO com.hazelcast.client.impl.connection.ClientConnectionManager - hz.client_1 [seatunnel-350594] [5.1] Removed connection to endpoint: [192.168.31.131]:5801:58341cfa-4b67-40f7-bea4-3e4423335968, connection: ClientConnection{alive=false, connectionId=1, channel=NioChannel{/127.0.0.1:60825->localhost/127.0.0.1:5801}, remoteAddress=[192.168.31.131]:5801, lastReadTime=2024-01-28 14:05:36.568, lastWriteTime=2024-01-28 14:05:36.437, closedTime=2024-01-28 14:05:37.091, connected server version=5.1} 2024-01-28 14:05:37,092 INFO com.hazelcast.core.LifecycleService - hz.client_1 [seatunnel-350594] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is CLIENT_DISCONNECTED 2024-01-28 14:05:37,093 INFO com.hazelcast.client.impl.ClientEndpointManager - [192.168.31.131]:5801 [seatunnel-350594] [5.1] Destroying ClientEndpoint{connection=Connection[id=1, /127.0.0.1:5801->/127.0.0.1:60825, qualifier=null, endpoint=[127.0.0.1]:60825, remoteUuid=52344932-24fa-4f77-b2fa-d5ef3397c357, alive=false, connectionType=JVM, planeIndex=-1], clientUuid=52344932-24fa-4f77-b2fa-d5ef3397c357, clientName=hz.client_1, authenticated=true, clientVersion=5.1, creationTime=1706421936311, latest clientAttributes=lastStatisticsCollectionTime=1706421936330,enterprise=false,clientType=JVM,clientVersion=5.1,clusterConnectionTimestamp=1706421936306,clientAddress=127.0.0.1,clientName=hz.client_1,credentials.principal=null,os.committedVirtualMemorySize=14733103104,os.freePhysicalMemorySize=60635299840,os.freeSwapSpaceSize=17179869184,os.maxFileDescriptorCount=1048576,os.openFileDescriptorCount=86,os.processCpuTime=4090000000,os.systemLoadAverage=0.10791015625,os.totalPhysicalMemorySi ze=67328905216,os.totalSwapSpaceSize=17179869184,runtime.availableProcessors=32,runtime.freeMemory=977310920,runtime.maxMemory=1029177344,runtime.totalMemory=1029177344,runtime.uptime=2931,runtime.usedMemory=51866424, labels=[]} 2024-01-28 14:05:37,094 INFO com.hazelcast.core.LifecycleService - hz.client_1 [seatunnel-350594] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is SHUTDOWN 2024-01-28 14:05:37,094 INFO org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand - Closed SeaTunnel client...... 2024-01-28 14:05:37,094 INFO com.hazelcast.core.LifecycleService - [192.168.31.131]:5801 [seatunnel-350594] [5.1] [192.168.31.131]:5801 is SHUTTING_DOWN 2024-01-28 14:05:37,097 INFO com.hazelcast.internal.partition.impl.MigrationManager - [192.168.31.131]:5801 [seatunnel-350594] [5.1] Shutdown request of Member [192.168.31.131]:5801 - 58341cfa-4b67-40f7-bea4-3e4423335968 this is handled 2024-01-28 14:05:37,100 INFO com.hazelcast.instance.impl.Node - [192.168.31.131]:5801 [seatunnel-350594] [5.1] Shutting down multicast service... 2024-01-28 14:05:37,100 INFO com.hazelcast.instance.impl.Node - [192.168.31.131]:5801 [seatunnel-350594] [5.1] Shutting down connection manager... 2024-01-28 14:05:37,101 INFO com.hazelcast.instance.impl.Node - [192.168.31.131]:5801 [seatunnel-350594] [5.1] Shutting down node engine... 2024-01-28 14:05:40,122 INFO com.hazelcast.instance.impl.NodeExtension - [192.168.31.131]:5801 [seatunnel-350594] [5.1] Destroying node NodeExtension. 2024-01-28 14:05:40,123 INFO com.hazelcast.instance.impl.Node - [192.168.31.131]:5801 [seatunnel-350594] [5.1] Hazelcast Shutdown is completed in 3027 ms. 2024-01-28 14:05:40,123 INFO com.hazelcast.core.LifecycleService - [192.168.31.131]:5801 [seatunnel-350594] [5.1] [192.168.31.131]:5801 is SHUTDOWN 2024-01-28 14:05:40,123 INFO org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand - Closed HazelcastInstance ...... 2024-01-28 14:05:40,124 ERROR org.apache.seatunnel.core.starter.SeaTunnel - =============================================================================== 2024-01-28 14:05:40,124 ERROR org.apache.seatunnel.core.starter.SeaTunnel - Fatal Error, 2024-01-28 14:05:40,124 ERROR org.apache.seatunnel.core.starter.SeaTunnel - Please submit bug report in https://github.com/apache/seatunnel/issues 2024-01-28 14:05:40,124 ERROR org.apache.seatunnel.core.starter.SeaTunnel - Reason:SeaTunnel job executed failed 2024-01-28 14:05:40,126 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.IllegalArgumentException: Cannot get split 'all_stock' to get databaseName and tableName at org.apache.seatunnel.api.table.catalog.TablePath.of(TablePath.java:45) at org.apache.seatunnel.connectors.seatunnel.cdc.mysql.source.MySqlIncrementalSource.createDebeziumDeserializationSchema(MySqlIncrementalSource.java:113) at org.apache.seatunnel.connectors.cdc.base.source.IncrementalSource.prepare(IncrementalSource.java:119) at org.apache.seatunnel.engine.core.parse.JobConfigParser.parseSource(JobConfigParser.java:85) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSource(MultipleTableJobConfigParser.java:317) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:179) at org.apache.seatunnel.engine.core.job.AbstractJobEnvironment.getLogicalDag(AbstractJobEnvironment.java:109) at org.apache.seatunnel.engine.client.job.JobExecutionEnvironment.execute(JobExecutionEnvironment.java:73) at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:143) ... 2 more 2024-01-28 14:05:40,126 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.IllegalArgumentException: Cannot get split 'all_stock' to get databaseName and tableName at org.apache.seatunnel.api.table.catalog.TablePath.of(TablePath.java:45) at org.apache.seatunnel.connectors.seatunnel.cdc.mysql.source.MySqlIncrementalSource.createDebeziumDeserializationSchema(MySqlIncrementalSource.java:113) at org.apache.seatunnel.connectors.cdc.base.source.IncrementalSource.prepare(IncrementalSource.java:119) at org.apache.seatunnel.engine.core.parse.JobConfigParser.parseSource(JobConfigParser.java:85) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSource(MultipleTableJobConfigParser.java:317) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:179) at org.apache.seatunnel.engine.core.job.AbstractJobEnvironment.getLogicalDag(AbstractJobEnvironment.java:109) at org.apache.seatunnel.engine.client.job.JobExecutionEnvironment.execute(JobExecutionEnvironment.java:73) at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:143) ... 2 more ``` ### Zeta or Flink or Spark Version 2.3.3 ### Java or Scala Version java1.8.0 ### Screenshots _No response_ ### Are you willing to submit PR? - [ ] 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]
