[flink] branch master updated (11b5330 -> 1f6b1e6)

[pn...@apache.org]

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

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


    from 11b5330  [FLINK-17541][table] Support inline structured types
     add f0ed29c  [FLINK-8871][checkpoint] Support to cancel checkpoing via notification on task side
     add fae6a6c  [FLINK-8871][checkpoint] Support to cancel checkpoing via notification on checkpoint coordinator side
     add 1f6b1e6  [FLINK-8871][checkpoint][tests] Add ITcase for NotifiCheckpointAborted mechanism

No new revisions were added by this update.

Summary of changes:
 .../connectors/fs/bucketing/BucketingSink.java     |   4 +
 .../connectors/gcp/pubsub/PubSubSource.java        |   4 +
 .../gcp/pubsub/common/AcknowledgeOnCheckpoint.java |   4 +
 .../connectors/kafka/FlinkKafkaConsumerBase.java   |   4 +
 .../connectors/kafka/KafkaConsumerTestBase.java    |   4 +
 .../connectors/kafka/KafkaProducerTestBase.java    |   4 +
 .../kafka/testutils/FailingIdentityMapper.java     |   4 +
 .../connectors/kafka/testutils/IntegerSource.java  |   4 +
 .../flink/streaming/tests/FailureMapper.java       |   4 +
 .../HeavyDeploymentStressTestProgram.java          |   4 +
 .../StickyAllocationAndLocalRecoveryTestJob.java   |   4 +
 .../api/runtime/SavepointTaskStateManager.java     |   5 +
 .../flink/state/api/output/SnapshotUtilsTest.java  |   4 +
 .../itcases/AbstractQueryableStateTestBase.java    |   4 +
 .../runtime/checkpoint/CheckpointCoordinator.java  |  16 +
 .../checkpoint/CheckpointFailureManager.java       |   1 +
 .../checkpoint/CheckpointFailureReason.java        |   2 +
 .../flink/runtime/executiongraph/Execution.java    |  19 +
 .../runtime/jobgraph/tasks/AbstractInvokable.java  |  12 +
 .../jobmanager/slots/TaskManagerGateway.java       |  14 +
 .../runtime/jobmaster/RpcTaskManagerGateway.java   |   5 +
 .../flink/runtime/state/CheckpointListener.java    |   8 +
 .../runtime/state/NoOpTaskLocalStateStoreImpl.java |   4 +
 .../flink/runtime/state/TaskLocalStateStore.java   |   6 +
 .../runtime/state/TaskLocalStateStoreImpl.java     |   9 +
 .../flink/runtime/state/TaskStateManagerImpl.java  |  10 +-
 .../runtime/state/heap/HeapKeyedStateBackend.java  |   5 +
 .../flink/runtime/taskexecutor/TaskExecutor.java   |  23 +-
 .../runtime/taskexecutor/TaskExecutorGateway.java  |  11 +
 .../org/apache/flink/runtime/taskmanager/Task.java |  28 ++
 .../checkpoint/CheckpointCoordinatorTest.java      |   7 +
 .../utils/SimpleAckingTaskManagerGateway.java      |   7 +
 .../runtime/state/TaskLocalStateStoreImplTest.java |  23 +-
 .../runtime/state/TestTaskLocalStateStore.java     |  19 +
 .../flink/runtime/state/TestTaskStateManager.java  |  11 +
 .../state/ttl/mock/MockKeyedStateBackend.java      |   5 +
 .../taskexecutor/TestingTaskExecutorGateway.java   |   5 +
 .../streaming/state/RocksDBKeyedStateBackend.java  |   7 +
 .../state/snapshot/RocksFullSnapshotStrategy.java  |   5 +
 .../snapshot/RocksIncrementalSnapshotStrategy.java |   7 +
 .../functions/sink/TwoPhaseCommitSinkFunction.java |   4 +
 .../sink/filesystem/StreamingFileSink.java         |   4 +
 .../source/MessageAcknowledgingSourceBase.java     |   4 +
 .../api/operators/AbstractStreamOperator.java      |   5 +
 .../api/operators/AbstractStreamOperatorV2.java    |   5 +
 .../api/operators/StreamOperatorStateHandler.java  |   6 +
 .../api/operators/collect/CollectSinkFunction.java |   4 +
 .../runtime/tasks/AsyncCheckpointRunnable.java     |  22 +-
 .../flink/streaming/runtime/tasks/StreamTask.java  |   7 +
 .../tasks/SubtaskCheckpointCoordinator.java        |  12 +
 .../tasks/SubtaskCheckpointCoordinatorImpl.java    | 198 ++++++++-
 .../AbstractUdfStreamOperatorLifecycleTest.java    |   1 +
 .../runtime/tasks/ExceptionallyDoneFuture.java     |   2 +-
 .../runtime/tasks/LocalStateForwardingTest.java    |   3 +-
 .../MockSubtaskCheckpointCoordinatorBuilder.java   |  14 +-
 .../tasks/SubtaskCheckpointCoordinatorTest.java    | 297 +++++++++++++-
 .../runtime/tasks/SynchronousCheckpointITCase.java |   6 +
 .../runtime/utils/FailingCollectionSource.java     |   4 +
 .../runtime/stream/FsStreamingSinkITCaseBase.scala |   3 +
 .../flink/streaming/util/FiniteTestSource.java     |   4 +
 .../jobmaster/JobMasterStopWithSavepointIT.java    |   5 +
 .../jobmaster/JobMasterTriggerSavepointITCase.java |   5 +
 .../checkpointing/CoStreamCheckpointingITCase.java |   4 +
 .../ContinuousFileProcessingCheckpointITCase.java  |   4 +
 .../KeyedStateCheckpointingITCase.java             |   4 +
 .../NotifyCheckpointAbortedITCase.java             | 449 +++++++++++++++++++++
 .../checkpointing/StateCheckpointedITCase.java     |   4 +
 .../StreamCheckpointNotifierITCase.java            |  20 +
 .../checkpointing/UnalignedCheckpointITCase.java   |   8 +
 .../ZooKeeperHighAvailabilityITCase.java           |   4 +
 .../utils/AccumulatingIntegerSink.java             |   4 +
 .../utils/CancellingIntegerSource.java             |   4 +
 .../test/checkpointing/utils/FailingSource.java    |   4 +
 .../jar/CheckpointedStreamingProgram.java          |   4 +
 .../jar/CheckpointingCustomKvStateProgram.java     |   4 +
 .../ReinterpretDataStreamAsKeyedStreamITCase.java  |   4 +
 76 files changed, 1436 insertions(+), 26 deletions(-)
 create mode 100644 flink-tests/src/test/java/org/apache/flink/test/checkpointing/NotifyCheckpointAbortedITCase.java