Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[Bug] [oracle-cdc] from oracle （19c） to starrocks : No viable statement for input 'CREATE TABLE IF NOT EXISTS #8452

Open
2 of 3 tasks
nihaobienao opened this issue Jan 4, 2025 · 1 comment
Open
2 of 3 tasks

[Bug] [oracle-cdc] from oracle （19c） to starrocks : No viable statement for input 'CREATE TABLE IF NOT EXISTS #8452

nihaobienao opened this issue Jan 4, 2025 · 1 comment
Labels
bug

Comments

@nihaobienao
Copy link

Search before asking

  • I had searched in the issues and found no similar issues.

What happened

1

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

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

Run directly in the browser

Error Exception

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

Are you willing to submit PR?

  • Yes I am willing to submit a PR!

Code of Conduct
@nihaobienao nihaobienao added the bug label Jan 4, 2025
@nihaobienao
Copy link
Author

2024-12-31 16:18:33,547 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is CLIENT_DISCONNECTED
2024-12-31 16:18:33,549 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is SHUTDOWN
2024-12-31 16:18:33,549 INFO [s.c.s.s.c.ClientExecuteCommand] [main] - Closed SeaTunnel client......
2024-12-31 16:18:33,550 ERROR [o.a.s.c.s.SeaTunnel ] [main] -

===============================================================================


2024-12-31 16:18:33,550 ERROR [o.a.s.c.s.SeaTunnel           ] [main] - Fatal Error, 

2024-12-31 16:18:33,550 ERROR [o.a.s.c.s.SeaTunnel           ] [main] - Please submit bug report in https://github.com/apache/seatunnel/issues

2024-12-31 16:18:33,550 ERROR [o.a.s.c.s.SeaTunnel           ] [main] - Reason:SeaTunnel job executed failed 

2024-12-31 16:18:33,551 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:199)
	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.common.exception.SeaTunnelRuntimeException: ErrorCode:[API-09], ErrorDescription:[Handle save mode failed]
	at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.handleSaveMode(MultipleTableJobConfigParser.java:669)
	at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.createSinkAction(MultipleTableJobConfigParser.java:655)
	at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSink(MultipleTableJobConfigParser.java:567)
	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:161)
	at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:146)
	... 2 more
