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 c5fcfe668fbf1b3b8982ebd0f632fe20a4f41c9a Author: klion26 <[email protected]> AuthorDate: Thu Jan 30 14:22:58 2020 +0800 [FLINK-13632] Port BaseTypeSerializer test to TypeSerializerUpgradeTestBase --- .../BaseTypeSerializerSnapshotMigrationTest.java | 73 -- .../base/BasicTypeSerializerUpgradeTest.java | 199 ++++ ...sicTypeSerializerUpgradeTestSpecifications.java | 1002 ++++++++++++++++++++ .../resources/flink-1.6-big-dec-serializer-data | Bin 300 -> 0 bytes .../flink-1.6-big-dec-serializer-snapshot | Bin 394 -> 0 bytes .../resources/flink-1.6-big-int-serializer-data | Bin 64 -> 0 bytes .../flink-1.6-big-int-serializer-snapshot | Bin 394 -> 0 bytes .../resources/flink-1.6-boolean-serializer-data | 1 - .../flink-1.6-boolean-serializer-snapshot | Bin 396 -> 0 bytes .../flink-1.6-boolean-value-serializer-data | Bin 10 -> 0 bytes .../flink-1.6-boolean-value-serializer-snapshot | Bin 406 -> 0 bytes .../test/resources/flink-1.6-byte-serializer-data | 1 - .../resources/flink-1.6-byte-serializer-snapshot | Bin 390 -> 0 bytes .../resources/flink-1.6-byte-value-serializer-data | 1 - .../flink-1.6-byte-value-serializer-snapshot | Bin 400 -> 0 bytes .../test/resources/flink-1.6-char-serializer-data | Bin 20 -> 0 bytes .../resources/flink-1.6-char-serializer-snapshot | Bin 390 -> 0 bytes .../resources/flink-1.6-char-value-serializer-data | Bin 20 -> 0 bytes .../flink-1.6-char-value-serializer-snapshot | Bin 400 -> 0 bytes .../test/resources/flink-1.6-date-serializer-data | Bin 80 -> 0 bytes .../resources/flink-1.6-date-serializer-snapshot | Bin 390 -> 0 bytes .../resources/flink-1.6-double-serializer-data | 1 - .../resources/flink-1.6-double-serializer-snapshot | Bin 394 -> 0 bytes .../flink-1.6-double-value-serializer-data | 1 - .../flink-1.6-double-value-serializer-snapshot | Bin 404 -> 0 bytes .../test/resources/flink-1.6-float-serializer-data | 1 - .../resources/flink-1.6-float-serializer-snapshot | Bin 392 -> 0 bytes .../flink-1.6-float-value-serializer-data | 1 - .../flink-1.6-float-value-serializer-snapshot | Bin 402 -> 0 bytes .../test/resources/flink-1.6-int-serializer-data | Bin 40 -> 0 bytes .../resources/flink-1.6-int-serializer-snapshot | Bin 388 -> 0 bytes .../resources/flink-1.6-int-value-serializer-data | Bin 40 -> 0 bytes .../flink-1.6-int-value-serializer-snapshot | Bin 398 -> 0 bytes .../test/resources/flink-1.6-long-serializer-data | Bin 80 -> 0 bytes .../resources/flink-1.6-long-serializer-snapshot | Bin 390 -> 0 bytes .../resources/flink-1.6-long-value-serializer-data | Bin 80 -> 0 bytes .../flink-1.6-long-value-serializer-snapshot | Bin 400 -> 0 bytes .../resources/flink-1.6-null-value-serializer-data | 0 .../flink-1.6-null-value-serializer-snapshot | Bin 400 -> 0 bytes .../test/resources/flink-1.6-short-serializer-data | Bin 20 -> 0 bytes .../resources/flink-1.6-short-serializer-snapshot | Bin 392 -> 0 bytes .../flink-1.6-short-value-serializer-data | Bin 20 -> 0 bytes .../flink-1.6-short-value-serializer-snapshot | Bin 402 -> 0 bytes .../resources/flink-1.6-sql-date-serializer-data | Bin 80 -> 0 bytes .../flink-1.6-sql-date-serializer-snapshot | Bin 396 -> 0 bytes .../resources/flink-1.6-sql-time-serializer-data | Bin 80 -> 0 bytes .../flink-1.6-sql-time-serializer-snapshot | Bin 396 -> 0 bytes .../flink-1.6-sql-timestamp-serializer-data | Bin 120 -> 0 bytes .../flink-1.6-sql-timestamp-serializer-snapshot | Bin 406 -> 0 bytes .../resources/flink-1.6-string-serializer-data | 1 - .../resources/flink-1.6-string-serializer-snapshot | Bin 394 -> 0 bytes .../flink-1.6-string-value-serializer-data | 1 - .../flink-1.6-string-value-serializer-snapshot | Bin 404 -> 0 bytes .../resources/flink-1.7-big-dec-serializer-data | Bin 300 -> 0 bytes .../flink-1.7-big-dec-serializer-snapshot | Bin 155 -> 0 bytes .../resources/flink-1.7-big-int-serializer-data | Bin 150 -> 0 bytes .../flink-1.7-big-int-serializer-snapshot | Bin 155 -> 0 bytes .../resources/flink-1.7-boolean-serializer-data | 1 - .../flink-1.7-boolean-serializer-snapshot | Bin 158 -> 0 bytes .../flink-1.7-boolean-value-serializer-data | Bin 10 -> 0 bytes .../flink-1.7-boolean-value-serializer-snapshot | Bin 173 -> 0 bytes .../test/resources/flink-1.7-byte-serializer-data | 1 - .../resources/flink-1.7-byte-serializer-snapshot | Bin 149 -> 0 bytes .../resources/flink-1.7-byte-value-serializer-data | 1 - .../flink-1.7-byte-value-serializer-snapshot | Bin 164 -> 0 bytes .../test/resources/flink-1.7-char-serializer-data | Bin 20 -> 0 bytes .../resources/flink-1.7-char-serializer-snapshot | Bin 149 -> 0 bytes .../resources/flink-1.7-char-value-serializer-data | Bin 20 -> 0 bytes .../flink-1.7-char-value-serializer-snapshot | Bin 164 -> 0 bytes .../test/resources/flink-1.7-date-serializer-data | Bin 80 -> 0 bytes .../resources/flink-1.7-date-serializer-snapshot | Bin 149 -> 0 bytes .../resources/flink-1.7-double-serializer-data | 1 - .../resources/flink-1.7-double-serializer-snapshot | Bin 155 -> 0 bytes .../flink-1.7-double-value-serializer-data | 1 - .../flink-1.7-double-value-serializer-snapshot | Bin 170 -> 0 bytes .../test/resources/flink-1.7-float-serializer-data | 1 - .../resources/flink-1.7-float-serializer-snapshot | Bin 152 -> 0 bytes .../flink-1.7-float-value-serializer-data | 1 - .../flink-1.7-float-value-serializer-snapshot | Bin 167 -> 0 bytes .../test/resources/flink-1.7-int-serializer-data | Bin 40 -> 0 bytes .../resources/flink-1.7-int-serializer-snapshot | Bin 146 -> 0 bytes .../resources/flink-1.7-int-value-serializer-data | Bin 40 -> 0 bytes .../flink-1.7-int-value-serializer-snapshot | Bin 161 -> 0 bytes .../test/resources/flink-1.7-long-serializer-data | Bin 80 -> 0 bytes .../resources/flink-1.7-long-serializer-snapshot | Bin 149 -> 0 bytes .../resources/flink-1.7-long-value-serializer-data | Bin 80 -> 0 bytes .../flink-1.7-long-value-serializer-snapshot | Bin 164 -> 0 bytes .../resources/flink-1.7-null-value-serializer-data | 0 .../flink-1.7-null-value-serializer-snapshot | Bin 164 -> 0 bytes .../test/resources/flink-1.7-short-serializer-data | Bin 20 -> 0 bytes .../resources/flink-1.7-short-serializer-snapshot | Bin 152 -> 0 bytes .../flink-1.7-short-value-serializer-data | Bin 20 -> 0 bytes .../flink-1.7-short-value-serializer-snapshot | Bin 167 -> 0 bytes .../resources/flink-1.7-sql-date-serializer-data | Bin 80 -> 0 bytes .../flink-1.7-sql-date-serializer-snapshot | Bin 158 -> 0 bytes .../resources/flink-1.7-sql-time-serializer-data | Bin 80 -> 0 bytes .../flink-1.7-sql-time-serializer-snapshot | Bin 158 -> 0 bytes .../flink-1.7-sql-timestamp-serializer-data | Bin 120 -> 0 bytes .../flink-1.7-sql-timestamp-serializer-snapshot | Bin 173 -> 0 bytes .../resources/flink-1.7-string-serializer-data | 1 - .../resources/flink-1.7-string-serializer-snapshot | Bin 155 -> 0 bytes .../flink-1.7-string-value-serializer-data | 1 - .../flink-1.7-string-value-serializer-snapshot | Bin 170 -> 0 bytes 103 files changed, 1201 insertions(+), 91 deletions(-) diff --git a/flink-core/src/test/java/org/apache/flink/api/common/typeutils/base/BaseTypeSerializerSnapshotMigrationTest.java b/flink-core/src/test/java/org/apache/flink/api/common/typeutils/base/BaseTypeSerializerSnapshotMigrationTest.java deleted file mode 100644 index 2ed4a85..0000000 --- a/flink-core/src/test/java/org/apache/flink/api/common/typeutils/base/BaseTypeSerializerSnapshotMigrationTest.java +++ /dev/null @@ -1,73 +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; - -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 basic type serializers' snapshots. - */ -@RunWith(Parameterized.class) -public class BaseTypeSerializerSnapshotMigrationTest extends TypeSerializerSnapshotMigrationTestBase<Object> { - - public BaseTypeSerializerSnapshotMigrationTest(TestSpecification<Object> testSpecification) { - super(testSpecification); - } - - @SuppressWarnings("unchecked") - @Parameterized.Parameters(name = "Test Specification = {0}") - public static Collection<TestSpecification<?>> testSpecifications() { - - final TestSpecifications testSpecifications = new TestSpecifications(MigrationVersion.v1_6, MigrationVersion.v1_7); - - testSpecifications.add("big-dec-serializer", BigDecSerializer.class, BigDecSerializer.BigDecSerializerSnapshot.class, () -> BigDecSerializer.INSTANCE); - testSpecifications.add("big-int-serializer", BigIntSerializer.class, BigIntSerializer.BigIntSerializerSnapshot.class, () -> BigIntSerializer.INSTANCE); - testSpecifications.add("boolean-serializer", BooleanSerializer.class, BooleanSerializer.BooleanSerializerSnapshot.class, () -> BooleanSerializer.INSTANCE); - testSpecifications.add("boolean-value-serializer", BooleanValueSerializer.class, BooleanValueSerializer.BooleanValueSerializerSnapshot.class, () -> BooleanValueSerializer.INSTANCE); - testSpecifications.add("byte-serializer", ByteSerializer.class, ByteSerializer.ByteSerializerSnapshot.class, () -> ByteSerializer.INSTANCE); - testSpecifications.add("byte-value-serializer", ByteValueSerializer.class, ByteValueSerializer.ByteValueSerializerSnapshot.class, () -> ByteValueSerializer.INSTANCE); - testSpecifications.add("char-serializer", CharSerializer.class, CharSerializer.CharSerializerSnapshot.class, () -> CharSerializer.INSTANCE); - testSpecifications.add("char-value-serializer", CharValueSerializer.class, CharValueSerializer.CharValueSerializerSnapshot.class, () -> CharValueSerializer.INSTANCE); - testSpecifications.add("date-serializer", DateSerializer.class, DateSerializer.DateSerializerSnapshot.class, () -> DateSerializer.INSTANCE); - testSpecifications.add("double-serializer", DoubleSerializer.class, DoubleSerializer.DoubleSerializerSnapshot.class, () -> DoubleSerializer.INSTANCE); - testSpecifications.add("double-value-serializer", DoubleValueSerializer.class, DoubleValueSerializer.DoubleValueSerializerSnapshot.class, () -> DoubleValueSerializer.INSTANCE); - testSpecifications.add("float-serializer", FloatSerializer.class, FloatSerializer.FloatSerializerSnapshot.class, () -> FloatSerializer.INSTANCE); - testSpecifications.add("float-value-serializer", FloatValueSerializer.class, FloatValueSerializer.FloatValueSerializerSnapshot.class, () -> FloatValueSerializer.INSTANCE); - testSpecifications.add("int-serializer", IntSerializer.class, IntSerializer.IntSerializerSnapshot.class, () -> IntSerializer.INSTANCE); - testSpecifications.add("int-value-serializer", IntValueSerializer.class, IntValueSerializer.IntValueSerializerSnapshot.class, () -> IntValueSerializer.INSTANCE); - testSpecifications.add("long-serializer", LongSerializer.class, LongSerializer.LongSerializerSnapshot.class, () -> LongSerializer.INSTANCE); - testSpecifications.add("long-value-serializer", LongValueSerializer.class, LongValueSerializer.LongValueSerializerSnapshot.class, () -> LongValueSerializer.INSTANCE); - testSpecifications.add("null-value-serializer", NullValueSerializer.class, NullValueSerializer.NullValueSerializerSnapshot.class, () -> NullValueSerializer.INSTANCE); - testSpecifications.add("short-serializer", ShortSerializer.class, ShortSerializer.ShortSerializerSnapshot.class, () -> ShortSerializer.INSTANCE); - testSpecifications.add("short-value-serializer", ShortValueSerializer.class, ShortValueSerializer.ShortValueSerializerSnapshot.class, () -> ShortValueSerializer.INSTANCE); - testSpecifications.add("sql-date-serializer", SqlDateSerializer.class, SqlDateSerializer.SqlDateSerializerSnapshot.class, () -> SqlDateSerializer.INSTANCE); - testSpecifications.add("sql-time-serializer", SqlTimeSerializer.class, SqlTimeSerializer.SqlTimeSerializerSnapshot.class, () -> SqlTimeSerializer.INSTANCE); - testSpecifications.add("sql-timestamp-serializer", SqlTimestampSerializer.class, SqlTimestampSerializer.SqlTimestampSerializerSnapshot.class, () -> SqlTimestampSerializer.INSTANCE); - testSpecifications.add("string-serializer", StringSerializer.class, StringSerializer.StringSerializerSnapshot.class, () -> StringSerializer.INSTANCE); - testSpecifications.add("string-value-serializer", StringValueSerializer.class, StringValueSerializer.StringValueSerializerSnapshot.class, () -> StringValueSerializer.INSTANCE); - - return testSpecifications.get(); - } -} diff --git a/flink-core/src/test/java/org/apache/flink/api/common/typeutils/base/BasicTypeSerializerUpgradeTest.java b/flink-core/src/test/java/org/apache/flink/api/common/typeutils/base/BasicTypeSerializerUpgradeTest.java new file mode 100644 index 0000000..4b3bbd8 --- /dev/null +++ b/flink-core/src/test/java/org/apache/flink/api/common/typeutils/base/BasicTypeSerializerUpgradeTest.java @@ -0,0 +1,199 @@ +/* + * 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; + +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; + +/** + * A {@link TypeSerializerUpgradeTestBase} for BaseType Serializers. + */ +@RunWith(Parameterized.class) +public class BasicTypeSerializerUpgradeTest extends TypeSerializerUpgradeTestBase<Object, Object> { + + public BasicTypeSerializerUpgradeTest(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<>( + "big-dec-serializer", + migrationVersion, + BasicTypeSerializerUpgradeTestSpecifications.BigDecSerializerSetup.class, + BasicTypeSerializerUpgradeTestSpecifications.BigDecSerializerVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "big-int-serializer", + migrationVersion, + BasicTypeSerializerUpgradeTestSpecifications.BigIntSerializerSetup.class, + BasicTypeSerializerUpgradeTestSpecifications.BigIntSerializerVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "boolean-serializer", + migrationVersion, + BasicTypeSerializerUpgradeTestSpecifications.BooleanSerializerSetup.class, + BasicTypeSerializerUpgradeTestSpecifications.BooleanSerializerVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "boolean-value-serializer", + migrationVersion, + BasicTypeSerializerUpgradeTestSpecifications.BooleanValueSerializerSetup.class, + BasicTypeSerializerUpgradeTestSpecifications.BooleanValueSerializerVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "byte-serializer", + migrationVersion, + BasicTypeSerializerUpgradeTestSpecifications.ByteSerializerSetup.class, + BasicTypeSerializerUpgradeTestSpecifications.ByteSerializerVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "byte-value-serializer", + migrationVersion, + BasicTypeSerializerUpgradeTestSpecifications.ByteValueSerializerSetup.class, + BasicTypeSerializerUpgradeTestSpecifications.ByteValueSerializerVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "char-serializer", + migrationVersion, + BasicTypeSerializerUpgradeTestSpecifications.CharSerializerSetup.class, + BasicTypeSerializerUpgradeTestSpecifications.CharSerializerVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "char-value-serializer", + migrationVersion, + BasicTypeSerializerUpgradeTestSpecifications.CharValueSerializerSetup.class, + BasicTypeSerializerUpgradeTestSpecifications.CharValueSerializerVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "date-serializer", + migrationVersion, + BasicTypeSerializerUpgradeTestSpecifications.DateSerializerSetup.class, + BasicTypeSerializerUpgradeTestSpecifications.DateSerializerVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "double-serializer", + migrationVersion, + BasicTypeSerializerUpgradeTestSpecifications.DoubleSerializerSetup.class, + BasicTypeSerializerUpgradeTestSpecifications.DoubleSerializerVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "double-value-serializer", + migrationVersion, + BasicTypeSerializerUpgradeTestSpecifications.DoubleValueSerializerSetup.class, + BasicTypeSerializerUpgradeTestSpecifications.DoubleValueSerializerVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "float-serializer", + migrationVersion, + BasicTypeSerializerUpgradeTestSpecifications.FloatSerializerSetup.class, + BasicTypeSerializerUpgradeTestSpecifications.FloatSerializerVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "float-value-serializer", + migrationVersion, + BasicTypeSerializerUpgradeTestSpecifications.FloatValueSerializerSetup.class, + BasicTypeSerializerUpgradeTestSpecifications.FloatValueSerializerVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "int-serializer", + migrationVersion, + BasicTypeSerializerUpgradeTestSpecifications.IntSerializerSetup.class, + BasicTypeSerializerUpgradeTestSpecifications.IntSerializerVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "int-value-serializer", + migrationVersion, + BasicTypeSerializerUpgradeTestSpecifications.IntValueSerializerSetup.class, + BasicTypeSerializerUpgradeTestSpecifications.IntValueSerializerVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "long-serializer", + migrationVersion, + BasicTypeSerializerUpgradeTestSpecifications.LongSerializerSetup.class, + BasicTypeSerializerUpgradeTestSpecifications.LongSerializerVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "long-value-serializer", + migrationVersion, + BasicTypeSerializerUpgradeTestSpecifications.LongValueSerializerSetup.class, + BasicTypeSerializerUpgradeTestSpecifications.LongValueSerializerVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "null-value-serializer", + migrationVersion, + BasicTypeSerializerUpgradeTestSpecifications.NullValueSerializerSetup.class, + BasicTypeSerializerUpgradeTestSpecifications.NullValueSerializerVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "short-serializer", + migrationVersion, + BasicTypeSerializerUpgradeTestSpecifications.ShortSerializerSetup.class, + BasicTypeSerializerUpgradeTestSpecifications.ShortSerializerVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "short-value-serializer", + migrationVersion, + BasicTypeSerializerUpgradeTestSpecifications.ShortValueSerializerSetup.class, + BasicTypeSerializerUpgradeTestSpecifications.ShortValueSerializerVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "sql-date-serializer", + migrationVersion, + BasicTypeSerializerUpgradeTestSpecifications.SqlDateSerializerSetup.class, + BasicTypeSerializerUpgradeTestSpecifications.SqlDateSerializerVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "sql-time-serializer", + migrationVersion, + BasicTypeSerializerUpgradeTestSpecifications.SqlTimeSerializerSetup.class, + BasicTypeSerializerUpgradeTestSpecifications.SqlTimeSerializerVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "sql-timestamp-serializer", + migrationVersion, + BasicTypeSerializerUpgradeTestSpecifications.SqlTimestampSerializerSetup.class, + BasicTypeSerializerUpgradeTestSpecifications.SqlTimestampSerializerVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "string-serializer", + migrationVersion, + BasicTypeSerializerUpgradeTestSpecifications.StringSerializerSetup.class, + BasicTypeSerializerUpgradeTestSpecifications.StringSerializerVerifier.class)); + testSpecifications.add( + new TestSpecification<>( + "string-value-serializer", + migrationVersion, + BasicTypeSerializerUpgradeTestSpecifications.StringValueSerializerSetup.class, + BasicTypeSerializerUpgradeTestSpecifications.StringValueSerializerVerifier.class)); + } + + return testSpecifications; + } +} diff --git a/flink-core/src/test/java/org/apache/flink/api/common/typeutils/base/BasicTypeSerializerUpgradeTestSpecifications.java b/flink-core/src/test/java/org/apache/flink/api/common/typeutils/base/BasicTypeSerializerUpgradeTestSpecifications.java new file mode 100644 index 0000000..3bea9f7 --- /dev/null +++ b/flink-core/src/test/java/org/apache/flink/api/common/typeutils/base/BasicTypeSerializerUpgradeTestSpecifications.java @@ -0,0 +1,1002 @@ +/* + * 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; + +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.testutils.migration.MigrationVersion; +import org.apache.flink.types.BooleanValue; +import org.apache.flink.types.ByteValue; +import org.apache.flink.types.CharValue; +import org.apache.flink.types.DoubleValue; +import org.apache.flink.types.FloatValue; +import org.apache.flink.types.IntValue; +import org.apache.flink.types.LongValue; +import org.apache.flink.types.NullValue; +import org.apache.flink.types.ShortValue; +import org.apache.flink.types.StringValue; + +import org.hamcrest.Matcher; +import org.hamcrest.Matchers; + +import java.math.BigDecimal; +import java.math.BigInteger; +import java.sql.Time; +import java.sql.Timestamp; +import java.util.Date; + + +/** + * Test specifications for {@link BasicTypeSerializerUpgradeTest}. + */ +public class BasicTypeSerializerUpgradeTestSpecifications { + // ---------------------------------------------------------------------------------------------- + // Specification for "big-dec-serializer" + // ---------------------------------------------------------------------------------------------- + /** + * BigDecSerializerSetup. + */ + public static final class BigDecSerializerSetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup<BigDecimal> { + @Override + public TypeSerializer<BigDecimal> createPriorSerializer() { + return BigDecSerializer.INSTANCE; + } + + @Override + public BigDecimal createTestData() { + return new BigDecimal("123456789012345678901234567890123456.789"); + } + } + + /** + * BigDecSerializerVerifier. + */ + public static final class BigDecSerializerVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier<BigDecimal> { + @Override + public TypeSerializer<BigDecimal> createUpgradedSerializer() { + return BigDecSerializer.INSTANCE; + } + + @Override + public Matcher<BigDecimal> testDataMatcher() { + return Matchers.is(new BigDecimal("123456789012345678901234567890123456.789")); + } + + @Override + public Matcher<TypeSerializerSchemaCompatibility<BigDecimal>> schemaCompatibilityMatcher( + MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "big-int-serializer" + // ---------------------------------------------------------------------------------------------- + /** + * BigIntSerializerSetup. + */ + public static final class BigIntSerializerSetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup<BigInteger> { + @Override + public TypeSerializer<BigInteger> createPriorSerializer() { + return BigIntSerializer.INSTANCE; + } + + @Override + public BigInteger createTestData() { + return new BigInteger("123456789012345678901234567890123456"); + } + } + + /** + * BigIntSerializerVerifier. + */ + public static final class BigIntSerializerVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier<BigInteger> { + @Override + public TypeSerializer<BigInteger> createUpgradedSerializer() { + return BigIntSerializer.INSTANCE; + } + + @Override + public Matcher<BigInteger> testDataMatcher() { + return Matchers.is(new BigInteger("123456789012345678901234567890123456")); + } + + @Override + public Matcher<TypeSerializerSchemaCompatibility<BigInteger>> schemaCompatibilityMatcher(MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "BooleanSerializer" + // ---------------------------------------------------------------------------------------------- + /** + * BooleanSerializerSetup. + */ + public static final class BooleanSerializerSetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup<Boolean> { + @Override + public TypeSerializer<Boolean> createPriorSerializer() { + return BooleanSerializer.INSTANCE; + } + + @Override + public Boolean createTestData() { + return Boolean.TRUE; + } + } + + /** + * BooleanSerializerVerifier. + */ + public static final class BooleanSerializerVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier<Boolean> { + @Override + public TypeSerializer<Boolean> createUpgradedSerializer() { + return BooleanSerializer.INSTANCE; + } + + @Override + public Matcher<Boolean> testDataMatcher() { + return Matchers.is(Boolean.TRUE); + } + + @Override + public Matcher<TypeSerializerSchemaCompatibility<Boolean>> schemaCompatibilityMatcher(MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "boolean-value-serializer" + // ---------------------------------------------------------------------------------------------- + /** + * BooleanValueSerializerSetup. + */ + public static final class BooleanValueSerializerSetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup<BooleanValue> { + @Override + public TypeSerializer<BooleanValue> createPriorSerializer() { + return BooleanValueSerializer.INSTANCE; + } + + @Override + public BooleanValue createTestData() { + return BooleanValue.TRUE; + } + } + + /** + * BooleanValueSerializerVerifier. + */ + public static final class BooleanValueSerializerVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier<BooleanValue> { + @Override + public TypeSerializer<BooleanValue> createUpgradedSerializer() { + return BooleanValueSerializer.INSTANCE; + } + + @Override + public Matcher<BooleanValue> testDataMatcher() { + return Matchers.is(BooleanValue.TRUE); + } + + @Override + public Matcher<TypeSerializerSchemaCompatibility<BooleanValue>> schemaCompatibilityMatcher(MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "byte-serializer" + // ---------------------------------------------------------------------------------------------- + /** + * ByteSerializerSetup. + */ + public static final class ByteSerializerSetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup<Byte> { + @Override + public TypeSerializer<Byte> createPriorSerializer() { + return ByteSerializer.INSTANCE; + } + + @Override + public Byte createTestData() { + return Byte.valueOf("42"); + } + } + + /** + * ByteSerializerVerifier. + */ + public static final class ByteSerializerVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier<Byte> { + @Override + public TypeSerializer<Byte> createUpgradedSerializer() { + return ByteSerializer.INSTANCE; + } + + @Override + public Matcher<Byte> testDataMatcher() { + return Matchers.is(Byte.valueOf("42")); + } + + @Override + public Matcher<TypeSerializerSchemaCompatibility<Byte>> schemaCompatibilityMatcher(MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "byte-value-serializer" + // ---------------------------------------------------------------------------------------------- + /** + * ByteValueSerializerSetup. + */ + public static final class ByteValueSerializerSetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup<ByteValue> { + @Override + public TypeSerializer<ByteValue> createPriorSerializer() { + return ByteValueSerializer.INSTANCE; + } + + @Override + public ByteValue createTestData() { + return new ByteValue((byte) 42); + } + } + + /** + * ByteValueSerializerVerifier. + */ + public static final class ByteValueSerializerVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier<ByteValue> { + @Override + public TypeSerializer<ByteValue> createUpgradedSerializer() { + return ByteValueSerializer.INSTANCE; + } + + @Override + public Matcher<ByteValue> testDataMatcher() { + return Matchers.is(new ByteValue((byte) 42)); + } + + @Override + public Matcher<TypeSerializerSchemaCompatibility<ByteValue>> schemaCompatibilityMatcher(MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "char-serializer" + // ---------------------------------------------------------------------------------------------- + /** + * CharSerializerSetup. + */ + public static final class CharSerializerSetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup<Character> { + @Override + public TypeSerializer<Character> createPriorSerializer() { + return CharSerializer.INSTANCE; + } + + @Override + public Character createTestData() { + return Character.MAX_VALUE; + } + } + + /** + * CharSerializerVerifier. + */ + public static final class CharSerializerVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier<Character> { + @Override + public TypeSerializer<Character> createUpgradedSerializer() { + return CharSerializer.INSTANCE; + } + + @Override + public Matcher<Character> testDataMatcher() { + return Matchers.is(Character.MAX_VALUE); + } + + @Override + public Matcher<TypeSerializerSchemaCompatibility<Character>> schemaCompatibilityMatcher(MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "char-value-serializer" + // ---------------------------------------------------------------------------------------------- + /** + * CharValueSerializerSetup. + */ + public static final class CharValueSerializerSetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup<CharValue> { + @Override + public TypeSerializer<CharValue> createPriorSerializer() { + return CharValueSerializer.INSTANCE; + } + + @Override + public CharValue createTestData() { + return new CharValue((char) 42); + } + } + + /** + * CharValueSerializerVerifier. + */ + public static final class CharValueSerializerVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier<CharValue> { + @Override + public TypeSerializer<CharValue> createUpgradedSerializer() { + return CharValueSerializer.INSTANCE; + } + + @Override + public Matcher<CharValue> testDataMatcher() { + return Matchers.is(new CharValue((char) 42)); + } + + @Override + public Matcher<TypeSerializerSchemaCompatibility<CharValue>> schemaCompatibilityMatcher(MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "date-serializer" + // ---------------------------------------------------------------------------------------------- + /** + * DateSerializerSetup. + */ + public static final class DateSerializerSetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup<Date> { + @Override + public TypeSerializer<Date> createPriorSerializer() { + return DateSerializer.INSTANCE; + } + + @Override + public Date createTestData() { + return new Date(1580382960L); + } + } + + /** + * DateSerializerVerifier. + */ + public static final class DateSerializerVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier<Date> { + @Override + public TypeSerializer<Date> createUpgradedSerializer() { + return DateSerializer.INSTANCE; + } + + @Override + public Matcher<Date> testDataMatcher() { + return Matchers.is(new Date(1580382960L)); + } + + @Override + public Matcher<TypeSerializerSchemaCompatibility<Date>> schemaCompatibilityMatcher(MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "double-serializer" + // ---------------------------------------------------------------------------------------------- + /** + * DoubleSerializerSetup. + */ + public static final class DoubleSerializerSetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup<Double> { + @Override + public TypeSerializer<Double> createPriorSerializer() { + return DoubleSerializer.INSTANCE; + } + + @Override + public Double createTestData() { + return new Double("12345.6789"); + } + } + + /** + * DoubleSerializerVerifier. + */ + public static final class DoubleSerializerVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier<Double> { + @Override + public TypeSerializer<Double> createUpgradedSerializer() { + return DoubleSerializer.INSTANCE; + } + + @Override + public Matcher<Double> testDataMatcher() { + return Matchers.is(new Double("12345.6789")); + } + + @Override + public Matcher<TypeSerializerSchemaCompatibility<Double>> schemaCompatibilityMatcher(MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "double-value-serializer" + // ---------------------------------------------------------------------------------------------- + /** + * DoubleValueSerializerSetup. + */ + public static final class DoubleValueSerializerSetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup<DoubleValue> { + @Override + public TypeSerializer<DoubleValue> createPriorSerializer() { + return DoubleValueSerializer.INSTANCE; + } + + @Override + public DoubleValue createTestData() { + return new DoubleValue(12345.6789); + } + } + + /** + * DoubleValueSerializerVerifier. + */ + public static final class DoubleValueSerializerVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier<DoubleValue> { + @Override + public TypeSerializer<DoubleValue> createUpgradedSerializer() { + return DoubleValueSerializer.INSTANCE; + } + + @Override + public Matcher<DoubleValue> testDataMatcher() { + return Matchers.is(new DoubleValue(12345.6789)); + } + + @Override + public Matcher<TypeSerializerSchemaCompatibility<DoubleValue>> schemaCompatibilityMatcher(MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "float-serializer" + // ---------------------------------------------------------------------------------------------- + /** + * FloatSerializerSetup. + */ + public static final class FloatSerializerSetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup<Float> { + @Override + public TypeSerializer<Float> createPriorSerializer() { + return FloatSerializer.INSTANCE; + } + + @Override + public Float createTestData() { + return new Float("123.456"); + } + } + + /** + * FloatSerializerVerifier. + */ + public static final class FloatSerializerVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier<Float> { + @Override + public TypeSerializer<Float> createUpgradedSerializer() { + return FloatSerializer.INSTANCE; + } + + @Override + public Matcher<Float> testDataMatcher() { + return Matchers.is(new Float("123.456")); + } + + @Override + public Matcher<TypeSerializerSchemaCompatibility<Float>> schemaCompatibilityMatcher(MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "float-value-serializer" + // ---------------------------------------------------------------------------------------------- + /** + * FloatValueSerializerSetup. + */ + public static final class FloatValueSerializerSetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup<FloatValue> { + @Override + public TypeSerializer<FloatValue> createPriorSerializer() { + return FloatValueSerializer.INSTANCE; + } + + @Override + public FloatValue createTestData() { + return new FloatValue(123.456f); + } + } + + /** + * FloatValueSerializerVerifier. + */ + public static final class FloatValueSerializerVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier<FloatValue> { + @Override + public TypeSerializer<FloatValue> createUpgradedSerializer() { + return FloatValueSerializer.INSTANCE; + } + + @Override + public Matcher<FloatValue> testDataMatcher() { + return Matchers.is(new FloatValue(123.456f)); + } + + @Override + public Matcher<TypeSerializerSchemaCompatibility<FloatValue>> schemaCompatibilityMatcher(MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "int-serializer" + // ---------------------------------------------------------------------------------------------- + /** + * IntSerializerSetup. + */ + public static final class IntSerializerSetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup<Integer> { + @Override + public TypeSerializer<Integer> createPriorSerializer() { + return IntSerializer.INSTANCE; + } + + @Override + public Integer createTestData() { + return 123456; + } + } + + /** + * IntSerializerVerifier. + */ + public static final class IntSerializerVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier<Integer> { + @Override + public TypeSerializer<Integer> createUpgradedSerializer() { + return IntSerializer.INSTANCE; + } + + @Override + public Matcher<Integer> testDataMatcher() { + return Matchers.is(123456); + } + + @Override + public Matcher<TypeSerializerSchemaCompatibility<Integer>> schemaCompatibilityMatcher(MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "int-value-serializer" + // ---------------------------------------------------------------------------------------------- + /** + * IntValueSerializerSetup. + */ + public static final class IntValueSerializerSetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup<IntValue> { + @Override + public TypeSerializer<IntValue> createPriorSerializer() { + return IntValueSerializer.INSTANCE; + } + + @Override + public IntValue createTestData() { + return new IntValue(123456); + } + } + + /** + * IntValueSerializerVerifier. + */ + public static final class IntValueSerializerVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier<IntValue> { + @Override + public TypeSerializer<IntValue> createUpgradedSerializer() { + return IntValueSerializer.INSTANCE; + } + + @Override + public Matcher<IntValue> testDataMatcher() { + return Matchers.is(new IntValue(123456)); + } + + @Override + public Matcher<TypeSerializerSchemaCompatibility<IntValue>> schemaCompatibilityMatcher(MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "long-serializer" + // ---------------------------------------------------------------------------------------------- + /** + * LongSerializerSetup. + */ + public static final class LongSerializerSetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup<Long> { + @Override + public TypeSerializer<Long> createPriorSerializer() { + return LongSerializer.INSTANCE; + } + + @Override + public Long createTestData() { + return 1234567890L; + } + } + + /** + * LongSerializerVerifier. + */ + public static final class LongSerializerVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier<Long> { + @Override + public TypeSerializer<Long> createUpgradedSerializer() { + return LongSerializer.INSTANCE; + } + + @Override + public Matcher<Long> testDataMatcher() { + return Matchers.is(1234567890L); + } + + @Override + public Matcher<TypeSerializerSchemaCompatibility<Long>> schemaCompatibilityMatcher(MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "long-value-serializer" + // ---------------------------------------------------------------------------------------------- + /** + * LongValueSerializerSetup. + */ + public static final class LongValueSerializerSetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup<LongValue> { + @Override + public TypeSerializer<LongValue> createPriorSerializer() { + return LongValueSerializer.INSTANCE; + } + + @Override + public LongValue createTestData() { + return new LongValue(1234567890); + } + } + + /** + * LongValueSerializerVerifier. + */ + public static final class LongValueSerializerVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier<LongValue> { + @Override + public TypeSerializer<LongValue> createUpgradedSerializer() { + return LongValueSerializer.INSTANCE; + } + + @Override + public Matcher<LongValue> testDataMatcher() { + return Matchers.is(new LongValue(1234567890)); + } + + @Override + public Matcher<TypeSerializerSchemaCompatibility<LongValue>> schemaCompatibilityMatcher(MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "null-value-serializer" + // ---------------------------------------------------------------------------------------------- + /** + * NullValueSerializerSetup. + */ + public static final class NullValueSerializerSetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup<NullValue> { + @Override + public TypeSerializer<NullValue> createPriorSerializer() { + return NullValueSerializer.INSTANCE; + } + + @Override + public NullValue createTestData() { + return NullValue.getInstance(); + } + } + + /** + * NullValueSerializerVerifier. + */ + public static final class NullValueSerializerVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier<NullValue> { + @Override + public TypeSerializer<NullValue> createUpgradedSerializer() { + return NullValueSerializer.INSTANCE; + } + + @Override + public Matcher<NullValue> testDataMatcher() { + return Matchers.is(NullValue.getInstance()); + } + + @Override + public Matcher<TypeSerializerSchemaCompatibility<NullValue>> schemaCompatibilityMatcher(MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "short-serializer" + // ---------------------------------------------------------------------------------------------- + /** + * ShortSerializerSetup. + */ + public static final class ShortSerializerSetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup<Short> { + @Override + public TypeSerializer<Short> createPriorSerializer() { + return ShortSerializer.INSTANCE; + } + + @Override + public Short createTestData() { + return 123; + } + } + + /** + * ShortSerializerVerifier. + */ + public static final class ShortSerializerVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier<Short> { + @Override + public TypeSerializer<Short> createUpgradedSerializer() { + return ShortSerializer.INSTANCE; + } + + @Override + public Matcher<Short> testDataMatcher() { + return Matchers.is((short) 123); + } + + @Override + public Matcher<TypeSerializerSchemaCompatibility<Short>> schemaCompatibilityMatcher(MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "short-value-serializer" + // ---------------------------------------------------------------------------------------------- + /** + * ShortValueSerializerSetup. + */ + public static final class ShortValueSerializerSetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup<ShortValue> { + @Override + public TypeSerializer<ShortValue> createPriorSerializer() { + return ShortValueSerializer.INSTANCE; + } + + @Override + public ShortValue createTestData() { + return new ShortValue((short) 123); + } + } + + /** + * ShortValueSerializerVerifier. + */ + public static final class ShortValueSerializerVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier<ShortValue> { + @Override + public TypeSerializer<ShortValue> createUpgradedSerializer() { + return ShortValueSerializer.INSTANCE; + } + + @Override + public Matcher<ShortValue> testDataMatcher() { + return Matchers.is(new ShortValue((short) 123)); + } + + @Override + public Matcher<TypeSerializerSchemaCompatibility<ShortValue>> schemaCompatibilityMatcher(MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "sql-date-serializer" + // ---------------------------------------------------------------------------------------------- + /** + * SqlDateSerializerSetup. + */ + public static final class SqlDateSerializerSetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup<java.sql.Date> { + @Override + public TypeSerializer<java.sql.Date> createPriorSerializer() { + return SqlDateSerializer.INSTANCE; + } + + @Override + public java.sql.Date createTestData() { + return new java.sql.Date(1580382960L); + } + } + + /** + * SqlDateSerializerVerifier. + */ + public static final class SqlDateSerializerVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier<java.sql.Date> { + @Override + public TypeSerializer<java.sql.Date> createUpgradedSerializer() { + return SqlDateSerializer.INSTANCE; + } + + @Override + public Matcher<java.sql.Date> testDataMatcher() { + return Matchers.is(new java.sql.Date(1580382960L)); + } + + @Override + public Matcher<TypeSerializerSchemaCompatibility<java.sql.Date>> schemaCompatibilityMatcher(MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "sql-time-serializer" + // ---------------------------------------------------------------------------------------------- + /** + * SqlTimeSerializerSetup. + */ + public static final class SqlTimeSerializerSetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup<Time> { + @Override + public TypeSerializer<Time> createPriorSerializer() { + return SqlTimeSerializer.INSTANCE; + } + + @Override + public Time createTestData() { + return new Time(1580382960L); + } + } + + /** + * SqlTimeSerializerVerifier. + */ + public static final class SqlTimeSerializerVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier<Time> { + @Override + public TypeSerializer<Time> createUpgradedSerializer() { + return SqlTimeSerializer.INSTANCE; + } + + @Override + public Matcher<Time> testDataMatcher() { + return Matchers.is(new Time(1580382960L)); + } + + @Override + public Matcher<TypeSerializerSchemaCompatibility<Time>> schemaCompatibilityMatcher(MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "sql-timestamp-serializer" + // ---------------------------------------------------------------------------------------------- + /** + * SqlTimestampSerializerSetup. + */ + public static final class SqlTimestampSerializerSetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup<Timestamp> { + @Override + public TypeSerializer<Timestamp> createPriorSerializer() { + return SqlTimestampSerializer.INSTANCE; + } + + @Override + public Timestamp createTestData() { + return new Timestamp(1580382960L); + } + } + + /** + * SqlTimestampSerializerVerifier. + */ + public static final class SqlTimestampSerializerVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier<Timestamp> { + @Override + public TypeSerializer<Timestamp> createUpgradedSerializer() { + return SqlTimestampSerializer.INSTANCE; + } + + @Override + public Matcher<Timestamp> testDataMatcher() { + return Matchers.is(new Timestamp(1580382960L)); + } + + @Override + public Matcher<TypeSerializerSchemaCompatibility<Timestamp>> schemaCompatibilityMatcher(MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "string-serializer" + // ---------------------------------------------------------------------------------------------- + /** + * StringSerializerSetup. + */ + public static final class StringSerializerSetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup<String> { + @Override + public TypeSerializer<String> createPriorSerializer() { + return StringSerializer.INSTANCE; + } + + @Override + public String createTestData() { + return "123456789012345678901234567890123456"; + } + } + + /** + * StringSerializerVerifier. + */ + public static final class StringSerializerVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier<String> { + @Override + public TypeSerializer<String> createUpgradedSerializer() { + return StringSerializer.INSTANCE; + } + + @Override + public Matcher<String> testDataMatcher() { + return Matchers.is("123456789012345678901234567890123456"); + } + + @Override + public Matcher<TypeSerializerSchemaCompatibility<String>> schemaCompatibilityMatcher(MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } + + // ---------------------------------------------------------------------------------------------- + // Specification for "string-value-serializer" + // ---------------------------------------------------------------------------------------------- + /** + * StringValueSerializerSetup. + */ + public static final class StringValueSerializerSetup implements TypeSerializerUpgradeTestBase.PreUpgradeSetup<StringValue> { + @Override + public TypeSerializer<StringValue> createPriorSerializer() { + return StringValueSerializer.INSTANCE; + } + + @Override + public StringValue createTestData() { + return new StringValue("123456789012345678901234567890123456"); + } + } + + /** + * StringValueSerializerVerifier. + */ + public static final class StringValueSerializerVerifier implements TypeSerializerUpgradeTestBase.UpgradeVerifier<StringValue> { + @Override + public TypeSerializer<StringValue> createUpgradedSerializer() { + return StringValueSerializer.INSTANCE; + } + + @Override + public Matcher<StringValue> testDataMatcher() { + return Matchers.is(new StringValue("123456789012345678901234567890123456")); + } + + @Override + public Matcher<TypeSerializerSchemaCompatibility<StringValue>> schemaCompatibilityMatcher(MigrationVersion version) { + return TypeSerializerMatchers.isCompatibleAsIs(); + } + } +} + diff --git a/flink-core/src/test/resources/flink-1.6-big-dec-serializer-data b/flink-core/src/test/resources/flink-1.6-big-dec-serializer-data deleted file mode 100644 index 77e75f8..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-big-dec-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-big-dec-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-big-dec-serializer-snapshot deleted file mode 100644 index 0bc8486..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-big-dec-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-big-int-serializer-data b/flink-core/src/test/resources/flink-1.6-big-int-serializer-data deleted file mode 100644 index fdc853a..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-big-int-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-big-int-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-big-int-serializer-snapshot deleted file mode 100644 index ed8d782..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-big-int-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-boolean-serializer-data b/flink-core/src/test/resources/flink-1.6-boolean-serializer-data deleted file mode 100644 index 21808bb..0000000 --- a/flink-core/src/test/resources/flink-1.6-boolean-serializer-data +++ /dev/null @@ -1 +0,0 @@ - \ No newline at end of file diff --git a/flink-core/src/test/resources/flink-1.6-boolean-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-boolean-serializer-snapshot deleted file mode 100644 index 533a105..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-boolean-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-boolean-value-serializer-data b/flink-core/src/test/resources/flink-1.6-boolean-value-serializer-data deleted file mode 100644 index cb43b5c..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-boolean-value-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-boolean-value-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-boolean-value-serializer-snapshot deleted file mode 100644 index c870827..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-boolean-value-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-byte-serializer-data b/flink-core/src/test/resources/flink-1.6-byte-serializer-data deleted file mode 100644 index cf0e76b..0000000 --- a/flink-core/src/test/resources/flink-1.6-byte-serializer-data +++ /dev/null @@ -1 +0,0 @@ -NNNNNNNNNN \ No newline at end of file diff --git a/flink-core/src/test/resources/flink-1.6-byte-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-byte-serializer-snapshot deleted file mode 100644 index 4cfdc41..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-byte-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-byte-value-serializer-data b/flink-core/src/test/resources/flink-1.6-byte-value-serializer-data deleted file mode 100644 index cf0e76b..0000000 --- a/flink-core/src/test/resources/flink-1.6-byte-value-serializer-data +++ /dev/null @@ -1 +0,0 @@ -NNNNNNNNNN \ No newline at end of file diff --git a/flink-core/src/test/resources/flink-1.6-byte-value-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-byte-value-serializer-snapshot deleted file mode 100644 index f4637ed..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-byte-value-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-char-serializer-data b/flink-core/src/test/resources/flink-1.6-char-serializer-data deleted file mode 100644 index 9ecd9cd..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-char-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-char-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-char-serializer-snapshot deleted file mode 100644 index 3f5b3d1..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-char-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-char-value-serializer-data b/flink-core/src/test/resources/flink-1.6-char-value-serializer-data deleted file mode 100644 index 9ecd9cd..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-char-value-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-char-value-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-char-value-serializer-snapshot deleted file mode 100644 index d53d503..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-char-value-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-date-serializer-data b/flink-core/src/test/resources/flink-1.6-date-serializer-data deleted file mode 100644 index 7cbcacc..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-date-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-date-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-date-serializer-snapshot deleted file mode 100644 index 16e2c3f..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-date-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-double-serializer-data b/flink-core/src/test/resources/flink-1.6-double-serializer-data deleted file mode 100644 index 49fbf3f..0000000 --- a/flink-core/src/test/resources/flink-1.6-double-serializer-data +++ /dev/null @@ -1 +0,0 @@ -@ !���n@ !���n@ !���n@ !���n@ !���n@ !���n@ !���n@ !���n@ !���n@ !���n \ No newline at end of file diff --git a/flink-core/src/test/resources/flink-1.6-double-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-double-serializer-snapshot deleted file mode 100644 index 8939b39..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-double-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-double-value-serializer-data b/flink-core/src/test/resources/flink-1.6-double-value-serializer-data deleted file mode 100644 index 49fbf3f..0000000 --- a/flink-core/src/test/resources/flink-1.6-double-value-serializer-data +++ /dev/null @@ -1 +0,0 @@ -@ !���n@ !���n@ !���n@ !���n@ !���n@ !���n@ !���n@ !���n@ !���n@ !���n \ No newline at end of file diff --git a/flink-core/src/test/resources/flink-1.6-double-value-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-double-value-serializer-snapshot deleted file mode 100644 index 457df0f..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-double-value-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-float-serializer-data b/flink-core/src/test/resources/flink-1.6-float-serializer-data deleted file mode 100644 index 2d8b79f..0000000 --- a/flink-core/src/test/resources/flink-1.6-float-serializer-data +++ /dev/null @@ -1 +0,0 @@ -@I�@I�@I�@I�@I�@I�@I�@I�@I�@I� \ No newline at end of file diff --git a/flink-core/src/test/resources/flink-1.6-float-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-float-serializer-snapshot deleted file mode 100644 index fe6797b..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-float-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-float-value-serializer-data b/flink-core/src/test/resources/flink-1.6-float-value-serializer-data deleted file mode 100644 index 2d8b79f..0000000 --- a/flink-core/src/test/resources/flink-1.6-float-value-serializer-data +++ /dev/null @@ -1 +0,0 @@ -@I�@I�@I�@I�@I�@I�@I�@I�@I�@I� \ No newline at end of file diff --git a/flink-core/src/test/resources/flink-1.6-float-value-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-float-value-serializer-snapshot deleted file mode 100644 index c2fb4c9..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-float-value-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-int-serializer-data b/flink-core/src/test/resources/flink-1.6-int-serializer-data deleted file mode 100644 index a69d5c4..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-int-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-int-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-int-serializer-snapshot deleted file mode 100644 index 53baae3..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-int-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-int-value-serializer-data b/flink-core/src/test/resources/flink-1.6-int-value-serializer-data deleted file mode 100644 index a69d5c4..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-int-value-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-int-value-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-int-value-serializer-snapshot deleted file mode 100644 index 7a9e4bf..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-int-value-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-long-serializer-data b/flink-core/src/test/resources/flink-1.6-long-serializer-data deleted file mode 100644 index 0bf438f..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-long-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-long-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-long-serializer-snapshot deleted file mode 100644 index fb44387..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-long-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-long-value-serializer-data b/flink-core/src/test/resources/flink-1.6-long-value-serializer-data deleted file mode 100644 index 0bf438f..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-long-value-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-long-value-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-long-value-serializer-snapshot deleted file mode 100644 index 7ef6b05..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-long-value-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-null-value-serializer-data b/flink-core/src/test/resources/flink-1.6-null-value-serializer-data deleted file mode 100644 index e69de29..0000000 diff --git a/flink-core/src/test/resources/flink-1.6-null-value-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-null-value-serializer-snapshot deleted file mode 100644 index f0ead87..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-null-value-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-short-serializer-data b/flink-core/src/test/resources/flink-1.6-short-serializer-data deleted file mode 100644 index c1a8300..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-short-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-short-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-short-serializer-snapshot deleted file mode 100644 index 55b7620..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-short-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-short-value-serializer-data b/flink-core/src/test/resources/flink-1.6-short-value-serializer-data deleted file mode 100644 index c1a8300..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-short-value-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-short-value-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-short-value-serializer-snapshot deleted file mode 100644 index eb52425..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-short-value-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-sql-date-serializer-data b/flink-core/src/test/resources/flink-1.6-sql-date-serializer-data deleted file mode 100644 index 7cbcacc..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-sql-date-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-sql-date-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-sql-date-serializer-snapshot deleted file mode 100644 index 1a1a1ac..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-sql-date-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-sql-time-serializer-data b/flink-core/src/test/resources/flink-1.6-sql-time-serializer-data deleted file mode 100644 index 6666e4b..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-sql-time-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-sql-time-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-sql-time-serializer-snapshot deleted file mode 100644 index 715f7eb..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-sql-time-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-sql-timestamp-serializer-data b/flink-core/src/test/resources/flink-1.6-sql-timestamp-serializer-data deleted file mode 100644 index fc74907..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-sql-timestamp-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-sql-timestamp-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-sql-timestamp-serializer-snapshot deleted file mode 100644 index 852556f..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-sql-timestamp-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-string-serializer-data b/flink-core/src/test/resources/flink-1.6-string-serializer-data deleted file mode 100644 index 383ccad..0000000 --- a/flink-core/src/test/resources/flink-1.6-string-serializer-data +++ /dev/null @@ -1 +0,0 @@ - hello world hello world hello world hello world hello world hello world hello world hello world hello world hello world \ No newline at end of file diff --git a/flink-core/src/test/resources/flink-1.6-string-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-string-serializer-snapshot deleted file mode 100644 index a8be15e..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-string-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.6-string-value-serializer-data b/flink-core/src/test/resources/flink-1.6-string-value-serializer-data deleted file mode 100644 index bc2d605..0000000 --- a/flink-core/src/test/resources/flink-1.6-string-value-serializer-data +++ /dev/null @@ -1 +0,0 @@ - hello world hello world hello world hello world hello world hello world hello world hello world hello world hello world \ No newline at end of file diff --git a/flink-core/src/test/resources/flink-1.6-string-value-serializer-snapshot b/flink-core/src/test/resources/flink-1.6-string-value-serializer-snapshot deleted file mode 100644 index 3d39434..0000000 Binary files a/flink-core/src/test/resources/flink-1.6-string-value-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-big-dec-serializer-data b/flink-core/src/test/resources/flink-1.7-big-dec-serializer-data deleted file mode 100644 index 77e75f8..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-big-dec-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-big-dec-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-big-dec-serializer-snapshot deleted file mode 100644 index 06f174d..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-big-dec-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-big-int-serializer-data b/flink-core/src/test/resources/flink-1.7-big-int-serializer-data deleted file mode 100644 index 5cabbfc..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-big-int-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-big-int-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-big-int-serializer-snapshot deleted file mode 100644 index 3a8111e..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-big-int-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-boolean-serializer-data b/flink-core/src/test/resources/flink-1.7-boolean-serializer-data deleted file mode 100644 index 21808bb..0000000 --- a/flink-core/src/test/resources/flink-1.7-boolean-serializer-data +++ /dev/null @@ -1 +0,0 @@ - \ No newline at end of file diff --git a/flink-core/src/test/resources/flink-1.7-boolean-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-boolean-serializer-snapshot deleted file mode 100644 index c65c7db..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-boolean-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-boolean-value-serializer-data b/flink-core/src/test/resources/flink-1.7-boolean-value-serializer-data deleted file mode 100644 index cb43b5c..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-boolean-value-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-boolean-value-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-boolean-value-serializer-snapshot deleted file mode 100644 index d4e5cf8..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-boolean-value-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-byte-serializer-data b/flink-core/src/test/resources/flink-1.7-byte-serializer-data deleted file mode 100644 index 0120536..0000000 --- a/flink-core/src/test/resources/flink-1.7-byte-serializer-data +++ /dev/null @@ -1 +0,0 @@ - \ No newline at end of file diff --git a/flink-core/src/test/resources/flink-1.7-byte-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-byte-serializer-snapshot deleted file mode 100644 index a09d139..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-byte-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-byte-value-serializer-data b/flink-core/src/test/resources/flink-1.7-byte-value-serializer-data deleted file mode 100644 index 0120536..0000000 --- a/flink-core/src/test/resources/flink-1.7-byte-value-serializer-data +++ /dev/null @@ -1 +0,0 @@ - \ No newline at end of file diff --git a/flink-core/src/test/resources/flink-1.7-byte-value-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-byte-value-serializer-snapshot deleted file mode 100644 index c37f0aa..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-byte-value-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-char-serializer-data b/flink-core/src/test/resources/flink-1.7-char-serializer-data deleted file mode 100644 index 9ecd9cd..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-char-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-char-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-char-serializer-snapshot deleted file mode 100644 index 2671531..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-char-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-char-value-serializer-data b/flink-core/src/test/resources/flink-1.7-char-value-serializer-data deleted file mode 100644 index 9ecd9cd..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-char-value-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-char-value-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-char-value-serializer-snapshot deleted file mode 100644 index 3d10a36..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-char-value-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-date-serializer-data b/flink-core/src/test/resources/flink-1.7-date-serializer-data deleted file mode 100644 index d374944..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-date-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-date-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-date-serializer-snapshot deleted file mode 100644 index d5084d2..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-date-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-double-serializer-data b/flink-core/src/test/resources/flink-1.7-double-serializer-data deleted file mode 100644 index 49fbf3f..0000000 --- a/flink-core/src/test/resources/flink-1.7-double-serializer-data +++ /dev/null @@ -1 +0,0 @@ -@ !���n@ !���n@ !���n@ !���n@ !���n@ !���n@ !���n@ !���n@ !���n@ !���n \ No newline at end of file diff --git a/flink-core/src/test/resources/flink-1.7-double-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-double-serializer-snapshot deleted file mode 100644 index 2cce3e5..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-double-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-double-value-serializer-data b/flink-core/src/test/resources/flink-1.7-double-value-serializer-data deleted file mode 100644 index 49fbf3f..0000000 --- a/flink-core/src/test/resources/flink-1.7-double-value-serializer-data +++ /dev/null @@ -1 +0,0 @@ -@ !���n@ !���n@ !���n@ !���n@ !���n@ !���n@ !���n@ !���n@ !���n@ !���n \ No newline at end of file diff --git a/flink-core/src/test/resources/flink-1.7-double-value-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-double-value-serializer-snapshot deleted file mode 100644 index 1c87532..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-double-value-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-float-serializer-data b/flink-core/src/test/resources/flink-1.7-float-serializer-data deleted file mode 100644 index 2d8b79f..0000000 --- a/flink-core/src/test/resources/flink-1.7-float-serializer-data +++ /dev/null @@ -1 +0,0 @@ -@I�@I�@I�@I�@I�@I�@I�@I�@I�@I� \ No newline at end of file diff --git a/flink-core/src/test/resources/flink-1.7-float-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-float-serializer-snapshot deleted file mode 100644 index 76e52b4..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-float-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-float-value-serializer-data b/flink-core/src/test/resources/flink-1.7-float-value-serializer-data deleted file mode 100644 index 2d8b79f..0000000 --- a/flink-core/src/test/resources/flink-1.7-float-value-serializer-data +++ /dev/null @@ -1 +0,0 @@ -@I�@I�@I�@I�@I�@I�@I�@I�@I�@I� \ No newline at end of file diff --git a/flink-core/src/test/resources/flink-1.7-float-value-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-float-value-serializer-snapshot deleted file mode 100644 index c6d2d12..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-float-value-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-int-serializer-data b/flink-core/src/test/resources/flink-1.7-int-serializer-data deleted file mode 100644 index a69d5c4..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-int-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-int-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-int-serializer-snapshot deleted file mode 100644 index de2be82..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-int-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-int-value-serializer-data b/flink-core/src/test/resources/flink-1.7-int-value-serializer-data deleted file mode 100644 index a69d5c4..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-int-value-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-int-value-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-int-value-serializer-snapshot deleted file mode 100644 index 124b4e4..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-int-value-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-long-serializer-data b/flink-core/src/test/resources/flink-1.7-long-serializer-data deleted file mode 100644 index 0bf438f..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-long-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-long-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-long-serializer-snapshot deleted file mode 100644 index 85cfea9..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-long-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-long-value-serializer-data b/flink-core/src/test/resources/flink-1.7-long-value-serializer-data deleted file mode 100644 index 0bf438f..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-long-value-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-long-value-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-long-value-serializer-snapshot deleted file mode 100644 index 93de3c5..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-long-value-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-null-value-serializer-data b/flink-core/src/test/resources/flink-1.7-null-value-serializer-data deleted file mode 100644 index e69de29..0000000 diff --git a/flink-core/src/test/resources/flink-1.7-null-value-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-null-value-serializer-snapshot deleted file mode 100644 index c7a05b1..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-null-value-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-short-serializer-data b/flink-core/src/test/resources/flink-1.7-short-serializer-data deleted file mode 100644 index c1a8300..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-short-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-short-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-short-serializer-snapshot deleted file mode 100644 index 3d79053..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-short-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-short-value-serializer-data b/flink-core/src/test/resources/flink-1.7-short-value-serializer-data deleted file mode 100644 index c1a8300..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-short-value-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-short-value-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-short-value-serializer-snapshot deleted file mode 100644 index 91db2ab..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-short-value-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-sql-date-serializer-data b/flink-core/src/test/resources/flink-1.7-sql-date-serializer-data deleted file mode 100644 index 141ae41..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-sql-date-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-sql-date-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-sql-date-serializer-snapshot deleted file mode 100644 index ded2e33..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-sql-date-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-sql-time-serializer-data b/flink-core/src/test/resources/flink-1.7-sql-time-serializer-data deleted file mode 100644 index 086ab90..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-sql-time-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-sql-time-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-sql-time-serializer-snapshot deleted file mode 100644 index f9a4597..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-sql-time-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-sql-timestamp-serializer-data b/flink-core/src/test/resources/flink-1.7-sql-timestamp-serializer-data deleted file mode 100644 index 5639302..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-sql-timestamp-serializer-data and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-sql-timestamp-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-sql-timestamp-serializer-snapshot deleted file mode 100644 index 300a1b6..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-sql-timestamp-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-string-serializer-data b/flink-core/src/test/resources/flink-1.7-string-serializer-data deleted file mode 100644 index 383ccad..0000000 --- a/flink-core/src/test/resources/flink-1.7-string-serializer-data +++ /dev/null @@ -1 +0,0 @@ - hello world hello world hello world hello world hello world hello world hello world hello world hello world hello world \ No newline at end of file diff --git a/flink-core/src/test/resources/flink-1.7-string-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-string-serializer-snapshot deleted file mode 100644 index a9d82ff..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-string-serializer-snapshot and /dev/null differ diff --git a/flink-core/src/test/resources/flink-1.7-string-value-serializer-data b/flink-core/src/test/resources/flink-1.7-string-value-serializer-data deleted file mode 100644 index 0857b1e..0000000 --- a/flink-core/src/test/resources/flink-1.7-string-value-serializer-data +++ /dev/null @@ -1 +0,0 @@ - hello-world hello-world hello-world hello-world hello-world hello-world hello-world hello-world hello-world hello-world \ No newline at end of file diff --git a/flink-core/src/test/resources/flink-1.7-string-value-serializer-snapshot b/flink-core/src/test/resources/flink-1.7-string-value-serializer-snapshot deleted file mode 100644 index a435f70..0000000 Binary files a/flink-core/src/test/resources/flink-1.7-string-value-serializer-snapshot and /dev/null differ
