[flink] branch master updated (2a9ceb7cb03 -> 838b79f5b9c)

[hx...@apache.org]

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

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


    from 2a9ceb7cb03 [FLINK-30724][docs] Update kafka-per-partition watermark to new source
     add 9ebb331be45 [FLINK-30753][python] Fix the invocation process of Table.explain()
     add 838b79f5b9c [FLINK-29421][python] Support python 3.10

No new revisions were added by this update.

Summary of changes:
 NOTICE                                             |   2 +-
 docs/content.zh/docs/deployment/cli.md             |   6 +-
 .../resource-providers/standalone/docker.md        |  17 -----
 .../docs/dev/python/datastream_tutorial.md         |   2 +-
 docs/content.zh/docs/dev/python/installation.md    |   4 +-
 .../docs/dev/python/table/udfs/python_udfs.md      |   2 +-
 .../python/table/udfs/vectorized_python_udfs.md    |   2 +-
 .../docs/dev/python/table_api_tutorial.md          |   2 +-
 docs/content.zh/docs/dev/table/sqlClient.md        |   4 +-
 docs/content.zh/docs/flinkDev/building.md          |   4 +-
 docs/content/docs/deployment/cli.md                |   6 +-
 .../resource-providers/standalone/docker.md        |  17 -----
 .../content/docs/dev/python/datastream_tutorial.md |   2 +-
 docs/content/docs/dev/python/installation.md       |   4 +-
 .../docs/dev/python/table/udfs/python_udfs.md      |   2 +-
 .../python/table/udfs/vectorized_python_udfs.md    |   2 +-
 docs/content/docs/dev/python/table_api_tutorial.md |   2 +-
 docs/content/docs/dev/table/sqlClient.md           |   4 +-
 docs/content/docs/flinkDev/building.md             |   4 +-
 .../shortcodes/generated/python_configuration.html |   2 +-
 .../apache/flink/client/cli/CliFrontendParser.java |   2 +-
 flink-python/README.md                             |   2 +-
 flink-python/dev/build-wheels.sh                   |   2 +-
 flink-python/dev/dev-requirements.txt              |  15 ++--
 flink-python/dev/lint-python.sh                    |  10 +--
 flink-python/lib/cloudpickle-2.1.0-src.zip         | Bin 24648 -> 0 bytes
 flink-python/lib/cloudpickle-2.2.0-src.zip         | Bin 0 -> 21387 bytes
 flink-python/pom.xml                               |   2 +-
 .../pyflink/datastream/formats/tests/test_csv.py   |   4 --
 .../datastream/stream_execution_environment.py     |   4 +-
 .../pyflink/datastream/tests/test_data_stream.py   |   5 --
 .../tests/test_stream_execution_environment.py     |   2 +-
 .../pyflink/datastream/tests/test_window.py        |   4 --
 .../pyflink/fn_execution/beam/beam_boot.py         |  21 +++---
 .../fn_execution/beam/beam_worker_pool_service.py  |   6 +-
 flink-python/pyflink/fn_execution/state_impl.py    |  21 +++---
 .../fn_execution/tests/test_process_mode_boot.py   |   8 +--
 flink-python/pyflink/table/statement_set.py        |   4 +-
 flink-python/pyflink/table/table.py                |   3 +-
 flink-python/pyflink/table/table_config.py         |   4 +-
 .../pyflink/table/tests/test_dependency.py         |   5 +-
 flink-python/pyflink/table/tests/test_udf.py       |   3 -
 flink-python/pyflink/table/tests/test_udtf.py      |   4 --
 flink-python/pyproject.toml                        |   6 +-
 flink-python/setup.py                              |  29 +++-----
 .../fnexecution/state/GrpcStateService.java        |   4 +-
 .../apache/beam/sdk/fn/server/ServerFactory.java   |  20 +++---
 .../io/grpc/internal/SharedResourceHolder.java     |   4 +-
 .../org/apache/flink/python/PythonOptions.java     |   4 +-
 .../embedded/EmbeddedPythonEnvironmentManager.java |   8 ---
 .../org/apache/flink/python/util/ProtoUtils.java   |   2 +-
 .../beam/BeamDataStreamPythonFunctionRunner.java   |   4 +-
 .../python/beam/BeamPythonFunctionRunner.java      |   8 +--
 .../python/beam/state/BeamBagStateHandler.java     |   2 +-
 .../python/beam/state/BeamMapStateHandler.java     |   2 +-
 .../python/beam/state/BeamStateRequestHandler.java |   4 +-
 .../python/beam/BeamTablePythonFunctionRunner.java |   2 +-
 flink-python/src/main/resources/META-INF/NOTICE    |  79 ++++++++++-----------
 .../PassThroughPythonAggregateFunctionRunner.java  |   2 +-
 .../PassThroughPythonScalarFunctionRunner.java     |   2 +-
 .../PassThroughPythonTableFunctionRunner.java      |   2 +-
 ...ThroughStreamAggregatePythonFunctionRunner.java |   2 +-
 ...amGroupWindowAggregatePythonFunctionRunner.java |   2 +-
 ...ghStreamTableAggregatePythonFunctionRunner.java |   2 +-
 flink-python/tox.ini                               |   2 +-
 pom.xml                                            |   2 +-
 tools/releasing/NOTICE-binary_PREAMBLE.txt         |   2 +-
 tools/releasing/create_binary_release.sh           |   4 +-
 68 files changed, 177 insertions(+), 244 deletions(-)
 delete mode 100644 flink-python/lib/cloudpickle-2.1.0-src.zip
 create mode 100644 flink-python/lib/cloudpickle-2.2.0-src.zip
 rename flink-python/src/main/java/org/apache/beam/vendor/grpc/{v1p43p2 => v1p48p1}/io/grpc/internal/SharedResourceHolder.java (98%)