Skip to content

Commit

Permalink
[fix](upgrade) fix partition key problem introduced by be41811 (#39373)
Browse files Browse the repository at this point in the history
## Proposed changes

fix #31613
  • Loading branch information
dataroaring authored Aug 15, 2024
1 parent 7caddd0 commit 5c68c92
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -388,11 +388,11 @@ public void write(DataOutput out) throws IOException {
public void readFields(DataInput in) throws IOException {
int count = in.readInt();
for (int i = 0; i < count; i++) {
PrimitiveType type = PrimitiveType.valueOf(Text.readString(in));
PrimitiveType type = PrimitiveType.valueOf(Text.readString(in).toUpperCase());
boolean isMax = in.readBoolean();
if (type == PrimitiveType.NULL_TYPE) {
String realType = StringLiteral.read(in).getStringValue();
type = PrimitiveType.valueOf(realType);
type = PrimitiveType.valueOf(realType.toUpperCase());
types.add(type);
keys.add(NullLiteral.create(Type.fromPrimitiveType(type)));
continue;
Expand Down

0 comments on commit 5c68c92

Please sign in to comment.