-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/31339/
-----------------------------------------------------------
(Updated March 5, 2015, 4:58 a.m.)
Review request for Flume.
Changes
-------
As per the new design for Authenticator/PrivilegedExecutor, mentioned in
FLUME-2631, made the changes. Some documentation needs updating, will do it in
parallel. Thanks.
Bugs: FLUME-2631
https://issues.apache.org/jira/browse/FLUME-2631
Repository: flume-git
Description
-------
End to End authentication in Flume
Diffs (updated)
-----
flume-ng-auth/pom.xml PRE-CREATION
flume-ng-auth/src/main/java/org/apache/flume/api/SecureRpcClientFactory.java
PRE-CREATION
flume-ng-auth/src/main/java/org/apache/flume/api/SecureThriftRpcClient.java
PRE-CREATION
flume-ng-auth/src/main/java/org/apache/flume/auth/FlumeAuthenticationUtil.java
PRE-CREATION
flume-ng-auth/src/main/java/org/apache/flume/auth/FlumeAuthenticator.java
PRE-CREATION
flume-ng-auth/src/main/java/org/apache/flume/auth/KerberosAuthenticator.java
PRE-CREATION
flume-ng-auth/src/main/java/org/apache/flume/auth/PrivilegedExecutor.java
PRE-CREATION
flume-ng-auth/src/main/java/org/apache/flume/auth/ProxyExecutor.java
PRE-CREATION
flume-ng-auth/src/main/java/org/apache/flume/auth/SecurityException.java
PRE-CREATION
flume-ng-auth/src/main/java/org/apache/flume/auth/SimpleAuthenticator.java
PRE-CREATION
flume-ng-auth/src/test/java/org/apache/flume/auth/TestFlumeAuthenticator.java
PRE-CREATION
flume-ng-core/pom.xml 8992414
flume-ng-core/src/main/java/org/apache/flume/sink/ThriftSink.java baa60d0
flume-ng-core/src/main/java/org/apache/flume/source/ThriftSource.java 06bb604
flume-ng-dist/pom.xml a083fe2
flume-ng-dist/src/main/assembly/bin.xml 5aa7cc6
flume-ng-dist/src/main/assembly/src.xml b1e79a2
flume-ng-sdk/src/main/java/org/apache/flume/api/RpcClientConfigurationConstants.java
33a2330
flume-ng-sdk/src/main/java/org/apache/flume/api/ThriftRpcClient.java 4f75a2b
flume-ng-sinks/flume-dataset-sink/pom.xml e929d60
flume-ng-sinks/flume-dataset-sink/src/main/java/org/apache/flume/sink/kite/DatasetSink.java
3e66532
flume-ng-sinks/flume-dataset-sink/src/main/java/org/apache/flume/sink/kite/KerberosUtil.java
c0dbffb
flume-ng-sinks/flume-dataset-sink/src/test/java/org/apache/flume/sink/kite/TestKerberosUtil.java
f53ef73
flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/BucketWriter.java
62f4eee
flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSEventSink.java
33f73a9
flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/HBaseSink.java
5de0bd5
flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/HBaseSinkSecurityManager.java
762fce9
pom.xml ea7ffe3
Diff: https://reviews.apache.org/r/31339/diff/
Testing
-------
Tested in kerberos cluster with combinations of Thrift Src, Sink and Hdfs Sink
Thanks,
Johny Rufus John