(nifi) branch main updated: NIFI-14994 Fix flaky Test TestQueryRecord.testAggregateFunction by enforcing deterministic row order

[pvillard]

This is an automated email from the ASF dual-hosted git repository.

pvillard pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git


The following commit(s) were added to refs/heads/main by this push:
     new edf49ce80c NIFI-14994 Fix flaky Test 
TestQueryRecord.testAggregateFunction by enforcing deterministic row order
edf49ce80c is described below

commit edf49ce80c1f012b6f688ef353741d51c56f6200
Author: Kangwei Zhu <anicaa...@gmail.com>
AuthorDate: Thu Sep 18 16:53:43 2025 -0400

    NIFI-14994 Fix flaky Test TestQueryRecord.testAggregateFunction by 
enforcing deterministic row order
    
    Signed-off-by: Pierre Villard <pierre.villard...@gmail.com>
    
    This closes #10325.
---
 .../test/java/org/apache/nifi/processors/standard/TestQueryRecord.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestQueryRecord.java
 
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestQueryRecord.java
index b4448ac62f..f63d802a4b 100644
--- 
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestQueryRecord.java
+++ 
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestQueryRecord.java
@@ -1090,7 +1090,7 @@ public class TestQueryRecord {
         runner.addControllerService("writer", writer);
         runner.enableControllerService(writer);
 
-        runner.setProperty(REL_NAME, "select name, sum(points) as points from 
FLOWFILE GROUP BY name");
+        runner.setProperty(REL_NAME, "select name, sum(points) as points from 
FLOWFILE GROUP BY name ORDER BY points DESC");
         runner.setProperty(QueryRecord.RECORD_READER_FACTORY, "parser");
         runner.setProperty(QueryRecord.RECORD_WRITER_FACTORY, "writer");