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 742ee6d7ef5 [hotfix][javadoc] Correct the default value of chaining
strategy
add 5eeb2fc8197 [FLINK-37823][python] Add Python 3.12 support (#26579)
No new revisions were added by this update.
Summary of changes:
.github/workflows/template.flink-ci.yml | 4 +-
.../content/docs/dev/python/datastream_tutorial.md | 2 +-
docs/content/docs/dev/python/installation.md | 4 +-
docs/content/docs/dev/python/table_api_tutorial.md | 2 +-
docs/content/docs/flinkDev/building.md | 4 +-
.../test-scripts/test_pyflink.sh | 2 +-
.../test-scripts/test_pyflink_yarn.sh | 2 +-
flink-python/README.md | 2 +-
flink-python/apache-flink-libraries/setup.py | 3 +-
flink-python/dev/build-wheels.sh | 2 +-
flink-python/dev/dev-requirements.txt | 8 +-
flink-python/dev/install_command.sh | 3 +
flink-python/dev/lint-python.sh | 12 +-
flink-python/pom.xml | 2 +-
.../pyflink/datastream/connectors/kafka.py | 8 +-
.../datastream/connectors/tests/test_kafka.py | 2 +-
flink-python/pyflink/datastream/data_stream.py | 50 +-
flink-python/pyflink/datastream/functions.py | 16 +-
flink-python/pyflink/datastream/state.py | 4 +-
.../datastream/stream_execution_environment.py | 2 +-
.../pyflink/datastream/tests/test_data_stream.py | 30 +-
.../pyflink/datastream/tests/test_window.py | 76 +-
.../pyflink/examples/table/streaming_word_count.py | 2 +-
.../fn_execution/beam/beam_operations_slow.py | 4 +-
.../fn_execution/datastream/embedded/operations.py | 6 +-
.../datastream/embedded/runtime_context.py | 2 +-
.../datastream/embedded/side_output_context.py | 4 +-
.../fn_execution/datastream/process/operations.py | 4 +-
.../datastream/process/runtime_context.py | 4 +-
.../datastream/window/window_operator.py | 18 +-
.../pyflink/fn_execution/flink_fn_execution_pb2.py | 239 ++---
.../fn_execution/flink_fn_execution_pb2.pyi | 975 +++++++++++----------
flink-python/pyflink/fn_execution/state_impl.py | 4 +-
.../pyflink/fn_execution/table/aggregate_slow.py | 10 +-
.../pyflink/fn_execution/table/operations.py | 4 +-
.../fn_execution/table/window_aggregate_slow.py | 12 +-
.../pyflink/fn_execution/table/window_assigner.py | 4 +-
.../pyflink/fn_execution/table/window_context.py | 8 +-
.../fn_execution/table/window_process_function.py | 14 +-
.../pyflink/fn_execution/table/window_trigger.py | 6 +-
.../pyflink/fn_execution/tests/test_coders.py | 4 +-
flink-python/pyflink/gen_protos.py | 8 +-
flink-python/pyflink/java_gateway.py | 7 +-
flink-python/pyflink/table/expressions.py | 8 +-
flink-python/pyflink/table/tests/test_udaf.py | 2 +-
flink-python/pyflink/table/types.py | 2 +-
flink-python/pyproject.toml | 2 +-
flink-python/setup.py | 5 +-
flink-python/src/main/resources/META-INF/NOTICE | 2 +-
flink-python/tox.ini | 4 +-
tools/azure-pipelines/build-python-wheels.yml | 4 +-
tools/azure-pipelines/e2e-template.yml | 2 +-
tools/releasing/create_binary_release.sh | 4 +-
53 files changed, 851 insertions(+), 763 deletions(-)
