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
   
   
![1](https://github.com/user-attachments/assets/c9216a53-d193-4e7c-904f-eeb1d3f6bf6e)
   
   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
   
   
![1](https://github.com/user-attachments/assets/0ab93c1b-f9a8-423a-a06d-5567717af4fe)
   
   
   ### 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

Reply via email to