diff --git a/flink-scala/src/main/java/org/apache/flink/api/scala/typeutils/ScalaCaseClassSerializerSnapshot.java b/flink-scala/src/main/java/org/apache/flink/api/scala/typeutils/ScalaCaseClassSerializerSnapshot.java index 0145d2ac665ec..ec7b0cb9d1a79 100644 --- a/flink-scala/src/main/java/org/apache/flink/api/scala/typeutils/ScalaCaseClassSerializerSnapshot.java +++ b/flink-scala/src/main/java/org/apache/flink/api/scala/typeutils/ScalaCaseClassSerializerSnapshot.java @@ -103,7 +103,7 @@ protected void readOuterSnapshot(int readOuterSnapshotVersion, DataInputView in, } @Override - protected OuterSchemaCompatibility resolveOuterSchemaCompatibility(ScalaCaseClassSerializer newSerializer) { + protected CompositeTypeSerializerSnapshot.OuterSchemaCompatibility resolveOuterSchemaCompatibility(ScalaCaseClassSerializer newSerializer) { return (Objects.equals(type, newSerializer.getTupleClass())) ? OuterSchemaCompatibility.COMPATIBLE_AS_IS : OuterSchemaCompatibility.INCOMPATIBLE; diff --git a/flink-scala/src/main/java/org/apache/flink/api/scala/typeutils/TraversableSerializerSnapshot.java b/flink-scala/src/main/java/org/apache/flink/api/scala/typeutils/TraversableSerializerSnapshot.java index 08d7ad6a05e00..37f94edcacb6b 100644 --- a/flink-scala/src/main/java/org/apache/flink/api/scala/typeutils/TraversableSerializerSnapshot.java +++ b/flink-scala/src/main/java/org/apache/flink/api/scala/typeutils/TraversableSerializerSnapshot.java @@ -98,7 +98,7 @@ protected void readOuterSnapshot( } @Override - protected OuterSchemaCompatibility resolveOuterSchemaCompatibility(TraversableSerializer newSerializer) { + protected CompositeTypeSerializerSnapshot.OuterSchemaCompatibility resolveOuterSchemaCompatibility(TraversableSerializer newSerializer) { return (cbfCode.equals(newSerializer.cbfCode())) ? OuterSchemaCompatibility.COMPATIBLE_AS_IS : OuterSchemaCompatibility.INCOMPATIBLE; diff --git a/flink-scala/src/main/java/org/apache/flink/api/scala/typeutils/Tuple2CaseClassSerializerSnapshot.java b/flink-scala/src/main/java/org/apache/flink/api/scala/typeutils/Tuple2CaseClassSerializerSnapshot.java index 9591663e55e68..971f200a533d3 100644 --- a/flink-scala/src/main/java/org/apache/flink/api/scala/typeutils/Tuple2CaseClassSerializerSnapshot.java +++ b/flink-scala/src/main/java/org/apache/flink/api/scala/typeutils/Tuple2CaseClassSerializerSnapshot.java @@ -95,7 +95,7 @@ protected void readOuterSnapshot(int readOuterSnapshotVersion, DataInputView in, } @Override - protected OuterSchemaCompatibility resolveOuterSchemaCompatibility(ScalaCaseClassSerializer> newSerializer) { + protected CompositeTypeSerializerSnapshot.OuterSchemaCompatibility resolveOuterSchemaCompatibility(ScalaCaseClassSerializer> newSerializer) { return (Objects.equals(type, newSerializer.getTupleClass())) ? OuterSchemaCompatibility.COMPATIBLE_AS_IS : OuterSchemaCompatibility.INCOMPATIBLE;