You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by jo...@apache.org on 2021/02/25 05:57:12 UTC
[nifi] 03/24: NIFI-8235 UnsupportedOpertationException in
PutAccumuloRecord
This is an automated email from the ASF dual-hosted git repository.
joewitt pushed a commit to branch support/nifi-1.13
in repository https://gitbox.apache.org/repos/asf/nifi.git
commit 877cc2613b37698f9c7ca900867ae4456c75b54c
Author: Zsihovszki Krisztina <kz...@cloudera.com>
AuthorDate: Thu Feb 18 16:02:47 2021 +0100
NIFI-8235 UnsupportedOpertationException in PutAccumuloRecord
---
.../java/org/apache/nifi/accumulo/processors/PutAccumuloRecord.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/nifi-nar-bundles/nifi-accumulo-bundle/nifi-accumulo-processors/src/main/java/org/apache/nifi/accumulo/processors/PutAccumuloRecord.java b/nifi-nar-bundles/nifi-accumulo-bundle/nifi-accumulo-processors/src/main/java/org/apache/nifi/accumulo/processors/PutAccumuloRecord.java
index dbcc3e7..b643638 100644
--- a/nifi-nar-bundles/nifi-accumulo-bundle/nifi-accumulo-processors/src/main/java/org/apache/nifi/accumulo/processors/PutAccumuloRecord.java
+++ b/nifi-nar-bundles/nifi-accumulo-bundle/nifi-accumulo-processors/src/main/java/org/apache/nifi/accumulo/processors/PutAccumuloRecord.java
@@ -70,7 +70,6 @@ import javax.xml.bind.DatatypeConverter;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.Collection;
-import java.util.Collections;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
@@ -264,7 +263,7 @@ public class PutAccumuloRecord extends BaseAccumuloProcessor {
@Override
protected Collection<ValidationResult> customValidate(ValidationContext validationContext) {
- Collection<ValidationResult> set = Collections.emptySet();
+ Collection<ValidationResult> set = new HashSet<>();
if (!validationContext.getProperty(COLUMN_FAMILY).isSet() && !validationContext.getProperty(COLUMN_FAMILY_FIELD).isSet())
set.add(new ValidationResult.Builder().explanation("Column Family OR Column family field name must be defined").build());
else if (validationContext.getProperty(COLUMN_FAMILY).isSet() && validationContext.getProperty(COLUMN_FAMILY_FIELD).isSet())