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 574e80f [FLINK-24276][python] Avoid confusing output when executing
in loopback mode
574e80f is described below
commit 574e80fb30772d5b62c6b70d26fff6a7740680bb
Author: huangxingbo <[email protected]>
AuthorDate: Tue Sep 14 11:23:01 2021 +0800
[FLINK-24276][python] Avoid confusing output when executing in loopback mode
This closes #17274.
---
flink-python/pyflink/fn_execution/beam/beam_worker_pool_service.py | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/flink-python/pyflink/fn_execution/beam/beam_worker_pool_service.py
b/flink-python/pyflink/fn_execution/beam/beam_worker_pool_service.py
index 925695d..b49002a 100644
--- a/flink-python/pyflink/fn_execution/beam/beam_worker_pool_service.py
+++ b/flink-python/pyflink/fn_execution/beam/beam_worker_pool_service.py
@@ -24,6 +24,10 @@ import threading
import traceback
import grpc
+
+# In order to remove confusing infos produced by beam.
+logging.getLogger().setLevel(logging.WARNING)
+
from apache_beam.options.pipeline_options import DebugOptions
from apache_beam.options.pipeline_options import ProfilingOptions
from apache_beam.portability.api import beam_fn_api_pb2
