linguoxuan opened a new pull request, #4363: URL: https://github.com/apache/flink-cdc/pull/4363
### Purpose Fix a bug in the StarRocks pipeline sink where executing AlterColumnTypeEvent would cause the existing default value of a column to be lost. ### Bug When AlterColumnTypeEvent is applied to modify a column's data type in StarRocks, the event does not carry the column's original default value. As a result, the generated ALTER TABLE ... MODIFY COLUMN SQL statement omits the DEFAULT clause, causing StarRocks to throw an error. ### Changes Added getColumnDefaultValue() method in StarRocksEnrichedCatalog to query the current default value of a column from information_schema.COLUMNS. Added getConnection() helper method to obtain a JDBC connection from the parent StarRocksCatalog via reflection. Modified alterColumnType() to check and preserve the existing default value when the new column definition does not specify one. Added integration test testAlterColumnTypePreservesDefaultValue to verify that the default value is retained after altering the column type. -- 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]
