Skip to content

Commit 63d991f

Browse files
nokiaMSgithubgxll
authored andcommitted
[fix][dingo-sdk] Decimal pushdown - fix key prefix encoding issue.
1 parent a0aeea6 commit 63d991f

File tree

1 file changed

+7
-3
lines changed

1 file changed

+7
-3
lines changed

java/dingo-sdk/src/main/java/io/dingodb/sdk/common/serial/schema/DecimalSchema.java

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -288,7 +288,7 @@ public String decodeKeyPrefix(Buf buf) {
288288
}
289289

290290
//Forward skip codec version field.
291-
buf.reverseSkipInt();
291+
//buf.reverseSkipInt();
292292

293293
return internalReadDecimal(buf);
294294
}
@@ -379,10 +379,14 @@ public void encodeKeyPrefix(Buf buf, String data) {
379379
buf.ensureRemainder(1);
380380
buf.write(NOTNULL);
381381

382-
internalEncodeKeyV2(buf, data);
382+
int size = internalEncodeKeyV2(buf, data);
383+
buf.ensureRemainder(4);
384+
buf.reverseWriteInt(size);
383385
}
384386
} else {
385-
internalEncodeKeyV2(buf, data);
387+
int size = internalEncodeKeyV2(buf, data);
388+
buf.ensureRemainder(4);
389+
buf.reverseWriteInt(size);
386390
}
387391
}
388392

0 commit comments

Comments
 (0)