[flink] 03/09: [hotfix] Fix Nonnull annotation in RegisteredKeyValueStateBackendMetaInfo

[dwysakowicz]

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 <dwysakow...@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();
     }