Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5230#discussion_r159222186
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/SerializationProxiesTest.java
---
@@ -287,16 +339,60 @@ public void
testOperatorStateMetaInfoReadSerializerFailureResilience() throws Ex
PowerMockito.whenNew(TypeSerializerSerializationUtil.TypeSerializerSerializationProxy.class).withAnyArguments().thenReturn(mockProxy);
try (ByteArrayInputStreamWithPos in = new
ByteArrayInputStreamWithPos(serialized)) {
+ final DataInputViewStreamWrapper inWrapper = new
DataInputViewStreamWrapper(in);
+
metaInfo =
OperatorBackendStateMetaInfoSnapshotReaderWriters
-
.getReaderForVersion(OperatorBackendSerializationProxy.VERSION,
Thread.currentThread().getContextClassLoader())
--- End diff --
The test below does it but why do you write it here as well?
---
