(flink) branch master updated: [hotfix][docs] Fix example code in documentation

[guoweijie]

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

guoweijie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 0c7b1aec829 [hotfix][docs] Fix example code in documentation
0c7b1aec829 is described below

commit 0c7b1aec829eee17a43a2628b9ea2d093c53d676
Author: Zmm <102840730+zmmbigd...@users.noreply.github.com>
AuthorDate: Fri May 31 15:46:06 2024 +0800

    [hotfix][docs] Fix example code in documentation
---
 docs/content.zh/docs/dev/table/sql/gettingStarted.md   | 3 ++-
 docs/content.zh/docs/dev/table/sql/queries/overview.md | 1 +
 docs/content/docs/dev/table/sql/gettingStarted.md      | 3 ++-
 docs/content/docs/dev/table/sql/queries/overview.md    | 1 +
 4 files changed, 6 insertions(+), 2 deletions(-)

diff --git a/docs/content.zh/docs/dev/table/sql/gettingStarted.md 
b/docs/content.zh/docs/dev/table/sql/gettingStarted.md
index d529fc60575..5990bbe7d2b 100644
--- a/docs/content.zh/docs/dev/table/sql/gettingStarted.md
+++ b/docs/content.zh/docs/dev/table/sql/gettingStarted.md
@@ -139,7 +139,8 @@ INSERT INTO department_counts
  SELECT 
        dept_id,
        COUNT(*) as emp_count 
-FROM employee_information;
+FROM employee_information
+GROUP BY dept_id;
  ``` 
  
 提交后，它将运行并将结果直接存储到 sink 表中，而不是将结果加载到系统内存中。
diff --git a/docs/content.zh/docs/dev/table/sql/queries/overview.md 
b/docs/content.zh/docs/dev/table/sql/queries/overview.md
index eea0f17bd85..6f8b12193f0 100644
--- a/docs/content.zh/docs/dev/table/sql/queries/overview.md
+++ b/docs/content.zh/docs/dev/table/sql/queries/overview.md
@@ -77,6 +77,7 @@ final Schema schema = Schema.newBuilder()
 
 final TableDescriptor sinkDescriptor = 
TableDescriptor.forConnector("filesystem")
     .schema(schema)
+    .option("path", "/path/to/file")
     .format(FormatDescriptor.forFormat("csv")
         .option("field-delimiter", ",")
         .build())
diff --git a/docs/content/docs/dev/table/sql/gettingStarted.md 
b/docs/content/docs/dev/table/sql/gettingStarted.md
index 2a909d14e2e..7d34ac6dad7 100644
--- a/docs/content/docs/dev/table/sql/gettingStarted.md
+++ b/docs/content/docs/dev/table/sql/gettingStarted.md
@@ -140,7 +140,8 @@ INSERT INTO department_counts
  SELECT 
        dept_id,
        COUNT(*) as emp_count 
-FROM employee_information;
+FROM employee_information
+GROUP BY dept_id;
  ``` 
  
 Once submitted, this will run and store the results into the sink table 
directly, instead of loading the results into the system memory. 
diff --git a/docs/content/docs/dev/table/sql/queries/overview.md 
b/docs/content/docs/dev/table/sql/queries/overview.md
index ebda36e7b99..a5cebac833c 100644
--- a/docs/content/docs/dev/table/sql/queries/overview.md
+++ b/docs/content/docs/dev/table/sql/queries/overview.md
@@ -77,6 +77,7 @@ final Schema schema = Schema.newBuilder()
 
 final TableDescriptor sinkDescriptor = 
TableDescriptor.forConnector("filesystem")
     .schema(schema)
+    .option("path", "/path/to/file")    
     .format(FormatDescriptor.forFormat("csv")
         .option("field-delimiter", ",")
         .build())