Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NIFI-8235 UnsupportedOpertationException in PutAccumuloRecord

This commit is contained in:
Zsihovszki Krisztina 2021-02-18 16:02:47 +01:00 committed by markap14
parent 042b34cb43
commit 6801704846
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
nifi-nar-bundles/nifi-accumulo-bundle/nifi-accumulo-processors/src/main/java/org/apache/nifi/accumulo/processors/PutAccumuloRecord.java
View File

@ -70,7 +70,6 @@ import javax.xml.bind.DatatypeConverter;
import java.io.InputStream; import java.io.InputStream;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Collection; import java.util.Collection;
import java.util.Collections;
import java.util.HashMap; import java.util.HashMap;
import java.util.HashSet; import java.util.HashSet;
import java.util.List; import java.util.List;
@ -264,7 +263,7 @@ public class PutAccumuloRecord extends BaseAccumuloProcessor {
@Override @Override
protected Collection<ValidationResult> customValidate(ValidationContext validationContext) { 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()) 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()); 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()) else if (validationContext.getProperty(COLUMN_FAMILY).isSet() && validationContext.getProperty(COLUMN_FAMILY_FIELD).isSet())