Caused by: org.apache.seatunnel.api.table.catalog.exception.CatalogException: ErrorCode:[API-03], ErrorDescription:[Catalog initialize failed] - Failed create table in catalog StarRocks, sql :[CREATE TABLE IF NOT EXISTS `prod`.`ods_ycdfg_tos_test_SHIP_WORK_UNIT_BAK` (
,
`WORK_UNIT_ID` VARCHAR(144) NOT NULL ,
`WORK_UNIT_NO` VARCHAR(144) NOT NULL ,
`SHIP_VISIT_NO` VARCHAR(80) NOT NULL ,
`IMP_EXP_MARK` VARCHAR(40) NOT NULL ,
`LINE_RLS_NO` VARCHAR(200) NULL ,
`UNIT_SPECIFIED` VARCHAR(4) NOT NULL ,
`UNSPECIFIED_NO` VARCHAR(80) NOT NULL ,
`UNIT_CLASS` VARCHAR(40) NOT NULL ,
`UNIT_VISIT_NO` VARCHAR(80) NULL ,
`UNIT_NO` VARCHAR(160) NULL ,
`UNIT_ISO_CODE` VARCHAR(40) NOT NULL ,
`UNIT_SIZE_CODE` VARCHAR(40) NOT NULL ,
`UNIT_TYPE_CODE` VARCHAR(40) NOT NULL ,
`UNIT_HEIGHT_CODE` VARCHAR(40) NOT NULL ,
`EMPTY_FULL_MARK` VARCHAR(40) NOT NULL ,
`UNIT_GRADE_CODE` VARCHAR(80) NULL ,
`UNIT_OWNER_CODE` VARCHAR(80) NULL ,
`UNIT_OPERATOR_CODE` VARCHAR(80) NULL ,
`UNIT_AGENT_CODE` VARCHAR(80) NULL ,
`UNIT_GROSS_WGT` Decimal(38, 18) NULL ,
`UNIT_TARE_WGT` Decimal(38, 18) NULL ,
`ON_SHIP_POSITION` VARCHAR(80) NULL ,
`PLAN_ON_SHIP_POSITION` VARCHAR(80) NULL ,
`STOW_REQUIRES` VARCHAR(4000) NULL ,
`BILL_NO` VARCHAR(200) NULL ,
`BOOKING_NO` VARCHAR(200) NULL ,
`TRADE_TYPE` VARCHAR(80) NOT NULL ,
`ORIGINAL_LOC_CODE` VARCHAR(80) NULL ,
`ORIGINAL_LOC_NAME` VARCHAR(800) NULL ,
`ORIGINAL_POL_CODE` VARCHAR(80) NULL ,
`POL_CODE` VARCHAR(80) NOT NULL ,
`POD_CODE` VARCHAR(80) NOT NULL ,
`SECOND_POD_CODE` VARCHAR(80) NULL ,
`FINAL_POD_CODE` VARCHAR(80) NULL ,
`ONCARRIAGE_LOC_CODE` VARCHAR(80) NULL ,
`ONCARRIAGE_LOC_NAME` VARCHAR(800) NULL ,
`UNIT_CATEGORY` VARCHAR(40) NOT NULL ,
`TRANSSHIPMENT_MARK` VARCHAR(4) NOT NULL ,
`TRANS_TYPE_CODE` VARCHAR(80) NULL ,
`SHIPPING_TYPE_CODE` VARCHAR(80) NULL ,
`DECLARE_SHIP_CODE` VARCHAR(80) NULL ,
`DECLARE_SHIP_NAME` VARCHAR(800) NULL ,
`DECLARE_VOYAGE` VARCHAR(80) NULL ,
`DECLARE_UNIT_OPER_CODE` VARCHAR(80) NULL ,
`NEXT_SERVICE_CODE` VARCHAR(80) NULL ,
`NEXT_VISIT_NO` VARCHAR(80) NULL ,
`SEAL_NO1` VARCHAR(320) NULL ,
`SEAL_NO2` VARCHAR(320) NULL ,
`SEAL_NO3` VARCHAR(320) NULL ,
`SEAL_NO4` VARCHAR(320) NULL ,
`LCL_MARK` VARCHAR(4) NOT NULL ,
`HAZARD_MARK` VARCHAR(4) NOT NULL ,
`IMDG_CODE` VARCHAR(20) NULL ,
`UNDG_NO` VARCHAR(40) NULL ,
`HAZARDS` VARCHAR(4000) NULL ,
`REEFER_MARK` VARCHAR(4) NOT NULL ,
`TEMP_UNIT` VARCHAR(40) NULL ,
`TEMP_SET` Decimal(38, 18) NULL ,
`MIN_TEMP` Decimal(38, 18) NULL ,
`MAX_TEMP` Decimal(38, 18) NULL ,
`VENTILATION` Decimal(38, 18) NULL ,
`VENTILATION_UNIT` VARCHAR(40) NULL ,
`HUMIDITY` Decimal(38, 18) NULL ,
`OOG_MARK` VARCHAR(4) NOT NULL ,
`OOG_LEFT` Decimal(38, 18) NULL ,
`OOG_RIGHT` Decimal(38, 18) NULL ,
`OOG_FRONT` Decimal(38, 18) NULL ,
`OOG_BACK` Decimal(38, 18) NULL ,
`OOG_HIGH` Decimal(38, 18) NULL ,
`UNIT_FEATURES` VARCHAR(4000) NULL ,
`UNIT_CONDITIONS` VARCHAR(4000) NULL ,
`BUNDLED_MARK` VARCHAR(4) NOT NULL ,
`PARENT_UNIT_VISIT_NO` VARCHAR(80) NULL ,
`CLEARANCE_TYPE_CODE` VARCHAR(80) NULL ,
`DAMAGE_MARK` VARCHAR(4) NOT NULL ,
`DAMAGES` VARCHAR(4000) NULL ,
`CARGO_CODE` VARCHAR(80) NULL ,
`CARGO_NAME` VARCHAR(4000) NULL ,
`CARGO_LABEL` VARCHAR(4000) NULL ,
`PACKAGE_UNIT_CODE` VARCHAR(80) NULL ,
`CARGO_QTY` BIGINT NULL ,
`CARGO_VOLUME` Decimal(38, 18) NULL ,
`DELIVERY_CLAUSE_CODE` VARCHAR(80) NULL ,
`OVERLANDED_MARK` VARCHAR(4) NOT NULL ,
`WORK_TYPE` VARCHAR(80) NULL ,
`WORK_FLOW_CODE` VARCHAR(80) NULL ,
`WORK_METHOD_CODE` VARCHAR(80) NULL ,
`DREDGE_MARK` VARCHAR(4) NOT NULL ,
`DIFFICULT_TYPE_CODE` VARCHAR(80) NOT NULL ,
`WORK_QUEUE_NO` VARCHAR(160) NULL ,
`WORK_QUEUE_NAME` VARCHAR(400) NULL ,
`WORK_MOVE_NO` VARCHAR(160) NULL ,
`SEND_TIME` DATETIME NULL ,
`SENDER_NO` VARCHAR(80) NULL ,
`SHIP_CRANE_NO` VARCHAR(80) NULL ,
`SHIP_CRANE_DRIVER_NO` VARCHAR(80) NULL ,
`SHIP_CRANE_WORK_MODE` VARCHAR(40) NULL ,
`QUAY_ARRIVE_TIME` DATETIME NULL ,
`QUAY_WORK_TIME` DATETIME NOT NULL ,
`QUAY_DEPART_TIME` DATETIME NULL ,
`QUAY_TALLYMAN_NO` VARCHAR(80) NULL ,
`QUAY_TWIN_NO` VARCHAR(144) NULL ,
`TRUCK_VISIT_NO` VARCHAR(80) NULL ,
`TRUCK_NO` VARCHAR(80) NULL ,
`TRUCK_DRIVER_NO` VARCHAR(80) NULL ,
`ON_TRUCK_POSITION` VARCHAR(40) NULL ,
`YARD_CRANE_NO` VARCHAR(80) NULL ,
`YARD_CRANE_DRIVER_NO` VARCHAR(80) NULL ,
`YARD_CRANE_WORK_MODE` VARCHAR(40) NULL ,
`YARD_ARRIVE_TIME` DATETIME NULL ,
`YARD_WORK_TIME` DATETIME NULL ,
`YARD_DEPART_TIME` DATETIME NULL ,
`YARD_TALLYMAN_NO` VARCHAR(80) NULL ,
`YARD_TWIN_NO` VARCHAR(144) NULL ,
`ON_YARD_POSITION` VARCHAR(80) NULL ,
`PLAN_ON_YARD_POSITION` VARCHAR(80) NULL ,
`ROLLBACK_MARK` VARCHAR(4) NULL ,
`NOTES` VARCHAR(4000) NULL ,
`FACILITY_ID` VARCHAR(144) NOT NULL ,
`CREATOR` VARCHAR(144) NOT NULL ,
`CREATED_ON` DATETIME NOT NULL ,
`CHANGER` VARCHAR(144) NOT NULL ,
`CHANGED_ON` DATETIME NOT NULL ,
`WORK_SHIFT_NO` VARCHAR(80) NULL ,
`PROJECT_CARGO_CODE` VARCHAR(80) NULL ,
`TRANSPORT_FEE_ID` VARCHAR(4) NULL ,
`LAST_PORT_CODE` VARCHAR(20) NULL 
) ENGINE=OLAP
 PRIMARY KEY ()
DISTRIBUTED BY HASH ()PROPERTIES (
    "replication_num" = "1" 
)]
	at org.apache.seatunnel.connectors.seatunnel.starrocks.catalog.StarRocksCatalog.createTable(StarRocksCatalog.java:399)
	at org.apache.seatunnel.connectors.seatunnel.starrocks.catalog.StarRocksCatalog.createTable(StarRocksCatalog.java:216)
	at org.apache.seatunnel.api.sink.DefaultSaveModeHandler.createTable(DefaultSaveModeHandler.java:142)
	at org.apache.seatunnel.api.sink.DefaultSaveModeHandler.createSchemaWhenNotExist(DefaultSaveModeHandler.java:101)
	at org.apache.seatunnel.api.sink.DefaultSaveModeHandler.handleSchemaSaveMode(DefaultSaveModeHandler.java:62)
	at org.apache.seatunnel.api.sink.SaveModeHandler.handleSaveMode(SaveModeHandler.java:27)
	at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.handleSaveMode(MultipleTableJobConfigParser.java:667)
	... 8 more
