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)