SendDreams commented on issue #4382: URL: https://github.com/apache/flink-cdc/issues/4382#issuecomment-4311890964
If the timestamp type field in the postgresql database has the default value CURRENT TIMESTAMP, then when the flink cdc pipeline creates tables in the target database starrocks, starrocks failed to recognize the CURRENT TIMESTAMP, resulting in an exception being thrown <img width="876" height="75" alt="Image" src="https://github.com/user-attachments/assets/11da3f97-0c3e-471a-a1bf-3db399f2be85"; /> 2026-04-21 18:07:43 org.apache.flink.util.FlinkException: Global failure triggered by OperatorCoordinator for 'Source: icos-basic147initial -> SchemaOperator -> PrePartition' (operator 9899a42c64d67ef3172b7e3be3c1bbb9). at org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder$LazyInitializedCoordinatorContext.failJob(OperatorCoordinatorHolder.java:651) at org.apache.flink.cdc.runtime.operators.schema.common.SchemaRegistry.failJob(SchemaRegistry.java:392) at org.apache.flink.cdc.runtime.operators.schema.regular.SchemaCoordinator.lambda$startSchemaChangesEvolve$1(SchemaCoordinator.java:249) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) at java.base/java.util.concurrent.FutureTask.run(Unknown Source) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) at java.base/java.lang.Thread.run(Unknown Source) Caused by: org.apache.flink.util.FlinkRuntimeException: Failed to apply schema change event. ... 6 more Caused by: SchemaEvolveException{applyingEvent=CreateTableEvent{tableId=ods_rt.icos_basic_basic_main_info, schema=columns={`id` BIGINT NOT NULL,`contract_no` VARCHAR(32),`apply_no` VARCHAR(32),`business_type` VARCHAR(32),`car_nature` VARCHAR(32),`contract_status` VARCHAR(32),`loan_model` VARCHAR(32),`cancel_date` TIMESTAMP(6),`end_date` TIMESTAMP(6),`start_date` TIMESTAMP(6),`loan_date` TIMESTAMP(6),`settle_date` TIMESTAMP(6),`close_date` TIMESTAMP(6),`into_first_date` TIMESTAMP(6),`lend_pass_date` TIMESTAMP(6),`product_id` VARCHAR(32),`product_name` VARCHAR(128),`grace_period_days` INT,`channel_full_name` VARCHAR(200),`channel_type` VARCHAR(32) ''COMMON_CAR_DEALER'::character varying',`create_by` VARCHAR(32),`create_time` TIMESTAMP(6) NOT NULL 'CURRENT_TIMESTAMP',`update_by` VARCHAR(32),`update_time` TIMESTAMP(6) NOT NULL 'CURRENT_TIMESTAMP',`del_flag` INT,`channel_id` VARCHAR(32),`channel_belong` VARCHAR(32),`repayment_date` VARCHAR(32),`loan_classification_cde` VARCHAR(32),`sen d_status` VARCHAR(10),`car_purpose` VARCHAR(32),`case_approve_date` TIMESTAMP(6),`loan_approve_date` TIMESTAMP(6),`case_type` VARCHAR(20),`last_identification_method` VARCHAR(20),`identification_method` VARCHAR(20),`five_category` VARCHAR(20),`is_locked` VARCHAR(20),`continuous_repayment_times` INT,`five_category_time` DATE,`five_category_days` INT,`last_five_days` INT,`last_five_category` VARCHAR(20),`sufficient_repayment_times` INT,`lock_case_type` VARCHAR(20),`penalty_end_date` TIMESTAMP(6),`cust_type` VARCHAR(32) ''PERSON'::character varying',`batch_no` VARCHAR(32),`guarantee_way` VARCHAR(128),`sign_loan_status` VARCHAR(15),`data_source` VARCHAR(32),`lpr_change_date` TIMESTAMP(6),`product_type` VARCHAR(32),`observe_period_date` DATE,`observe_period_type` INT,`channel_source` VARCHAR(32),`free_mortgage_flag` VARCHAR(32),`tail_loan_flag` VARCHAR(32),`organ_type` VARCHAR(32) NOT NUL L ''CAR'::character varying',`loan_type` VARCHAR(5) ''00001'::character varying',`farmer_flag` VARCH AR(2) 'NULL::character varying',`channel_code` VARCHAR(50) '''::character varying'}, primaryKeys=id, options=()}, exceptionMessage='Failed to create table', cause='com.starrocks.connector.flink.catalog.StarRocksCatalogException: Failed to create table ods_rt.ods_rt'} at org.apache.flink.cdc.connectors.starrocks.sink.StarRocksMetadataApplier.applyCreateTable(StarRocksMetadataApplier.java:151) at org.apache.flink.cdc.connectors.starrocks.sink.StarRocksMetadataApplier.lambda$applySchemaChange$2(StarRocksMetadataApplier.java:115) at org.apache.flink.cdc.common.event.visitor.SchemaChangeEventVisitor.visit(SchemaChangeEventVisitor.java:57) at org.apache.flink.cdc.connectors.starrocks.sink.StarRocksMetadataApplier.applySchemaChange(StarRocksMetadataApplier.java:104) at org.apache.flink.cdc.runtime.operators.schema.regular.SchemaCoordinator.applyAndUpdateEvolvedSchemaChange(SchemaCoordinator.java:437) at org.apache.flink.cdc.runtime.operators.schema.regular.SchemaCoordinator.applySchemaChange(SchemaCoordinator.java:406) at org.apache.flink.cdc.runtime.operators.schema.regular.SchemaCoordinator.lambda$startSchemaChangesEvolve$1(SchemaCoordinator.java:247) ... 5 more Caused by: com.starrocks.connector.flink.catalog.StarRocksCatalogException: Failed to create table ods_rt.ods_rt at com.starrocks.connector.flink.catalog.StarRocksCatalog.createTable(StarRocksCatalog.java:292) at org.apache.flink.cdc.connectors.starrocks.sink.StarRocksMetadataApplier.applyCreateTable(StarRocksMetadataApplier.java:147) ... 11 more Caused by: com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException: Getting analyzing error. Detail message: Invalid default value for 'create_time': date literal [CURRENT_TIMESTAMP] is invalid. at java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) at java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance(Unknown Source) at java.base/jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(Unknown Source) at java.base/java.lang.reflect.Constructor.newInstance(Unknown Source) at com.mysql.jdbc.Util.handleNewInstance(Util.java:403) at com.mysql.jdbc.Util.getInstance(Util.java:386) at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:944) at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3933) at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3869) at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:2524) at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:2675) at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2465) at com.mysql.jdbc.StatementImpl.executeUpdateInternal(StatementImpl.java:1536) at com.mysql.jdbc.StatementImpl.executeLargeUpdate(StatementImpl.java:2585) at com.mysql.jdbc.StatementImpl.executeUpdate(StatementImpl.java:1464) at com.starrocks.connector.flink.catalog.StarRocksCatalog.executeUpdateStatement(StarRocksCatalog.java:505) at com.starrocks.connector.flink.catalog.StarRocksCatalog.createTable(StarRocksCatalog.java:285) ... 12 more -- 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]
