You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by dw...@apache.org on 2021/01/26 10:41:19 UTC
[flink] branch master updated (35247bb -> 8778f56)

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

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


    from 35247bb  [FLINK-21026][flink-sql-parser] Align column list specification syntax with hive in INSERT statement
     add 230f172  [hotfix] Remove a supportsAsynchronousSnapshots method used in tests only
     add 8778f56  [FLINK-21072] Refactor the SnapshotStrategy hierarchy

No new revisions were added by this update.

Summary of changes:
 .../runtime/state/AbstractKeyedStateBackend.java   |   5 -
 .../runtime/state/AbstractSnapshotStrategy.java    |  75 ------
 .../state/CheckpointableKeyedStateBackend.java     |   8 +-
 .../runtime/state/DefaultOperatorStateBackend.java |  17 +-
 .../state/DefaultOperatorStateBackendBuilder.java  |  18 +-
 ...efaultOperatorStateBackendSnapshotStrategy.java | 262 +++++++++++----------
 .../flink/runtime/state/OperatorStateBackend.java  |   4 +-
 .../flink/runtime/state/SnapshotResources.java     |  14 +-
 .../flink/runtime/state/SnapshotStrategy.java      |  58 +++--
 .../runtime/state/SnapshotStrategyRunner.java      | 133 +++++++++++
 .../{SnapshotStrategy.java => Snapshotable.java}   |  10 +-
 ...AsyncSnapshotStrategySynchronicityBehavior.java |  44 ----
 .../runtime/state/heap/HeapKeyedStateBackend.java  |  34 +--
 .../state/heap/HeapKeyedStateBackendBuilder.java   |  37 +--
 .../runtime/state/heap/HeapRestoreOperation.java   |   8 +-
 .../runtime/state/heap/HeapSnapshotStrategy.java   | 245 +++++++++----------
 ...onicityBehavior.java => StateTableFactory.java} |  16 +-
 .../SyncSnapshotStrategySynchronicityBehavior.java |  50 ----
 .../flink/runtime/state/FileStateBackendTest.java  |   5 +
 .../HeapKeyedStateBackendAsyncByDefaultTest.java   |  39 ---
 .../runtime/state/MemoryStateBackendTest.java      |   5 +
 .../flink/runtime/state/StateBackendTestBase.java  |   6 +-
 .../streaming/state/RocksDBKeyedStateBackend.java  |  32 +--
 .../state/RocksDBKeyedStateBackendBuilder.java     |  13 +-
 .../snapshot/RocksDBSnapshotStrategyBase.java      |  52 +---
 .../state/snapshot/RocksFullSnapshotStrategy.java  | 130 +++++-----
 .../snapshot/RocksIncrementalSnapshotStrategy.java | 128 ++++++----
 .../streaming/state/RocksDBStateBackendTest.java   |   5 +
 .../tasks/TaskCheckpointingBehaviourTest.java      |  55 +++--
 .../NotifyCheckpointAbortedITCase.java             |  37 +--
 30 files changed, 756 insertions(+), 789 deletions(-)
 delete mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractSnapshotStrategy.java
 copy flink-python/src/main/java/org/apache/flink/table/runtime/arrow/ArrowReader.java => flink-runtime/src/main/java/org/apache/flink/runtime/state/SnapshotResources.java (74%)
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/state/SnapshotStrategyRunner.java
 copy flink-runtime/src/main/java/org/apache/flink/runtime/state/{SnapshotStrategy.java => Snapshotable.java} (85%)
 delete mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/AsyncSnapshotStrategySynchronicityBehavior.java
 rename flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/{SnapshotStrategySynchronicityBehavior.java => StateTableFactory.java} (73%)
 delete mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/SyncSnapshotStrategySynchronicityBehavior.java