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/02/05 17:41:19 UTC
[flink] 03/09: [hotfix] Fix Nonnull annotation in
RegisteredKeyValueStateBackendMetaInfo
This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 0967580b237d0e9e4a7cb451ad9ed49f4ff85932
Author: Dawid Wysakowicz <dw...@apache.org>
AuthorDate: Fri Jan 29 09:57:41 2021 +0100
[hotfix] Fix Nonnull annotation in RegisteredKeyValueStateBackendMetaInfo
Some of the methods are annotated with @Nullable even though they
forward to methods annotated with @Nonnull.
---
.../flink/runtime/state/RegisteredKeyValueStateBackendMetaInfo.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/state/RegisteredKeyValueStateBackendMetaInfo.java b/flink-runtime/src/main/java/org/apache/flink/runtime/state/RegisteredKeyValueStateBackendMetaInfo.java
index bfb43fc..6a26a37 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/state/RegisteredKeyValueStateBackendMetaInfo.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/state/RegisteredKeyValueStateBackendMetaInfo.java
@@ -133,7 +133,7 @@ public class RegisteredKeyValueStateBackendMetaInfo<N, S> extends RegisteredStat
newNamespaceSerializer);
}
- @Nullable
+ @Nonnull
public TypeSerializer<N> getPreviousNamespaceSerializer() {
return namespaceSerializerProvider.previousSchemaSerializer();
}
@@ -149,7 +149,7 @@ public class RegisteredKeyValueStateBackendMetaInfo<N, S> extends RegisteredStat
return stateSerializerProvider.registerNewSerializerForRestoredState(newStateSerializer);
}
- @Nullable
+ @Nonnull
public TypeSerializer<S> getPreviousStateSerializer() {
return stateSerializerProvider.previousSchemaSerializer();
}