nihaobienao commented on issue #8452:
URL: https://github.com/apache/seatunnel/issues/8452#issuecomment-2570810372
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
--
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]
