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");