This is an automated email from the ASF dual-hosted git repository.
sanjeet pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/phoenix.git
The following commit(s) were added to refs/heads/master by this push:
new 42dc7dba7f PHOENIX-7789: Fix Flappers in SlowestScanMetricsIT (#2396)
42dc7dba7f is described below
commit 42dc7dba7fec406d2ed807e0f2aa2f96abc1d558
Author: sanjeet006py <[email protected]>
AuthorDate: Wed Apr 1 16:12:57 2026 +0530
PHOENIX-7789: Fix Flappers in SlowestScanMetricsIT (#2396)
---
.../phoenix/monitoring/SlowestScanMetricsIT.java | 18 +++++++++---------
1 file changed, 9 insertions(+), 9 deletions(-)
diff --git
a/phoenix-core/src/it/java/org/apache/phoenix/monitoring/SlowestScanMetricsIT.java
b/phoenix-core/src/it/java/org/apache/phoenix/monitoring/SlowestScanMetricsIT.java
index d79edeb958..db5f0734a3 100644
---
a/phoenix-core/src/it/java/org/apache/phoenix/monitoring/SlowestScanMetricsIT.java
+++
b/phoenix-core/src/it/java/org/apache/phoenix/monitoring/SlowestScanMetricsIT.java
@@ -644,7 +644,7 @@ public class SlowestScanMetricsIT extends BaseTest {
@Test
public void testQueryOnCoveredIndex() throws Exception {
- int topN = 2;
+ int topN = 3;
String tableName = generateUniqueName();
String indexName = generateUniqueName();
try (Connection conn = DriverManager.getConnection(getUrl())) {
@@ -669,8 +669,8 @@ public class SlowestScanMetricsIT extends BaseTest {
JsonArray slowestScanMetricsJsonArray =
getSlowestScanMetricsJsonArray(rs);
int totalBroc = 0;
- // Outer array has size 2 as the base table is salted so, salt bucket
no. of parallel scans
- // are generated and topN is 2.
+ // Outer array has size 3 as the base table is salted so, salt bucket
no. of parallel scans
+ // are generated and topN is 3.
assertEquals(topN, slowestScanMetricsJsonArray.size());
for (int i = 0; i < topN; i++) {
JsonArray groupArray =
slowestScanMetricsJsonArray.get(i).getAsJsonArray();
@@ -693,7 +693,7 @@ public class SlowestScanMetricsIT extends BaseTest {
@Test
public void testQueryOnUncoveredIndex() throws Exception {
- int topN = 2;
+ int topN = 3;
String tableName = generateUniqueName();
String indexName = generateUniqueName();
try (Connection conn = DriverManager.getConnection(getUrl())) {
@@ -718,8 +718,8 @@ public class SlowestScanMetricsIT extends BaseTest {
JsonArray slowestScanMetricsJsonArray =
getSlowestScanMetricsJsonArray(rs);
int totalBroc = 0;
- // Outer array has size 2 as the base table is salted so, salt bucket
no. of parallel scans
- // are generated and topN is 2.
+ // Outer array has size 3 as the base table is salted so, salt bucket
no. of parallel scans
+ // are generated and topN is 3.
assertEquals(topN, slowestScanMetricsJsonArray.size());
for (int i = 0; i < topN; i++) {
JsonArray groupArray =
slowestScanMetricsJsonArray.get(i).getAsJsonArray();
@@ -787,7 +787,7 @@ public class SlowestScanMetricsIT extends BaseTest {
@Test
public void testQueryOnViewIndex() throws Exception {
- int topN = 2;
+ int topN = 3;
String tableName = generateUniqueName();
String viewName = generateUniqueName();
String viewIndexName = generateUniqueName();
@@ -816,8 +816,8 @@ public class SlowestScanMetricsIT extends BaseTest {
JsonArray slowestScanMetricsJsonArray =
getSlowestScanMetricsJsonArray(rs);
int totalBroc = 0;
- // Outer array has size 2 as the base table is salted so, salt bucket
no. of parallel scans
- // are generated and topN is 2.
+ // Outer array has size 3 as the base table is salted so, salt bucket
no. of parallel scans
+ // are generated and topN is 3.
assertEquals(topN, slowestScanMetricsJsonArray.size());
for (int i = 0; i < topN; i++) {
JsonArray groupArray =
slowestScanMetricsJsonArray.get(i).getAsJsonArray();