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 <hxbks...@gmail.com> 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