Skip to content

Commit e547646

Browse files
committed
fix
1 parent 9a177c7 commit e547646

File tree

4 files changed

+4
-4
lines changed

4 files changed

+4
-4
lines changed

paimon-core/src/main/java/org/apache/paimon/mergetree/lookup/DefaultLookupSerializerFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ public Function<InternalRow, byte[]> createSerializer(RowType currentSchema) {
4242

4343
@Override
4444
public Function<byte[], InternalRow> createDeserializer(
45-
@Nullable RowType fileSchema, RowType currentSchema) {
45+
RowType currentSchema, @Nullable RowType fileSchema) {
4646
if (fileSchema != null && !fileSchema.equalsIgnoreNullable(currentSchema)) {
4747
throw new UnsupportedOperationException();
4848
}

paimon-core/src/main/java/org/apache/paimon/mergetree/lookup/LookupSerializerFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,7 @@ public interface LookupSerializerFactory {
3737
Function<InternalRow, byte[]> createSerializer(RowType currentSchema);
3838

3939
Function<byte[], InternalRow> createDeserializer(
40-
@Nullable RowType fileSchema, RowType currentSchema);
40+
RowType currentSchema, @Nullable RowType fileSchema);
4141

4242
Supplier<LookupSerializerFactory> INSTANCE =
4343
Suppliers.memoize(

paimon-core/src/main/java/org/apache/paimon/mergetree/lookup/PersistPositionProcessor.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -108,7 +108,7 @@ public PersistProcessor<PositionedKeyValue> create(
108108
LookupSerializerFactory serializerFactory, @Nullable RowType fileSchema) {
109109
return new PersistPositionProcessor(
110110
serializerFactory.createSerializer(valueType),
111-
serializerFactory.createDeserializer(fileSchema, valueType),
111+
serializerFactory.createDeserializer(valueType, fileSchema),
112112
persistValue);
113113
}
114114
};

paimon-core/src/main/java/org/apache/paimon/mergetree/lookup/PersistValueProcessor.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ public PersistProcessor<KeyValue> create(
7676
LookupSerializerFactory serializerFactory, @Nullable RowType fileSchema) {
7777
return new PersistValueProcessor(
7878
serializerFactory.createSerializer(valueType),
79-
serializerFactory.createDeserializer(fileSchema, valueType));
79+
serializerFactory.createDeserializer(valueType, fileSchema));
8080
}
8181
};
8282
}

0 commit comments

Comments
 (0)