This is an automated email from the ASF dual-hosted git repository.
sjwiesman pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 0d77a1a [FLINK-25597][conf][docs] Clarify options for local
directories
add 8bed8bf [FLINK-25423][state-processor-api] Enable loading state
backend via configuration in SavepointWriter
add 77adfb9 [refactor][state-processor-api] Move state backend loading
and restoration into utility
add cefdfc1 [refactor][state-processor-api] Remove usages of deprecated
class
add 846ce04 [FLINK-25423][state-processor-api] Enable loading state
backend via configuration in SavepointReader
add 8069a0f [FLINK-25423][state-processor-api] Enable loading state
backend via configuration in DataSet API
No new revisions were added by this update.
Summary of changes:
.../flink/state/api/BootstrapTransformation.java | 8 +-
.../flink/state/api/EvictingWindowReader.java | 7 +-
.../state/api/EvictingWindowSavepointReader.java | 17 +--
.../apache/flink/state/api/ExistingSavepoint.java | 29 ++--
.../java/org/apache/flink/state/api/Savepoint.java | 53 ++++++++
.../apache/flink/state/api/SavepointReader.java | 91 ++++++++++---
.../apache/flink/state/api/SavepointWriter.java | 63 ++++++++-
.../state/api/StateBootstrapTransformation.java | 3 +-
.../org/apache/flink/state/api/WindowReader.java | 7 +-
.../flink/state/api/WindowSavepointReader.java | 17 +--
.../apache/flink/state/api/WritableSavepoint.java | 7 +-
.../state/api/input/BroadcastStateInputFormat.java | 13 +-
.../state/api/input/KeyedStateInputFormat.java | 60 ++++-----
.../state/api/input/ListStateInputFormat.java | 14 +-
.../state/api/input/OperatorStateInputFormat.java | 69 +++++-----
.../api/input/StreamOperatorContextBuilder.java | 146 +++++++++++++++++++++
.../state/api/input/UnionStateInputFormat.java | 14 +-
.../api/input/splits/KeyGroupRangeInputSplit.java | 4 +-
.../api/input/splits/OperatorStateInputSplit.java | 22 +++-
.../PrioritizedOperatorSubtaskStateInputSplit.java | 15 +--
.../api/runtime/metadata/SavepointMetadataV2.java | 8 +-
.../flink/state/api/SavepointWriterITCase.java | 30 ++++-
.../flink/state/api/SavepointWriterTest.java | 64 +++++++++
.../api/input/BroadcastStateInputFormatTest.java | 3 +-
.../state/api/input/ListStateInputFormatTest.java | 4 +-
.../input/StreamOperatorContextBuilderTest.java | 70 ++++++++++
.../state/api/input/UnionStateInputFormatTest.java | 4 +-
.../state/api/utils/CustomStateBackendFactory.java | 22 ++--
28 files changed, 685 insertions(+), 179 deletions(-)
create mode 100644
flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/input/StreamOperatorContextBuilder.java
copy
flink-clients/src/main/java/org/apache/flink/client/program/ClusterClientProvider.java
=>
flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/input/splits/PrioritizedOperatorSubtaskStateInputSplit.java
(68%)
create mode 100644
flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/SavepointWriterTest.java
create mode 100644
flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/input/StreamOperatorContextBuilderTest.java
copy
flink-runtime/src/main/java/org/apache/flink/runtime/state/hashmap/HashMapStateBackendFactory.java
=>
flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/utils/CustomStateBackendFactory.java
(58%)
