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 2024/09/19 20:58:27 UTC
(nifi) branch support/nifi-1.x updated: NIFI-13763 Fixed HashSet Filtering for DeduplicateRecord (#9276)
This is an automated email from the ASF dual-hosted git repository.
exceptionfactory pushed a commit to branch support/nifi-1.x
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/support/nifi-1.x by this push:
new 76ce42e4d4 NIFI-13763 Fixed HashSet Filtering for DeduplicateRecord (#9276)
76ce42e4d4 is described below
commit 76ce42e4d423cf9d01813ff904fd57ec1229a59b
Author: timeabarna <38...@users.noreply.github.com>
AuthorDate: Thu Sep 19 22:58:21 2024 +0200
NIFI-13763 Fixed HashSet Filtering for DeduplicateRecord (#9276)
Signed-off-by: David Handermann <ex...@apache.org>
---
.../java/org/apache/nifi/processors/standard/DeduplicateRecord.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/DeduplicateRecord.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/DeduplicateRecord.java
index 0c1ea0e93e..0f44074654 100644
--- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/DeduplicateRecord.java
+++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/DeduplicateRecord.java
@@ -405,7 +405,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))