This is an automated email from the ASF dual-hosted git repository.
mapohl pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 9050fd5 [FLINK-24228][connectors/firehose] Allows end users to supply
a serialization schema rather than an ElementConverter, thereby encapsulating
the Firehose `Record` from the user, verifying stream objects in
KinesisFirehoseITCase
add 9f61e12 [FLINK-25445] No need to create local recovery dirs when
disabled local-recovery in TaskExecutorLocalStateStoresManager
No new revisions were added by this update.
Summary of changes:
.../runtime/SavepointLocalRecoveryProvider.java | 64 ----------------------
.../api/runtime/SavepointTaskStateManager.java | 4 +-
.../flink/runtime/state/LocalRecoveryConfig.java | 35 ++++++------
.../state/TaskExecutorLocalStateStoresManager.java | 16 +++---
.../runtime/state/TaskLocalStateStoreImpl.java | 44 +++++++++------
.../runtime/state/heap/HeapSnapshotStrategy.java | 5 +-
.../TaskExecutorLocalStateStoresManagerTest.java | 43 ++++++++++++++-
.../runtime/state/TaskLocalStateStoreImplTest.java | 5 +-
.../runtime/state/TaskStateManagerImplTest.java | 5 +-
.../runtime/state/TestLocalRecoveryConfig.java | 5 +-
.../state/snapshot/RocksFullSnapshotStrategy.java | 4 +-
.../snapshot/RocksIncrementalSnapshotStrategy.java | 9 ++-
.../benchmark/StateBackendBenchmarkUtils.java | 12 +---
.../runtime/tasks/LocalStateForwardingTest.java | 2 +-
.../runtime/tasks/StreamTaskTestHarness.java | 1 -
.../restore/StreamOperatorSnapshotRestoreTest.java | 9 +--
16 files changed, 123 insertions(+), 140 deletions(-)
delete mode 100644
flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/runtime/SavepointLocalRecoveryProvider.java
