From 564cdf6290f1df6b5bfbf321fc58c0abbaad79b0 Mon Sep 17 00:00:00 2001 From: sidhdirenge Date: Thu, 12 Sep 2024 17:36:53 +0530 Subject: [PATCH] Fix issue with parameters --- .../io/cdap/cdap/storage/spanner/SpannerStructuredTable.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/cdap-storage-ext-spanner/src/main/java/io/cdap/cdap/storage/spanner/SpannerStructuredTable.java b/cdap-storage-ext-spanner/src/main/java/io/cdap/cdap/storage/spanner/SpannerStructuredTable.java index fdc71fc4a571..2c90fd21dae9 100644 --- a/cdap-storage-ext-spanner/src/main/java/io/cdap/cdap/storage/spanner/SpannerStructuredTable.java +++ b/cdap-storage-ext-spanner/src/main/java/io/cdap/cdap/storage/spanner/SpannerStructuredTable.java @@ -465,7 +465,6 @@ private Statement getCountStatement(Collection ranges, if (whereClause != null) { builder.append(" WHERE " + whereClause); - parameters.forEach((name, value) -> builder.bind(name).to(value)); } if (!filterIndexes.isEmpty()) { if (whereClause != null) { @@ -473,10 +472,9 @@ private Statement getCountStatement(Collection ranges, } else { builder.append(" WHERE "); } - parameters = new HashMap<>(); builder.append(getIndexesFilterClause(filterIndexes, parameters)); - parameters.forEach((name, value) -> builder.bind(name).to(value)); } + parameters.forEach((name, value) -> builder.bind(name).to(value)); LOG.trace("SQL statement: {}", builder.build().getSql()); return builder.build(); }