This is an automated email from the ASF dual-hosted git repository.

hxb pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 02f6ca4  [hotfix][python] Remove unnecessary output in startup of 
loopback mode
02f6ca4 is described below

commit 02f6ca49a628641b17940e556ae0b44f7a6e57c9
Author: huangxingbo <[email protected]>
AuthorDate: Wed Aug 18 20:06:17 2021 +0800

    [hotfix][python] Remove unnecessary output in startup of loopback mode
---
 flink-python/pyflink/fn_execution/beam/beam_boot.py | 2 --
 1 file changed, 2 deletions(-)

diff --git a/flink-python/pyflink/fn_execution/beam/beam_boot.py 
b/flink-python/pyflink/fn_execution/beam/beam_boot.py
index 5887434..551f6ce 100644
--- a/flink-python/pyflink/fn_execution/beam/beam_boot.py
+++ b/flink-python/pyflink/fn_execution/beam/beam_boot.py
@@ -106,8 +106,6 @@ if __name__ == "__main__":
             ApiServiceDescriptor(url=control_endpoint))
 
         env = dict(os.environ)
-        with open('/tmp/test.txt', 'a') as fd:
-            fd.write(str(env) + '\n')
 
         if "FLINK_BOOT_TESTING" in os.environ and 
os.environ["FLINK_BOOT_TESTING"] == "1":
             exit(0)

Reply via email to