This is an automated email from the ASF dual-hosted git repository.
arvid pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from f6e08cd [FLINK-20613][table] Update TableResult.collect() to the new
type system
add 52b400f [FLINK-22290][checkpointing] Use duration for alignment
timeout.
add 7359d61 [FLINK-22290][checkpointing] Adding alignment timeout and
force unaligned checkpoint options to PyFlink and polished Java API.
add de069df [hotfix][docs] Fix config doc structure
No new revisions were added by this update.
Summary of changes:
docs/content.zh/docs/deployment/config.md | 49 +++++++++++-----------
docs/content/docs/deployment/config.md | 49 +++++++++++-----------
.../pyflink/datastream/checkpoint_config.py | 46 ++++++++++++++++++++
.../datastream/tests/test_check_point_config.py | 12 ++++--
.../api/environment/CheckpointConfig.java | 25 +++++------
.../environment/StreamExecutionEnvironment.java | 4 +-
.../flink/streaming/api/graph/StreamConfig.java | 11 +++--
.../api/graph/StreamingJobGraphGenerator.java | 2 +-
.../runtime/tasks/SourceOperatorStreamTask.java | 2 +-
.../streaming/runtime/tasks/SourceStreamTask.java | 2 +-
...tStreamTaskChainedSourcesCheckpointingTest.java | 2 +-
.../runtime/tasks/MultipleInputStreamTaskTest.java | 3 +-
.../UnalignedCheckpointCompatibilityITCase.java | 3 +-
.../checkpointing/UnalignedCheckpointTestBase.java | 2 +-
14 files changed, 134 insertions(+), 78 deletions(-)
