commit 9f1c2d83e5fb3b43782c26fbd065b8c90604d8b5
author Dian Fu <dianfu@apache.org> Fri Sep 10 16:56:10 2021 +0800
committer Dian Fu <dianfu@apache.org> Mon Sep 13 11:21:00 2021 +0800
tree 4ffa07f6cc3d563a5ebd10be931cc58c0336b6a5
parent e3d716783a8421638095a3938e3a9d8f7911f4ba

[FLINK-24244][python] Logging whether it's executed in loopback mode

This closes #17234.

flink-python/pyflink/fn_execution/beam/beam_worker_pool_service.py

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 3d0e868..925695d 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
@@ -125,8 +125,11 @@
 
             # Send all logs to the runner.
             fn_log_handler = FnApiLogRecordHandler(logging_service_descriptor)
-            logging.getLogger().setLevel(logging.ERROR)
+            logging.getLogger().setLevel(logging.INFO)
+            # Remove all the built-in log handles
+            logging.getLogger().handlers = []
             logging.getLogger().addHandler(fn_log_handler)
+            logging.info("Starting up Python worker in loopback mode.")
         except Exception:
             _LOGGER.error(
                 "Failed to set up logging handler, continuing without.",