[docs] Fix docs confusing point about catalog create (#2503)

apache · Dec 13, 2023 · 866e26f · 866e26f
1 parent c4f74c4
commit 866e26f
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/docs/content/api/flink-api.md b/docs/content/api/flink-api.md
@@ -199,18 +199,15 @@ public class WriteCdcToTable {
 
         new RichCdcSinkBuilder()
                 .withInput(dataStream)
-                .withTable(createTableIfNotExists(identifier))
+                .withTable(createTableIfNotExists(catalogLoader.load(), identifier))
                 .withIdentifier(identifier)
                 .withCatalogLoader(catalogLoader)
                 .build();
 
         env.execute();
     }
 
-    private static Table createTableIfNotExists(Identifier identifier) throws Exception {
-        CatalogContext context = CatalogContext.create(new Path("..."));
-        Catalog catalog = CatalogFactory.createCatalog(context);
-
+    private static Table createTableIfNotExists(Catalog catalog, Identifier identifier) throws Exception {
         Schema.Builder schemaBuilder = Schema.newBuilder();
         schemaBuilder.primaryKey("order_id");
         schemaBuilder.column("order_id", DataTypes.BIGINT());