You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by di...@apache.org on 2021/09/02 01:57:22 UTC
[flink] branch release-1.14 updated: [FLINK-24097][python] Remove
is_streaming_mode checks in StreamTableEnvironment
This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a commit to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.14 by this push:
new 3f348ba [FLINK-24097][python] Remove is_streaming_mode checks in StreamTableEnvironment
3f348ba is described below
commit 3f348ba01be8727d81d3b1cd61533500c25eb31c
Author: Dian Fu <di...@apache.org>
AuthorDate: Wed Sep 1 14:36:05 2021 +0800
[FLINK-24097][python] Remove is_streaming_mode checks in StreamTableEnvironment
This closes #17094.
---
flink-python/pyflink/table/table_environment.py | 3 ---
1 file changed, 3 deletions(-)
diff --git a/flink-python/pyflink/table/table_environment.py b/flink-python/pyflink/table/table_environment.py
index ef05028..2a039b7 100644
--- a/flink-python/pyflink/table/table_environment.py
+++ b/flink-python/pyflink/table/table_environment.py
@@ -1846,9 +1846,6 @@ class StreamTableEnvironment(TableEnvironment):
gateway = get_gateway()
if environment_settings is not None:
- if not environment_settings.is_streaming_mode():
- raise ValueError("The environment settings for StreamTableEnvironment must be "
- "set to streaming mode.")
if stream_execution_environment is None:
j_tenv = gateway.jvm.TableEnvironment.create(
environment_settings._j_environment_settings)