This is an automated email from the ASF dual-hosted git repository.
sewen pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 333e374 [FLINK-16182][table-api] Remove check against null types as a
result of an input type inference when deriving output type based on
surrounding info.
new e3cbe8b [FLINK-16191][state backends] Improve error message on
Windows when RocksDB is give a too long path.
new 90dd45b [hotfix][runtime] Fix checkstyle in
org.apache.flink.runtime.checkpoint (main scope)
new 55272b3 [hotfix][DataStream API] Minor JavaDoc / deprecation cleanup
in CheckpointedFunction
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../checkpoint/AbstractCheckpointStats.java | 1 +
.../checkpoint/CheckpointCoordinatorGateway.java | 3 +
.../checkpoint/CheckpointFailureManager.java | 2 +-
.../runtime/checkpoint/CheckpointMetaData.java | 4 +-
.../runtime/checkpoint/CheckpointMetrics.java | 10 +--
.../checkpoint/CheckpointRetentionPolicy.java | 2 +-
.../runtime/checkpoint/CheckpointStatsHistory.java | 10 +--
.../checkpoint/CheckpointStatsSnapshot.java | 2 +-
.../checkpoint/CompletedCheckpointStore.java | 2 +-
.../DefaultLastStateConnectionStateListener.java | 3 +
.../runtime/checkpoint/FailedCheckpointStats.java | 1 +
.../flink/runtime/checkpoint/OperatorState.java | 16 ++--
.../runtime/checkpoint/OperatorSubtaskState.java | 2 +-
.../runtime/checkpoint/PendingCheckpointStats.java | 3 +-
.../PrioritizedOperatorSubtaskState.java | 7 +-
.../checkpoint/StateAssignmentOperation.java | 8 +-
.../runtime/checkpoint/StateObjectCollection.java | 1 +
.../flink/runtime/checkpoint/SubtaskState.java | 4 +-
.../apache/flink/runtime/checkpoint/TaskState.java | 11 ++-
.../flink/runtime/checkpoint/TaskStateStats.java | 1 +
.../ZooKeeperCheckpointRecoveryFactory.java | 3 +-
.../ZooKeeperCompletedCheckpointStore.java | 5 +-
.../runtime/checkpoint/hooks/MasterHooks.java | 13 +---
.../checkpoint/savepoint/SavepointSerializers.java | 6 +-
.../runtime/checkpoint/savepoint/SavepointV1.java | 4 +-
.../savepoint/SavepointV1Serializer.java | 7 +-
.../runtime/checkpoint/savepoint/SavepointV2.java | 18 ++---
.../savepoint/SavepointV2Serializer.java | 16 ++--
.../state/memory/ByteStreamStateHandle.java | 2 +-
.../savepoint/SavepointV2SerializerTest.java | 10 +--
.../streaming/state/RocksDBOperationUtils.java | 17 +++++
.../state/RocksDBOperationsUtilsTest.java | 88 ++++++++++++++++++++++
.../api/checkpoint/CheckpointedFunction.java | 6 +-
tools/maven/suppressions-runtime.xml | 6 +-
34 files changed, 200 insertions(+), 94 deletions(-)
create mode 100644
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBOperationsUtilsTest.java
