[ 
https://issues.apache.org/jira/browse/FLINK-38248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

ASF GitHub Bot updated FLINK-38248:
-----------------------------------
    Labels: pull-request-available  (was: )

> 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.3.0, cdc-3.4.0
>            Reporter: Yanquan Lv
>            Assignee: suhwan
>            Priority: Major
>              Labels: pull-request-available
>
> 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