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)