This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git
commit c99e5229f0aa50fceb991da286d5126a736403f4 Author: Aljoscha Krettek <[email protected]> AuthorDate: Fri Jan 31 16:55:19 2020 +0100 [FLINK-13632] Port KryoSerializer upgrade test to TypeSerializerUpgradeTestBase --- .../runtime/kryo/KryoPojosForMigrationTests.java | 18 ++ .../runtime/kryo/KryoSerializerUpgradeTest.java | 272 +++++++++++++++++++++ .../runtime/kryo/KryoSnapshotMigrationTest.java | 146 ----------- .../flink-1.6-kryo-type-serializer-custom-data | 1 - .../flink-1.6-kryo-type-serializer-custom-snapshot | Bin 4808 -> 0 bytes .../resources/flink-1.6-kryo-type-serializer-data | 1 - ...link-1.6-kryo-type-serializer-empty-config-data | Bin 180 -> 0 bytes ...-1.6-kryo-type-serializer-empty-config-snapshot | Bin 2759 -> 0 bytes .../flink-1.6-kryo-type-serializer-snapshot | Bin 3854 -> 0 bytes .../flink-1.7-kryo-type-serializer-custom-data | 1 - .../flink-1.7-kryo-type-serializer-custom-snapshot | Bin 4796 -> 0 bytes .../resources/flink-1.7-kryo-type-serializer-data | 1 - ...link-1.7-kryo-type-serializer-empty-config-data | Bin 892 -> 0 bytes ...-1.7-kryo-type-serializer-empty-config-snapshot | Bin 2747 -> 0 bytes .../flink-1.7-kryo-type-serializer-snapshot | Bin 3842 -> 0 bytes 15 files changed, 290 insertions(+), 150 deletions(-) diff --git a/flink-core/src/test/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoPojosForMigrationTests.java b/flink-core/src/test/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoPojosForMigrationTests.java index c7b6cb0..efe15da 100644 --- a/flink-core/src/test/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoPojosForMigrationTests.java +++ b/flink-core/src/test/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoPojosForMigrationTests.java @@ -24,6 +24,7 @@ import com.esotericsoftware.kryo.io.Input; import com.esotericsoftware.kryo.io.Output; import java.io.Serializable; +import java.util.Objects; /** * POJOS needed for {@link KryoPojosForMigrationTests}. @@ -44,6 +45,23 @@ public class KryoPojosForMigrationTests { public String getName() { return name; } + + @Override + public boolean equals(Object o) { + if (this == o) { + return true; + } + if (o == null || getClass() != o.getClass()) { + return false; + } + Dog dog = (Dog) o; + return Objects.equals(name, dog.name); + } + + @Override + public int hashCode() { + return Objects.hash(name); + } } public static class Cat extends Animal { diff --git a/flink-core/src/test/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoSerializerUpgradeTest.java b/flink-core/src/test/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoSerializerUpgradeTest.java new file mode 100644 index 0000000..5e718d4 --- /dev/null +++ b/flink-core/src/test/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoSerializerUpgradeTest.java @@ -0,0 +1,272 @@ +/* + * 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.java.typeutils.runtime.kryo; + +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.runtime.kryo.KryoPojosForMigrationTests.Animal; +import org.apache.flink.api.java.typeutils.runtime.kryo.KryoPojosForMigrationTests.Cat; +import org.apache.flink.api.java.typeutils.runtime.kryo.KryoPojosForMigrationTests.Dog; +import org.apache.flink.api.java.typeutils.runtime.kryo.KryoPojosForMigrationTests.Parrot; +import org.apache.flink.testutils.migration.MigrationVersion; + +import com.esotericsoftware.kryo.serializers.DefaultSerializers; +import org.hamcrest.Matcher; +import org.junit.runner.RunWith; +import org.junit.runners.Parameterized; + +import java.util.ArrayList; +import java.util.Collection; + +import static org.apache.flink.api.common.typeutils.TypeSerializerMatchers.hasSameCompatibilityAs; +import static org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility.compatibleWithReconfiguredSerializer; +import static org.hamcrest.Matchers.is; + +/** + * Tests migrations for {@link KryoSerializerSnapshot}. + */ +@SuppressWarnings("WeakerAccess") +@RunWith(Parameterized.class) +public class KryoSerializerUpgradeTest extends TypeSerializerUpgradeTestBase<Object, Object> { + + public KryoSerializerUpgradeTest(TestSpecification<Object, Object> testSpecification) { + super(testSpecification); + } + + @Parameterized.Parameters(name = "Test Specification = {0}") + public static Collection<TestSpecification<?, ?>> testSpecifications() throws Exception { + ArrayList<TestSpecification<?, ?>> testSpecifications = new ArrayList<>(); + for (MigrationVersion migrationVersion : MIGRATION_VERSIONS) { + testSpecifications.add( + new TestSpecification<>( + "kryo-type-serializer-empty-config", + migrationVersion, + KryoTypeSerializerEmptyConfigSetup.class, + KryoTypeSerializerEmptyConfigVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "kryo-type-serializer-unrelated-config-after-restore", + migrationVersion, + KryoTypeSerializerEmptyConfigSetup.class, + KryoTypeSerializerWithUnrelatedConfigVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "kryo-type-serializer-changed-registration-order", + migrationVersion, + KryoTypeSerializerChangedRegistrationOrderSetup.class, + KryoTypeSerializerChangedRegistrationOrderVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "kryo-custom-type-serializer-changed-registration-order", + migrationVersion, + KryoCustomTypeSerializerChangedRegistrationOrderSetup.class, + KryoCustomTypeSerializerChangedRegistrationOrderVerifier.class)); + } + + return testSpecifications; + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "kryo-type-serializer-empty-config" + // ---------------------------------------------------------------------------------------------- + + public static final class KryoTypeSerializerEmptyConfigSetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup<Animal> { + + @Override + public TypeSerializer<Animal> createPriorSerializer() { + return new KryoSerializer<>(Animal.class, new ExecutionConfig()); + } + + @Override + public Animal createTestData() { + return new Dog("Hasso"); + } + } + + public static final class KryoTypeSerializerEmptyConfigVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier<Animal> { + + @Override + public TypeSerializer<Animal> createUpgradedSerializer() { + return new KryoSerializer<>(Animal.class, new ExecutionConfig()); + } + + @Override + public Matcher<Animal> testDataMatcher() { + return is(new Dog("Hasso")); + } + + @Override + public Matcher<TypeSerializerSchemaCompatibility<Animal>> schemaCompatibilityMatcher(MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "kryo-type-serializer-empty-config-then-some-config" + // ---------------------------------------------------------------------------------------------- + + public static final class KryoTypeSerializerWithUnrelatedConfigVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier<Animal> { + + @Override + public TypeSerializer<Animal> createUpgradedSerializer() { + ExecutionConfig executionConfig = new ExecutionConfig(); + executionConfig.registerKryoType(DummyClassOne.class); + executionConfig.registerTypeWithKryoSerializer( + DummyClassTwo.class, + DefaultSerializers.StringSerializer.class); + + return new KryoSerializer<>(Animal.class, executionConfig); + } + + @Override + public Matcher<Animal> testDataMatcher() { + return is(new Dog("Hasso")); + } + + @Override + public Matcher<TypeSerializerSchemaCompatibility<Animal>> schemaCompatibilityMatcher(MigrationVersion version) { + return hasSameCompatibilityAs(compatibleWithReconfiguredSerializer(new KryoSerializer<>( + Animal.class, + new ExecutionConfig()))); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "kryo-type-serializer-changed-registration-order" + // ---------------------------------------------------------------------------------------------- + + public static final class KryoTypeSerializerChangedRegistrationOrderSetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup<Animal> { + + @Override + public TypeSerializer<Animal> createPriorSerializer() { + ExecutionConfig executionConfig = new ExecutionConfig(); + executionConfig.registerKryoType(Dog.class); + executionConfig.registerKryoType(Cat.class); + executionConfig.registerKryoType(Parrot.class); + + return new KryoSerializer<>(Animal.class, executionConfig); + } + + @Override + public Animal createTestData() { + return new Dog("Hasso"); + } + } + + public static final class KryoTypeSerializerChangedRegistrationOrderVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier<Animal> { + + @Override + public TypeSerializer<Animal> createUpgradedSerializer() { + ExecutionConfig executionConfig = new ExecutionConfig(); + executionConfig.registerKryoType(DummyClassOne.class); + executionConfig.registerKryoType(Dog.class); + executionConfig.registerKryoType(DummyClassTwo.class); + executionConfig.registerKryoType(Cat.class); + executionConfig.registerKryoType(Parrot.class); + + return new KryoSerializer<>(Animal.class, executionConfig); + } + + @Override + public Matcher<Animal> testDataMatcher() { + return is(new Dog("Hasso")); + } + + @Override + public Matcher<TypeSerializerSchemaCompatibility<Animal>> schemaCompatibilityMatcher(MigrationVersion version) { + return hasSameCompatibilityAs(compatibleWithReconfiguredSerializer(new KryoSerializer<>( + Animal.class, + new ExecutionConfig()))); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "kryo-custom-type-serializer-changed-registration-order" + // ---------------------------------------------------------------------------------------------- + + public static final class KryoCustomTypeSerializerChangedRegistrationOrderSetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup<Animal> { + + @Override + public TypeSerializer<Animal> createPriorSerializer() { + ExecutionConfig executionConfig = new ExecutionConfig(); + executionConfig.registerTypeWithKryoSerializer( + Dog.class, + KryoPojosForMigrationTests.DogKryoSerializer.class); + executionConfig.registerKryoType(Cat.class); + executionConfig.registerTypeWithKryoSerializer( + Parrot.class, + KryoPojosForMigrationTests.ParrotKryoSerializer.class); + + return new KryoSerializer<>(Animal.class, executionConfig); + } + + @Override + public Animal createTestData() { + return new Dog("Hasso"); + } + } + + public static final class KryoCustomTypeSerializerChangedRegistrationOrderVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier<Animal> { + + @Override + public TypeSerializer<Animal> createUpgradedSerializer() { + ExecutionConfig executionConfig = new ExecutionConfig(); + executionConfig.registerKryoType(DummyClassOne.class); + executionConfig.registerTypeWithKryoSerializer( + Dog.class, + KryoPojosForMigrationTests.DogV2KryoSerializer.class); + executionConfig.registerKryoType(DummyClassTwo.class); + executionConfig.registerKryoType(Cat.class); + executionConfig.registerTypeWithKryoSerializer( + Parrot.class, + KryoPojosForMigrationTests.ParrotKryoSerializer.class); + + return new KryoSerializer<>(Animal.class, executionConfig); + } + + @Override + public Matcher<Animal> testDataMatcher() { + return is(new Dog("Hasso")); + } + + @Override + public Matcher<TypeSerializerSchemaCompatibility<Animal>> schemaCompatibilityMatcher(MigrationVersion version) { + return hasSameCompatibilityAs(compatibleWithReconfiguredSerializer(new KryoSerializer<>( + Animal.class, + new ExecutionConfig()))); + } + } + + /** + * Dummy class to be registered in the tests. + */ + public static final class DummyClassOne { + + } + + /** + * Dummy class to be registered in the tests. + */ + public static final class DummyClassTwo { + + } +} diff --git a/flink-core/src/test/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoSnapshotMigrationTest.java b/flink-core/src/test/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoSnapshotMigrationTest.java deleted file mode 100644 index a982eca..0000000 --- a/flink-core/src/test/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoSnapshotMigrationTest.java +++ /dev/null @@ -1,146 +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.java.typeutils.runtime.kryo; - -import org.apache.flink.api.common.ExecutionConfig; -import org.apache.flink.api.common.typeutils.TypeSerializer; -import org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility; -import org.apache.flink.api.common.typeutils.TypeSerializerSnapshotMigrationTestBase; -import org.apache.flink.api.java.typeutils.runtime.kryo.KryoPojosForMigrationTests.Animal; -import org.apache.flink.api.java.typeutils.runtime.kryo.KryoPojosForMigrationTests.Cat; -import org.apache.flink.api.java.typeutils.runtime.kryo.KryoPojosForMigrationTests.Dog; -import org.apache.flink.api.java.typeutils.runtime.kryo.KryoPojosForMigrationTests.DogV2KryoSerializer; -import org.apache.flink.api.java.typeutils.runtime.kryo.KryoPojosForMigrationTests.Parrot; -import org.apache.flink.api.java.typeutils.runtime.kryo.KryoPojosForMigrationTests.ParrotKryoSerializer; -import org.apache.flink.testutils.migration.MigrationVersion; - -import com.esotericsoftware.kryo.serializers.DefaultSerializers.StringSerializer; -import org.junit.runner.RunWith; -import org.junit.runners.Parameterized; - -import java.util.ArrayList; -import java.util.Collection; -import java.util.List; -import java.util.function.Supplier; - -import static org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility.compatibleAsIs; -import static org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility.compatibleWithReconfiguredSerializer; - -/** - * Tests migrations for {@link KryoSerializerSnapshot}. - */ -@SuppressWarnings("WeakerAccess") -@RunWith(Parameterized.class) -public class KryoSnapshotMigrationTest extends TypeSerializerSnapshotMigrationTestBase<KryoPojosForMigrationTests> { - - public KryoSnapshotMigrationTest(TestSpecification<KryoPojosForMigrationTests> testSpecification) { - super(testSpecification); - } - - @SuppressWarnings("unchecked") - @Parameterized.Parameters(name = "Test Specification = {0}") - public static Collection<Object[]> testSpecifications() { - - List<Object[]> specs = new ArrayList<>(); - - add(specs, "kryo-type-serializer-empty-config", - () -> new KryoSerializer<>(Animal.class, new ExecutionConfig())); - - add(specs, "kryo-type-serializer-empty-config", () -> { - - ExecutionConfig executionConfig = new ExecutionConfig(); - executionConfig.registerKryoType(DummyClassOne.class); - executionConfig.registerTypeWithKryoSerializer(DummyClassTwo.class, StringSerializer.class); - - return new KryoSerializer<>(Animal.class, executionConfig); - }, COMPATIBLE_WITH_RECONFIGURED); - - add(specs, "kryo-type-serializer", () -> { - - ExecutionConfig executionConfig = new ExecutionConfig(); - executionConfig.registerKryoType(DummyClassOne.class); - executionConfig.registerKryoType(Dog.class); - executionConfig.registerKryoType(DummyClassTwo.class); - executionConfig.registerKryoType(Cat.class); - executionConfig.registerKryoType(Parrot.class); - - return new KryoSerializer<>(Animal.class, executionConfig); - }, COMPATIBLE_WITH_RECONFIGURED); - - add(specs, "kryo-type-serializer-custom", () -> { - ExecutionConfig executionConfig = new ExecutionConfig(); - executionConfig.registerKryoType(DummyClassOne.class); - executionConfig.registerTypeWithKryoSerializer(Dog.class, DogV2KryoSerializer.class); - executionConfig.registerKryoType(DummyClassTwo.class); - executionConfig.registerKryoType(Cat.class); - executionConfig.registerTypeWithKryoSerializer(Parrot.class, ParrotKryoSerializer.class); - - return new KryoSerializer<>(Animal.class, executionConfig); - }, COMPATIBLE_WITH_RECONFIGURED); - - return specs; - } - - private static void add(List<Object[]> all, String name, Supplier<TypeSerializer<Animal>> supplier) { - add(all, name, supplier, compatibleAsIs()); - } - - private static void add(List<Object[]> all, - String name, Supplier<TypeSerializer<Animal>> supplier, - TypeSerializerSchemaCompatibility<Animal> expected) { - - TestSpecification<Animal> flink16 = TestSpecification.<Animal>builder( - MigrationVersion.v1_6 + " " + name, - KryoSerializer.class, - KryoSerializerSnapshot.class, - MigrationVersion.v1_6) - .withNewSerializerProvider(supplier, expected) - .withSnapshotDataLocation("flink-1.6-" + name + "-snapshot") - .withTestData("flink-1.6-" + name + "-data", 2); - - TestSpecification<Animal> flink17 = TestSpecification.<Animal>builder( - MigrationVersion.v1_7 + " " + name, - KryoSerializer.class, - KryoSerializerSnapshot.class, - MigrationVersion.v1_7) - .withNewSerializerProvider(supplier, expected) - .withSnapshotDataLocation("flink-1.7-" + name + "-snapshot") - .withTestData("flink-1.7-" + name + "-data", 2); - - all.add(new Object[]{flink16}); - all.add(new Object[]{flink17}); - } - - /** - * Dummy class to be registered in the tests. - */ - public static final class DummyClassOne { - - } - - /** - * Dummy class to be registered in the tests. - */ - public static final class DummyClassTwo { - - } - - private static final TypeSerializerSchemaCompatibility<Animal> COMPATIBLE_WITH_RECONFIGURED = - compatibleWithReconfiguredSerializer(new KryoSerializer<>(Animal.class, new ExecutionConfig())); -} diff --git a/flink-core/src/test/resources/flink-1.6-kryo-type-serializer-custom-data b/flink-core/src/test/resources/flink-1.6-kryo-type-serializer-custom-data deleted file mode 100644 index b273ce4..0000000 --- a/flink-core/src/test/resources/flink-1.6-kryo-type-serializer-custom-data +++ /dev/null @@ -1 +0,0 @@ -Scottis�Bobb�Scottis�Scottis�Scottis�Scottis�Scottis�Scottis�Scottis�Elvi� \ No newline at end of file diff --git a/flink-core/src/test/resources/flink-1.6-kryo-type-serializer-custom-snapshot b/flink-core/src/test/resources/flink-1.6-kryo-type-serializer-custom-snapshot deleted file mode 100644 index de61118..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-kryo-type-serializer-custom-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-kryo-type-serializer-data b/flink-core/src/test/resources/flink-1.6-kryo-type-serializer-data deleted file mode 100644 index 43cdb64..0000000 --- a/flink-core/src/test/resources/flink-1.6-kryo-type-serializer-data +++ /dev/null @@ -1 +0,0 @@ -PHome�Bob� \ No newline at end of file diff --git a/flink-core/src/test/resources/flink-1.6-kryo-type-serializer-empty-config-data b/flink-core/src/test/resources/flink-1.6-kryo-type-serializer-empty-config-data deleted file mode 100644 index 0c66b7d..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-kryo-type-serializer-empty-config-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-kryo-type-serializer-empty-config-snapshot b/flink-core/src/test/resources/flink-1.6-kryo-type-serializer-empty-config-snapshot deleted file mode 100644 index eff068b..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-kryo-type-serializer-empty-config-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-kryo-type-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-kryo-type-serializer-snapshot deleted file mode 100644 index 2af53a7..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-kryo-type-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-kryo-type-serializer-custom-data b/flink-core/src/test/resources/flink-1.7-kryo-type-serializer-custom-data deleted file mode 100644 index b273ce4..0000000 --- a/flink-core/src/test/resources/flink-1.7-kryo-type-serializer-custom-data +++ /dev/null @@ -1 +0,0 @@ -Scottis�Bobb�Scottis�Scottis�Scottis�Scottis�Scottis�Scottis�Scottis�Elvi� \ No newline at end of file diff --git a/flink-core/src/test/resources/flink-1.7-kryo-type-serializer-custom-snapshot b/flink-core/src/test/resources/flink-1.7-kryo-type-serializer-custom-snapshot deleted file mode 100644 index 4098c43..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-kryo-type-serializer-custom-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-kryo-type-serializer-data b/flink-core/src/test/resources/flink-1.7-kryo-type-serializer-data deleted file mode 100644 index d56bc15..0000000 --- a/flink-core/src/test/resources/flink-1.7-kryo-type-serializer-data +++ /dev/null @@ -1 +0,0 @@ -PHome�Bob�Bob�Bob�Bob�Bob�Bob�Bob�Bob�Bob� \ No newline at end of file diff --git a/flink-core/src/test/resources/flink-1.7-kryo-type-serializer-empty-config-data b/flink-core/src/test/resources/flink-1.7-kryo-type-serializer-empty-config-data deleted file mode 100644 index 62aa733..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-kryo-type-serializer-empty-config-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-kryo-type-serializer-empty-config-snapshot b/flink-core/src/test/resources/flink-1.7-kryo-type-serializer-empty-config-snapshot deleted file mode 100644 index 87f7ba9..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-kryo-type-serializer-empty-config-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-kryo-type-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-kryo-type-serializer-snapshot deleted file mode 100644 index 8117ac9..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-kryo-type-serializer-snapshot and /dev/null differ
