fix style

Author: cshuo

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-hudi/src/test/java/org/apache/flink/cdc/connectors/hudi/sink/HudiMetadataApplierTest.java

@@ -41,7 +41,7 @@
 import java.util.Map;
 import java.util.UUID;
 
-import static org.junit.jupiter.api.Assertions.assertDoesNotThrow;
+import static org.assertj.core.api.Assertions.assertThatNoException;
 
 /** Tests for {@link HudiMetadataApplier}. */
 class HudiMetadataApplierTest {
@@ -86,28 +86,32 @@ void testApplySchemaChange() throws Exception {
                                     "col3DefValue")));
             AddColumnEvent addColumnEvent =
                     new AddColumnEvent(TableId.parse("test.table1"), addedColumns);
-            assertDoesNotThrow(() -> metadataApplier.applySchemaChange(addColumnEvent));
+            assertThatNoException()
+                    .isThrownBy(() -> metadataApplier.applySchemaChange(addColumnEvent));
 
             // Test rename column
             Map<String, String> nameMapping = new HashMap<>();
             nameMapping.put("col2", "newcol2");
             nameMapping.put("col3", "newcol3");
             RenameColumnEvent renameColumnEvent =
                     new RenameColumnEvent(TableId.parse("test.table1"), nameMapping);
-            assertDoesNotThrow(() -> metadataApplier.applySchemaChange(renameColumnEvent));
+            assertThatNoException()
+                    .isThrownBy(() -> metadataApplier.applySchemaChange(renameColumnEvent));
 
             // Test alter column type
             Map<String, DataType> typeMapping = new HashMap<>();
             typeMapping.put("newcol2", org.apache.flink.cdc.common.types.DataTypes.STRING());
             AlterColumnTypeEvent alterColumnTypeEvent =
                     new AlterColumnTypeEvent(TableId.parse("test.table1"), typeMapping);
-            assertDoesNotThrow(() -> metadataApplier.applySchemaChange(alterColumnTypeEvent));
+            assertThatNoException()
+                    .isThrownBy(() -> metadataApplier.applySchemaChange(alterColumnTypeEvent));
 
             // Test drop column
             DropColumnEvent dropColumnEvent =
                     new DropColumnEvent(
                             TableId.parse("test.table1"), Collections.singletonList("newcol2"));
-            assertDoesNotThrow(() -> metadataApplier.applySchemaChange(dropColumnEvent));
+            assertThatNoException()
+                    .isThrownBy(() -> metadataApplier.applySchemaChange(dropColumnEvent));
         }
     }
 
@@ -182,7 +186,8 @@ void testCreateTableWithAllDataTypes() throws Exception {
                                             org.apache.flink.cdc.common.types.DataTypes.TIMESTAMP())
                                     .primaryKey("col1")
                                     .build());
-            assertDoesNotThrow(() -> metadataApplier.applySchemaChange(createTableEvent));
+            assertThatNoException()
+                    .isThrownBy(() -> metadataApplier.applySchemaChange(createTableEvent));
         }
     }
 
@@ -197,6 +202,6 @@ void testClose() throws Exception {
         config.set(HudiConfig.TABLE_TYPE, "MERGE_ON_READ");
 
         HudiMetadataApplier metadataApplier = new HudiMetadataApplier(config);
-        assertDoesNotThrow(metadataApplier::close);
+        assertThatNoException().isThrownBy(metadataApplier::close);
     }
 }