This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from e2b34eb [FLINK-19982][streaming] Change log level when
CollectSinkFunction receives invalid requests for future investigation
add af1b2cf [FLINK-20365][python] The native k8s cluster could not be
unregistered when executing Python DataStream jobs in attach mode
No new revisions were added by this update.
Summary of changes:
flink-python/pyflink/util/exceptions.py | 3 +++
.../java/org/apache/flink/client/python/PythonDriver.java | 13 ++++++++-----
.../java/org/apache/flink/client/python/PythonEnvUtils.java | 10 ++++++++++
3 files changed, 21 insertions(+), 5 deletions(-)