You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by di...@apache.org on 2020/09/08 02:07:36 UTC
[flink] branch master updated (13e0b35 -> c1a12e9)
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 13e0b35 [FLINK-18832][datastream] Add compatible check for blocking partition with buffer timeout
add c1a12e9 [FLINK-19131][python] Add support of Python 3.8 in PyFlink
No new revisions were added by this update.
Summary of changes:
docs/_includes/generated/python_configuration.html | 2 +-
docs/dev/python/installation.md | 4 +-
docs/dev/python/installation.zh.md | 4 +-
.../table-api-users-guide/udfs/python_udfs.md | 2 +-
.../table-api-users-guide/udfs/python_udfs.zh.md | 2 +-
.../udfs/vectorized_python_udfs.md | 2 +-
.../udfs/vectorized_python_udfs.zh.md | 2 +-
docs/dev/table/sqlClient.md | 2 +-
docs/dev/table/sqlClient.zh.md | 2 +-
docs/flinkDev/building.md | 4 +-
docs/flinkDev/building.zh.md | 4 +-
docs/ops/cli.md | 8 +-
docs/ops/cli.zh.md | 8 +-
.../apache/flink/client/cli/CliFrontendParser.java | 2 +-
flink-python/README.md | 2 +-
flink-python/dev/dev-requirements.txt | 2 +-
flink-python/dev/lint-python.sh | 6 +-
.../datastream/stream_execution_environment.py | 2 +-
.../pyflink/fn_execution/beam/beam_boot.py | 10 +-
.../fn_execution/beam/beam_operations_fast.pyx | 7 +-
.../fn_execution/beam/beam_operations_slow.py | 7 +-
.../fn_execution/tests/test_process_mode_boot.py | 11 -
flink-python/pyflink/table/table_config.py | 2 +-
flink-python/setup.py | 9 +-
.../fnexecution/state/GrpcStateService.java | 4 +-
.../grpc/v1p21p0/io/netty/buffer/PoolArena.java | 818 ---------------------
.../v1p21p0/io/netty/buffer/PoolThreadCache.java | 508 -------------
.../io/netty/buffer/PooledByteBufAllocator.java | 640 ----------------
...eamDataStreamPythonStatelessFunctionRunner.java | 2 +-
.../org/apache/flink/python/PythonOptions.java | 2 +-
.../flink/python/metric/FlinkMetricContainer.java | 11 +-
.../python/beam/BeamPythonFunctionRunner.java | 5 +-
.../beam/BeamPythonStatelessFunctionRunner.java | 26 +-
.../BeamTablePythonStatelessFunctionRunner.java | 2 +-
flink-python/src/main/resources/META-INF/NOTICE | 78 +-
.../python/metric/FlinkMetricContainerTest.java | 53 +-
.../PassThroughPythonScalarFunctionRunner.java | 2 +-
.../PassThroughPythonTableFunctionRunner.java | 2 +-
flink-python/tox.ini | 4 +-
pom.xml | 4 +-
40 files changed, 147 insertions(+), 2120 deletions(-)
delete mode 100644 flink-python/src/main/java/org/apache/beam/vendor/grpc/v1p21p0/io/netty/buffer/PoolArena.java
delete mode 100644 flink-python/src/main/java/org/apache/beam/vendor/grpc/v1p21p0/io/netty/buffer/PoolThreadCache.java
delete mode 100644 flink-python/src/main/java/org/apache/beam/vendor/grpc/v1p21p0/io/netty/buffer/PooledByteBufAllocator.java