StefanRRichter commented on a change in pull request #6875: [FLINK-9808] [state
backends] Migrate state when necessary in state backends
URL: https://github.com/apache/flink/pull/6875#discussion_r227709342
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/RegisteredKeyValueStateBackendMetaInfo.java
##########
@@ -151,79 +149,52 @@ public int hashCode() {
return result;
}
- /**
- * Checks compatibility of a restored k/v state, with the new {@link
StateDescriptor} provided to it.
- * This checks that the descriptor specifies identical names and state
types, as well as
- * serializers that are compatible for the restored k/v state bytes.
- */
@Nonnull
- public static <N, S> RegisteredKeyValueStateBackendMetaInfo<N, S>
resolveKvStateCompatibility(
- StateMetaInfoSnapshot restoredStateMetaInfoSnapshot,
- TypeSerializer<N> newNamespaceSerializer,
- StateDescriptor<?, S> newStateDescriptor,
- @Nullable StateSnapshotTransformer<S> snapshotTransformer)
throws StateMigrationException {
+ @Override
+ public StateMetaInfoSnapshot snapshot() {
+ return computeSnapshot();
+ }
-
Preconditions.checkState(restoredStateMetaInfoSnapshot.getBackendStateType()
+ public static <T> CompatibilityResult<T> resolveStateCompatibiliity(
Review comment:
Type: `resolveStateCompatibiliity` -> `resolveStateCompatibility`
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
