You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
at org.apache.doris.flink.catalog.doris.DorisSystem.execute(DorisSystem.java:131)
at org.apache.doris.flink.catalog.doris.DorisSystem.createTable(DorisSystem.java:122)
at org.apache.doris.flink.tools.cdc.DatabaseSync.build(DatabaseSync.java:145)
at org.apache.doris.flink.tools.cdc.CdcTools.syncDatabase(CdcTools.java:146)
at org.apache.doris.flink.tools.cdc.CdcTools.createMySQLSyncDatabase(CdcTools.java:74)
at org.apache.doris.flink.tools.cdc.CdcTools.main(CdcTools.java:51)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:355)
... 12 more
Caused by: java.sql.SQLException: errCode = 2, detailMessage = date literal [0000-00-00] is invalid: Text '0000-00-00' could not be parsed: Invalid value for MonthOfYear (valid values 1 - 12): 0
at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:129)
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.doris.flink.catalog.doris.DorisSystem.execute(DorisSystem.java:128)
... 22 more
`
Search before asking
Version
flink-doris-connector-1.17-1.5.2.jar
doris-2.0.3-rc06-37d31a5
mysql5.7
flink-sql-connector-mysql-cdc-2.4.0.jar
What's Wrong?
CREATE TABLE IF NOT EXISTS
xxx.
asku(
idLARGEINT,
dateDATEV2 DEFAULT '0000-00-00',
kVARCHAR(192) DEFAULT '',
store_idLARGEINT DEFAULT '0',
sku_idLARGEINT DEFAULT '0',
product_idLARGEINT DEFAULT '0',
tenant_idVARCHAR(36) DEFAULT '',
day_quantity_orderedINT DEFAULT '0',
day7_quantity_orderedINT DEFAULT '0',
day14_quantity_orderedINT DEFAULT '0',
day30_quantity_orderedINT DEFAULT '0',
week_quantity_orderedINT DEFAULT '0',
month_quantity_orderedINT DEFAULT '0',
today_total_priceDECIMALV3(20,2) DEFAULT '0.00',
day7_total_priceDECIMALV3(20,2) DEFAULT '0.00',
day14_total_priceDECIMALV3(20,2) DEFAULT '0.00',
day30_total_priceDECIMALV3(20,2) DEFAULT '0.00',
week_total_priceDECIMALV3(20,2) DEFAULT '0.00',
month_total_priceDECIMALV3(20,2) DEFAULT '0.00',
today_taxDECIMALV3(20,2) DEFAULT '0.00',
shipping_priceDECIMALV3(20,2) DEFAULT '0.00',
shipping_taxDECIMALV3(20,2) DEFAULT '0.00',
gift_wrap_priceDECIMALV3(20,2) DEFAULT '0.00',
gift_wrap_taxDECIMALV3(20,2) DEFAULT '0.00',
promotion_discountDECIMALV3(20,2) DEFAULT '0.00',
ship_promotion_discountDECIMALV3(20,2) DEFAULT '0.00',
can_sale_quantityINT DEFAULT '0',
fba_on_way_quantityINT DEFAULT '0',
fba_contains_on_way_quantityINT DEFAULT '0',
working_quantityINT DEFAULT '0',
inv_age_three_months_less_daysINT DEFAULT '0',
inv_age_three_six_months_daysINT DEFAULT '0',
inv_age_six_nine_months_daysINT DEFAULT '0',
inv_age_nine_twelve_months_daysINT DEFAULT '0',
inv_age_twelve_months_plus_daysINT DEFAULT '0',
inv_age_earlier_six_monthINT DEFAULT '0',
afn_unsellable_quantityINT DEFAULT '0',
mfn_fulfillable_quantityINT DEFAULT '0',
afn_warehouse_quantityINT DEFAULT '0',
afn_fulfillable_quantityINT DEFAULT '0',
afn_reserved_quantityINT DEFAULT '0',
afn_total_quantityINT DEFAULT '0',
afn_inbound_receiving_quantityINT DEFAULT '0',
reserved_qtyINT DEFAULT '0',
reserved_customer_ordersINT DEFAULT '0',
reserved_fc_transfersINT DEFAULT '0',
reserved_fc_processingINT DEFAULT '0' ) UNIQUE KEY(
id) DISTRIBUTED BY HASH(
id`) BUCKETS AUTO PROPERTIES ('replication_num'='1','light_schema_change'='true');at org.apache.doris.flink.catalog.doris.DorisSystem.execute(DorisSystem.java:131)
at org.apache.doris.flink.catalog.doris.DorisSystem.createTable(DorisSystem.java:122)
at org.apache.doris.flink.tools.cdc.DatabaseSync.build(DatabaseSync.java:145)
at org.apache.doris.flink.tools.cdc.CdcTools.syncDatabase(CdcTools.java:146)
at org.apache.doris.flink.tools.cdc.CdcTools.createMySQLSyncDatabase(CdcTools.java:74)
at org.apache.doris.flink.tools.cdc.CdcTools.main(CdcTools.java:51)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:355)
... 12 more
Caused by: java.sql.SQLException: errCode = 2, detailMessage = date literal [0000-00-00] is invalid: Text '0000-00-00' could not be parsed: Invalid value for MonthOfYear (valid values 1 - 12): 0
at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:129)
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.doris.flink.catalog.doris.DorisSystem.execute(DorisSystem.java:128)
... 22 more
`
What You Expected?
希望能兼容default的格式。有些人确实有些0000-00-00的习惯。
How to Reproduce?
No response
Anything Else?
No response
Are you willing to submit PR?
Code of Conduct
The text was updated successfully, but these errors were encountered: