This is an automated email from the ASF dual-hosted git repository.
palashc pushed a commit to branch 5.3
in repository https://gitbox.apache.org/repos/asf/phoenix.git
The following commit(s) were added to refs/heads/5.3 by this push:
new 087ac67426 PHOENIX-7880 addendum (#2509) (#2512)
087ac67426 is described below
commit 087ac674267f363c81d9ee9c367c4575bc1b5764
Author: Palash Chauhan <[email protected]>
AuthorDate: Wed Jun 10 12:01:51 2026 -0700
PHOENIX-7880 addendum (#2509) (#2512)
---
.../util/bson/UpdateExpressionUtils.java | 3 ++-
.../java/org/apache/phoenix/end2end/Bson3IT.java | 30 +++++++++++-----------
.../java/org/apache/phoenix/end2end/Bson4IT.java | 24 ++++++++---------
.../java/org/apache/phoenix/end2end/Bson5IT.java | 12 ++++-----
4 files changed, 35 insertions(+), 34 deletions(-)
diff --git
a/phoenix-core-client/src/main/java/org/apache/phoenix/expression/util/bson/UpdateExpressionUtils.java
b/phoenix-core-client/src/main/java/org/apache/phoenix/expression/util/bson/UpdateExpressionUtils.java
index 93efa2a366..a29c598ae1 100644
---
a/phoenix-core-client/src/main/java/org/apache/phoenix/expression/util/bson/UpdateExpressionUtils.java
+++
b/phoenix-core-client/src/main/java/org/apache/phoenix/expression/util/bson/UpdateExpressionUtils.java
@@ -98,7 +98,8 @@ public class UpdateExpressionUtils {
public static void updateExpression(final BsonDocument updateExpression,
final BsonDocument bsonDocument) {
- LOGGER.debug("Update Expression: {} , current bsonDocument: {}",
updateExpression, bsonDocument);
+ LOGGER.debug("Update Expression: {} , current bsonDocument: {}",
updateExpression,
+ bsonDocument);
if (updateExpression.containsKey("$SET")) {
executeSetExpression((BsonDocument) updateExpression.get("$SET"),
bsonDocument);
diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/Bson3IT.java
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/Bson3IT.java
index 1f78df07c0..d2bd414488 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/Bson3IT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/Bson3IT.java
@@ -232,9 +232,9 @@ public class Bson3IT extends ParallelStatsDisabledIT {
.append("browserling", new
BsonBinary(PDouble.INSTANCE.toBytes(-505169340.54880095)))
.append("track[0].shot[2][0].city.standard[5]", new
BsonString("soft"))
.append("track[0].shot[2][0].city.problem[2]",
- new BsonDocument().append("$ADD", new BsonArray(Arrays.asList(
- new BsonString("track[0].shot[2][0].city.problem[2]"),
- new BsonDouble(529.435))))))
+ new BsonDocument().append("$ADD",
+ new BsonArray(Arrays.asList(new
BsonString("track[0].shot[2][0].city.problem[2]"),
+ new BsonDouble(529.435))))))
.append("$UNSET",
new BsonDocument().append("track[0].shot[2][0].city.flame", new
BsonNull()));
@@ -766,9 +766,9 @@ public class Bson3IT extends ParallelStatsDisabledIT {
.append("browserling", new
BsonBinary(PDouble.INSTANCE.toBytes(-505169340.54880095)))
.append("track[0].shot[2][0].city.standard[5]", new
BsonString("soft"))
.append("track[0].shot[2][0].city.problem[2]",
- new BsonDocument().append("$ADD", new BsonArray(Arrays.asList(
- new BsonString("track[0].shot[2][0].city.problem[2]"),
- new BsonDouble(529.435))))))
+ new BsonDocument().append("$ADD",
+ new BsonArray(Arrays.asList(new
BsonString("track[0].shot[2][0].city.problem[2]"),
+ new BsonDouble(529.435))))))
.append("$UNSET",
new BsonDocument().append("track[0].shot[2][0].city.flame", new
BsonNull()));
@@ -1167,9 +1167,9 @@ public class Bson3IT extends ParallelStatsDisabledIT {
.append("browserling", new
BsonBinary(PDouble.INSTANCE.toBytes(-505169340.54880095)))
.append("track[0].shot[2][0].city.standard[5]", new
BsonString("soft"))
.append("track[0].shot[2][0].city.problem[2]",
- new BsonDocument().append("$ADD", new BsonArray(Arrays.asList(
- new BsonString("track[0].shot[2][0].city.problem[2]"),
- new BsonDouble(529.435))))))
+ new BsonDocument().append("$ADD",
+ new BsonArray(Arrays.asList(new
BsonString("track[0].shot[2][0].city.problem[2]"),
+ new BsonDouble(529.435))))))
.append("$UNSET",
new BsonDocument().append("track[0].shot[2][0].city.flame", new
BsonNull()));
@@ -1542,9 +1542,9 @@ public class Bson3IT extends ParallelStatsDisabledIT {
.append("browserling", new
BsonBinary(PDouble.INSTANCE.toBytes(-505169340.54880095)))
.append("track[0].shot[2][0].city.standard[5]", new
BsonString("soft"))
.append("track[0].shot[2][0].city.problem[2]",
- new BsonDocument().append("$ADD", new BsonArray(Arrays.asList(
- new BsonString("track[0].shot[2][0].city.problem[2]"),
- new BsonDouble(529.435))))))
+ new BsonDocument().append("$ADD",
+ new BsonArray(Arrays.asList(new
BsonString("track[0].shot[2][0].city.problem[2]"),
+ new BsonDouble(529.435))))))
.append("$UNSET",
new BsonDocument().append("track[0].shot[2][0].city.flame", new
BsonNull()));
@@ -1959,9 +1959,9 @@ public class Bson3IT extends ParallelStatsDisabledIT {
.append("browserling", new
BsonBinary(PDouble.INSTANCE.toBytes(-505169340.54880095)))
.append("track[0].shot[2][0].city.standard[5]", new
BsonString("soft"))
.append("track[0].shot[2][0].city.problem[2]",
- new BsonDocument().append("$ADD", new BsonArray(Arrays.asList(
- new BsonString("track[0].shot[2][0].city.problem[2]"),
- new BsonDouble(529.435))))))
+ new BsonDocument().append("$ADD",
+ new BsonArray(Arrays.asList(new
BsonString("track[0].shot[2][0].city.problem[2]"),
+ new BsonDouble(529.435))))))
.append("$UNSET",
new BsonDocument().append("track[0].shot[2][0].city.flame", new
BsonNull()));
diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/Bson4IT.java
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/Bson4IT.java
index f7f226e1c4..315932bdd0 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/Bson4IT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/Bson4IT.java
@@ -642,9 +642,9 @@ public class Bson4IT extends ParallelStatsDisabledIT {
.append("browserling", new
BsonBinary(PDouble.INSTANCE.toBytes(-505169340.54880095)))
.append("track[0].shot[2][0].city.standard[5]", new
BsonString("soft"))
.append("track[0].shot[2][0].city.problem[2]",
- new BsonDocument().append("$ADD", new BsonArray(Arrays.asList(
- new BsonString("track[0].shot[2][0].city.problem[2]"),
- new BsonDouble(529.435))))))
+ new BsonDocument().append("$ADD",
+ new BsonArray(Arrays.asList(new
BsonString("track[0].shot[2][0].city.problem[2]"),
+ new BsonDouble(529.435))))))
.append("$UNSET",
new BsonDocument().append("track[0].shot[2][0].city.flame", new
BsonNull()));
@@ -728,9 +728,9 @@ public class Bson4IT extends ParallelStatsDisabledIT {
.append("new_field1", new
BsonBinary(PDouble.INSTANCE.toBytes(-505169340.54880095)))
.append("track[0].shot[2][0].city.standard[5]", new
BsonString("soft_new_val"))
.append("track[0].shot[2][0].city.problem[2]",
- new BsonDocument().append("$ADD", new BsonArray(Arrays.asList(
- new BsonString("track[0].shot[2][0].city.problem[2]"),
- new BsonInt32(123))))));
+ new BsonDocument().append("$ADD",
+ new BsonArray(Arrays.asList(new
BsonString("track[0].shot[2][0].city.problem[2]"),
+ new BsonInt32(123))))));
stmt = conn.prepareStatement(
"UPSERT INTO " + tableName + " VALUES (?) ON DUPLICATE KEY UPDATE COL
= CASE WHEN"
@@ -832,9 +832,9 @@ public class Bson4IT extends ParallelStatsDisabledIT {
.append("browserling", new
BsonBinary(PDouble.INSTANCE.toBytes(-505169340.54880095)))
.append("track[0].shot[2][0].city.standard[5]", new
BsonString("soft"))
.append("track[0].shot[2][0].city.problem[2]",
- new BsonDocument().append("$ADD", new BsonArray(Arrays.asList(
- new BsonString("track[0].shot[2][0].city.problem[2]"),
- new BsonDouble(529.435))))))
+ new BsonDocument().append("$ADD",
+ new BsonArray(Arrays.asList(new
BsonString("track[0].shot[2][0].city.problem[2]"),
+ new BsonDouble(529.435))))))
.append("$UNSET",
new BsonDocument().append("track[0].shot[2][0].city.flame", new
BsonNull()));
@@ -914,9 +914,9 @@ public class Bson4IT extends ParallelStatsDisabledIT {
.append("new_field1", new
BsonBinary(PDouble.INSTANCE.toBytes(-505169340.54880095)))
.append("track[0].shot[2][0].city.standard[5]", new
BsonString("soft_new_val"))
.append("track[0].shot[2][0].city.problem[2]",
- new BsonDocument().append("$ADD", new BsonArray(Arrays.asList(
- new BsonString("track[0].shot[2][0].city.problem[2]"),
- new BsonInt32(123))))));
+ new BsonDocument().append("$ADD",
+ new BsonArray(Arrays.asList(new
BsonString("track[0].shot[2][0].city.problem[2]"),
+ new BsonInt32(123))))));
stmt = conn.prepareStatement(
"UPSERT INTO " + tableName + " VALUES (?) ON DUPLICATE KEY UPDATE_ONLY
COL = CASE WHEN"
diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/Bson5IT.java
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/Bson5IT.java
index 9d1b477d17..eea0ca8efe 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/Bson5IT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/Bson5IT.java
@@ -252,9 +252,9 @@ public class Bson5IT extends ParallelStatsDisabledIT {
.append("browserling", new
BsonBinary(PDouble.INSTANCE.toBytes(-505169340.54880095)))
.append("track[0].shot[2][0].city.standard[5]", new
BsonString("soft"))
.append("track[0].shot[2][0].city.problem[2]",
- new BsonDocument().append("$ADD", new BsonArray(Arrays.asList(
- new BsonString("track[0].shot[2][0].city.problem[2]"),
- new BsonDouble(529.435))))))
+ new BsonDocument().append("$ADD",
+ new BsonArray(Arrays.asList(new
BsonString("track[0].shot[2][0].city.problem[2]"),
+ new BsonDouble(529.435))))))
.append("$UNSET",
new BsonDocument().append("track[0].shot[2][0].city.flame", new
BsonNull()));
@@ -489,9 +489,9 @@ public class Bson5IT extends ParallelStatsDisabledIT {
.append("browserling", new
BsonBinary(PDouble.INSTANCE.toBytes(-505169340.54880095)))
.append("track[0].shot[2][0].city.standard[5]", new
BsonString("soft"))
.append("track[0].shot[2][0].city.problem[2]",
- new BsonDocument().append("$ADD", new BsonArray(Arrays.asList(
- new BsonString("track[0].shot[2][0].city.problem[2]"),
- new BsonDouble(529.435))))))
+ new BsonDocument().append("$ADD",
+ new BsonArray(Arrays.asList(new
BsonString("track[0].shot[2][0].city.problem[2]"),
+ new BsonDouble(529.435))))))
.append("$UNSET",
new BsonDocument().append("track[0].shot[2][0].city.flame", new
BsonNull()));
