nshigit opened a new issue, #7295: URL: https://github.com/apache/seatunnel/issues/7295
### 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 2024-07-31 14:08:14,944 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Fatal Error, 2024-07-31 14:08:14,944 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Please submit bug report in https://github.com/apache/seatunnel/issues 2024-07-31 14:08:14,944 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Reason:SeaTunnel job executed failed 2024-07-31 14:08:14,945 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.engine.common.exception.SeaTunnelEngineException: java.lang.RuntimeException: java.lang.RuntimeException: org.apache.seatunnel.common.exception.SeaTunnelRuntimeException: ErrorCode:[COMMON-23], ErrorDescription:[FileConnector write SeaTunnelRow failed, the SeaTunnelRow value is 'SeaTunnelRow{tableId=center_notice, kind=+I, fields=[1852700991000001, 18527, 99, 短信模版调整通知, 尊敬的XXX用户，您好！<br>根据工信部的最新要求，营销类短信的退订方式统一修改为“拒收请回复R”。当前阿里云短信平台已经开始分区域拦截没有按规则修改的短信。XXX零售管理系统会在2024年1月1日前，逐步停止末尾没有“拒收请回复R”的营销类短信的使用，请您尽快重新申请。XXX零售管理系统已完成功能升级，请尽快按照以下方式修改营销类短信模板：<br><ol><li> 营销类短信模板申请：末尾无需加退订方式，系统会自动为� �添加“拒收请回复R”字样。（拒收字样会计入短信字数）</li><li> 已审核通过的营销类短信模板：阿里云短信不支持申请通过的短信进行编辑修改，故需重新申请。申请流程：消息中心-短信-短信模版-新增，按规范填入短信内容即可。</li><li> 短信模版停止应用后，使用该模版的营销活动会下架，请您注意及时调整营销活动。</li></ol><p></p>感谢您的支持与配合！<br>XXX零售, 2023-12-28T15:59:55.772, 管理员, 管理员, null, 2024-01-27T15:59:55, 3, 制单|审核, 2023-12-28T15:59:55.814, null, 001, 加盟店网上公告, 1, null, null, null, null, null]}'.] at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:262) at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:68) at org.apache.seatunnel.engine.server.task.SeaTunnelTransformCollector.collect(SeaTunnelTransformCollector.java:39) at org.apache.seatunnel.engine.server.task.SeaTunnelTransformCollector.collect(SeaTunnelTransformCollector.java:27) at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.handleRecord(IntermediateBlockingQueue.java:70) at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.collect(IntermediateBlockingQueue.java:50) at org.apache.seatunnel.engine.server.task.flow.IntermediateQueueFlowLifeCycle.collect(IntermediateQueueFlowLifeCycle.java:51) at org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.collect(TransformSeaTunnelTask.java:73) at org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:168) at org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.call(TransformSeaTunnelTask.java:78) at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:703) at org.apache.seatunnel.engine.server.TaskExecutionService$NamedTaskWrapper.run(TaskExecutionService.java:1004) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) 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) Caused by: java.lang.RuntimeException: org.apache.seatunnel.common.exception.SeaTunnelRuntimeException: ErrorCode:[COMMON-23], ErrorDescription:[FileConnector write SeaTunnelRow failed, the SeaTunnelRow value is 'SeaTunnelRow{tableId=center_notice, kind=+I, fields=[1852700991000001, 18527, 99, 短信模版调整通知, 尊敬的XXX用户，您好！<br>根据工信部的最新要求，营销类短信的退订方式统一修改为“拒收请回复R”。当前阿里云短信平台已经开始分区域拦截没有按规则修改的短信。XXX零售管理系统会在2024年1月1日前，逐步停止末尾没有“拒收请回复R”的营销类短信的使用，请您尽快重新申请。XXX零售管理系统已完成功能升级，请尽快按照以下方式修改营销类短信模板：<br><ol><li> 营销类短信模板申请：末尾无需加退订方式，系统会自动为您添加“拒收请回复R”字样。（拒收字样会计入短信字数）</li><li> 已审� ��通过的营销类短信模板：阿里云短信不支持申请通过的短信进行编辑修改，故需重新申请。申请流程：消息中心-短信-短信模版-新增，按规范填入短信内容即可。</li><li> 短信模版停止应用后，使用该模版的营销活动会下架，请您注意及时调整营销活动。</li></ol><p></p>感谢您的支持与配合！<br>XXX零售, 2023-12-28T15:59:55.772, 管理员, 管理员, null, 2024-01-27T15:59:55, 3, 制单|审核, 2023-12-28T15:59:55.814, null, 001, 加盟店网上公告, 1, null, null, null, null, null]}'.] at org.apache.seatunnel.connectors.seatunnel.common.multitablesink.MultiTableSinkWriter.subSinkErrorCheck(MultiTableSinkWriter.java:121) at org.apache.seatunnel.connectors.seatunnel.common.multitablesink.MultiTableSinkWriter.prepareCommit(MultiTableSinkWriter.java:201) at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:191) ... 16 more Caused by: org.apache.seatunnel.common.exception.SeaTunnelRuntimeException: ErrorCode:[COMMON-23], ErrorDescription:[FileConnector write SeaTunnelRow failed, the SeaTunnelRow value is 'SeaTunnelRow{tableId=center_notice, kind=+I, fields=[1852700991000001, 18527, 99, 短信模版调整通知, 尊敬的XXX用户，您好！<br>根据工信部的最新要求，营销类短信的退订方式统一修改为“拒收请回复R”。当前阿里云短信平台已经开始分区域拦截没有按规则修改的短信。XXX零售管理系统会在2024年1月1日前，逐步停止末尾没有“拒收请回复R”的营销类短信的使用，请您尽快重新申请。XXX零售管理系统已完成功能升级，请尽快按照以下方式修改营销类短信模板：<br><ol><li> 营销类短信模板申请：末尾无需加退订方式，系统会自动为您添加“拒收请回复R”字样。（拒收字样会计入短信字数）</li><li> 已审核通过的营销类短信� �板：阿里云短信不支持申请通过的短信进行编辑修改，故需重新申请。申请流程：消息中心-短信-短信模版-新增，按规范填入短信内容即可。</li><li> 短信模版停止应用后，使用该模版的营销活动会下架，请您注意及时调整营销活动。</li></ol><p></p>感谢您的支持与配合！<br>XXX零售, 2023-12-28T15:59:55.772, 管理员, 管理员, null, 2024-01-27T15:59:55, 3, 制单|审核, 2023-12-28T15:59:55.814, null, 001, 加盟店网上公告, 1, null, null, null, null, null]}'.] at org.apache.seatunnel.common.exception.CommonError.writeSeaTunnelRowFailed(CommonError.java:86) at org.apache.seatunnel.connectors.seatunnel.file.sink.BaseFileSinkWriter.write(BaseFileSinkWriter.java:136) at org.apache.seatunnel.connectors.seatunnel.file.sink.BaseFileSinkWriter.write(BaseFileSinkWriter.java:46) at org.apache.seatunnel.connectors.seatunnel.common.multitablesink.MultiTableWriterRunnable.run(MultiTableWriterRunnable.java:62) ... 5 more Caused by: org.apache.seatunnel.connectors.seatunnel.file.exception.FileConnectorException: ErrorCode:[COMMON-07], ErrorDescription:[Unsupported data type] - SeaTunnel file connector is not supported for this data type [TIME] at org.apache.seatunnel.connectors.seatunnel.file.sink.writer.ParquetWriteStrategy.seaTunnelDataType2ParquetDataType(ParquetWriteStrategy.java:334) at org.apache.seatunnel.connectors.seatunnel.file.sink.writer.ParquetWriteStrategy.lambda$buildAvroSchemaWithRowType$2(ParquetWriteStrategy.java:347) at java.util.ArrayList.forEach(ArrayList.java:1259) at org.apache.seatunnel.connectors.seatunnel.file.sink.writer.ParquetWriteStrategy.buildAvroSchemaWithRowType(ParquetWriteStrategy.java:344) at org.apache.seatunnel.connectors.seatunnel.file.sink.writer.ParquetWriteStrategy.getOrCreateWriter(ParquetWriteStrategy.java:133) at org.apache.seatunnel.connectors.seatunnel.file.sink.writer.ParquetWriteStrategy.write(ParquetWriteStrategy.java:95) at org.apache.seatunnel.connectors.seatunnel.file.sink.BaseFileSinkWriter.write(BaseFileSinkWriter.java:134) ... 7 more at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:194) ... 2 more 2024-07-31 14:08:14,945 ERROR [o.a.s.c.s.SeaTunnel ] [main] - ### SeaTunnel Version 2.3.5 ### SeaTunnel Config ```conf { "env" : { "parallelism" : 2, "job.mode" : "BATCH" }, "source" : [ { "plugin_name" : "Jdbc", "url" : "jdbc:mysql://xxxxxxxx:3306/xxxxxxx?useUnicode=true&useSSL=false&characterEncoding=GBK&autoReconnect=true&zeroDateTimeBehavior=convertToNull&serverTimezone=GMT%2B8&profileSQL=false&useCursorFetch=true&zeroDateTimeBehavior=CONVERT_TO_NULL&connectTimeout=3000&profileSQL=false&useCursorFetch=true&defaultFetchSize=10000&profileSQL=false&useCursorFetch=true&defaultFetchSize=10000&zeroDateTimeBehavior=CONVERT_TO_NULL&connectTimeout=3000", "driver" : "com.mysql.cj.jdbc.Driver", "user" : "xxxxxx", "password" : "xxxxxxx", "database" : "ama200_mysql_new", "table_path" : "center_notice", "query" : "SELECT * FROM center_notice WHERE system_book_code = '18527'", "fetch_size" : 1000 } ], "sink" : [ { "plugin_name" : "OssFile", "path" : "/xxx/18527/20240731102556/center_notice/center_notice", "bucket" : "oss://xxxxx", "access_key" : "LTAI4FpPV8A4HYnFJNMJdSor", "access_secret" : "xxxxxx", "endpoint" : "oss-cn-hangzhou-internal.aliyuncs.com", "file_format_type" : "parquet", "compress_codec" : "zstd", "custom_filename" : true, "batch_size" : 10000000, "file_name_expression" : "18527_center_notice_center_notice_20240731102556_${transactionId}", "is_enable_transaction" : true } ] } ``` ### Running Command ```shell seatunnel.sh --config test.json ``` ### Error Exception ```log Jul 31, 2024 2:08:11 PM com.hazelcast.internal.config.AbstractConfigLocator INFO: Loading configuration '/home/XXX/apache-seatunnel-2.3.5/config/seatunnel.yaml' from System property 'seatunnel.config' Jul 31, 2024 2:08:11 PM com.hazelcast.internal.config.AbstractConfigLocator INFO: Using configuration file at /home/XXX/apache-seatunnel-2.3.5/config/seatunnel.yaml Jul 31, 2024 2:08:11 PM org.apache.seatunnel.engine.common.config.SeaTunnelConfig INFO: seatunnel.home is /home/XXX Jul 31, 2024 2:08:11 PM com.hazelcast.internal.config.AbstractConfigLocator INFO: Loading configuration '/home/XXX/apache-seatunnel-2.3.5/config/hazelcast.yaml' from System property 'hazelcast.config' Jul 31, 2024 2:08:11 PM com.hazelcast.internal.config.AbstractConfigLocator INFO: Using configuration file at /home/XXX/apache-seatunnel-2.3.5/config/hazelcast.yaml Jul 31, 2024 2:08:11 PM com.hazelcast.internal.config.AbstractConfigLocator INFO: Loading configuration '/home/XXX/apache-seatunnel-2.3.5/config/hazelcast-client.yaml' from System property 'hazelcast.client.config' Jul 31, 2024 2:08:11 PM com.hazelcast.internal.config.AbstractConfigLocator INFO: Using configuration file at /home/XXX/apache-seatunnel-2.3.5/config/hazelcast-client.yaml 2024-07-31 14:08:12,278 INFO [.c.i.s.ClientInvocationService] [main] - hz.client_1 [seatunnel] [5.1] Running with 2 response threads, dynamic=true 2024-07-31 14:08:12,357 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is STARTING 2024-07-31 14:08:12,358 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is STARTED 2024-07-31 14:08:12,386 INFO [.c.i.c.ClientConnectionManager] [main] - hz.client_1 [seatunnel] [5.1] Trying to connect to cluster: seatunnel 2024-07-31 14:08:12,389 INFO [.c.i.c.ClientConnectionManager] [main] - hz.client_1 [seatunnel] [5.1] Trying to connect to [localhost]:5801 2024-07-31 14:08:12,426 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is CLIENT_CONNECTED 2024-07-31 14:08:12,426 INFO [.c.i.c.ClientConnectionManager] [main] - hz.client_1 [seatunnel] [5.1] Authenticated with server [localhost]:5801:f04d5b52-efa6-41ab-aacd-6673e6a21d4c, server version: 5.1, local address: /127.0.0.1:62778 2024-07-31 14:08:12,428 INFO [c.h.i.d.Diagnostics ] [main] - hz.client_1 [seatunnel] [5.1] Diagnostics disabled. To enable add -Dhazelcast.diagnostics.enabled=true to the JVM arguments. 2024-07-31 14:08:12,437 INFO [c.h.c.i.s.ClientClusterService] [hz.client_1.event-5] - hz.client_1 [seatunnel] [5.1] Members [1] { Member [localhost]:5801 - f04d5b52-efa6-41ab-aacd-6673e6a21d4c } 2024-07-31 14:08:12,467 INFO [.c.i.s.ClientStatisticsService] [main] - Client statistics is enabled with period 5 seconds. 2024-07-31 14:08:12,635 INFO [.ClientJobExecutionEnvironment] [main] - add common jar in plugins :[] 2024-07-31 14:08:12,648 INFO [o.a.s.c.s.u.ConfigBuilder ] [main] - Loading config file from path: test2.json 2024-07-31 14:08:12,701 INFO [o.a.s.c.s.u.ConfigShadeUtils ] [main] - Load config shade spi: [base64] 2024-07-31 14:08:12,780 INFO [o.a.s.c.s.u.ConfigBuilder ] [main] - Parsed config file: { "env" : { "parallelism" : 2, "job.mode" : "BATCH" }, "source" : [ { "plugin_name" : "Jdbc", "url" : "jdbc:mysql://xxxxxxxx:3306/xxxxxxx?useUnicode=true&useSSL=false&characterEncoding=GBK&autoReconnect=true&zeroDateTimeBehavior=convertToNull&serverTimezone=GMT%2B8&profileSQL=false&useCursorFetch=true&zeroDateTimeBehavior=CONVERT_TO_NULL&connectTimeout=3000&profileSQL=false&useCursorFetch=true&defaultFetchSize=10000&profileSQL=false&useCursorFetch=true&defaultFetchSize=10000&zeroDateTimeBehavior=CONVERT_TO_NULL&connectTimeout=3000", "driver" : "com.mysql.cj.jdbc.Driver", "user" : "xxxxxx", "password" : "xxxxxxx", "database" : "ama200_mysql_new", "table_path" : "center_notice", "query" : "SELECT * FROM center_notice WHERE system_book_code = '18527'", "fetch_size" : 1000 } ], "sink" : [ { "plugin_name" : "OssFile", "path" : "/xxx/18527/20240731102556/center_notice/center_notice", "bucket" : "oss://xxxxx", "access_key" : "LTAI4FpPV8A4HYnFJNMJdSor", "access_secret" : "xxxxxx", "endpoint" : "oss-cn-hangzhou-internal.aliyuncs.com", "file_format_type" : "parquet", "compress_codec" : "zstd", "custom_filename" : true, "batch_size" : 10000000, "file_name_expression" : "18527_center_notice_center_notice_20240731102556_${transactionId}", "is_enable_transaction" : true } ] } 2024-07-31 14:08:12,796 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load SeaTunnelSink Plugin from /home/XXX/apache-seatunnel-2.3.5/connectors 2024-07-31 14:08:12,803 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Discovery plugin jar for: PluginIdentifier{engineType='seatunnel', pluginType='source', pluginName='Jdbc'} at: file:/home/XXX/apache-seatunnel-2.3.5/connectors/connector-jdbc-2.3.5.jar 2024-07-31 14:08:12,804 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Discovery plugin jar for: PluginIdentifier{engineType='seatunnel', pluginType='sink', pluginName='OssFile'} at: file:/home/XXX/apache-seatunnel-2.3.5/connectors/connector-file-oss-2.3.5.jar 2024-07-31 14:08:12,810 INFO [p.MultipleTableJobConfigParser] [main] - start generating all sources. 2024-07-31 14:08:12,870 INFO [o.a.s.c.s.j.u.JdbcCatalogUtils] [main] - Loading catalog tables for catalog : class org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.mysql.MySqlCatalog SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder". SLF4J: Defaulting to no-operation (NOP) logger implementation SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details. 2024-07-31 14:08:13,339 INFO [.s.c.s.j.c.AbstractJdbcCatalog] [main] - Catalog MySQL established connection to jdbc:mysql://pe-bp11g4u4pxu8ed4u2.rwlb.rds.aliyuncs.com:3306/ama200_mysql_new?useUnicode=true&useSSL=false&characterEncoding=GBK&autoReconnect=true&zeroDateTimeBehavior=convertToNull&serverTimezone=GMT%2B8&profileSQL=false&useCursorFetch=true&zeroDateTimeBehavior=CONVERT_TO_NULL&connectTimeout=3000&profileSQL=false&useCursorFetch=true&defaultFetchSize=10000&profileSQL=false&useCursorFetch=true&defaultFetchSize=10000&zeroDateTimeBehavior=CONVERT_TO_NULL&connectTimeout=3000 2024-07-31 14:08:13,376 INFO [o.a.s.c.s.j.u.JdbcCatalogUtils] [main] - Loaded catalog table : center_notice, JdbcSourceTable(tablePath=center_notice, query=SELECT * FROM center_notice WHERE system_book_code = '18527', partitionColumn=null, partitionNumber=10, partitionStart=null, partitionEnd=null, catalogTable=CatalogTable{tableId=jdbc_catalog.null.center_notice, tableSchema=TableSchema(columns=[PhysicalColumn(super=Column(name=notice_id, dataType=STRING, columnLength=256, scale=null, nullable=false, defaultValue=null, comment=null, sourceType=VARCHAR, options=null, isUnsigned=false, isZeroFill=false, bitLen=2048, longColumnLength=256)), PhysicalColumn(super=Column(name=system_book_code, dataType=STRING, columnLength=80, scale=null, nullable=false, defaultValue=null, comment=null, sourceType=VARCHAR, options=null, isUnsigned=false, isZeroFill=false, bitLen=640, longColumnLength=80)), PhysicalColumn(super=Column(name=branch_num, dataType=INT, columnLength=null, scale=null, nullab le=false, defaultValue=null, comment=null, sourceType=INT, options=null, isUnsigned=false, isZeroFill=false, bitLen=0, longColumnLength=null)), PhysicalColumn(super=Column(name=notice_title, dataType=STRING, columnLength=1000, scale=null, nullable=true, defaultValue=null, comment=null, sourceType=VARCHAR, options=null, isUnsigned=false, isZeroFill=false, bitLen=8000, longColumnLength=1000)), PhysicalColumn(super=Column(name=notice_context, dataType=STRING, columnLength=4294967295, scale=null, nullable=false, defaultValue=null, comment=null, sourceType=LONGTEXT, options=null, isUnsigned=false, isZeroFill=false, bitLen=34359738360, longColumnLength=4294967295)), PhysicalColumn(super=Column(name=notice_create_time, dataType=TIMESTAMP, columnLength=null, scale=0, nullable=false, defaultValue=null, comment=null, sourceType=DATETIME, options=null, isUnsigned=false, isZeroFill=false, bitLen=0, longColumnLength=null)), PhysicalColumn(super=Column(name=notice_creator, dataType=STRING, column Length=200, scale=null, nullable=false, defaultValue=null, comment=null, sourceType=VARCHAR, options=null, isUnsigned=false, isZeroFill=false, bitLen=1600, longColumnLength=200)), PhysicalColumn(super=Column(name=notice_auditor, dataType=STRING, columnLength=200, scale=null, nullable=true, defaultValue=null, comment=null, sourceType=VARCHAR, options=null, isUnsigned=false, isZeroFill=false, bitLen=1600, longColumnLength=200)), PhysicalColumn(super=Column(name=notice_cancelor, dataType=STRING, columnLength=200, scale=null, nullable=true, defaultValue=null, comment=null, sourceType=VARCHAR, options=null, isUnsigned=false, isZeroFill=false, bitLen=1600, longColumnLength=200)), PhysicalColumn(super=Column(name=notice_expire_day, dataType=TIMESTAMP, columnLength=null, scale=0, nullable=true, defaultValue=null, comment=null, sourceType=DATETIME, options=null, isUnsigned=false, isZeroFill=false, bitLen=0, longColumnLength=null)), PhysicalColumn(super=Column(name=notice_state_code, dataType =INT, columnLength=null, scale=null, nullable=false, defaultValue=null, comment=null, sourceType=INT, options=null, isUnsigned=false, isZeroFill=false, bitLen=0, longColumnLength=null)), PhysicalColumn(super=Column(name=notice_state_name, dataType=STRING, columnLength=800, scale=null, nullable=false, defaultValue=null, comment=null, sourceType=VARCHAR, options=null, isUnsigned=false, isZeroFill=false, bitLen=6400, longColumnLength=800)), PhysicalColumn(super=Column(name=notice_audit_time, dataType=TIMESTAMP, columnLength=null, scale=0, nullable=true, defaultValue=null, comment=null, sourceType=DATETIME, options=null, isUnsigned=false, isZeroFill=false, bitLen=0, longColumnLength=null)), PhysicalColumn(super=Column(name=notice_cancel_time, dataType=TIMESTAMP, columnLength=null, scale=0, nullable=true, defaultValue=null, comment=null, sourceType=DATETIME, options=null, isUnsigned=false, isZeroFill=false, bitLen=0, longColumnLength=null)), PhysicalColumn(super=Column(name=notice_type, dataType=STRING, columnLength=200, scale=null, nullable=true, defaultValue=null, comment=null, sourceType=VARCHAR, options=null, isUnsigned=false, isZeroFill=false, bitLen=1600, longColumnLength=200)), PhysicalColumn(super=Column(name=notice_category, dataType=STRING, columnLength=80, scale=null, nullable=true, defaultValue=null, comment=null, sourceType=VARCHAR, options=null, isUnsigned=false, isZeroFill=false, bitLen=640, longColumnLength=80)), PhysicalColumn(super=Column(name=notice_pop, dataType=TINYINT, columnLength=null, scale=null, nullable=true, defaultValue=null, comment=null, sourceType=TINYINT, options=null, isUnsigned=false, isZeroFill=false, bitLen=0, longColumnLength=null)), PhysicalColumn(super=Column(name=aged_timestamp, dataType=TIMESTAMP, columnLength=null, scale=0, nullable=true, defaultValue=null, comment=null, sourceType=DATETIME, options=null, isUnsigned=false, isZeroFill=false, bitLen=0, longColumnLength=null)), PhysicalColumn(super=Column(name=notice_top, dat aType=TINYINT, columnLength=null, scale=null, nullable=true, defaultValue=null, comment=null, sourceType=TINYINT, options=null, isUnsigned=false, isZeroFill=false, bitLen=0, longColumnLength=null)), PhysicalColumn(super=Column(name=notice_top_time, dataType=TIMESTAMP, columnLength=null, scale=0, nullable=true, defaultValue=null, comment=null, sourceType=DATETIME, options=null, isUnsigned=false, isZeroFill=false, bitLen=0, longColumnLength=null)), PhysicalColumn(super=Column(name=notice_cycle_flag, dataType=TINYINT, columnLength=null, scale=null, nullable=true, defaultValue=null, comment=null, sourceType=TINYINT, options=null, isUnsigned=false, isZeroFill=false, bitLen=0, longColumnLength=null)), PhysicalColumn(super=Column(name=notice_cycle_time, dataType=TIME, columnLength=null, scale=0, nullable=true, defaultValue=null, comment=null, sourceType=TIME, options=null, isUnsigned=false, isZeroFill=false, bitLen=0, longColumnLength=null))], primaryKey=null, constraintKeys=[]), options={ }, partitionKeys=[], comment='', catalogName='jdbc_catalog'}) 2024-07-31 14:08:13,377 INFO [o.a.s.c.s.j.u.JdbcCatalogUtils] [main] - Loaded 1 catalog tables for catalog : class org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.mysql.MySqlCatalog 2024-07-31 14:08:13,382 INFO [.s.c.s.j.c.AbstractJdbcCatalog] [main] - Catalog MySQL closing 2024-07-31 14:08:13,382 INFO [o.a.s.a.t.f.FactoryUtil ] [main] - get the CatalogTable from source Jdbc: jdbc_catalog.null.center_notice 2024-07-31 14:08:13,395 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load SeaTunnelSource Plugin from /home/XXX/apache-seatunnel-2.3.5/connectors 2024-07-31 14:08:13,399 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Discovery plugin jar for: PluginIdentifier{engineType='seatunnel', pluginType='source', pluginName='Jdbc'} at: file:/home/XXX/apache-seatunnel-2.3.5/connectors/connector-jdbc-2.3.5.jar 2024-07-31 14:08:13,402 INFO [p.MultipleTableJobConfigParser] [main] - start generating all transforms. 2024-07-31 14:08:13,402 INFO [p.MultipleTableJobConfigParser] [main] - start generating all sinks. 2024-07-31 14:08:13,405 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load SeaTunnelSink Plugin from /home/XXX/apache-seatunnel-2.3.5/connectors 2024-07-31 14:08:13,406 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Discovery plugin jar for: PluginIdentifier{engineType='seatunnel', pluginType='sink', pluginName='OssFile'} at: file:/home/XXX/apache-seatunnel-2.3.5/connectors/connector-file-oss-2.3.5.jar 2024-07-31 14:08:13,485 INFO [o.a.s.e.c.j.ClientJobProxy ] [main] - Start submit job, job id: 870910704293511169, with plugin jar [file:/home/XXX/apache-seatunnel-2.3.5/connectors/connector-file-oss-2.3.5.jar, file:/home/XXX/apache-seatunnel-2.3.5/connectors/connector-jdbc-2.3.5.jar] 2024-07-31 14:08:13,494 INFO [o.a.s.e.c.j.ClientJobProxy ] [main] - Submit job finished, job id: 870910704293511169, job name: SeaTunnel_Job 2024-07-31 14:08:13,513 WARN [o.a.s.e.c.j.JobMetricsRunner ] [job-metrics-runner-870910704293511169] - Failed to get job metrics summary, it maybe first-run 2024-07-31 14:08:14,937 INFO [o.a.s.e.c.j.ClientJobProxy ] [main] - Job (870910704293511169) end with state FAILED 2024-07-31 14:08:14,938 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is SHUTTING_DOWN 2024-07-31 14:08:14,941 INFO [.c.i.c.ClientConnectionManager] [main] - hz.client_1 [seatunnel] [5.1] Removed connection to endpoint: [localhost]:5801:f04d5b52-efa6-41ab-aacd-6673e6a21d4c, connection: ClientConnection{alive=false, connectionId=1, channel=NioChannel{/127.0.0.1:62778->localhost/127.0.0.1:5801}, remoteAddress=[localhost]:5801, lastReadTime=2024-07-31 14:08:14.924, lastWriteTime=2024-07-31 14:08:13.501, closedTime=2024-07-31 14:08:14.939, connected server version=5.1} 2024-07-31 14:08:14,941 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is CLIENT_DISCONNECTED 2024-07-31 14:08:14,943 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is SHUTDOWN 2024-07-31 14:08:14,943 INFO [s.c.s.s.c.ClientExecuteCommand] [main] - Closed SeaTunnel client...... 2024-07-31 14:08:14,944 INFO [s.c.s.s.c.ClientExecuteCommand] [main] - Closed metrics executor service ...... 2024-07-31 14:08:14,944 ERROR [o.a.s.c.s.SeaTunnel ] [main] - =============================================================================== 2024-07-31 14:08:14,944 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Fatal Error, 2024-07-31 14:08:14,944 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Please submit bug report in https://github.com/apache/seatunnel/issues 2024-07-31 14:08:14,944 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Reason:SeaTunnel job executed failed 2024-07-31 14:08:14,945 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.engine.common.exception.SeaTunnelEngineException: java.lang.RuntimeException: java.lang.RuntimeException: org.apache.seatunnel.common.exception.SeaTunnelRuntimeException: ErrorCode:[COMMON-23], ErrorDescription:[FileConnector write SeaTunnelRow failed, the SeaTunnelRow value is 'SeaTunnelRow{tableId=center_notice, kind=+I, fields=[1852700991000001, 18527, 99, 短信模版调整通知, 尊敬的XXX用户，您好！<br>根据工信部的最新要求，营销类短信的退订方式统一修改为“拒收请回复R”。当前阿里云短信平台已经开始分区域拦截没有按规则修改的短信。XXX零售管理系统会在2024年1月1日前，逐步停止末尾没有“拒收请回复R”的营销类短信的使用，请您尽快重新申请。XXX零售管理系统已完成功能升级，请尽快按照以下方式修改营销类短信模板：<br><ol><li> 营销类短信模板申请：末尾无需加退订方式，系统会自动为� �添加“拒收请回复R”字样。（拒收字样会计入短信字数）</li><li> 已审核通过的营销类短信模板：阿里云短信不支持申请通过的短信进行编辑修改，故需重新申请。申请流程：消息中心-短信-短信模版-新增，按规范填入短信内容即可。</li><li> 短信模版停止应用后，使用该模版的营销活动会下架，请您注意及时调整营销活动。</li></ol><p></p>感谢您的支持与配合！<br>XXX零售, 2023-12-28T15:59:55.772, 管理员, 管理员, null, 2024-01-27T15:59:55, 3, 制单|审核, 2023-12-28T15:59:55.814, null, 001, 加盟店网上公告, 1, null, null, null, null, null]}'.] at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:262) at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:68) at org.apache.seatunnel.engine.server.task.SeaTunnelTransformCollector.collect(SeaTunnelTransformCollector.java:39) at org.apache.seatunnel.engine.server.task.SeaTunnelTransformCollector.collect(SeaTunnelTransformCollector.java:27) at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.handleRecord(IntermediateBlockingQueue.java:70) at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.collect(IntermediateBlockingQueue.java:50) at org.apache.seatunnel.engine.server.task.flow.IntermediateQueueFlowLifeCycle.collect(IntermediateQueueFlowLifeCycle.java:51) at org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.collect(TransformSeaTunnelTask.java:73) at org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:168) at org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.call(TransformSeaTunnelTask.java:78) at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:703) at org.apache.seatunnel.engine.server.TaskExecutionService$NamedTaskWrapper.run(TaskExecutionService.java:1004) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) 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) Caused by: java.lang.RuntimeException: org.apache.seatunnel.common.exception.SeaTunnelRuntimeException: ErrorCode:[COMMON-23], ErrorDescription:[FileConnector write SeaTunnelRow failed, the SeaTunnelRow value is 'SeaTunnelRow{tableId=center_notice, kind=+I, fields=[1852700991000001, 18527, 99, 短信模版调整通知, 尊敬的XXX用户，您好！<br>根据工信部的最新要求，营销类短信的退订方式统一修改为“拒收请回复R”。当前阿里云短信平台已经开始分区域拦截没有按规则修改的短信。XXX零售管理系统会在2024年1月1日前，逐步停止末尾没有“拒收请回复R”的营销类短信的使用，请您尽快重新申请。XXX零售管理系统已完成功能升级，请尽快按照以下方式修改营销类短信模板：<br><ol><li> 营销类短信模板申请：末尾无需加退订方式，系统会自动为您添加“拒收请回复R”字样。（拒收字样会计入短信字数）</li><li> 已审� ��通过的营销类短信模板：阿里云短信不支持申请通过的短信进行编辑修改，故需重新申请。申请流程：消息中心-短信-短信模版-新增，按规范填入短信内容即可。</li><li> 短信模版停止应用后，使用该模版的营销活动会下架，请您注意及时调整营销活动。</li></ol><p></p>感谢您的支持与配合！<br>XXX零售, 2023-12-28T15:59:55.772, 管理员, 管理员, null, 2024-01-27T15:59:55, 3, 制单|审核, 2023-12-28T15:59:55.814, null, 001, 加盟店网上公告, 1, null, null, null, null, null]}'.] at org.apache.seatunnel.connectors.seatunnel.common.multitablesink.MultiTableSinkWriter.subSinkErrorCheck(MultiTableSinkWriter.java:121) at org.apache.seatunnel.connectors.seatunnel.common.multitablesink.MultiTableSinkWriter.prepareCommit(MultiTableSinkWriter.java:201) at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:191) ... 16 more Caused by: org.apache.seatunnel.common.exception.SeaTunnelRuntimeException: ErrorCode:[COMMON-23], ErrorDescription:[FileConnector write SeaTunnelRow failed, the SeaTunnelRow value is 'SeaTunnelRow{tableId=center_notice, kind=+I, fields=[1852700991000001, 18527, 99, 短信模版调整通知, 尊敬的XXX用户，您好！<br>根据工信部的最新要求，营销类短信的退订方式统一修改为“拒收请回复R”。当前阿里云短信平台已经开始分区域拦截没有按规则修改的短信。XXX零售管理系统会在2024年1月1日前，逐步停止末尾没有“拒收请回复R”的营销类短信的使用，请您尽快重新申请。XXX零售管理系统已完成功能升级，请尽快按照以下方式修改营销类短信模板：<br><ol><li> 营销类短信模板申请：末尾无需加退订方式，系统会自动为您添加“拒收请回复R”字样。（拒收字样会计入短信字数）</li><li> 已审核通过的营销类短信� �板：阿里云短信不支持申请通过的短信进行编辑修改，故需重新申请。申请流程：消息中心-短信-短信模版-新增，按规范填入短信内容即可。</li><li> 短信模版停止应用后，使用该模版的营销活动会下架，请您注意及时调整营销活动。</li></ol><p></p>感谢您的支持与配合！<br>XXX零售, 2023-12-28T15:59:55.772, 管理员, 管理员, null, 2024-01-27T15:59:55, 3, 制单|审核, 2023-12-28T15:59:55.814, null, 001, 加盟店网上公告, 1, null, null, null, null, null]}'.] at org.apache.seatunnel.common.exception.CommonError.writeSeaTunnelRowFailed(CommonError.java:86) at org.apache.seatunnel.connectors.seatunnel.file.sink.BaseFileSinkWriter.write(BaseFileSinkWriter.java:136) at org.apache.seatunnel.connectors.seatunnel.file.sink.BaseFileSinkWriter.write(BaseFileSinkWriter.java:46) at org.apache.seatunnel.connectors.seatunnel.common.multitablesink.MultiTableWriterRunnable.run(MultiTableWriterRunnable.java:62) ... 5 more Caused by: org.apache.seatunnel.connectors.seatunnel.file.exception.FileConnectorException: ErrorCode:[COMMON-07], ErrorDescription:[Unsupported data type] - SeaTunnel file connector is not supported for this data type [TIME] at org.apache.seatunnel.connectors.seatunnel.file.sink.writer.ParquetWriteStrategy.seaTunnelDataType2ParquetDataType(ParquetWriteStrategy.java:334) at org.apache.seatunnel.connectors.seatunnel.file.sink.writer.ParquetWriteStrategy.lambda$buildAvroSchemaWithRowType$2(ParquetWriteStrategy.java:347) at java.util.ArrayList.forEach(ArrayList.java:1259) at org.apache.seatunnel.connectors.seatunnel.file.sink.writer.ParquetWriteStrategy.buildAvroSchemaWithRowType(ParquetWriteStrategy.java:344) at org.apache.seatunnel.connectors.seatunnel.file.sink.writer.ParquetWriteStrategy.getOrCreateWriter(ParquetWriteStrategy.java:133) at org.apache.seatunnel.connectors.seatunnel.file.sink.writer.ParquetWriteStrategy.write(ParquetWriteStrategy.java:95) at org.apache.seatunnel.connectors.seatunnel.file.sink.BaseFileSinkWriter.write(BaseFileSinkWriter.java:134) ... 7 more at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:194) ... 2 more 2024-07-31 14:08:14,945 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.engine.common.exception.SeaTunnelEngineException: java.lang.RuntimeException: java.lang.RuntimeException: org.apache.seatunnel.common.exception.SeaTunnelRuntimeException: ErrorCode:[COMMON-23], ErrorDescription:[FileConnector write SeaTunnelRow failed, the SeaTunnelRow value is 'SeaTunnelRow{tableId=center_notice, kind=+I, fields=[1852700991000001, 18527, 99, 短信模版调整通知, 尊敬的XXX用户，您好！<br>根据工信部的最新要求，营销类短信的退订方式统一修改为“拒收请回复R”。当前阿里云短信平台已经开始分区域拦截没有按规则修改的短信。XXX零售管理系统会在2024年1月1日前，逐步停止末尾没有“拒收请回复R”的营销类短信的使用，请您尽快重新申请。XXX零售管理系统已完成功能升级，请尽快按照以下方式修改营销类短信模板：<br><ol><li> 营销类短信模板申请：末尾无需加退订方式，系统会自动为� �添加“拒收请回复R”字样。（拒收字样会计入短信字数）</li><li> 已审核通过的营销类短信模板：阿里云短信不支持申请通过的短信进行编辑修改，故需重新申请。申请流程：消息中心-短信-短信模版-新增，按规范填入短信内容即可。</li><li> 短信模版停止应用后，使用该模版的营销活动会下架，请您注意及时调整营销活动。</li></ol><p></p>感谢您的支持与配合！<br>XXX零售, 2023-12-28T15:59:55.772, 管理员, 管理员, null, 2024-01-27T15:59:55, 3, 制单|审核, 2023-12-28T15:59:55.814, null, 001, 加盟店网上公告, 1, null, null, null, null, null]}'.] at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:262) at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:68) at org.apache.seatunnel.engine.server.task.SeaTunnelTransformCollector.collect(SeaTunnelTransformCollector.java:39) at org.apache.seatunnel.engine.server.task.SeaTunnelTransformCollector.collect(SeaTunnelTransformCollector.java:27) at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.handleRecord(IntermediateBlockingQueue.java:70) at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.collect(IntermediateBlockingQueue.java:50) at org.apache.seatunnel.engine.server.task.flow.IntermediateQueueFlowLifeCycle.collect(IntermediateQueueFlowLifeCycle.java:51) at org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.collect(TransformSeaTunnelTask.java:73) at org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:168) at org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.call(TransformSeaTunnelTask.java:78) at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:703) at org.apache.seatunnel.engine.server.TaskExecutionService$NamedTaskWrapper.run(TaskExecutionService.java:1004) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) 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) Caused by: java.lang.RuntimeException: org.apache.seatunnel.common.exception.SeaTunnelRuntimeException: ErrorCode:[COMMON-23], ErrorDescription:[FileConnector write SeaTunnelRow failed, the SeaTunnelRow value is 'SeaTunnelRow{tableId=center_notice, kind=+I, fields=[1852700991000001, 18527, 99, 短信模版调整通知, 尊敬的XXX用户，您好！<br>根据工信部的最新要求，营销类短信的退订方式统一修改为“拒收请回复R”。当前阿里云短信平台已经开始分区域拦截没有按规则修改的短信。XXX零售管理系统会在2024年1月1日前，逐步停止末尾没有“拒收请回复R”的营销类短信的使用，请您尽快重新申请。XXX零售管理系统已完成功能升级，请尽快按照以下方式修改营销类短信模板：<br><ol><li> 营销类短信模板申请：末尾无需加退订方式，系统会自动为您添加“拒收请回复R”字样。（拒收字样会计入短信字数）</li><li> 已审� ��通过的营销类短信模板：阿里云短信不支持申请通过的短信进行编辑修改，故需重新申请。申请流程：消息中心-短信-短信模版-新增，按规范填入短信内容即可。</li><li> 短信模版停止应用后，使用该模版的营销活动会下架，请您注意及时调整营销活动。</li></ol><p></p>感谢您的支持与配合！<br>XXX零售, 2023-12-28T15:59:55.772, 管理员, 管理员, null, 2024-01-27T15:59:55, 3, 制单|审核, 2023-12-28T15:59:55.814, null, 001, 加盟店网上公告, 1, null, null, null, null, null]}'.] at org.apache.seatunnel.connectors.seatunnel.common.multitablesink.MultiTableSinkWriter.subSinkErrorCheck(MultiTableSinkWriter.java:121) at org.apache.seatunnel.connectors.seatunnel.common.multitablesink.MultiTableSinkWriter.prepareCommit(MultiTableSinkWriter.java:201) at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:191) ... 16 more Caused by: org.apache.seatunnel.common.exception.SeaTunnelRuntimeException: ErrorCode:[COMMON-23], ErrorDescription:[FileConnector write SeaTunnelRow failed, the SeaTunnelRow value is 'SeaTunnelRow{tableId=center_notice, kind=+I, fields=[1852700991000001, 18527, 99, 短信模版调整通知, 尊敬的XXX用户，您好！<br>根据工信部的最新要求，营销类短信的退订方式统一修改为“拒收请回复R”。当前阿里云短信平台已经开始分区域拦截没有按规则修改的短信。XXX零售管理系统会在2024年1月1日前，逐步停止末尾没有“拒收请回复R”的营销类短信的使用，请您尽快重新申请。XXX零售管理系统已完成功能升级，请尽快按照以下方式修改营销类短信模板：<br><ol><li> 营销类短信模板申请：末尾无需加退订方式，系统会自动为您添加“拒收请回复R”字样。（拒收字样会计入短信字数）</li><li> 已审核通过的营销类短信� �板：阿里云短信不支持申请通过的短信进行编辑修改，故需重新申请。申请流程：消息中心-短信-短信模版-新增，按规范填入短信内容即可。</li><li> 短信模版停止应用后，使用该模版的营销活动会下架，请您注意及时调整营销活动。</li></ol><p></p>感谢您的支持与配合！<br>XXX零售, 2023-12-28T15:59:55.772, 管理员, 管理员, null, 2024-01-27T15:59:55, 3, 制单|审核, 2023-12-28T15:59:55.814, null, 001, 加盟店网上公告, 1, null, null, null, null, null]}'.] at org.apache.seatunnel.common.exception.CommonError.writeSeaTunnelRowFailed(CommonError.java:86) at org.apache.seatunnel.connectors.seatunnel.file.sink.BaseFileSinkWriter.write(BaseFileSinkWriter.java:136) at org.apache.seatunnel.connectors.seatunnel.file.sink.BaseFileSinkWriter.write(BaseFileSinkWriter.java:46) at org.apache.seatunnel.connectors.seatunnel.common.multitablesink.MultiTableWriterRunnable.run(MultiTableWriterRunnable.java:62) ... 5 more Caused by: org.apache.seatunnel.connectors.seatunnel.file.exception.FileConnectorException: ErrorCode:[COMMON-07], ErrorDescription:[Unsupported data type] - SeaTunnel file connector is not supported for this data type [TIME] at org.apache.seatunnel.connectors.seatunnel.file.sink.writer.ParquetWriteStrategy.seaTunnelDataType2ParquetDataType(ParquetWriteStrategy.java:334) at org.apache.seatunnel.connectors.seatunnel.file.sink.writer.ParquetWriteStrategy.lambda$buildAvroSchemaWithRowType$2(ParquetWriteStrategy.java:347) at java.util.ArrayList.forEach(ArrayList.java:1259) at org.apache.seatunnel.connectors.seatunnel.file.sink.writer.ParquetWriteStrategy.buildAvroSchemaWithRowType(ParquetWriteStrategy.java:344) at org.apache.seatunnel.connectors.seatunnel.file.sink.writer.ParquetWriteStrategy.getOrCreateWriter(ParquetWriteStrategy.java:133) at org.apache.seatunnel.connectors.seatunnel.file.sink.writer.ParquetWriteStrategy.write(ParquetWriteStrategy.java:95) at org.apache.seatunnel.connectors.seatunnel.file.sink.BaseFileSinkWriter.write(BaseFileSinkWriter.java:134) ... 7 more at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:194) ... 2 more 2024-07-31 14:08:14,947 INFO [s.c.s.s.c.ClientExecuteCommand] [ForkJoinPool.commonPool-worker-9] - run shutdown hook because get close signal ``` ### Zeta or Flink or Spark Version Zeta ### Java or Scala Version 1.8 ### 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]