Caused by: java.sql.SQLSyntaxErrorException: Getting syntax error at line 2, column 0. Detail message: No viable statement for input 'CREATE TABLE IF NOT EXISTS `prod`.`ods_ycdfg_tos_test_SHIP_WORK_UNIT_BAK` (
,'.
	at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:120)
	at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122)
	at com.mysql.cj.jdbc.StatementImpl.executeInternal(StatementImpl.java:763)
	at com.mysql.cj.jdbc.StatementImpl.execute(StatementImpl.java:648)
	at org.apache.seatunnel.connectors.seatunnel.starrocks.catalog.StarRocksCatalog.createTable(StarRocksCatalog.java:396)
	... 14 more
 
2024-12-31 16:18:33,551 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:199)
	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.common.exception.SeaTunnelRuntimeException: ErrorCode:[API-09], ErrorDescription:[Handle save mode failed]
	at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.handleSaveMode(MultipleTableJobConfigParser.java:669)
	at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.createSinkAction(MultipleTableJobConfigParser.java:655)
	at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSink(MultipleTableJobConfigParser.java:567)
	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:161)
	at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:146)
	... 2 more
Caused by: org.apache.seatunnel.api.table.catalog.exception.CatalogException: ErrorCode:[API-03], ErrorDescription:[Catalog initialize failed] - Failed create table in catalog StarRocks, sql :[CREATE TABLE IF NOT EXISTS `prod`.`ods_ycdfg_tos_test_SHIP_WORK_UNIT_BAK` (
,
`WORK_UNIT_ID` VARCHAR(144) NOT NULL ,
`WORK_UNIT_NO` VARCHAR(144) NOT NULL ,
`SHIP_VISIT_NO` VARCHAR(80) NOT NULL ,
`IMP_EXP_MARK` VARCHAR(40) NOT NULL ,
`LINE_RLS_NO` VARCHAR(200) NULL ,
`UNIT_SPECIFIED` VARCHAR(4) NOT NULL ,
`UNSPECIFIED_NO` VARCHAR(80) NOT NULL ,
`UNIT_CLASS` VARCHAR(40) NOT NULL ,
`UNIT_VISIT_NO` VARCHAR(80) NULL ,
`UNIT_NO` VARCHAR(160) NULL ,
`UNIT_ISO_CODE` VARCHAR(40) NOT NULL ,
`UNIT_SIZE_CODE` VARCHAR(40) NOT NULL ,
`UNIT_TYPE_CODE` VARCHAR(40) NOT NULL ,
`UNIT_HEIGHT_CODE` VARCHAR(40) NOT NULL ,
`EMPTY_FULL_MARK` VARCHAR(40) NOT NULL ,
`UNIT_GRADE_CODE` VARCHAR(80) NULL ,
`UNIT_OWNER_CODE` VARCHAR(80) NULL ,
`UNIT_OPERATOR_CODE` VARCHAR(80) NULL ,
`UNIT_AGENT_CODE` VARCHAR(80) NULL ,
`UNIT_GROSS_WGT` Decimal(38, 18) NULL ,
`UNIT_TARE_WGT` Decimal(38, 18) NULL ,
`ON_SHIP_POSITION` VARCHAR(80) NULL ,
`PLAN_ON_SHIP_POSITION` VARCHAR(80) NULL ,
`STOW_REQUIRES` VARCHAR(4000) NULL ,
`BILL_NO` VARCHAR(200) NULL ,
`BOOKING_NO` VARCHAR(200) NULL ,
`TRADE_TYPE` VARCHAR(80) NOT NULL ,
`ORIGINAL_LOC_CODE` VARCHAR(80) NULL ,
`ORIGINAL_LOC_NAME` VARCHAR(800) NULL ,
`ORIGINAL_POL_CODE` VARCHAR(80) NULL ,
`POL_CODE` VARCHAR(80) NOT NULL ,
`POD_CODE` VARCHAR(80) NOT NULL ,
`SECOND_POD_CODE` VARCHAR(80) NULL ,
`FINAL_POD_CODE` VARCHAR(80) NULL ,
`ONCARRIAGE_LOC_CODE` VARCHAR(80) NULL ,
`ONCARRIAGE_LOC_NAME` VARCHAR(800) NULL ,
`UNIT_CATEGORY` VARCHAR(40) NOT NULL ,
`TRANSSHIPMENT_MARK` VARCHAR(4) NOT NULL ,
`TRANS_TYPE_CODE` VARCHAR(80) NULL ,
`SHIPPING_TYPE_CODE` VARCHAR(80) NULL ,
`DECLARE_SHIP_CODE` VARCHAR(80) NULL ,
`DECLARE_SHIP_NAME` VARCHAR(800) NULL ,
`DECLARE_VOYAGE` VARCHAR(80) NULL ,
`DECLARE_UNIT_OPER_CODE` VARCHAR(80) NULL ,
`NEXT_SERVICE_CODE` VARCHAR(80) NULL ,
`NEXT_VISIT_NO` VARCHAR(80) NULL ,
`SEAL_NO1` VARCHAR(320) NULL ,
`SEAL_NO2` VARCHAR(320) NULL ,
`SEAL_NO3` VARCHAR(320) NULL ,
`SEAL_NO4` VARCHAR(320) NULL ,
`LCL_MARK` VARCHAR(4) NOT NULL ,
`HAZARD_MARK` VARCHAR(4) NOT NULL ,
`IMDG_CODE` VARCHAR(20) NULL ,
`UNDG_NO` VARCHAR(40) NULL ,
`HAZARDS` VARCHAR(4000) NULL ,
`REEFER_MARK` VARCHAR(4) NOT NULL ,
`TEMP_UNIT` VARCHAR(40) NULL ,
`TEMP_SET` Decimal(38, 18) NULL ,
`MIN_TEMP` Decimal(38, 18) NULL ,
`MAX_TEMP` Decimal(38, 18) NULL ,
`VENTILATION` Decimal(38, 18) NULL ,
`VENTILATION_UNIT` VARCHAR(40) NULL ,
`HUMIDITY` Decimal(38, 18) NULL ,
`OOG_MARK` VARCHAR(4) NOT NULL ,
`OOG_LEFT` Decimal(38, 18) NULL ,
`OOG_RIGHT` Decimal(38, 18) NULL ,
`OOG_FRONT` Decimal(38, 18) NULL ,
`OOG_BACK` Decimal(38, 18) NULL ,
`OOG_HIGH` Decimal(38, 18) NULL ,
`UNIT_FEATURES` VARCHAR(4000) NULL ,
`UNIT_CONDITIONS` VARCHAR(4000) NULL ,
`BUNDLED_MARK` VARCHAR(4) NOT NULL ,
`PARENT_UNIT_VISIT_NO` VARCHAR(80) NULL ,
`CLEARANCE_TYPE_CODE` VARCHAR(80) NULL ,
`DAMAGE_MARK` VARCHAR(4) NOT NULL ,
`DAMAGES` VARCHAR(4000) NULL ,
`CARGO_CODE` VARCHAR(80) NULL ,
`CARGO_NAME` VARCHAR(4000) NULL ,
`CARGO_LABEL` VARCHAR(4000) NULL ,
`PACKAGE_UNIT_CODE` VARCHAR(80) NULL ,
`CARGO_QTY` BIGINT NULL ,
`CARGO_VOLUME` Decimal(38, 18) NULL ,
`DELIVERY_CLAUSE_CODE` VARCHAR(80) NULL ,
`OVERLANDED_MARK` VARCHAR(4) NOT NULL ,
`WORK_TYPE` VARCHAR(80) NULL ,
`WORK_FLOW_CODE` VARCHAR(80) NULL ,
`WORK_METHOD_CODE` VARCHAR(80) NULL ,
`DREDGE_MARK` VARCHAR(4) NOT NULL ,
`DIFFICULT_TYPE_CODE` VARCHAR(80) NOT NULL ,
`WORK_QUEUE_NO` VARCHAR(160) NULL ,
`WORK_QUEUE_NAME` VARCHAR(400) NULL ,
`WORK_MOVE_NO` VARCHAR(160) NULL ,
`SEND_TIME` DATETIME NULL ,
`SENDER_NO` VARCHAR(80) NULL ,
`SHIP_CRANE_NO` VARCHAR(80) NULL ,
`SHIP_CRANE_DRIVER_NO` VARCHAR(80) NULL ,
`SHIP_CRANE_WORK_MODE` VARCHAR(40) NULL ,
`QUAY_ARRIVE_TIME` DATETIME NULL ,
`QUAY_WORK_TIME` DATETIME NOT NULL ,
`QUAY_DEPART_TIME` DATETIME NULL ,
`QUAY_TALLYMAN_NO` VARCHAR(80) NULL ,
`QUAY_TWIN_NO` VARCHAR(144) NULL ,
`TRUCK_VISIT_NO` VARCHAR(80) NULL ,
`TRUCK_NO` VARCHAR(80) NULL ,
`TRUCK_DRIVER_NO` VARCHAR(80) NULL ,
`ON_TRUCK_POSITION` VARCHAR(40) NULL ,
`YARD_CRANE_NO` VARCHAR(80) NULL ,
`YARD_CRANE_DRIVER_NO` VARCHAR(80) NULL ,
`YARD_CRANE_WORK_MODE` VARCHAR(40) NULL ,
`YARD_ARRIVE_TIME` DATETIME NULL ,
`YARD_WORK_TIME` DATETIME NULL ,
`YARD_DEPART_TIME` DATETIME NULL ,
`YARD_TALLYMAN_NO` VARCHAR(80) NULL ,
`YARD_TWIN_NO` VARCHAR(144) NULL ,
`ON_YARD_POSITION` VARCHAR(80) NULL ,
`PLAN_ON_YARD_POSITION` VARCHAR(80) NULL ,
`ROLLBACK_MARK` VARCHAR(4) NULL ,
`NOTES` VARCHAR(4000) NULL ,
`FACILITY_ID` VARCHAR(144) NOT NULL ,
`CREATOR` VARCHAR(144) NOT NULL ,
`CREATED_ON` DATETIME NOT NULL ,
`CHANGER` VARCHAR(144) NOT NULL ,
`CHANGED_ON` DATETIME NOT NULL ,
`WORK_SHIFT_NO` VARCHAR(80) NULL ,
`PROJECT_CARGO_CODE` VARCHAR(80) NULL ,
`TRANSPORT_FEE_ID` VARCHAR(4) NULL ,
`LAST_PORT_CODE` VARCHAR(20) NULL 
) ENGINE=OLAP
 PRIMARY KEY ()
DISTRIBUTED BY HASH ()PROPERTIES (
    "replication_num" = "1" 
)]
	at org.apache.seatunnel.connectors.seatunnel.starrocks.catalog.StarRocksCatalog.createTable(StarRocksCatalog.java:399)
	at org.apache.seatunnel.connectors.seatunnel.starrocks.catalog.StarRocksCatalog.createTable(StarRocksCatalog.java:216)
	at org.apache.seatunnel.api.sink.DefaultSaveModeHandler.createTable(DefaultSaveModeHandler.java:142)
	at org.apache.seatunnel.api.sink.DefaultSaveModeHandler.createSchemaWhenNotExist(DefaultSaveModeHandler.java:101)
	at org.apache.seatunnel.api.sink.DefaultSaveModeHandler.handleSchemaSaveMode(DefaultSaveModeHandler.java:62)
	at org.apache.seatunnel.api.sink.SaveModeHandler.handleSaveMode(SaveModeHandler.java:27)
	at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.handleSaveMode(MultipleTableJobConfigParser.java:667)
	... 8 more
Caused by: java.sql.SQLSyntaxErrorException: Getting syntax error at line 2, column 0. Detail message: No viable statement for input 'CREATE TABLE IF NOT EXISTS `prod`.`ods_ycdfg_tos_test_SHIP_WORK_UNIT_BAK` (
,'.
	at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:120)
	at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122)
	at com.mysql.cj.jdbc.StatementImpl.executeInternal(StatementImpl.java:763)
	at com.mysql.cj.jdbc.StatementImpl.execute(StatementImpl.java:648)
	at org.apache.seatunnel.connectors.seatunnel.starrocks.catalog.StarRocksCatalog.createTable(StarRocksCatalog.java:396)
	... 14 more

[INFO] 2024-12-31 16:18:33.804 +0800 - process has exited. execute

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
bug
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
1 participant
@nihaobienao