PHOENIX-7469 Partitioned CDC Index for partitioned tables (addendum)

kadirozde · kadirozde · commit a75c4dca1208 · 2024-11-25T11:56:53.000-08:00
diff --git a/phoenix-core-client/src/main/java/org/apache/phoenix/expression/function/PartitionIdFunction.java b/phoenix-core-client/src/main/java/org/apache/phoenix/expression/function/PartitionIdFunction.java
@@ -66,6 +66,7 @@ public boolean evaluate(Tuple tuple, ImmutableBytesWritable ptr) {
         if (tuple == null) {
             return false;
         }
+        tuple.getKey(ptr);
         if (ptr.getLength() < PARTITION_ID_LENGTH) {
             return false;
         }

Original file line number	Diff line number	Diff line change
`@@ -66,6 +66,7 @@ public boolean evaluate(Tuple tuple, ImmutableBytesWritable ptr) {`
`66`	`66`	`if (tuple == null) {`
`67`	`67`	`return false;`
`68`	`68`	`}`
	`69`	`+ tuple.getKey(ptr);`
`69`	`70`	`if (ptr.getLength() < PARTITION_ID_LENGTH) {`
`70`	`71`	`return false;`
`71`	`72`	`}`