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 4a299bb [FLINK-20557][sql-client] Support STATEMENT SET in SQL CLI
add 89fde84 [FLINK-21945][streaming] Add StreamPartitioner#isPointwise.
add d15f7ea [FLINK-21945][checkpoint] Ensure that each operator is stored
in the checkpoint, but do not store empty subtask states.
add 03a6152 [FLINK-21936][checkpoint] Fail early if attempting to rescale
pointwise connection.
add c80883f [FLINK-21936][streaming] Explicitly encode support for
unaligned checkpoints into StreamEdge.
add 41936fe [FLINK-21945][streaming] Force aligned barriers on pointwise
connections.
add 6d6c777 [FLINK-21945][tests] Add pointwise connection to
UnalignedCheckpointRescaleITCase.
add 5eee24c [FLINK-21945][tests] Refactor
UnalignedCheckpoint(Rescale)ITCase to automatically determine slots.
add af57199 [FLINK-21945][streaming] Improved UnalignedCheckpointITCase
union tests to not capture all elements.
No new revisions were added by this update.
Summary of changes:
.../flink/state/api/output/SnapshotUtils.java | 2 +-
.../runtime/checkpoint/CheckpointOptions.java | 94 ++++--
.../runtime/checkpoint/PendingCheckpoint.java | 57 ++--
.../runtime/io/network/api/CheckpointBarrier.java | 6 +
.../network/api/serialization/EventSerializer.java | 13 +-
.../io/network/api/writer/SubtaskStateMapper.java | 11 +
.../checkpoint/CheckpointCoordinatorTest.java | 17 +-
.../runtime/checkpoint/CheckpointOptionsTest.java | 59 +++-
.../runtime/checkpoint/PendingCheckpointTest.java | 23 +-
.../flink/streaming/api/graph/StreamEdge.java | 10 +
.../streaming/api/graph/StreamGraphGenerator.java | 8 +
.../api/graph/StreamingJobGraphGenerator.java | 10 +-
.../streaming/runtime/io/RecordWriterOutput.java | 15 +-
.../runtime/partitioner/BroadcastPartitioner.java | 5 +
.../partitioner/CustomPartitionerWrapper.java | 5 +
.../runtime/partitioner/ForwardPartitioner.java | 12 +-
.../runtime/partitioner/GlobalPartitioner.java | 5 +
.../partitioner/KeyGroupStreamPartitioner.java | 5 +
.../runtime/partitioner/RebalancePartitioner.java | 5 +
.../runtime/partitioner/RescalePartitioner.java | 12 +-
.../runtime/partitioner/ShufflePartitioner.java | 5 +
.../runtime/partitioner/StreamPartitioner.java | 2 +
.../streaming/runtime/tasks/OperatorChain.java | 7 +-
.../tasks/SubtaskCheckpointCoordinatorImpl.java | 7 +
.../api/graph/StreamGraphGeneratorTest.java | 60 ++++
.../tasks/SubtaskCheckpointCoordinatorTest.java | 46 +++
.../runtime/partitioner/BinaryHashPartitioner.java | 5 +
.../checkpointing/UnalignedCheckpointITCase.java | 371 +++++++++++----------
.../UnalignedCheckpointRescaleITCase.java | 135 +++++---
.../checkpointing/UnalignedCheckpointTestBase.java | 169 ++++++----
30 files changed, 785 insertions(+), 396 deletions(-)
