You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by ex...@apache.org on 2022/12/09 16:50:57 UTC

[nifi] branch main updated: NIFI-10637 Deterministic TestGenerateTableFetch testMultipleColumnTypeMissing

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

exceptionfactory 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 ac8e3dae58 NIFI-10637 Deterministic TestGenerateTableFetch testMultipleColumnTypeMissing
ac8e3dae58 is described below

commit ac8e3dae58339c91177d5b8565e28fd3d5d74a83
Author: hj28 <hj...@fa22-cs527-097.cs.illinois.edu>
AuthorDate: Sun Dec 4 09:31:00 2022 -0600

    NIFI-10637 Deterministic TestGenerateTableFetch testMultipleColumnTypeMissing
    
    This closes #6754
    
    Signed-off-by: David Handermann <ex...@apache.org>
---
 .../org/apache/nifi/processors/standard/TestGenerateTableFetch.java   | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestGenerateTableFetch.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestGenerateTableFetch.java
index 11a209997f..53dc086bbb 100644
--- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestGenerateTableFetch.java
+++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestGenerateTableFetch.java
@@ -1467,9 +1467,7 @@ public class TestGenerateTableFetch {
 
 
         // Remove one element from columnTypeMap to simulate it's re-cache partial state
-        Map.Entry<String, Integer> entry = processor.columnTypeMap.entrySet().iterator().next();
-        String key = entry.getKey();
-        processor.columnTypeMap.remove(key);
+        processor.columnTypeMap.remove("TEST_QUERY_DB_TABLE");
 
         // Insert new records
         stmt.execute("insert into TEST_QUERY_DB_TABLE (id, bucket) VALUES (2, 0)");