From e125d8cdbb88ac6bc08adc21c35a197b1e32782b Mon Sep 17 00:00:00 2001 From: timeabarna <38653567+timeabarna@users.noreply.github.com> Date: Thu, 19 Sep 2024 22:57:44 +0200 Subject: [PATCH] NIFI-13763 Fixed HashSet Filtering for DeduplicateRecord (#9277) Signed-off-by: David Handermann --- .../org/apache/nifi/processors/standard/DeduplicateRecord.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/DeduplicateRecord.java b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/DeduplicateRecord.java index 21eb850913..1c5b9f6bf9 100644 --- a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/DeduplicateRecord.java +++ b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/DeduplicateRecord.java @@ -391,7 +391,7 @@ public class DeduplicateRecord extends AbstractProcessor { private FilterWrapper getFilter(ProcessContext context) { if (useInMemoryStrategy) { boolean useHashSet = context.getProperty(FILTER_TYPE).getValue() - .equals(context.getProperty(HASH_SET_VALUE.getValue()).getValue()); + .equals(HASH_SET_VALUE.getValue()); final int filterCapacity = context.getProperty(FILTER_CAPACITY_HINT).asInteger(); return useHashSet ? new HashSetFilterWrapper(new HashSet<>(filterCapacity))