This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 0fc1024d8 [doc] fix flink api error (#963)
0fc1024d8 is described below

commit 0fc1024d8af2aad599da1623f435ce9e442b4624
Author: SYG-ATONE <[email protected]>
AuthorDate: Thu Apr 20 19:21:39 2023 +0800

    [doc] fix flink api error (#963)
---
 docs/content/api/flink-api.md | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/docs/content/api/flink-api.md b/docs/content/api/flink-api.md
index 4ee56c0ae..d654c5d09 100644
--- a/docs/content/api/flink-api.md
+++ b/docs/content/api/flink-api.md
@@ -92,7 +92,7 @@ public class WriteToTable {
 
         // create paimon catalog
         tableEnv.executeSql("CREATE CATALOG paimon WITH ('type' = 'paimon', 
'warehouse'='...')");
-        tableEnv.executeSql("USE paimon");
+        tableEnv.executeSql("USE CATALOG paimon");
 
         // register the table under a name and perform an aggregation
         tableEnv.createTemporaryView("InputTable", table);
@@ -121,7 +121,7 @@ public class ReadFromTable {
 
         // create paimon catalog
         tableEnv.executeSql("CREATE CATALOG paimon WITH ('type' = 'paimon', 
'warehouse'='...')");
-        tableEnv.executeSql("USE paimon");
+        tableEnv.executeSql("USE CATALOG paimon");
 
         // convert to DataStream
         Table table = tableEnv.sqlQuery("SELECT * FROM my_paimon_table");

Reply via email to