NerushKirill opened a new issue, #9966: URL: https://github.com/apache/seatunnel/issues/9966
### 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 Hello everyone! Could you please help me? I've encountered a problem. I get an error when I run the job. although there are no problems with topics of the format "reg.country.user_activity". Could you please tell me how to solve this? Has anyone else encountered this? There's no option to change the topic name. Thanks! ### SeaTunnel Version Version:2.3.10 Commit: 5c8a4c0 ### SeaTunnel Config ```conf env { parallelism = 2 job.mode = "STREAMING" checkpoint.interval = 300000 } source { Kafka { bootstrap.servers = "host1,host2,host3:port" tables_configs = [ { topic = "reg.country.user_activity.activity" consumer.group = "consumer_gp_name" format = "json" kafka.auto.offset.reset = "earliest" kafka.max.poll.records = 500 kafka.session.timeout.ms = 45000 kafka.heartbeat.interval.ms = 15000 kafka.request.timeout.ms = 40000 kafka.admin.timeout.ms = 60000 kafka.default.api.timeout.ms = 60000 kafka.config = { security.protocol = "SSL" ssl.truststore.location = "/kafka/truststore.jks" ssl.truststore.password = "password" ssl.keystore.location = "/kafka/keystore.jks" ssl.keystore.password = "password" ssl.key.password = "password" } } ] } } sink { S3File { bucket = "s3a://bucket-prt-1" tmp_path = "/seatunnel_tmp/kafka/country" path = "s3a://bucket-prt-1/product=country/platform=kafka/env=prod/layer=raw/table=user_activity_activity" fs.s3a.endpoint = "https://my-minio.my/"; fs.s3a.aws.credentials.provider = "org.apache.hadoop.fs.s3a.SimpleAWSCredentialsProvider" access_key = "access_key" secret_key = "secret_key" file_format_type = "parquet" compress_codec = "SNAPPY" schema_save_mode = "CREATE_SCHEMA_WHEN_NOT_EXIST" data_save_mode = "APPEND_DATA" is_enable_transaction = "true" custom_filename = "true" file_name_expression = "date=${now}/${transactionId}" filename_time_format = "yyyy-MM-dd" rolling_policy = { max_part_size = "128MB" inactivity_interval = "15m" rollover_interval = "1h" } hadoop_s3_properties = { fs.s3a.path.style.access = "true" fs.s3a.endpoint.region = "region" } } } ``` ### Running Command ```shell API REST V.2 {{SeaTunnelHost}}/submit-job?format=hocon&jobName=kafka_to_s3__test_job&jobId=&isStartWithSavePoint=true >>out { "jobId": "1032283892776697857", "jobName": "kafka_to_s3__test_job" } ``` ### Error Exception ```log { "status": "fail", "message": "Cannot get split 'reg.country.user_activity.activity' to get databaseName and tableName" } ``` ### Zeta or Flink or Spark Version Zeta ### Java or Scala Version _No response_ ### 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]
