fix test

Author: loserwang1024

fluss-client/src/main/java/org/apache/fluss/client/lookup/AbstractLookuper.java

@@ -121,7 +121,7 @@ protected void handleLookupResponse(
                     if (error != null) {
                         lookupFuture.completeExceptionally(
                                 new RuntimeException(
-                                        "Failed to get schema infos for prefix lookup", error));
+                                        "Failed to get schema infos for lookup", error));
                     } else {
                         LookupResult lookupResult = processSchemaRequestedRows(schemas, valueList);
                         lookupFuture.complete(lookupResult);

fluss-common/src/main/java/org/apache/fluss/row/decode/FixedSchemaDecoder.java

@@ -51,7 +51,7 @@ public class FixedSchemaDecoder {
     public FixedSchemaDecoder(KvFormat kvFormat, Schema sourceSchema, Schema targetSchema) {
         this.rowDecoder =
                 RowDecoder.create(
-                        kvFormat, targetSchema.getRowType().getChildren().toArray(new DataType[0]));
+                        kvFormat, sourceSchema.getRowType().getChildren().toArray(new DataType[0]));
         this.fieldIdMapping = SchemaUtil.getIndexMapping(sourceSchema, targetSchema);
         this.noProjection = false;
     }