delete no need test

paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/FlinkCatalogTest.java

@@ -145,7 +145,22 @@ public void beforeEach() throws IOException {
     }
 
     private ResolvedSchema createSchema() {
-        return FlinkCatalogTestUtil.createSchema();
+        return new ResolvedSchema(
+                Arrays.asList(
+                        Column.physical("first", DataTypes.STRING()),
+                        Column.physical("second", DataTypes.INT()),
+                        Column.physical("third", DataTypes.STRING()),
+                        Column.physical(
+                                "four",
+                                DataTypes.ROW(
+                                        DataTypes.FIELD("f1", DataTypes.STRING()),
+                                        DataTypes.FIELD("f2", DataTypes.INT()),
+                                        DataTypes.FIELD(
+                                                "f3",
+                                                DataTypes.MAP(
+                                                        DataTypes.STRING(), DataTypes.INT()))))),
+                Collections.emptyList(),
+                null);
     }
 
     private List<String> createPartitionKeys() {
@@ -177,7 +192,14 @@ private CatalogTable createAnotherPartitionedTable(Map<String, String> options)
     }
 
     private CatalogTable createTable(Map<String, String> options) {
-        return FlinkCatalogTestUtil.createTable(options);
+        ResolvedSchema resolvedSchema = this.createSchema();
+        CatalogTable origin =
+                CatalogTable.of(
+                        Schema.newBuilder().fromResolvedSchema(resolvedSchema).build(),
+                        "test comment",
+                        Collections.emptyList(),
+                        options);
+        return new ResolvedCatalogTable(origin, resolvedSchema);
     }
 
     private CatalogTable createPartitionedTable(Map<String, String> options) {
@@ -342,7 +364,7 @@ public void testCreateFlinkTableWithPath() throws Exception {
     @MethodSource("streamingOptionProvider")
     public void testCreateTable_Streaming(Map<String, String> options) throws Exception {
         catalog.createDatabase(path1.getDatabaseName(), null, false);
-        CatalogTable table = FlinkCatalogTestUtil.createTable(options);
+        CatalogTable table = this.createTable(options);
         catalog.createTable(path1, table, false);
         checkCreateTable(path1, table, (CatalogTable) catalog.getTable(path1));
     }