From 02e13ea0f76d283b76320c1cd5dc59a7e76f18d7 Mon Sep 17 00:00:00 2001
From: Filip Drobnjakovic <drobnjakovicfilip@gmail.com>
Date: Fri, 27 Jan 2023 20:28:49 +0100
Subject: [PATCH] test upgrade.

Signed-off-by: Filip Drobnjakovic <drobnjakovicfilip@gmail.com>
---
 .../reader/ReaderMetricsProcessorTests.java                  | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/src/test/java/org/opensearch/performanceanalyzer/reader/ReaderMetricsProcessorTests.java b/src/test/java/org/opensearch/performanceanalyzer/reader/ReaderMetricsProcessorTests.java
index 36a733e2c..411cc7508 100644
--- a/src/test/java/org/opensearch/performanceanalyzer/reader/ReaderMetricsProcessorTests.java
+++ b/src/test/java/org/opensearch/performanceanalyzer/reader/ReaderMetricsProcessorTests.java
@@ -71,15 +71,20 @@ public void testShardBulkParseAndQuery() throws Exception {
                                 Arrays.asList("sum", "sum"),
                                 Arrays.asList("Operation"));
 
+        boolean shardbulkEncountered = false;
+
         for (Record record : res) {
             if (PerformanceAnalyzerMetrics.sShardBulkPath.equals(record.get("Operation"))) {
                 assertNotNull(record.get("ShardEvents"));
                 assertNotNull(record.get("ShardBulkDocs"));
                 assertTrue((Double) record.get("ShardEvents") >= 1.0);
                 assertTrue((Double) record.get("ShardBulkDocs") >= 1.0);
+                shardbulkEncountered = true;
             }
         }
 
+        assertTrue(shardbulkEncountered);
+
         mp.trimOldSnapshots();
         mp.trimOldMetricsDBFiles();
         mp.deleteDBs();