twalthr commented on a change in pull request #16018:
URL: https://github.com/apache/flink/pull/16018#discussion_r641552544
##########
File path: docs/content.zh/docs/dev/table/common.md
##########
@@ -224,7 +224,7 @@ import org.apache.flink.table.api.EnvironmentSettings
import org.apache.flink.table.api.bridge.scala.StreamTableEnvironment
val bsEnv = StreamExecutionEnvironment.getExecutionEnvironment
Review comment:
remove `bs` and `b_s_settings` etc. here and below? I think the "b"
stood for Blink in the past?
##########
File path: docs/content.zh/docs/dev/table/tableApi.md
##########
@@ -118,7 +117,7 @@ from pyflink.table import *
# environment configuration
t_env = BatchTableEnvironment.create(
Review comment:
update usages of `BatchTableEnvironment`?
##########
File path: docs/content.zh/docs/dev/table/common.md
##########
@@ -267,15 +267,15 @@ from pyflink.datastream import StreamExecutionEnvironment
from pyflink.table import StreamTableEnvironment, EnvironmentSettings
b_s_env = StreamExecutionEnvironment.get_execution_environment()
-b_s_settings =
EnvironmentSettings.new_instance().use_blink_planner().in_streaming_mode().build()
+b_s_settings = EnvironmentSettings.new_instance().in_streaming_mode().build()
b_s_t_env = StreamTableEnvironment.create(b_s_env,
environment_settings=b_s_settings)
# ******************
# BLINK BATCH QUERY
Review comment:
update?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
