andyuan1000 opened a new issue, #8428: URL: https://github.com/apache/seatunnel/issues/8428
### 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的字符串类型转换到日期类型，这样写到SR做对应里，发现普通的转换都报错，请问什么原因？ 还有官网能否增加转换的例子 ### SeaTunnel Version 2.3.5 ### SeaTunnel Config ```conf #定义一些作业的运行参数,具体可以参考 https://seatunnel.apache.org/docs/2.3.1/concept/JobEnvConfig env { parallelism=1 # 并行度，这里是启动5个Source Task来并行的读取数据 job.mode="STREAMING" #作业的运行模式，BATCH=离线批同步，STREAMING=实时同步 job.name="SeaTunnel_market_new_121_163_sr_STREAMING_Job" checkpoint.interval=20000 #每10000ms进行一次checkpoint，后面会详细介绍checkpoint对JDBC Source和StarRocks Sink这两个连接器的影响 } source { MySQL-CDC { result_table_name="Table250102" base-url = "jdbc:mysql://120.46.249.147:33306/market_new2?useUnicode=true&characterEncoding=utf-8&autoReconnect=true&zeroDateTimeBehavior=convertToNull&useSSL=false" username = "root" password = "Psjt@2020" table-names = ["market_new2.t_electronic_back_order"] startup.mode="earliest" table-names-config = [ { table = "market_new2.t_electronic_back_order" primaryKeys = ["id"] } ] } } transform { Sql { source_table_name = "Table250102" result_table_name = "Table25010201" query = "SELECT id, order_code, status, order_total_price, order_pay_mode, old_order_code, actual_money, operate_flag, order_commodity_weight, cabinet_name, cabinet_code FROM market_new2.t_electronic_back_order " } } sink { StarRocks { batch_max_rows=10240 # source_table_name="Table25010201" table="t_electronic_back_order_st" database="market_new_dw" base-url="jdbc:mysql://120.46.249.147:9030/" username="root" password="Hdic@2024" nodeUrls=[ "120.46.249.147:8030"] enable_upsert_delete = true } } ``` ### Running Command ```shell ./bin/seatunnel.sh --config ./config/mysql_to_sr_stream.config -m local ``` ### Error Exception ```log tUuid=39c58f03-0441-4721-bd1b-2753a72e99a0, clientName=hz.client_1, authenticated=true, clientVersion=5.1, creationTime=1735812854718, latest clientAttributes=lastStatisticsCollectionTime=1735812854759,enterprise=false,clientType=JVM,clientVersion=5.1,clusterConnectionTimestamp=1735812854705,clientAddress=127.0.0.1,clientName=hz.client_1,credentials.principal=null,os.committedVirtualMemorySize=0,os.freePhysicalMemorySize=0,os.freeSwapSpaceSize=0,os.maxFileDescriptorCount=0,os.openFileDescriptorCount=0,os.processCpuTime=0,os.systemLoadAverage=0.05,os.totalPhysicalMemorySize=0,os.totalSwapSpaceSize=0,runtime.availableProcessors=8,runtime.freeMemory=221884832,runtime.maxMemory=536870912,runtime.totalMemory=268435456,runtime.uptime=2882,runtime.usedMemory=46619736, labels=[]} 2025-01-02 18:14:15,474 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel-815510] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is SHUTDOWN 2025-01-02 18:14:15,475 INFO [s.c.s.s.c.ClientExecuteCommand] [main] - Closed SeaTunnel client...... 2025-01-02 18:14:15,475 INFO [c.h.c.LifecycleService ] [main] - [localhost]:5801 [seatunnel-815510] [5.1] [localhost]:5801 is SHUTTING_DOWN 2025-01-02 18:14:15,478 INFO [c.h.i.p.i.MigrationManager ] [hz.main.cached.thread-4] - [localhost]:5801 [seatunnel-815510] [5.1] Shutdown request of Member [localhost]:5801 - fb96b930-e951-40ca-8981-9a6c8653a851 this is handled 2025-01-02 18:14:15,483 INFO [c.h.i.i.Node ] [main] - [localhost]:5801 [seatunnel-815510] [5.1] Shutting down connection manager... 2025-01-02 18:14:15,485 INFO [c.h.i.i.Node ] [main] - [localhost]:5801 [seatunnel-815510] [5.1] Shutting down node engine... 2025-01-02 18:14:15,491 INFO [.c.c.DefaultClassLoaderService] [main] - close classloader service 2025-01-02 18:14:15,493 INFO [o.a.s.e.s.TaskExecutionService] [event-forwarder-0] - [localhost]:5801 [seatunnel-815510] [5.1] Event forward thread interrupted 2025-01-02 18:14:18,512 INFO [c.h.i.i.NodeExtension ] [main] - [localhost]:5801 [seatunnel-815510] [5.1] Destroying node NodeExtension. 2025-01-02 18:14:18,512 INFO [c.h.i.i.Node ] [main] - [localhost]:5801 [seatunnel-815510] [5.1] Hazelcast Shutdown is completed in 3035 ms. 2025-01-02 18:14:18,513 INFO [c.h.c.LifecycleService ] [main] - [localhost]:5801 [seatunnel-815510] [5.1] [localhost]:5801 is SHUTDOWN 2025-01-02 18:14:18,513 INFO [s.c.s.s.c.ClientExecuteCommand] [main] - Closed HazelcastInstance ...... 2025-01-02 18:14:18,513 ERROR [o.a.s.c.s.SeaTunnel ] [main] - =============================================================================== 2025-01-02 18:14:18,513 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Fatal Error, 2025-01-02 18:14:18,513 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Please submit bug report in https://github.com/apache/seatunnel/issues 2025-01-02 18:14:18,513 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Reason:SeaTunnel job executed failed 2025-01-02 18:14:18,515 ERROR [o.a.s.c.s.SeaTunnel ] [main] - 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:202) 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: org.apache.seatunnel.transform.exception.TransformException: ErrorCode:[COMMON-05], ErrorDescription:[Unsupported operation] - SQL validate failed: SELECT id, order_code, status, order_total_price, order_pay_mode, old_order_code, actual_money, operate_flag, order_commodity_weight, cabinet_name, cabinet_code FROM market_new2.t_electronic_back_order , cause: Unsupported schema syntax at org.apache.seatunnel.transform.sql.zeta.ZetaSQLEngine.validateSQL(ZetaSQLEngine.java:153) at org.apache.seatunnel.transform.sql.zeta.ZetaSQLEngine.parseSQL(ZetaSQLEngine.java:90) at org.apache.seatunnel.transform.sql.zeta.ZetaSQLEngine.init(ZetaSQLEngine.java:83) at org.apache.seatunnel.transform.sql.SQLTransform.open(SQLTransform.java:99) at org.apache.seatunnel.transform.sql.SQLTransform.tryOpen(SQLTransform.java:108) at org.apache.seatunnel.transform.sql.SQLTransform.transformTableSchema(SQLTransform.java:120) at org.apache.seatunnel.transform.common.AbstractCatalogSupportTransform.transformCatalogTable(AbstractCatalogSupportTransform.java:50) at org.apache.seatunnel.transform.common.AbstractCatalogSupportTransform.getProducedCatalogTable(AbstractCatalogSupportTransform.java:40) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseTransform(MultipleTableJobConfigParser.java:434) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseTransforms(MultipleTableJobConfigParser.java:362) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:193) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.getLogicalDag(ClientJobExecutionEnvironment.java:88) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.execute(ClientJobExecutionEnvironment.java:156) at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:149) ... 2 more 2025-01-02 18:14:18,516 ERROR [o.a.s.c.s.SeaTunnel ] [main] - =============================================================================== 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:202) 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: org.apache.seatunnel.transform.exception.TransformException: ErrorCode:[COMMON-05], ErrorDescription:[Unsupported operation] - SQL validate failed: SELECT id, order_code, status, order_total_price, order_pay_mode, old_order_code, actual_money, operate_flag, order_commodity_weight, cabinet_name, cabinet_code FROM market_new2.t_electronic_back_order , cause: Unsupported schema syntax at org.apache.seatunnel.transform.sql.zeta.ZetaSQLEngine.validateSQL(ZetaSQLEngine.java:153) at org.apache.seatunnel.transform.sql.zeta.ZetaSQLEngine.parseSQL(ZetaSQLEngine.java:90) at org.apache.seatunnel.transform.sql.zeta.ZetaSQLEngine.init(ZetaSQLEngine.java:83) at org.apache.seatunnel.transform.sql.SQLTransform.open(SQLTransform.java:99) at org.apache.seatunnel.transform.sql.SQLTransform.tryOpen(SQLTransform.java:108) at org.apache.seatunnel.transform.sql.SQLTransform.transformTableSchema(SQLTransform.java:120) at org.apache.seatunnel.transform.common.AbstractCatalogSupportTransform.transformCatalogTable(AbstractCatalogSupportTransform.java:50) at org.apache.seatunnel.transform.common.AbstractCatalogSupportTransform.getProducedCatalogTable(AbstractCatalogSupportTransform.java:40) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseTransform(MultipleTableJobConfigParser.java:434) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseTransforms(MultipleTableJobConfigParser.java:362) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:193) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.getLogicalDag(ClientJobExecutionEnvironment.java:88) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.execute(ClientJobExecutionEnvironment.java:156) at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:149) ... 2 more ``` ### Zeta or Flink or Spark Version 无 ### Java or Scala Version 11 ### 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]
