This is an automated email from the ASF dual-hosted git repository.
zakelly pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 42e25939e4a [FLINK-36871][runtime] add rescale metrics in scheduler
(#25770)
add 7597fe34dbc [FLINK-37030][Runtime/State] Support lazy initialization
for state serializer in State V2 (#25918)
No new revisions were added by this update.
Summary of changes:
.../state/v2/AggregatingStateDescriptor.java | 18 ----
.../runtime/state/v2/DefaultKeyedStateStore.java | 12 ++-
.../runtime/state/v2/ListStateDescriptor.java | 16 ---
.../flink/runtime/state/v2/MapStateDescriptor.java | 78 +++++++++------
.../runtime/state/v2/ReducingStateDescriptor.java | 17 ----
.../flink/runtime/state/v2/StateDescriptor.java | 71 +++++++++-----
.../runtime/state/v2/StateDescriptorUtils.java | 96 +++++++++---------
.../runtime/state/v2/StateSerializerReference.java | 107 +++++++++++++++++++++
.../runtime/state/v2/ValueStateDescriptor.java | 16 ---
.../api/operators/StreamOperatorStateHandler.java | 10 +-
.../api/operators/StreamingRuntimeContext.java | 5 +
.../flink/runtime/state/StateBackendTestUtils.java | 3 +
.../runtime/state/v2/StateDescriptorTest.java | 7 +-
.../api/operators/StreamingRuntimeContextTest.java | 24 +++--
.../flink/state/forst/ForStKeyedStateBackend.java | 8 ++
.../state/forst/ForStKeyedStateBackendBuilder.java | 5 +
.../flink/state/forst/ForStStateBackend.java | 1 +
.../state/forst/ForStDBOperationTestBase.java | 9 +-
.../flink/state/forst/ForStListStateTest.java | 3 +-
19 files changed, 320 insertions(+), 186 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/StateSerializerReference.java
