Fixed failing test after indices change

nik9000 · Nov 26, 2024 · e0b84f0 · e0b84f0
1 parent 9dc6ad1
commit e0b84f0
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 10 deletions.
diff --git a/...c/test/java/org/elasticsearch/compute/aggregation/blockhash/CategorizeBlockHashTests.java b/...c/test/java/org/elasticsearch/compute/aggregation/blockhash/CategorizeBlockHashTests.java
@@ -50,9 +50,6 @@
 
 public class CategorizeBlockHashTests extends BlockHashTestCase {
 
-    /**
-     * Replicate the existing csv test, using sample_data.csv
-     */
     public void testCategorizeRaw() {
         final Page page;
         final int positions = 7;
@@ -66,7 +63,7 @@ public void testCategorizeRaw() {
             builder.appendBytesRef(new BytesRef("Connected to 10.1.0.3"));
             page = new Page(builder.build());
         }
-        // final int emitBatchSize = between(positions, 10 * 1024);
+
         try (BlockHash hash = new CategorizeRawBlockHash(0, blockFactory, true)) {
             hash.add(page, new GroupingAggregatorFunction.AddInput() {
                 @Override
@@ -125,7 +122,7 @@ public void testCategorizeIntermediate() {
             builder.appendBytesRef(new BytesRef("System shutdown"));
             page2 = new Page(builder.build());
         }
-        // final int emitBatchSize = between(positions, 10 * 1024);
+
         try (
             BlockHash rawHash1 = new CategorizeRawBlockHash(0, blockFactory, true);
             BlockHash rawHash2 = new CategorizeRawBlockHash(0, blockFactory, true);

diff --git a/x-pack/plugin/esql/qa/testFixtures/src/main/resources/categorize.csv-spec b/x-pack/plugin/esql/qa/testFixtures/src/main/resources/categorize.csv-spec
@@ -60,7 +60,7 @@ COUNT():long | category:keyword
            1 | .*?disconnected.*?
 ;
 
-mv with multiple indices
+with multiple indices
 required_capability: categorize
 required_capability: union_types
 
@@ -70,10 +70,9 @@ FROM sample_data*
 ;
 
 COUNT():long | category:keyword
-           7 | .*?Banana.*?
-           15 | .*?Connected.+?to.*?
-           15 | .*?Connection.+?error.*?
-           5 | .*?Disconnected.*?
+          12 | .*?Connected.+?to.*?
+          12 | .*?Connection.+?error.*?
+           4 | .*?Disconnected.*?
 ;
 
 mv with many values