diff --git a/flink-core/src/test/java/org/apache/flink/api/common/typeutils/base/array/PrimitiveArraySerializerSnapshotMigrationTest.java b/flink-core/src/test/java/org/apache/flink/api/common/typeutils/base/array/PrimitiveArraySerializerSnapshotMigrationTest.java deleted file mode 100644 index 6163e2cb77ebc..0000000000000 --- a/flink-core/src/test/java/org/apache/flink/api/common/typeutils/base/array/PrimitiveArraySerializerSnapshotMigrationTest.java +++ /dev/null @@ -1,94 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.flink.api.common.typeutils.base.array; - -import org.apache.flink.api.common.typeutils.TypeSerializerSnapshotMigrationTestBase; -import org.apache.flink.testutils.migration.MigrationVersion; - -import org.junit.runner.RunWith; -import org.junit.runners.Parameterized; - -import java.util.Collection; - -/** - * Migration tests for primitive array type serializers' snapshots. - */ -@RunWith(Parameterized.class) -public class PrimitiveArraySerializerSnapshotMigrationTest extends TypeSerializerSnapshotMigrationTestBase { - - public PrimitiveArraySerializerSnapshotMigrationTest(TestSpecification testSpecification) { - super(testSpecification); - } - - @SuppressWarnings("unchecked") - @Parameterized.Parameters(name = "Test Specification = {0}") - public static Collection> testSpecifications() { - - final TestSpecifications testSpecifications = new TestSpecifications(MigrationVersion.v1_6, MigrationVersion.v1_7); - - testSpecifications.add( - "boolean-primitive-array-serializer", - BooleanPrimitiveArraySerializer.class, - BooleanPrimitiveArraySerializer.BooleanPrimitiveArraySerializerSnapshot.class, - () -> BooleanPrimitiveArraySerializer.INSTANCE); - testSpecifications.add( - "byte-primitive-array-serializer", - BytePrimitiveArraySerializer.class, - BytePrimitiveArraySerializer.BytePrimitiveArraySerializerSnapshot.class, - () -> BytePrimitiveArraySerializer.INSTANCE); - testSpecifications.add( - "char-primitive-array-serializer", - CharPrimitiveArraySerializer.class, - CharPrimitiveArraySerializer.CharPrimitiveArraySerializerSnapshot.class, - () -> CharPrimitiveArraySerializer.INSTANCE); - testSpecifications.add( - "double-primitive-array-serializer", - DoublePrimitiveArraySerializer.class, - DoublePrimitiveArraySerializer.DoublePrimitiveArraySerializerSnapshot.class, - () -> DoublePrimitiveArraySerializer.INSTANCE); - testSpecifications.add( - "float-primitive-array-serializer", - FloatPrimitiveArraySerializer.class, - FloatPrimitiveArraySerializer.FloatPrimitiveArraySerializerSnapshot.class, - () -> FloatPrimitiveArraySerializer.INSTANCE); - testSpecifications.add( - "int-primitive-array-serializer", - IntPrimitiveArraySerializer.class, - IntPrimitiveArraySerializer.IntPrimitiveArraySerializerSnapshot.class, - () -> IntPrimitiveArraySerializer.INSTANCE); - testSpecifications.add( - "long-primitive-array-serializer", - LongPrimitiveArraySerializer.class, - LongPrimitiveArraySerializer.LongPrimitiveArraySerializerSnapshot.class, - () -> LongPrimitiveArraySerializer.INSTANCE); - testSpecifications.add( - "short-primitive-array-serializer", - ShortPrimitiveArraySerializer.class, - ShortPrimitiveArraySerializer.ShortPrimitiveArraySerializerSnapshot.class, - () -> ShortPrimitiveArraySerializer.INSTANCE); - testSpecifications.add( - "string-array-serializer", - StringArraySerializer.class, - StringArraySerializer.StringArraySerializerSnapshot.class, - () -> StringArraySerializer.INSTANCE); - - return testSpecifications.get(); - } - -} diff --git a/flink-core/src/test/java/org/apache/flink/api/common/typeutils/base/array/PrimitiveArraySerializerUpgradeTest.java b/flink-core/src/test/java/org/apache/flink/api/common/typeutils/base/array/PrimitiveArraySerializerUpgradeTest.java new file mode 100644 index 0000000000000..b783da328f40f --- /dev/null +++ b/flink-core/src/test/java/org/apache/flink/api/common/typeutils/base/array/PrimitiveArraySerializerUpgradeTest.java @@ -0,0 +1,102 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.flink.api.common.typeutils.base.array; + +import org.apache.flink.api.common.typeutils.TypeSerializerUpgradeTestBase; +import org.apache.flink.testutils.migration.MigrationVersion; + +import org.junit.runner.RunWith; +import org.junit.runners.Parameterized; + +import java.util.ArrayList; +import java.util.Collection; + +/** + * Migration tests for primitive array type serializers' snapshots. + */ +@RunWith(Parameterized.class) +public class PrimitiveArraySerializerUpgradeTest extends TypeSerializerUpgradeTestBase { + public PrimitiveArraySerializerUpgradeTest(TestSpecification testSpecification) { + super(testSpecification); + } + + @Parameterized.Parameters(name = "Test Specification = {0}") + public static Collection> testSpecifications() throws Exception { + ArrayList> testSpecifications = new ArrayList<>(); + for (MigrationVersion migrationVersion : MIGRATION_VERSIONS) { + testSpecifications.add( + new TestSpecification<>( + "boolean-primitive-array-serializer", + migrationVersion, + PrimitiveArraySerializerUpgradeTestSpecifications.PrimitiveBooleanArraySetup.class, + PrimitiveArraySerializerUpgradeTestSpecifications.PrimitiveBooleanArrayVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "byte-primitive-array-serializer", + migrationVersion, + PrimitiveArraySerializerUpgradeTestSpecifications.PrimitiveByteArraySetup.class, + PrimitiveArraySerializerUpgradeTestSpecifications.PrimitiveByteArrayVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "char-primitive-array-serializer", + migrationVersion, + PrimitiveArraySerializerUpgradeTestSpecifications.PrimitiveCharArraySetup.class, + PrimitiveArraySerializerUpgradeTestSpecifications.PrimitiveCharArrayVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "double-primitive-array-serializer", + migrationVersion, + PrimitiveArraySerializerUpgradeTestSpecifications.PrimitiveDoubleArraySetup.class, + PrimitiveArraySerializerUpgradeTestSpecifications.PrimitiveDoubleArrayVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "float-primitive-array-serializer", + migrationVersion, + PrimitiveArraySerializerUpgradeTestSpecifications.PrimitiveFloatArraySetup.class, + PrimitiveArraySerializerUpgradeTestSpecifications.PrimitiveFloatArrayVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "int-primitive-array-serializer", + migrationVersion, + PrimitiveArraySerializerUpgradeTestSpecifications.PrimitiveIntArraySetup.class, + PrimitiveArraySerializerUpgradeTestSpecifications.PrimitiveIntArrayVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "long-primitive-array-serializer", + migrationVersion, + PrimitiveArraySerializerUpgradeTestSpecifications.PrimitiveLongArraySetup.class, + PrimitiveArraySerializerUpgradeTestSpecifications.PrimitiveLongArrayVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "short-primitive-array-serializer", + migrationVersion, + PrimitiveArraySerializerUpgradeTestSpecifications.PrimitiveShortArraySetup.class, + PrimitiveArraySerializerUpgradeTestSpecifications.PrimitiveShortArrayVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "string-array-serializer", + migrationVersion, + PrimitiveArraySerializerUpgradeTestSpecifications.PrimitiveStringArraySetup.class, + PrimitiveArraySerializerUpgradeTestSpecifications.PrimitiveStringArrayVerifier.class)); + } + + return testSpecifications; + } +} + diff --git a/flink-core/src/test/java/org/apache/flink/api/common/typeutils/base/array/PrimitiveArraySerializerUpgradeTestSpecifications.java b/flink-core/src/test/java/org/apache/flink/api/common/typeutils/base/array/PrimitiveArraySerializerUpgradeTestSpecifications.java new file mode 100644 index 0000000000000..c5a972923ca47 --- /dev/null +++ b/flink-core/src/test/java/org/apache/flink/api/common/typeutils/base/array/PrimitiveArraySerializerUpgradeTestSpecifications.java @@ -0,0 +1,431 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.flink.api.common.typeutils.base.array; + +import org.apache.flink.api.common.ExecutionConfig; +import org.apache.flink.api.common.typeutils.TypeSerializer; +import org.apache.flink.api.common.typeutils.TypeSerializerMatchers; +import org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility; +import org.apache.flink.api.common.typeutils.TypeSerializerUpgradeTestBase; +import org.apache.flink.api.java.typeutils.TypeExtractor; +import org.apache.flink.testutils.migration.MigrationVersion; + +import org.hamcrest.Matcher; + +import static org.hamcrest.Matchers.is; +import static org.junit.Assert.assertSame; + +public class PrimitiveArraySerializerUpgradeTestSpecifications { + // ---------------------------------------------------------------------------------------------- + // Specification for "primitive boolean array" + // ---------------------------------------------------------------------------------------------- + public static final class PrimitiveBooleanArraySetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup { + @Override + public TypeSerializer createPriorSerializer() { + TypeSerializer serializer = TypeExtractor.createTypeInfo(boolean[].class).createSerializer(new ExecutionConfig()); + assertSame(serializer.getClass(), BooleanPrimitiveArraySerializer.class); + return serializer; + } + + @Override + public boolean[] createTestData() { + boolean[] data = new boolean[2]; + data[0] = true; + data[1] = false; + return data; + } + } + + public static final class PrimitiveBooleanArrayVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier { + @Override + public TypeSerializer createUpgradedSerializer() { + TypeSerializer serializer = TypeExtractor.createTypeInfo(boolean[].class).createSerializer(new ExecutionConfig()); + assertSame(serializer.getClass(), BooleanPrimitiveArraySerializer.class); + return serializer; + } + + @Override + public Matcher testDataMatcher() { + boolean[] expected = new boolean[2]; + expected[0] = true; + expected[1] = false; + return is(expected); + } + + @Override + public Matcher> schemaCompatibilityMatcher( + MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "primitive byte array" + // ---------------------------------------------------------------------------------------------- + public static final class PrimitiveByteArraySetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup { + @Override + public TypeSerializer createPriorSerializer() { + TypeSerializer serializer = TypeExtractor.createTypeInfo(byte[].class).createSerializer(new ExecutionConfig()); + assertSame(serializer.getClass(), BytePrimitiveArraySerializer.class); + return serializer; + } + + @Override + public byte[] createTestData() { + byte[] dummy = new byte[10]; + for (int i = 0; i < dummy.length; ++i) { + dummy[i] = (byte) i; + } + return dummy; + } + } + + public static final class PrimitiveByteArrayVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier { + @Override + public TypeSerializer createUpgradedSerializer() { + TypeSerializer serializer = TypeExtractor.createTypeInfo(byte[].class).createSerializer(new ExecutionConfig()); + assertSame(serializer.getClass(), BytePrimitiveArraySerializer.class); + return serializer; + } + + @Override + public Matcher testDataMatcher() { + byte[] expected = new byte[10]; + for (int i = 0; i < expected.length; ++i) { + expected[i] = (byte) i; + } + return is(expected); + } + + @Override + public Matcher> schemaCompatibilityMatcher(MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "primitive char array" + // ---------------------------------------------------------------------------------------------- + public static final class PrimitiveCharArraySetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup { + @Override + public TypeSerializer createPriorSerializer() { + TypeSerializer serializer = TypeExtractor.createTypeInfo(char[].class).createSerializer(new ExecutionConfig()); + assertSame(serializer.getClass(), CharPrimitiveArraySerializer.class); + return serializer; + } + + @Override + public char[] createTestData() { + char[] data = new char[10]; + for (int i = 0; i < data.length; ++i) { + data[i] = (char) i; + } + return data; + } + } + + public static final class PrimitiveCharArrayVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier { + @Override + public TypeSerializer createUpgradedSerializer() { + TypeSerializer serializer = TypeExtractor.createTypeInfo(char[].class).createSerializer(new ExecutionConfig()); + assertSame(serializer.getClass(), CharPrimitiveArraySerializer.class); + return serializer; + } + + @Override + public Matcher testDataMatcher() { + char[] data = new char[10]; + for (int i = 0; i < data.length; ++i) { + data[i] = (char) i; + } + return is(data); + } + + @Override + public Matcher> schemaCompatibilityMatcher(MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "primitive double array" + // ---------------------------------------------------------------------------------------------- + public static final class PrimitiveDoubleArraySetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup { + @Override + public TypeSerializer createPriorSerializer() { + TypeSerializer serializer = TypeExtractor.createTypeInfo(double[].class).createSerializer(new ExecutionConfig()); + assertSame(serializer.getClass(), DoublePrimitiveArraySerializer.class); + return serializer; + } + + @Override + public double[] createTestData() { + double[] data = new double[10]; + for (int i = 0; i < data.length; ++i) { + data[i] = i + 0.1f; + } + return data; + } + } + + public static final class PrimitiveDoubleArrayVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier { + @Override + public TypeSerializer createUpgradedSerializer() { + TypeSerializer serializer = TypeExtractor.createTypeInfo(double[].class).createSerializer(new ExecutionConfig()); + assertSame(serializer.getClass(), DoublePrimitiveArraySerializer.class); + return serializer; + } + + @Override + public Matcher testDataMatcher() { + double[] data = new double[10]; + for (int i = 0; i < data.length; ++i) { + data[i] = i + 0.1f; + } + return is(data); + } + + @Override + public Matcher> schemaCompatibilityMatcher(MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "primitive float array" + // ---------------------------------------------------------------------------------------------- + public static final class PrimitiveFloatArraySetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup { + @Override + public TypeSerializer createPriorSerializer() { + TypeSerializer serializer = TypeExtractor.createTypeInfo(float[].class).createSerializer(new ExecutionConfig()); + assertSame(serializer.getClass(), FloatPrimitiveArraySerializer.class); + return serializer; + } + + @Override + public float[] createTestData() { + float[] data = new float[10]; + for (int i = 0; i < data.length; ++i) { + data[i] = i + 0.2f; + } + return data; + } + } + + public static final class PrimitiveFloatArrayVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier { + @Override + public TypeSerializer createUpgradedSerializer() { + TypeSerializer serializer = TypeExtractor.createTypeInfo(float[].class).createSerializer(new ExecutionConfig()); + assertSame(serializer.getClass(), FloatPrimitiveArraySerializer.class); + return serializer; + } + + @Override + public Matcher testDataMatcher() { + float[] data = new float[10]; + for (int i = 0; i < data.length; ++i) { + data[i] = i + 0.2f; + } + return is(data); + } + + @Override + public Matcher> schemaCompatibilityMatcher(MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "primitive int array" + // ---------------------------------------------------------------------------------------------- + public static final class PrimitiveIntArraySetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup { + @Override + public TypeSerializer createPriorSerializer() { + TypeSerializer serializer = TypeExtractor.createTypeInfo(int[].class).createSerializer(new ExecutionConfig()); + assertSame(serializer.getClass(), IntPrimitiveArraySerializer.class); + return serializer; + } + + @Override + public int[] createTestData() { + int[] data = new int[10]; + for (int i = 0; i < data.length; ++i) { + data[i] = i; + } + return data; + } + } + + public static final class PrimitiveIntArrayVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier { + @Override + public TypeSerializer createUpgradedSerializer() { + TypeSerializer serializer = TypeExtractor.createTypeInfo(int[].class).createSerializer(new ExecutionConfig()); + assertSame(serializer.getClass(), IntPrimitiveArraySerializer.class); + return serializer; + } + + @Override + public Matcher testDataMatcher() { + int[] data = new int[10]; + for (int i = 0; i < data.length; ++i) { + data[i] = i; + } + return is(data); + } + + @Override + public Matcher> schemaCompatibilityMatcher(MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "primitive long array" + // ---------------------------------------------------------------------------------------------- + public static final class PrimitiveLongArraySetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup { + @Override + public TypeSerializer createPriorSerializer() { + TypeSerializer serializer = TypeExtractor.createTypeInfo(long[].class).createSerializer(new ExecutionConfig()); + assertSame(serializer.getClass(), LongPrimitiveArraySerializer.class); + return serializer; + } + + @Override + public long[] createTestData() { + long[] data = new long[10]; + for (int i = 0; i < data.length; ++i) { + data[i] = i; + } + return data; + } + } + + public static final class PrimitiveLongArrayVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier { + @Override + public TypeSerializer createUpgradedSerializer() { + TypeSerializer serializer = TypeExtractor.createTypeInfo(long[].class).createSerializer(new ExecutionConfig()); + assertSame(serializer.getClass(), LongPrimitiveArraySerializer.class); + return serializer; + } + + @Override + public Matcher testDataMatcher() { + long[] data = new long[10]; + for (int i = 0; i < data.length; ++i) { + data[i] = i; + } + return is(data); + } + + @Override + public Matcher> schemaCompatibilityMatcher(MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "primitive short array" + // ---------------------------------------------------------------------------------------------- + public static final class PrimitiveShortArraySetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup { + @Override + public TypeSerializer createPriorSerializer() { + TypeSerializer serializer = TypeExtractor.createTypeInfo(short[].class).createSerializer(new ExecutionConfig()); + assertSame(serializer.getClass(), ShortPrimitiveArraySerializer.class); + return serializer; + } + + @Override + public short[] createTestData() { + short[] data = new short[10]; + for (int i = 0; i < data.length; ++i) { + data[i] = (short) i; + } + return data; + } + } + + public static final class PrimitiveShortArrayVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier { + @Override + public TypeSerializer createUpgradedSerializer() { + TypeSerializer serializer = TypeExtractor.createTypeInfo(short[].class).createSerializer(new ExecutionConfig()); + assertSame(serializer.getClass(), ShortPrimitiveArraySerializer.class); + return serializer; + } + + @Override + public Matcher testDataMatcher() { + short[] data = new short[10]; + for (int i = 0; i < data.length; ++i) { + data[i] = (short) i; + } + return is(data); + } + + @Override + public Matcher> schemaCompatibilityMatcher(MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "primitive string array" + // ---------------------------------------------------------------------------------------------- + public static final class PrimitiveStringArraySetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup { + @Override + public TypeSerializer createPriorSerializer() { + TypeSerializer serializer = TypeExtractor.createTypeInfo(String[].class).createSerializer(new ExecutionConfig()); + assertSame(serializer.getClass(), StringArraySerializer.class); + return serializer; + } + + @Override + public String[] createTestData() { + String[] data = new String[10]; + for (int i = 0; i < data.length; ++i) { + data[i] = String.valueOf(i); + } + return data; + } + } + + public static final class PrimitiveStringArrayVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier { + @Override + public TypeSerializer createUpgradedSerializer() { + TypeSerializer serializer = TypeExtractor.createTypeInfo(String[].class).createSerializer(new ExecutionConfig()); + assertSame(serializer.getClass(), StringArraySerializer.class); + return serializer; + } + + @Override + public Matcher testDataMatcher() { + String[] data = new String[10]; + for (int i = 0; i < data.length; ++i) { + data[i] = String.valueOf(i); + } + return is(data); + } + + @Override + public Matcher> schemaCompatibilityMatcher(MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + +} + diff --git a/flink-core/src/test/resources/flink-1.6-boolean-primitive-array-serializer-data b/flink-core/src/test/resources/flink-1.6-boolean-primitive-array-serializer-data deleted file mode 100644 index 2a22d355bf474..0000000000000 Binary files a/flink-core/src/test/resources/flink-1.6-boolean-primitive-array-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-boolean-primitive-array-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-boolean-primitive-array-serializer-snapshot deleted file mode 100644 index 2558994cf9a26..0000000000000 Binary files a/flink-core/src/test/resources/flink-1.6-boolean-primitive-array-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-byte-primitive-array-serializer-data b/flink-core/src/test/resources/flink-1.6-byte-primitive-array-serializer-data deleted file mode 100644 index 9e71b0f3f5cb4..0000000000000 Binary files a/flink-core/src/test/resources/flink-1.6-byte-primitive-array-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-byte-primitive-array-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-byte-primitive-array-serializer-snapshot deleted file mode 100644 index 2938a7cbd9438..0000000000000 Binary files a/flink-core/src/test/resources/flink-1.6-byte-primitive-array-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-char-primitive-array-serializer-data b/flink-core/src/test/resources/flink-1.6-char-primitive-array-serializer-data deleted file mode 100644 index d267c92d68d8b..0000000000000 Binary files a/flink-core/src/test/resources/flink-1.6-char-primitive-array-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-char-primitive-array-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-char-primitive-array-serializer-snapshot deleted file mode 100644 index 412c1f070c7f3..0000000000000 Binary files a/flink-core/src/test/resources/flink-1.6-char-primitive-array-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-double-primitive-array-serializer-data b/flink-core/src/test/resources/flink-1.6-double-primitive-array-serializer-data deleted file mode 100644 index 200fe9c6e3985..0000000000000 Binary files a/flink-core/src/test/resources/flink-1.6-double-primitive-array-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-double-primitive-array-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-double-primitive-array-serializer-snapshot deleted file mode 100644 index 28a81827fb643..0000000000000 Binary files a/flink-core/src/test/resources/flink-1.6-double-primitive-array-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-float-primitive-array-serializer-data b/flink-core/src/test/resources/flink-1.6-float-primitive-array-serializer-data deleted file mode 100644 index 771461ae4615e..0000000000000 Binary files a/flink-core/src/test/resources/flink-1.6-float-primitive-array-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-float-primitive-array-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-float-primitive-array-serializer-snapshot deleted file mode 100644 index 970c5beccc62b..0000000000000 Binary files a/flink-core/src/test/resources/flink-1.6-float-primitive-array-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-int-primitive-array-serializer-data b/flink-core/src/test/resources/flink-1.6-int-primitive-array-serializer-data deleted file mode 100644 index bce445f71c30f..0000000000000 Binary files a/flink-core/src/test/resources/flink-1.6-int-primitive-array-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-int-primitive-array-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-int-primitive-array-serializer-snapshot deleted file mode 100644 index 3e054e9ed1b0f..0000000000000 Binary files a/flink-core/src/test/resources/flink-1.6-int-primitive-array-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-long-primitive-array-serializer-data b/flink-core/src/test/resources/flink-1.6-long-primitive-array-serializer-data deleted file mode 100644 index 0b0ce3d2f1463..0000000000000 Binary files a/flink-core/src/test/resources/flink-1.6-long-primitive-array-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-long-primitive-array-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-long-primitive-array-serializer-snapshot deleted file mode 100644 index 1f8f8e1e82f6e..0000000000000 Binary files a/flink-core/src/test/resources/flink-1.6-long-primitive-array-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-short-primitive-array-serializer-data b/flink-core/src/test/resources/flink-1.6-short-primitive-array-serializer-data deleted file mode 100644 index 4f0df79bee9f8..0000000000000 Binary files a/flink-core/src/test/resources/flink-1.6-short-primitive-array-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-short-primitive-array-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-short-primitive-array-serializer-snapshot deleted file mode 100644 index 94ae742440bf6..0000000000000 Binary files a/flink-core/src/test/resources/flink-1.6-short-primitive-array-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-boolean-primitive-array-serializer-data b/flink-core/src/test/resources/flink-1.7-boolean-primitive-array-serializer-data deleted file mode 100644 index 96acd9c0ef650..0000000000000 Binary files a/flink-core/src/test/resources/flink-1.7-boolean-primitive-array-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-boolean-primitive-array-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-boolean-primitive-array-serializer-snapshot deleted file mode 100644 index 7001c14315306..0000000000000 Binary files a/flink-core/src/test/resources/flink-1.7-boolean-primitive-array-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-byte-primitive-array-serializer-data b/flink-core/src/test/resources/flink-1.7-byte-primitive-array-serializer-data deleted file mode 100644 index 89566690f960e..0000000000000 Binary files a/flink-core/src/test/resources/flink-1.7-byte-primitive-array-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-byte-primitive-array-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-byte-primitive-array-serializer-snapshot deleted file mode 100644 index a9cba34bbd042..0000000000000 Binary files a/flink-core/src/test/resources/flink-1.7-byte-primitive-array-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-char-primitive-array-serializer-data b/flink-core/src/test/resources/flink-1.7-char-primitive-array-serializer-data deleted file mode 100644 index 918413ba75aad..0000000000000 Binary files a/flink-core/src/test/resources/flink-1.7-char-primitive-array-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-char-primitive-array-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-char-primitive-array-serializer-snapshot deleted file mode 100644 index 3f7deae1ce64c..0000000000000 Binary files a/flink-core/src/test/resources/flink-1.7-char-primitive-array-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-double-primitive-array-serializer-data b/flink-core/src/test/resources/flink-1.7-double-primitive-array-serializer-data deleted file mode 100644 index 16e618387b869..0000000000000 Binary files a/flink-core/src/test/resources/flink-1.7-double-primitive-array-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-double-primitive-array-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-double-primitive-array-serializer-snapshot deleted file mode 100644 index 3e4ee96cc2cfc..0000000000000 Binary files a/flink-core/src/test/resources/flink-1.7-double-primitive-array-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-float-primitive-array-serializer-data b/flink-core/src/test/resources/flink-1.7-float-primitive-array-serializer-data deleted file mode 100644 index e5371bbdec1a3..0000000000000 Binary files a/flink-core/src/test/resources/flink-1.7-float-primitive-array-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-float-primitive-array-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-float-primitive-array-serializer-snapshot deleted file mode 100644 index 7e01a51c9598f..0000000000000 Binary files a/flink-core/src/test/resources/flink-1.7-float-primitive-array-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-int-primitive-array-serializer-data b/flink-core/src/test/resources/flink-1.7-int-primitive-array-serializer-data deleted file mode 100644 index 6966366ffacfb..0000000000000 Binary files a/flink-core/src/test/resources/flink-1.7-int-primitive-array-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-int-primitive-array-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-int-primitive-array-serializer-snapshot deleted file mode 100644 index 6ef72a2fb556b..0000000000000 Binary files a/flink-core/src/test/resources/flink-1.7-int-primitive-array-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-long-primitive-array-serializer-data b/flink-core/src/test/resources/flink-1.7-long-primitive-array-serializer-data deleted file mode 100644 index 267bb12c12bc9..0000000000000 Binary files a/flink-core/src/test/resources/flink-1.7-long-primitive-array-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-long-primitive-array-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-long-primitive-array-serializer-snapshot deleted file mode 100644 index eec2da304296c..0000000000000 Binary files a/flink-core/src/test/resources/flink-1.7-long-primitive-array-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-short-primitive-array-serializer-data b/flink-core/src/test/resources/flink-1.7-short-primitive-array-serializer-data deleted file mode 100644 index 9dcf64f1f92e3..0000000000000 Binary files a/flink-core/src/test/resources/flink-1.7-short-primitive-array-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-short-primitive-array-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-short-primitive-array-serializer-snapshot deleted file mode 100644 index e07dc66be57a5..0000000000000 Binary files a/flink-core/src/test/resources/flink-1.7-short-primitive-array-serializer-snapshot and /dev/null differ