Yanquan Lv created FLINK-38248:
----------------------------------

             Summary: The default value of '0000-00-00 00:00:00' for MySQL 
TIMESTAMP fields is not supported in downstream systems.
                 Key: FLINK-38248
                 URL: https://issues.apache.org/jira/browse/FLINK-38248
             Project: Flink
          Issue Type: Improvement
          Components: Flink CDC
    Affects Versions: cdc-3.4.0, cdc-3.3.0
            Reporter: Yanquan Lv


The default value of '0000-00-00 00:00:00' for MySQL TIMESTAMP fields is not 
supported in downstream systems like Doris & Paimon, we need to adjust this 
default value based on downstream systems.

The current error stack is as follows:
{code:java}
Caused by: 
SchemaEvolveException{applyingEvent=CreateTableEvent{tableId=test.orders, 
schema=columns={order_id INT NOT NULL,order_date TIMESTAMP(0) NOT 
NULL,customer_name VARCHAR(255) NOT NULL,price DECIMAL(10, 5) NOT 
NULL,product_id INT NOT NULL,order_status BOOLEAN NOT NULL,ctime 
TIMESTAMP_LTZ(0) NOT NULL '0000-00-00 00:00:00',name VARCHAR(64) NOT NULL ''}, 
primaryKeys=order_id, options=()}, exceptionMessage='Failed to schemaChange, 
response: {"msg":"Error","code":1,"data":"Failed to execute sql: 
java.sql.SQLException: (conn=216) errCode = 2, detailMessage = date literal 
[0000-00-00 00:00:00] is invalid: Text '0000-00-00 00:00:00' could not be 
parsed: Invalid value for MonthOfYear (valid values 1 - 12): 0","count":0}', 
cause='org.apache.doris.flink.exception.DorisSchemaChangeException: Failed to 
schemaChange, response: {"msg":"Error","code":1,"data":"Failed to execute sql: 
java.sql.SQLException: (conn=216) errCode = 2, detailMessage = date literal 
[0000-00-00 00:00:00] is invalid: Text '0000-00-00 00:00:00' could not be 
parsed: Invalid value for MonthOfYear (valid values 1 - 12): 0","count":0}'}
at 
org.apache.flink.cdc.connectors.doris.sink.DorisMetadataApplier.applyCreateTableEvent(DorisMetadataApplier.java:167)
 {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to