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 31d661d [FLINK-16057][task] Optimize TaskMailbox state retrieval
add 77e5494 [FLINK-17923][python] Allow Python worker to use off-heap
memory
No new revisions were added by this update.
Summary of changes:
docs/_includes/generated/python_configuration.html | 6 +++
flink-python/pyflink/testing/test_case_utils.py | 8 +++
.../java/org/apache/flink/python/PythonConfig.java | 10 ++++
.../org/apache/flink/python/PythonOptions.java | 14 +++++
.../python/AbstractPythonFunctionOperator.java | 4 +-
.../client/python/PythonFunctionFactoryTest.java | 3 ++
.../org/apache/flink/python/PythonConfigTest.java | 9 ++++
.../PythonScalarFunctionOperatorTestBase.java | 3 ++
.../plan/nodes/common/CommonPythonBase.scala | 61 ++++++++++++++++++++-
.../nodes/physical/batch/BatchExecPythonCalc.scala | 21 ++------
.../physical/batch/BatchExecPythonCorrelate.scala | 9 +++-
.../physical/stream/StreamExecPythonCalc.scala | 6 ++-
.../stream/StreamExecPythonCorrelate.scala | 9 +++-
.../flink/table/plan/nodes/CommonPythonBase.scala | 62 +++++++++++++++++++++-
14 files changed, 201 insertions(+), 24 deletions(-)
