From d2ca03c3ce1c85b62d3d27b2c94377106169df07 Mon Sep 17 00:00:00 2001 From: "yunhao.w" Date: Sat, 31 Jan 2026 22:33:00 +0800 Subject: [PATCH 1/4] add Fix microseconds default value --- .../doris/sink/DorisMetadataApplier.java | 2 +- .../sink/DorisMetadataApplierITCase.java | 105 ++++++++++++++++++ .../paimon/sink/SchemaChangeProvider.java | 2 +- .../starrocks/sink/StarRocksUtils.java | 2 +- 4 files changed, 108 insertions(+), 3 deletions(-) diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisMetadataApplier.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisMetadataApplier.java index fdf4b53669b..f83b366e149 100644 --- a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisMetadataApplier.java +++ b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisMetadataApplier.java @@ -331,7 +331,7 @@ private String convertInvalidTimestampDefaultValue(String defaultValue, DataType || dataType instanceof TimestampType || dataType instanceof ZonedTimestampType) { - if (DorisSchemaUtils.INVALID_OR_MISSING_DATATIME.equals(defaultValue)) { + if (defaultValue.startsWith(DorisSchemaUtils.INVALID_OR_MISSING_DATATIME)) { return DorisSchemaUtils.DEFAULT_DATETIME; } } diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/test/java/org/apache/flink/cdc/connectors/doris/sink/DorisMetadataApplierITCase.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/test/java/org/apache/flink/cdc/connectors/doris/sink/DorisMetadataApplierITCase.java index bf8ff7e523a..bb63b7f2ed0 100644 --- a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/test/java/org/apache/flink/cdc/connectors/doris/sink/DorisMetadataApplierITCase.java +++ b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/test/java/org/apache/flink/cdc/connectors/doris/sink/DorisMetadataApplierITCase.java @@ -630,6 +630,111 @@ void testMysqlDefaultTimestampValueConversionInAddColumn(boolean batchMode) thro assertEqualsInOrder(expected, actual); } + /** Microsecond variant: '0000-00-00 00:00:00.000000' */ + private static final String INVALID_DATETIME_WITH_MICROS = "0000-00-00 00:00:00.000000"; + + @ParameterizedTest(name = "batchMode: {0}") + @ValueSource(booleans = {true, false}) + void testMysqlDefaultTimestampValueWithMicrosInCreateTable(boolean batchMode) throws Exception { + TableId tableId = + TableId.tableId( + DorisContainer.DORIS_DATABASE_NAME, DorisContainer.DORIS_TABLE_NAME); + + Schema schema = + Schema.newBuilder() + .column(new PhysicalColumn("id", DataTypes.INT().notNull(), null)) + .column(new PhysicalColumn("name", DataTypes.VARCHAR(50), null)) + .column( + new PhysicalColumn( + "created_time", + DataTypes.TIMESTAMP(6), + null, + INVALID_DATETIME_WITH_MICROS)) + .column( + new PhysicalColumn( + "updated_time", + DataTypes.TIMESTAMP_LTZ(6), + null, + INVALID_DATETIME_WITH_MICROS)) + .primaryKey("id") + .build(); + + runJobWithEvents( + Collections.singletonList(new CreateTableEvent(tableId, schema)), batchMode); + + List actual = inspectTableSchema(tableId); + + List expected = + Arrays.asList( + "id | INT | Yes | true | null", + "name | VARCHAR(150) | Yes | false | null", + "created_time | DATETIME(6) | Yes | false | " + + DorisSchemaUtils.DEFAULT_DATETIME, + "updated_time | DATETIME(6) | Yes | false | " + + DorisSchemaUtils.DEFAULT_DATETIME); + + assertEqualsInOrder(expected, actual); + } + + @ParameterizedTest(name = "batchMode: {0}") + @ValueSource(booleans = {true, false}) + void testMysqlDefaultTimestampValueWithMicrosInAddColumn(boolean batchMode) throws Exception { + TableId tableId = + TableId.tableId( + DorisContainer.DORIS_DATABASE_NAME, DorisContainer.DORIS_TABLE_NAME); + + Schema initialSchema = + Schema.newBuilder() + .column(new PhysicalColumn("id", DataTypes.INT().notNull(), null)) + .column(new PhysicalColumn("name", DataTypes.VARCHAR(50), null)) + .primaryKey("id") + .build(); + + List events = new ArrayList<>(); + events.add(new CreateTableEvent(tableId, initialSchema)); + + PhysicalColumn createdTimeCol = + new PhysicalColumn( + "created_time", + DataTypes.TIMESTAMP(6), + null, + INVALID_DATETIME_WITH_MICROS); + + PhysicalColumn updatedTimeCol = + new PhysicalColumn( + "updated_time", + DataTypes.TIMESTAMP_LTZ(6), + null, + INVALID_DATETIME_WITH_MICROS); + + events.add( + new AddColumnEvent( + tableId, + Collections.singletonList( + new AddColumnEvent.ColumnWithPosition(createdTimeCol)))); + + events.add( + new AddColumnEvent( + tableId, + Collections.singletonList( + new AddColumnEvent.ColumnWithPosition(updatedTimeCol)))); + + runJobWithEvents(events, batchMode); + + List actual = inspectTableSchema(tableId); + + List expected = + Arrays.asList( + "id | INT | Yes | true | null", + "name | VARCHAR(150) | Yes | false | null", + "created_time | DATETIME(6) | Yes | false | " + + DorisSchemaUtils.DEFAULT_DATETIME, + "updated_time | DATETIME(6) | Yes | false | " + + DorisSchemaUtils.DEFAULT_DATETIME); + + assertEqualsInOrder(expected, actual); + } + private void runJobWithEvents(List events, boolean batchMode) throws Exception { DataStream stream = env.fromCollection(events, TypeInformation.of(Event.class)).setParallelism(1); diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/SchemaChangeProvider.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/SchemaChangeProvider.java index 22ee7ade10f..5e8beacc950 100644 --- a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/SchemaChangeProvider.java +++ b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/SchemaChangeProvider.java @@ -161,7 +161,7 @@ private static String convertInvalidTimestampDefaultValue( || dataType instanceof TimestampType || dataType instanceof ZonedTimestampType) { - if (INVALID_OR_MISSING_DATATIME.equals(defaultValue)) { + if (defaultValue.startsWith(INVALID_OR_MISSING_DATATIME)) { return DEFAULT_DATETIME; } } diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksUtils.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksUtils.java index d302f297e2d..548ecf795fe 100644 --- a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksUtils.java +++ b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksUtils.java @@ -404,7 +404,7 @@ public static String convertInvalidTimestampDefaultValue( || dataType instanceof org.apache.flink.cdc.common.types.TimestampType || dataType instanceof org.apache.flink.cdc.common.types.ZonedTimestampType) { - if (INVALID_OR_MISSING_DATATIME.equals(defaultValue)) { + if (defaultValue.startsWith(INVALID_OR_MISSING_DATATIME)) { return DEFAULT_DATETIME; } } From c2a0b75d39060e46c38b3bdabefc89708578905b Mon Sep 17 00:00:00 2001 From: "yunhao.w" Date: Sat, 31 Jan 2026 22:36:37 +0800 Subject: [PATCH 2/4] add tests for Paimon and StarRocks --- .../sink/PaimonMetadataApplierTest.java | 54 +++++++++ .../sink/StarRocksMetadataApplierITCase.java | 104 ++++++++++++++++++ 2 files changed, 158 insertions(+) diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/test/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplierTest.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/test/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplierTest.java index 7f0ed436db4..1fb176ce006 100644 --- a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/test/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplierTest.java +++ b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/test/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplierTest.java @@ -669,4 +669,58 @@ public void testMysqlDefaultTimestampValueConversionInAddColumn() Assertions.assertThat(table).isNotNull(); } + + /** Microsecond variant: '0000-00-00 00:00:00.000000' */ + private static final String INVALID_DATETIME_WITH_MICROS = "0000-00-00 00:00:00.000000"; + + @Test + public void testMysqlDefaultTimestampValueWithMicrosInAddColumn() + throws SchemaEvolveException, + Catalog.TableNotExistException, + Catalog.DatabaseNotEmptyException, + Catalog.DatabaseNotExistException { + initialize("filesystem"); + Map tableOptions = new HashMap<>(); + tableOptions.put("bucket", "-1"); + MetadataApplier metadataApplier = + new PaimonMetadataApplier(catalogOptions, tableOptions, new HashMap<>()); + + CreateTableEvent createTableEvent = + new CreateTableEvent( + TableId.parse("test.timestamp_micros_test"), + org.apache.flink.cdc.common.schema.Schema.newBuilder() + .physicalColumn( + "id", + org.apache.flink.cdc.common.types.DataTypes.INT().notNull()) + .physicalColumn( + "name", + org.apache.flink.cdc.common.types.DataTypes.STRING()) + .primaryKey("id") + .build()); + metadataApplier.applySchemaChange(createTableEvent); + + List addedColumns = new ArrayList<>(); + addedColumns.add( + AddColumnEvent.last( + Column.physicalColumn( + "created_time", + org.apache.flink.cdc.common.types.DataTypes.TIMESTAMP(6), + null, + INVALID_DATETIME_WITH_MICROS))); + addedColumns.add( + AddColumnEvent.last( + Column.physicalColumn( + "updated_time", + org.apache.flink.cdc.common.types.DataTypes.TIMESTAMP_LTZ(6), + null, + INVALID_DATETIME_WITH_MICROS))); + + AddColumnEvent addColumnEvent = + new AddColumnEvent(TableId.parse("test.timestamp_micros_test"), addedColumns); + metadataApplier.applySchemaChange(addColumnEvent); + + Table table = catalog.getTable(Identifier.fromString("test.timestamp_micros_test")); + + Assertions.assertThat(table).isNotNull(); + } } diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksMetadataApplierITCase.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksMetadataApplierITCase.java index e2dc50551da..30da621c923 100644 --- a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksMetadataApplierITCase.java +++ b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksMetadataApplierITCase.java @@ -577,4 +577,108 @@ void testMysqlDefaultTimestampValueConversionInAddColumn() throws Exception { assertEqualsInOrder(expected, actual); } + + /** Microsecond variant: '0000-00-00 00:00:00.000000' */ + private static final String INVALID_DATETIME_WITH_MICROS = "0000-00-00 00:00:00.000000"; + + @Test + void testMysqlDefaultTimestampValueWithMicrosInCreateTable() throws Exception { + TableId tableId = + TableId.tableId( + StarRocksContainer.STARROCKS_DATABASE_NAME, + StarRocksContainer.STARROCKS_TABLE_NAME); + + Schema schema = + Schema.newBuilder() + .column(new PhysicalColumn("id", DataTypes.INT().notNull(), null)) + .column(new PhysicalColumn("name", DataTypes.VARCHAR(50), null)) + .column( + new PhysicalColumn( + "created_time", + DataTypes.TIMESTAMP(6), + null, + INVALID_DATETIME_WITH_MICROS)) + .column( + new PhysicalColumn( + "updated_time", + DataTypes.TIMESTAMP_LTZ(6), + null, + INVALID_DATETIME_WITH_MICROS)) + .primaryKey("id") + .build(); + + runJobWithEvents(Collections.singletonList(new CreateTableEvent(tableId, schema))); + + List actual = inspectTableSchema(tableId); + + List expected = + Arrays.asList( + "id | int | NO | true | null", + "name | varchar(150) | YES | false | null", + "created_time | datetime | YES | false | " + + StarRocksUtils.DEFAULT_DATETIME, + "updated_time | datetime | YES | false | " + + StarRocksUtils.DEFAULT_DATETIME); + + assertEqualsInOrder(expected, actual); + } + + @Test + void testMysqlDefaultTimestampValueWithMicrosInAddColumn() throws Exception { + TableId tableId = + TableId.tableId( + StarRocksContainer.STARROCKS_DATABASE_NAME, + StarRocksContainer.STARROCKS_TABLE_NAME); + + Schema initialSchema = + Schema.newBuilder() + .column(new PhysicalColumn("id", DataTypes.INT().notNull(), null)) + .column(new PhysicalColumn("name", DataTypes.VARCHAR(50), null)) + .primaryKey("id") + .build(); + + List events = new ArrayList<>(); + events.add(new CreateTableEvent(tableId, initialSchema)); + + PhysicalColumn createdTimeCol = + new PhysicalColumn( + "created_time", + DataTypes.TIMESTAMP(6), + null, + INVALID_DATETIME_WITH_MICROS); + + PhysicalColumn updatedTimeCol = + new PhysicalColumn( + "updated_time", + DataTypes.TIMESTAMP_LTZ(6), + null, + INVALID_DATETIME_WITH_MICROS); + + events.add( + new AddColumnEvent( + tableId, + Collections.singletonList( + new AddColumnEvent.ColumnWithPosition(createdTimeCol)))); + + events.add( + new AddColumnEvent( + tableId, + Collections.singletonList( + new AddColumnEvent.ColumnWithPosition(updatedTimeCol)))); + + runJobWithEvents(events); + + List actual = inspectTableSchema(tableId); + + List expected = + Arrays.asList( + "id | int | NO | true | null", + "name | varchar(150) | YES | false | null", + "created_time | datetime | YES | false | " + + StarRocksUtils.DEFAULT_DATETIME, + "updated_time | datetime | YES | false | " + + StarRocksUtils.DEFAULT_DATETIME); + + assertEqualsInOrder(expected, actual); + } } From 7c6b4b67fbffe8cca7e730334c47fd1e42066ec7 Mon Sep 17 00:00:00 2001 From: "yunhao.w" Date: Sat, 31 Jan 2026 22:46:43 +0800 Subject: [PATCH 3/4] lint code --- .../connectors/doris/sink/DorisMetadataApplierITCase.java | 5 +---- .../starrocks/sink/StarRocksMetadataApplierITCase.java | 5 +---- 2 files changed, 2 insertions(+), 8 deletions(-) diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/test/java/org/apache/flink/cdc/connectors/doris/sink/DorisMetadataApplierITCase.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/test/java/org/apache/flink/cdc/connectors/doris/sink/DorisMetadataApplierITCase.java index bb63b7f2ed0..39aab169e16 100644 --- a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/test/java/org/apache/flink/cdc/connectors/doris/sink/DorisMetadataApplierITCase.java +++ b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/test/java/org/apache/flink/cdc/connectors/doris/sink/DorisMetadataApplierITCase.java @@ -695,10 +695,7 @@ void testMysqlDefaultTimestampValueWithMicrosInAddColumn(boolean batchMode) thro PhysicalColumn createdTimeCol = new PhysicalColumn( - "created_time", - DataTypes.TIMESTAMP(6), - null, - INVALID_DATETIME_WITH_MICROS); + "created_time", DataTypes.TIMESTAMP(6), null, INVALID_DATETIME_WITH_MICROS); PhysicalColumn updatedTimeCol = new PhysicalColumn( diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksMetadataApplierITCase.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksMetadataApplierITCase.java index 30da621c923..57cf844c769 100644 --- a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksMetadataApplierITCase.java +++ b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksMetadataApplierITCase.java @@ -642,10 +642,7 @@ void testMysqlDefaultTimestampValueWithMicrosInAddColumn() throws Exception { PhysicalColumn createdTimeCol = new PhysicalColumn( - "created_time", - DataTypes.TIMESTAMP(6), - null, - INVALID_DATETIME_WITH_MICROS); + "created_time", DataTypes.TIMESTAMP(6), null, INVALID_DATETIME_WITH_MICROS); PhysicalColumn updatedTimeCol = new PhysicalColumn( From 63d4375dfdbbe047c8730df7a96e380c8ee11cd4 Mon Sep 17 00:00:00 2001 From: "yunhao.w" Date: Sun, 1 Feb 2026 00:40:53 +0800 Subject: [PATCH 4/4] lint --- .../cdc/connectors/doris/sink/DorisMetadataApplierITCase.java | 2 +- .../cdc/connectors/paimon/sink/PaimonMetadataApplierTest.java | 2 +- .../starrocks/sink/StarRocksMetadataApplierITCase.java | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/test/java/org/apache/flink/cdc/connectors/doris/sink/DorisMetadataApplierITCase.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/test/java/org/apache/flink/cdc/connectors/doris/sink/DorisMetadataApplierITCase.java index 39aab169e16..bdfde60ef7c 100644 --- a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/test/java/org/apache/flink/cdc/connectors/doris/sink/DorisMetadataApplierITCase.java +++ b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/test/java/org/apache/flink/cdc/connectors/doris/sink/DorisMetadataApplierITCase.java @@ -630,7 +630,7 @@ void testMysqlDefaultTimestampValueConversionInAddColumn(boolean batchMode) thro assertEqualsInOrder(expected, actual); } - /** Microsecond variant: '0000-00-00 00:00:00.000000' */ + /** Microsecond variant: '0000-00-00 00:00:00.000000'. */ private static final String INVALID_DATETIME_WITH_MICROS = "0000-00-00 00:00:00.000000"; @ParameterizedTest(name = "batchMode: {0}") diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/test/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplierTest.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/test/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplierTest.java index 1fb176ce006..9d7e1829a08 100644 --- a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/test/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplierTest.java +++ b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/test/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplierTest.java @@ -670,7 +670,7 @@ public void testMysqlDefaultTimestampValueConversionInAddColumn() Assertions.assertThat(table).isNotNull(); } - /** Microsecond variant: '0000-00-00 00:00:00.000000' */ + /** Microsecond variant: '0000-00-00 00:00:00.000000'. */ private static final String INVALID_DATETIME_WITH_MICROS = "0000-00-00 00:00:00.000000"; @Test diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksMetadataApplierITCase.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksMetadataApplierITCase.java index 57cf844c769..3c2e9b0a947 100644 --- a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksMetadataApplierITCase.java +++ b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksMetadataApplierITCase.java @@ -578,7 +578,7 @@ void testMysqlDefaultTimestampValueConversionInAddColumn() throws Exception { assertEqualsInOrder(expected, actual); } - /** Microsecond variant: '0000-00-00 00:00:00.000000' */ + /** Microsecond variant: '0000-00-00 00:00:00.000000'. */ private static final String INVALID_DATETIME_WITH_MICROS = "0000-00-00 00:00:00.000000"; @Test