nihaobienao opened a new issue, #8452: URL: https://github.com/apache/seatunnel/issues/8452
### 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  DDL: -- SMART_CITOS.SHIP_WORK_UNIT definition CREATE TABLE "SMART_CITOS"."SHIP_WORK_UNIT" ( "WORK_UNIT_ID" VARCHAR2(36 CHAR) NOT NULL ENABLE, "WORK_UNIT_NO" VARCHAR2(36 CHAR) NOT NULL ENABLE, "SHIP_VISIT_NO" VARCHAR2(20 CHAR) NOT NULL ENABLE, "IMP_EXP_MARK" VARCHAR2(10 CHAR) NOT NULL ENABLE, "LINE_RLS_NO" VARCHAR2(50 CHAR), "UNIT_SPECIFIED" VARCHAR2(1 CHAR) DEFAULT '0' NOT NULL ENABLE, "UNSPECIFIED_NO" VARCHAR2(20 CHAR) DEFAULT '0' NOT NULL ENABLE, "UNIT_CLASS" VARCHAR2(10 CHAR) DEFAULT 'CN' NOT NULL ENABLE, "UNIT_VISIT_NO" VARCHAR2(20 CHAR), "UNIT_NO" VARCHAR2(40 CHAR), "UNIT_ISO_CODE" VARCHAR2(10 CHAR) NOT NULL ENABLE, "UNIT_SIZE_CODE" VARCHAR2(10 CHAR) NOT NULL ENABLE, "UNIT_TYPE_CODE" VARCHAR2(10 CHAR) NOT NULL ENABLE, "UNIT_HEIGHT_CODE" VARCHAR2(10 CHAR) NOT NULL ENABLE, "EMPTY_FULL_MARK" VARCHAR2(10 CHAR) NOT NULL ENABLE, "UNIT_GRADE_CODE" VARCHAR2(20 CHAR), "UNIT_OWNER_CODE" VARCHAR2(20 CHAR), "UNIT_OPERATOR_CODE" VARCHAR2(20 CHAR), "UNIT_AGENT_CODE" VARCHAR2(20 CHAR), "UNIT_GROSS_WGT" NUMBER(14,5), "UNIT_TARE_WGT" NUMBER(14,5), "ON_SHIP_POSITION" VARCHAR2(20 CHAR), "PLAN_ON_SHIP_POSITION" VARCHAR2(20 CHAR), "STOW_REQUIRES" VARCHAR2(2000 CHAR), "BILL_NO" VARCHAR2(50 CHAR), "BOOKING_NO" VARCHAR2(50 CHAR), "TRADE_TYPE" VARCHAR2(20 CHAR) NOT NULL ENABLE, "ORIGINAL_LOC_CODE" VARCHAR2(20 CHAR), "ORIGINAL_LOC_NAME" VARCHAR2(200 CHAR), "ORIGINAL_POL_CODE" VARCHAR2(20 CHAR), "POL_CODE" VARCHAR2(20 CHAR) NOT NULL ENABLE, "POD_CODE" VARCHAR2(20 CHAR) NOT NULL ENABLE, "SECOND_POD_CODE" VARCHAR2(20 CHAR), "FINAL_POD_CODE" VARCHAR2(20 CHAR), "ONCARRIAGE_LOC_CODE" VARCHAR2(20 CHAR), "ONCARRIAGE_LOC_NAME" VARCHAR2(200 CHAR), "UNIT_CATEGORY" VARCHAR2(10 CHAR) NOT NULL ENABLE, "TRANSSHIPMENT_MARK" VARCHAR2(1 CHAR) DEFAULT '0' NOT NULL ENABLE, "TRANS_TYPE_CODE" VARCHAR2(20 CHAR), "SHIPPING_TYPE_CODE" VARCHAR2(20 CHAR), "DECLARE_SHIP_CODE" VARCHAR2(20 CHAR), "DECLARE_SHIP_NAME" VARCHAR2(200 CHAR), "DECLARE_VOYAGE" VARCHAR2(20 CHAR), "DECLARE_UNIT_OPER_CODE" VARCHAR2(20 CHAR), "NEXT_SERVICE_CODE" VARCHAR2(20 CHAR), "NEXT_VISIT_NO" VARCHAR2(20 CHAR), "SEAL_NO1" VARCHAR2(80 CHAR), "SEAL_NO2" VARCHAR2(80 CHAR), "SEAL_NO3" VARCHAR2(80 CHAR), "SEAL_NO4" VARCHAR2(80 CHAR), "LCL_MARK" VARCHAR2(1 CHAR) DEFAULT '0' NOT NULL ENABLE, "HAZARD_MARK" VARCHAR2(1 CHAR) DEFAULT '0' NOT NULL ENABLE, "IMDG_CODE" VARCHAR2(5 CHAR), "UNDG_NO" VARCHAR2(10 CHAR), "HAZARDS" VARCHAR2(2000 CHAR), "REEFER_MARK" VARCHAR2(1 CHAR) DEFAULT '0' NOT NULL ENABLE, "TEMP_UNIT" VARCHAR2(10 CHAR), "TEMP_SET" NUMBER(10,3), "MIN_TEMP" NUMBER(10,3), "MAX_TEMP" NUMBER(10,3), "VENTILATION" NUMBER(10,3), "VENTILATION_UNIT" VARCHAR2(10 CHAR), "HUMIDITY" NUMBER(10,3), "OOG_MARK" VARCHAR2(1 CHAR) DEFAULT '0' NOT NULL ENABLE, "OOG_LEFT" NUMBER(10,2), "OOG_RIGHT" NUMBER(10,2), "OOG_FRONT" NUMBER(10,2), "OOG_BACK" NUMBER(10,2), "OOG_HIGH" NUMBER(10,2), "UNIT_FEATURES" VARCHAR2(2000 CHAR), "UNIT_CONDITIONS" VARCHAR2(2000 CHAR), "BUNDLED_MARK" VARCHAR2(1 CHAR) DEFAULT '0' NOT NULL ENABLE, "PARENT_UNIT_VISIT_NO" VARCHAR2(20 CHAR), "CLEARANCE_TYPE_CODE" VARCHAR2(20 CHAR), "DAMAGE_MARK" VARCHAR2(1 CHAR) DEFAULT '0' NOT NULL ENABLE, "DAMAGES" VARCHAR2(2000 CHAR) DEFAULT '0', "CARGO_CODE" VARCHAR2(20 CHAR), "CARGO_NAME" VARCHAR2(2000 CHAR), "CARGO_LABEL" VARCHAR2(2000 CHAR), "PACKAGE_UNIT_CODE" VARCHAR2(20 CHAR), "CARGO_QTY" NUMBER(10,0), "CARGO_VOLUME" NUMBER(14,5), "DELIVERY_CLAUSE_CODE" VARCHAR2(20 CHAR), "OVERLANDED_MARK" VARCHAR2(1 CHAR) DEFAULT '0' NOT NULL ENABLE, "WORK_TYPE" VARCHAR2(20 CHAR), "WORK_FLOW_CODE" VARCHAR2(20 CHAR), "WORK_METHOD_CODE" VARCHAR2(20 CHAR), "DREDGE_MARK" VARCHAR2(1 CHAR) DEFAULT '0' NOT NULL ENABLE, "DIFFICULT_TYPE_CODE" VARCHAR2(20 CHAR) DEFAULT '0' NOT NULL ENABLE, "WORK_QUEUE_NO" VARCHAR2(40 CHAR), "WORK_QUEUE_NAME" VARCHAR2(100 CHAR), "WORK_MOVE_NO" VARCHAR2(40 CHAR), "SEND_TIME" TIMESTAMP (6), "SENDER_NO" VARCHAR2(20 CHAR), "SHIP_CRANE_NO" VARCHAR2(20 CHAR), "SHIP_CRANE_DRIVER_NO" VARCHAR2(20 CHAR), "SHIP_CRANE_WORK_MODE" VARCHAR2(10 CHAR), "QUAY_ARRIVE_TIME" TIMESTAMP (6), "QUAY_WORK_TIME" TIMESTAMP (6) NOT NULL ENABLE, "QUAY_DEPART_TIME" TIMESTAMP (6), "QUAY_TALLYMAN_NO" VARCHAR2(20 CHAR), "QUAY_TWIN_NO" VARCHAR2(36 CHAR), "TRUCK_VISIT_NO" VARCHAR2(20 CHAR), "TRUCK_NO" VARCHAR2(20 CHAR), "TRUCK_DRIVER_NO" VARCHAR2(20 CHAR), "ON_TRUCK_POSITION" VARCHAR2(10 CHAR), "YARD_CRANE_NO" VARCHAR2(20 CHAR), "YARD_CRANE_DRIVER_NO" VARCHAR2(20 CHAR), "YARD_CRANE_WORK_MODE" VARCHAR2(10 CHAR), "YARD_ARRIVE_TIME" TIMESTAMP (6), "YARD_WORK_TIME" TIMESTAMP (6), "YARD_DEPART_TIME" TIMESTAMP (6), "YARD_TALLYMAN_NO" VARCHAR2(20 CHAR), "YARD_TWIN_NO" VARCHAR2(36 CHAR), "ON_YARD_POSITION" VARCHAR2(20 CHAR), "PLAN_ON_YARD_POSITION" VARCHAR2(20 CHAR), "ROLLBACK_MARK" VARCHAR2(1 CHAR) DEFAULT '0', "NOTES" VARCHAR2(4000 CHAR), "FACILITY_ID" VARCHAR2(36 CHAR) DEFAULT '0' NOT NULL ENABLE, "CREATOR" VARCHAR2(36 CHAR) NOT NULL ENABLE, "CREATED_ON" TIMESTAMP (6) NOT NULL ENABLE, "CHANGER" VARCHAR2(36 CHAR) NOT NULL ENABLE, "CHANGED_ON" TIMESTAMP (6) NOT NULL ENABLE, "WORK_SHIFT_NO" VARCHAR2(20 CHAR), "PROJECT_CARGO_CODE" VARCHAR2(20 CHAR), "TRANSPORT_FEE_ID" VARCHAR2(1 CHAR) DEFAULT '0', "LAST_PORT_CODE" VARCHAR2(20), SUPPLEMENTAL LOG DATA (FOREIGN KEY) COLUMNS, SUPPLEMENTAL LOG DATA (PRIMARY KEY) COLUMNS, SUPPLEMENTAL LOG DATA (UNIQUE INDEX) COLUMNS, SUPPLEMENTAL LOG GROUP "GGS_78100" ("WORK_UNIT_ID") ALWAYS ) SEGMENT CREATION IMMEDIATE PCTFREE 10 PCTUSED 40 INITRANS 1 MAXTRANS 255 NOCOMPRESS LOGGING STORAGE(INITIAL 65536 NEXT 1048576 MINEXTENTS 1 MAXEXTENTS 2147483645 PCTINCREASE 0 FREELISTS 1 FREELIST GROUPS 1 BUFFER_POOL DEFAULT FLASH_CACHE DEFAULT CELL_FLASH_CACHE DEFAULT) TABLESPACE "CITOS_SPA" NO INMEMORY ; CREATE UNIQUE INDEX "SMART_CITOS"."PK_SHIP_WORK_UNIT" ON "SMART_CITOS"."SHIP_WORK_UNIT" ("WORK_UNIT_ID") PCTFREE 10 INITRANS 2 MAXTRANS 255 COMPUTE STATISTICS NOLOGGING STORAGE(INITIAL 65536 NEXT 1048576 MINEXTENTS 1 MAXEXTENTS 2147483645 PCTINCREASE 0 FREELISTS 1 FREELIST GROUPS 1 BUFFER_POOL DEFAULT FLASH_CACHE DEFAULT CELL_FLASH_CACHE DEFAULT) TABLESPACE "CITOS_SPA" ; ALTER TABLE "SMART_CITOS"."SHIP_WORK_UNIT" ADD CONSTRAINT "PK_SHIP_WORK_UNIT" PRIMARY KEY ("WORK_UNIT_ID") USING INDEX "SMART_CITOS"."PK_SHIP_WORK_UNIT" ENABLE; CREATE INDEX "SMART_CITOS"."IDX_SHIP_WORK_UNIT_02" ON "SMART_CITOS"."SHIP_WORK_UNIT" ("FACILITY_ID", "SHIP_VISIT_NO", "IMP_EXP_MARK", "UNIT_VISIT_NO") PCTFREE 10 INITRANS 2 MAXTRANS 255 COMPUTE STATISTICS NOLOGGING STORAGE(INITIAL 65536 NEXT 1048576 MINEXTENTS 1 MAXEXTENTS 2147483645 PCTINCREASE 0 FREELISTS 1 FREELIST GROUPS 1 BUFFER_POOL DEFAULT FLASH_CACHE DEFAULT CELL_FLASH_CACHE DEFAULT) TABLESPACE "CITOS_SPA" ; CREATE INDEX "SMART_CITOS"."IDX_SHIP_WORK_UNIT" ON "SMART_CITOS"."SHIP_WORK_UNIT" ("SHIP_VISIT_NO", "IMP_EXP_MARK", "UNIT_VISIT_NO", "FACILITY_ID") PCTFREE 10 INITRANS 2 MAXTRANS 255 COMPUTE STATISTICS NOLOGGING STORAGE(INITIAL 65536 NEXT 1048576 MINEXTENTS 1 MAXEXTENTS 2147483645 PCTINCREASE 0 FREELISTS 1 FREELIST GROUPS 1 BUFFER_POOL DEFAULT FLASH_CACHE DEFAULT CELL_FLASH_CACHE DEFAULT) TABLESPACE "CITOS_SPA" ; CREATE INDEX "SMART_CITOS"."IDX_WORK_SHIFT" ON "SMART_CITOS"."SHIP_WORK_UNIT" ("WORK_SHIFT_NO", "FACILITY_ID") PCTFREE 10 INITRANS 2 MAXTRANS 255 COMPUTE STATISTICS NOLOGGING STORAGE(INITIAL 65536 NEXT 1048576 MINEXTENTS 1 MAXEXTENTS 2147483645 PCTINCREASE 0 FREELISTS 1 FREELIST GROUPS 1 BUFFER_POOL DEFAULT FLASH_CACHE DEFAULT CELL_FLASH_CACHE DEFAULT) TABLESPACE "CITOS_SPA" ; CREATE INDEX "SMART_CITOS"."INDEX_SAS_USE_SHIP" ON "SMART_CITOS"."SHIP_WORK_UNIT" ("QUAY_WORK_TIME", "WORK_TYPE", "IMP_EXP_MARK", "UNIT_VISIT_NO", "FACILITY_ID", "ROLLBACK_MARK") PCTFREE 10 INITRANS 2 MAXTRANS 255 COMPUTE STATISTICS NOLOGGING STORAGE(INITIAL 65536 NEXT 1048576 MINEXTENTS 1 MAXEXTENTS 2147483645 PCTINCREASE 0 FREELISTS 1 FREELIST GROUPS 1 BUFFER_POOL DEFAULT FLASH_CACHE DEFAULT CELL_FLASH_CACHE DEFAULT) TABLESPACE "CITOS_SPA" ; CREATE UNIQUE INDEX "SMART_CITOS"."PK_SHIP_WORK_UNIT" ON "SMART_CITOS"."SHIP_WORK_UNIT" ("WORK_UNIT_ID") PCTFREE 10 INITRANS 2 MAXTRANS 255 COMPUTE STATISTICS NOLOGGING STORAGE(INITIAL 65536 NEXT 1048576 MINEXTENTS 1 MAXEXTENTS 2147483645 PCTINCREASE 0 FREELISTS 1 FREELIST GROUPS 1 BUFFER_POOL DEFAULT FLASH_CACHE DEFAULT CELL_FLASH_CACHE DEFAULT) TABLESPACE "CITOS_SPA" ; CREATE UNIQUE INDEX "SMART_CITOS"."IDX_WORK_MOVE_NO" ON "SMART_CITOS"."SHIP_WORK_UNIT" (NVL("WORK_MOVE_NO","WORK_UNIT_ID")) PCTFREE 10 INITRANS 2 MAXTRANS 255 COMPUTE STATISTICS NOLOGGING STORAGE(INITIAL 65536 NEXT 1048576 MINEXTENTS 1 MAXEXTENTS 2147483645 PCTINCREASE 0 FREELISTS 1 FREELIST GROUPS 1 BUFFER_POOL DEFAULT FLASH_CACHE DEFAULT CELL_FLASH_CACHE DEFAULT) TABLESPACE "CITOS_SPA" ; GRANT FLASHBACK ON "SMART_CITOS"."SHIP_WORK_UNIT" TO "SMART_EDS"; GRANT DEBUG ON "SMART_CITOS"."SHIP_WORK_UNIT" TO "SMART_EDS"; GRANT QUERY REWRITE ON "SMART_CITOS"."SHIP_WORK_UNIT" TO "SMART_EDS"; GRANT ON COMMIT REFRESH ON "SMART_CITOS"."SHIP_WORK_UNIT" TO "SMART_EDS"; GRANT READ ON "SMART_CITOS"."SHIP_WORK_UNIT" TO "SMART_EDS"; GRANT REFERENCES ON "SMART_CITOS"."SHIP_WORK_UNIT" TO "SMART_EDS"; GRANT UPDATE ON "SMART_CITOS"."SHIP_WORK_UNIT" TO "SMART_EDS"; GRANT SELECT ON "SMART_CITOS"."SHIP_WORK_UNIT" TO "SMART_EDS"; GRANT INSERT ON "SMART_CITOS"."SHIP_WORK_UNIT" TO "SMART_EDS"; GRANT INDEX ON "SMART_CITOS"."SHIP_WORK_UNIT" TO "SMART_EDS"; GRANT DELETE ON "SMART_CITOS"."SHIP_WORK_UNIT" TO "SMART_EDS"; GRANT ALTER ON "SMART_CITOS"."SHIP_WORK_UNIT" TO "SMART_EDS"; ### SeaTunnel Version 2.3.4 ### SeaTunnel Config ```conf env { execution.parallelism = 2 job.mode = "STREAMING" checkpoint.timeout = 50000 checkpoint.interval = 50000 } source { Oracle-CDC { driver = "oracle.jdbc.driver.OracleDriver" username = "LOGMINER_USER" password = "oracle" database-names = ["YCTOS"] schema-names = ["SMART_CITOS"] table-names = ["YCTOS.SMART_CITOS.SHIP_WORK_UNIT_BAK"] base-url = "jdbc:oracle:thin:@XX.X.X.XXX:1521/YCTOS" source.reader.close.timeout = 500000 } } sink { StarRocks { nodeUrls = ["192.XX.XX.XX:8030","192.XX.XX.XX:8030","192.XX.XX.XX:8030"] base-url = "jdbc:mysql://192.192.XX.XX.XX:9030/prod?characterEncoding=UTF-8&serverTimeZone=Asia/Shanghai" username = root password = 123456 database = prod enable_upsert_delete = true table = "ods_ycdfg_tos_test_SHIP_WORK_UNIT" } } ``` ### Running Command ```shell Run directly in the browser ``` ### Error Exception ```log 2024-12-31 16:18:33547信息[c.h.c.LifecycleService][主]-hz.client_1[seatunnel][5.1]Hazelcast客户端5.1(20220228-21f20e7)已断开连接 2024-12-31 16:18:33549信息[c.h.c.LifecycleService][主]-hz.client_1[seatunnel][5.1]Hazelcast客户端5.1(20220228-21f20e7)已关闭 2024-12-31 16:18:33549信息[s.c.s.s.c.ClientExecuteCommand][主]-封闭式海底隧道客户端。。。。。。 2024-12-31 16:18:33550错误[o.a.s.c.s.SeaTunnel][主]- =============================================================================== 2024-12-31 16:18:33550错误[o.a.s.c.s.SeaTunnel][main]-致命错误, 2024-12-31 16:18:33550错误[o.a.s.c.s.SeaTunnel][main]-请在https://github.com/apache/seatunnel/issues 2024-12-31 16:18:33550错误[o.a.s.c.s.SeaTunnel][main]-原因:执行SeaTunnel作业失败 2024-12-31 16:18:33551错误[o.a.s.c.s.SeaTunnel][main]-异常堆栈跟踪:org.apache.SeaTunnel.core.starter.Exception。CommandExecuteException:执行SeaTunnel作业失败 在org.apache.seatunnel.core.starter.seatunnel.command上。ClientExecuteCommand.execute(ClientExecuteCommand.java:199) 在org.apache.seatunnel.core.starter上。SeaTunnel.run(SeaTunnel.java:40) 在org.apache.seatunnel.core.starter.seatunnel。SeaTunnelClient.main(SeaTunnelClient.java:34) 原因:org.apache.seatunnel.common.exception。SeaTunnelRuntimeException:错误代码:[API-09],错误描述:[句柄保存模式失败] 在org.apache.seatunnel.engineer.core.parse上。MultipleTableJobConfigParser.handleSaveMode(MultipleTableJobConfig Parser.java:669) 在org.apache.seatunnel.engineer.core.parse上。MultipleTableJobConfigParser.createSinkAction(MultipleTableJobConfig Parser.java:655) 在org.apache.seatunnel.engineer.core.parse上。MultipleTableJobConfigParser.parseSink(MultipleTableJobConfig Parser.java:567) 在org.apache.seatunnel.engineer.core.parse上。MultipleTableJobConfigParser.parse(MultipleTableJobConfig Parser.java:193) 在org.apache.seatunnel.engine.client.job上。ClientJobExecutionEnvironment.getLogicalDag(ClientJobExecutionEnvironment.java:88) 在org.apache.seatunnel.engine.client.job上。ClientJobExecutionEnvironment.execute(ClientJobExecutionEnvironment.java:161) 在org.apache.seatunnel.core.starter.seatunnel.command上。ClientExecuteCommand.execute(ClientExecuteCommand.java:146) …2更多 原因:org.apache.seatunnel.api.table.catalog.exception。CatalogException:错误代码:[API-03],错误描述:[Catalog initialize failed]-在目录StarRocks中创建表失败,sql:[create table IF NOT EXISTS`prod`.`ods_ycdfg_tos_test_SHIP_WORK_UNIT_BAK`( , `WORK_UNIT_ID `VARCHAR(144)不为空, `WORK_UNIT_NO`VARCHAR(144)不为空, `SHIP_VISIT_NO'VARCHAR(80)不为空, `IMP_EXP_MARK'VARCHAR(40)不为空, `LINE_RLS_NO`VARCHAR(200)为空, `UNIT_SPECIFIED的`VARCHAR(4)不为空, `未指定_ NO'VARCHAR(80)不为空, `UNIT_CLASS `VARCHAR(40)不为空, `UNIT_VISIT_NO‘VARCHAR(80)为空, `UNIT_NO`VARCHAR(160)为空, `UNIT_ISO-CODE `VARCHAR(40)不为空, `UNIT_SIZE_CODE `VARCHAR(40)不为空, `UNIT_TYPE_CODE `VARCHAR(40)不为空, `UNIT_HEIGHT_CODE'VARCHAR(40)不为空, `EMPTY_FULL_MARK'VARCHAR(40)不为空, `UNIT_GRADE_CODE `VARCHAR(80)为空, `UNIT_OWNER_CODE `VARCHAR(80)为空, `UNIT_OPERATOR_CODE `VARCHAR(80)为空, `UNIT_AGENT_CODE `VARCHAR(80)为空, `UNIT_GROSS_WGT`十进制(38,18)NULL, `UNIT_ARE_WGT`十进制(38,18)NULL, `ON_SHIP_POSITION`VARCHAR(80)为空, `PLAN_ON_SHIP_POSITION`VARCHAR(80)为空, `STOW_要求`VARCHAR(4000)为空, `BILL_NO`VARCHAR(200)为空, `BOOKING_NO'VARCHAR(200)为空, `TRADE_TYPE `VARCHAR(80)不为空, `ORIGINAL_LOC_CODE `VARCHAR(80)为空, `ORIGINAL_LOC_NAME` VARCHAR(800)为空, `原始POL_CODE'VARCHAR(80)为空, `POL_CODE'VARCHAR(80)不为空, `POD_CODE `VARCHAR(80)不为空, `SECOND_POD_CODE `VARCHAR(80)为空, `FINAL_POD_CODE `VARCHAR(80)为空, `ONCARRIAGE_LOC_CODE `VARCHAR(80)为空, `ONCARRIAGE_LOC_NAME `VARCHAR(800)为空, `UNIT_CATEGORY'VARCHAR(40)不为空, `TRANSSHIPMENT_MARK'VARCHAR(4)不为空, `TRANS_TYPE_CODE `VARCHAR(80)为空, `SHIPPING_TYPE_CODE `VARCHAR(80)为空, `DECLARE_SHIP_CODE `VARCHAR(80)为空, `DECLARE_SHIP_NAME`VARCHAR(800)为空, `DECLARE_avoyage `VARCHAR(80)为空, `DECLARE_UNIT_OPER_CODE `VARCHAR(80)为空, `NEXT_SERVICE_CODE `VARCHAR(80)为空, `NEXT_VISIT_NO'VARCHAR(80)为空, `SEAL_NO1`VARCHAR(320)为空, `SEAL_NO2`VARCHAR(320)为空, `SEAL_NO3`VARCHAR(320)为空, `SEAL_NO4`VARCHAR(320)为空, `LCL_MARK`VARCHAR(4)不为空, `HAZARD_MARK'VARCHAR(4)不为空, `IMDG_CODE `VARCHAR(20)为空, `UNDG_NO` VARCHAR(40)为空, `危害‘VARCHAR(4000)为空, `REEFER_MARK'VARCHAR(4)不为空, `TEMP_UNIT`VARCHAR(40)为空, `TEMP_SET`十进制(38,18)NULL, `MIN_TEMP`十进制(38,18)NULL, `MAX_TEMP`十进制(38,18)NULL, `通风`十进制(38,18)NULL ``` ### Zeta or Flink or Spark Version _No response_ ### Java or Scala Version JDK 1.8 ### Screenshots  ### 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: commits-unsubscr...@seatunnel.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org