org.apache.flink.test.util

Class SecureTestEnvironment

java.lang.Object

org.apache.flink.test.util.SecureTestEnvironment

public class SecureTestEnvironment
extends Object

Helper SecureTestEnvironment to handle MiniKDC lifecycle. This class can be used to start/stop MiniKDC and create secure configurations for MiniDFSCluster and MiniYarn.

If you use this class in your project, please make sure to add a dependency to hadoop-minikdc, e.g. in your pom.xml:

 ...
 <dependencies>
   <dependency>
     <groupId>org.apache.hadoop</groupId>
     <artifactId>hadoop-minikdc</artifactId>
     <version>${minikdc.version}</version>
     <scope>compile</scope>
   </dependency>
 ...
 </dependencies>
 ...

 <build>
   <plugins>
     <!--
       https://issues.apache.org/jira/browse/DIRSHARED-134
       Required to pull the Mini-KDC transitive dependency
     -->
     <plugin>
     <groupId>org.apache.felix</groupId>
     <artifactId>maven-bundle-plugin</artifactId>
     <version>3.0.1</version>
     <inherited>true</inherited>
     <extensions>true</extensions>
   </plugin>
 ...
 

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
SecureTestEnvironment()

Method Summary

Modifier and Type	Method and Description
static void	cleanup()
static Map<String,org.apache.flink.test.util.TestingSecurityContext.ClientSecurityConfiguration>	getClientSecurityConfigurationMap()
static String	getHadoopServicePrincipal()
static String	getTestKeytab()
static Configuration	populateFlinkSecureConfigurations(Configuration flinkConf)
static void	prepare(org.junit.rules.TemporaryFolder tempFolder)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOG

protected static final org.slf4j.Logger LOG

Constructor Detail

SecureTestEnvironment

public SecureTestEnvironment()

Method Detail

prepare

public static void prepare(org.junit.rules.TemporaryFolder tempFolder)

cleanup

public static void cleanup()

populateFlinkSecureConfigurations

public static Configuration populateFlinkSecureConfigurations(@Nullable
                                                              Configuration flinkConf)

getClientSecurityConfigurationMap

public static Map<String,org.apache.flink.test.util.TestingSecurityContext.ClientSecurityConfiguration> getClientSecurityConfigurationMap()

getTestKeytab

public static String getTestKeytab()

getHadoopServicePrincipal

public static String getHadoopServicePrincipal()