Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5732#discussion_r176220129
--- Diff:
flink-core/src/test/java/org/apache/flink/api/common/state/ValueStateDescriptorTest.java
---
@@ -149,13 +145,9 @@ public void testVeryLargeDefaultValue() throws
Exception {
@SuppressWarnings("unchecked")
@Test
public void testSerializerDuplication() {
- TypeSerializer<String> statefulSerializer =
mock(TypeSerializer.class);
- when(statefulSerializer.duplicate()).thenAnswer(new
Answer<TypeSerializer<String>>() {
- @Override
- public TypeSerializer<String> answer(InvocationOnMock
invocation) throws Throwable {
- return mock(TypeSerializer.class);
- }
- });
+ // we need a serializer that actually duplicates for testing (a
stateful one)
--- End diff --
See above
---
