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

NIFI-2765: Fixed Kerberos support for PutHiveStreaming 

This closes #1012.

Signed-off-by: Bryan Bende <bbende@apache.org>
This commit is contained in:
Matt Burgess 2016-09-13 10:20:27 -04:00 committed by Bryan Bende
parent b48355e75a
commit 6c9291ad53
No known key found for this signature in database
GPG Key ID: A0DDA9ED50711C39
1 changed files with 20 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

45
nifi-nar-bundles/nifi-hive-bundle/nifi-hive-processors/src/main/java/org/apache/nifi/processors/hive/PutHiveStreaming.java
View File

@ -238,8 +238,8 @@ public class PutHiveStreaming extends AbstractProcessor {
+ "can be used to provide a retry capability since full rollback is not possible.") + "can be used to provide a retry capability since full rollback is not possible.")
.build(); .build();
private final static List<PropertyDescriptor> propertyDescriptors; private List<PropertyDescriptor> propertyDescriptors;
private final static Set<Relationship> relationships; private Set<Relationship> relationships;
private static final long TICKET_RENEWAL_PERIOD = 60000; private static final long TICKET_RENEWAL_PERIOD = 60000;
@ -258,21 +258,24 @@ public class PutHiveStreaming extends AbstractProcessor {
protected Map<HiveEndPoint, HiveWriter> allWriters; protected Map<HiveEndPoint, HiveWriter> allWriters;
/* @Override
* Will ensure that the list of property descriptors is build only once. protected void init(ProcessorInitializationContext context) {
* Will also create a Set of relationships List<PropertyDescriptor> props = new ArrayList<>();
*/ props.add(METASTORE_URI);
static { props.add(HIVE_CONFIGURATION_RESOURCES);
propertyDescriptors = new ArrayList<>(); props.add(DB_NAME);
propertyDescriptors.add(METASTORE_URI); props.add(TABLE_NAME);
propertyDescriptors.add(HIVE_CONFIGURATION_RESOURCES); props.add(PARTITION_COLUMNS);
propertyDescriptors.add(DB_NAME); props.add(AUTOCREATE_PARTITIONS);
propertyDescriptors.add(TABLE_NAME); props.add(MAX_OPEN_CONNECTIONS);
propertyDescriptors.add(PARTITION_COLUMNS); props.add(HEARTBEAT_INTERVAL);
propertyDescriptors.add(AUTOCREATE_PARTITIONS); props.add(TXNS_PER_BATCH);
propertyDescriptors.add(MAX_OPEN_CONNECTIONS);
propertyDescriptors.add(HEARTBEAT_INTERVAL); kerberosConfigFile = context.getKerberosConfigurationFile();
propertyDescriptors.add(TXNS_PER_BATCH); kerberosProperties = new KerberosProperties(kerberosConfigFile);
props.add(kerberosProperties.getKerberosPrincipal());
props.add(kerberosProperties.getKerberosKeytab());
propertyDescriptors = Collections.unmodifiableList(props);
Set<Relationship> _relationships = new HashSet<>(); Set<Relationship> _relationships = new HashSet<>();
_relationships.add(REL_SUCCESS); _relationships.add(REL_SUCCESS);
@ -281,14 +284,6 @@ public class PutHiveStreaming extends AbstractProcessor {
relationships = Collections.unmodifiableSet(_relationships); relationships = Collections.unmodifiableSet(_relationships);
} }
@Override
protected void init(ProcessorInitializationContext context) {
kerberosConfigFile = context.getKerberosConfigurationFile();
kerberosProperties = new KerberosProperties(kerberosConfigFile);
propertyDescriptors.add(kerberosProperties.getKerberosPrincipal());
propertyDescriptors.add(kerberosProperties.getKerberosKeytab());
}
@Override @Override
protected List<PropertyDescriptor> getSupportedPropertyDescriptors() { protected List<PropertyDescriptor> getSupportedPropertyDescriptors() {
return propertyDescriptors; return propertyDescriptors;