[flink] branch release-1.13 updated: [hotfix][python][docs] Update the examples to use latest API

[dianfu]

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

dianfu pushed a commit to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.13 by this push:
     new 4d56fce  [hotfix][python][docs] Update the examples to use latest API
4d56fce is described below

commit 4d56fce7c029f365449d0df8f6f99ea6df7d37c8
Author: Dian Fu <dia...@apache.org>
AuthorDate: Tue Aug 24 19:23:56 2021 +0800

    [hotfix][python][docs] Update the examples to use latest API
---
 docs/content.zh/docs/dev/python/debugging.md          | 2 +-
 docs/content.zh/docs/dev/python/table_api_tutorial.md | 6 ++----
 docs/content/docs/dev/python/debugging.md             | 2 +-
 docs/content/docs/dev/python/table_api_tutorial.md    | 4 ++--
 4 files changed, 6 insertions(+), 8 deletions(-)

diff --git a/docs/content.zh/docs/dev/python/debugging.md 
b/docs/content.zh/docs/dev/python/debugging.md
index 114bcac..231306f 100644
--- a/docs/content.zh/docs/dev/python/debugging.md
+++ b/docs/content.zh/docs/dev/python/debugging.md
@@ -37,7 +37,7 @@ under the License.
 from pyflink.table import EnvironmentSettings, TableEnvironment
 
 # 创建 TableEnvironment
-env_settings = EnvironmentSettings.in_streaming_mode()
+env_settings = EnvironmentSettings.new_instance().in_streaming_mode().build()
 table_env = TableEnvironment.create(env_settings)
 
 table = table_env.from_elements([(1, 'Hi'), (2, 'Hello')])
diff --git a/docs/content.zh/docs/dev/python/table_api_tutorial.md 
b/docs/content.zh/docs/dev/python/table_api_tutorial.md
index ae9779b..398281f 100644
--- a/docs/content.zh/docs/dev/python/table_api_tutorial.md
+++ b/docs/content.zh/docs/dev/python/table_api_tutorial.md
@@ -29,8 +29,6 @@ under the License.
 
 # Table API 教程
 
-
-
 Apache Flink 提供 Table API 关系型 API 
来统一处理流和批，即查询在无边界的实时流或有边界的批处理数据集上以相同的语义执行，并产生相同的结果。 Flink 的 Table API 
易于编写，通常能简化数据分析，数据管道和ETL应用的编码。
 
 ## 概要
@@ -117,8 +115,8 @@ my_sink_ddl = """
     )
 """
 
-t_env.sql_update(my_source_ddl)
-t_env.sql_update(my_sink_ddl)
+t_env.execute_sql(my_source_ddl)
+t_env.execute_sql(my_sink_ddl)
 ```
 
 上面的程序展示了如何创建及在`ExecutionEnvironment`中注册表名分别为`mySource`和`mySink`的表。
diff --git a/docs/content/docs/dev/python/debugging.md 
b/docs/content/docs/dev/python/debugging.md
index cef33ec..84c4d18 100644
--- a/docs/content/docs/dev/python/debugging.md
+++ b/docs/content/docs/dev/python/debugging.md
@@ -38,7 +38,7 @@ of the client during job submission.
 from pyflink.table import EnvironmentSettings, TableEnvironment
 
 # create a TableEnvironment
-env_settings = EnvironmentSettings.in_streaming_mode()
+env_settings = EnvironmentSettings.new_instance().in_streaming_mode().build()
 table_env = TableEnvironment.create(env_settings)
 
 table = table_env.from_elements([(1, 'Hi'), (2, 'Hello')])
diff --git a/docs/content/docs/dev/python/table_api_tutorial.md 
b/docs/content/docs/dev/python/table_api_tutorial.md
index 49fdbd4..948ef3a 100644
--- a/docs/content/docs/dev/python/table_api_tutorial.md
+++ b/docs/content/docs/dev/python/table_api_tutorial.md
@@ -118,8 +118,8 @@ my_sink_ddl = """
     )
 """
 
-t_env.sql_update(my_source_ddl)
-t_env.sql_update(my_sink_ddl)
+t_env.execute_sql(my_source_ddl)
+t_env.execute_sql(my_sink_ddl)
 ```
 This registers a table named `mySource` and a table named `mySink` in the 
execution environment.
 The table `mySource` has only one column, word, and it consumes strings read 
from file `/tmp/input`.