Yanquan Lv created FLINK-39373:
----------------------------------
Summary: An error occurred when modifying the default value of a
column while executing the StarRocks Pipeline Sink operation
Key: FLINK-39373
URL: https://issues.apache.org/jira/browse/FLINK-39373
Project: Flink
Issue Type: Improvement
Components: Flink CDC
Affects Versions: cdc-3.6.0
Reporter: Yanquan Lv
An error occurred while modifying the default value of a column.
Error message:
{code:java}
Caused by: java.sql.SQLSyntaxErrorException: Can not change default value
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.executeUpdateInternal(StatementImpl.java:1335)
~[?:?]
at
com.mysql.cj.jdbc.StatementImpl.executeLargeUpdate(StatementImpl.java:2084)
~[?:?]
at
com.mysql.cj.jdbc.StatementImpl.executeUpdate(StatementImpl.java:1246) ~[?:?]
at
com.starrocks.connector.flink.catalog.StarRocksCatalog.executeUpdateStatement(StarRocksCatalog.java:418)
~[?:?]
at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
~[?:?]
at
jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
~[?:?]
at
jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
~[?:?]
at java.lang.reflect.Method.invoke(Method.java:566) ~[?:?]
at
org.apache.flink.cdc.connectors.starrocks.sink.StarRocksEnrichedCatalog.executeUpdateStatementWrapped(StarRocksEnrichedCatalog.java:156)
~[?:?]
at
org.apache.flink.cdc.connectors.starrocks.sink.StarRocksEnrichedCatalog.alterColumnType(StarRocksEnrichedCatalog.java:106)
~[?:?]
at
org.apache.flink.cdc.connectors.starrocks.sink.StarRocksMetadataApplier.applyAlterColumnType(StarRocksMetadataApplier.java:321)
~[?:?]
at
org.apache.flink.cdc.connectors.starrocks.sink.StarRocksMetadataApplier.lambda$applySchemaChange$1(StarRocksMetadataApplier.java:116)
~[?:?]
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
