You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ranger.apache.org by co...@apache.org on 2017/07/10 11:48:25 UTC
ranger git commit: Temporarily adding some logs to try to debug the
jenkins failures
Repository: ranger
Updated Branches:
refs/heads/master f695b5def -> eb77374d1
Temporarily adding some logs to try to debug the jenkins failures
Project: http://git-wip-us.apache.org/repos/asf/ranger/repo
Commit: http://git-wip-us.apache.org/repos/asf/ranger/commit/eb77374d
Tree: http://git-wip-us.apache.org/repos/asf/ranger/tree/eb77374d
Diff: http://git-wip-us.apache.org/repos/asf/ranger/diff/eb77374d
Branch: refs/heads/master
Commit: eb77374d14120f20c50b8e862fd0e7ad2dd53c01
Parents: f695b5d
Author: Colm O hEigeartaigh <co...@apache.org>
Authored: Mon Jul 10 12:48:10 2017 +0100
Committer: Colm O hEigeartaigh <co...@apache.org>
Committed: Mon Jul 10 12:48:10 2017 +0100
----------------------------------------------------------------------
.../kafka/authorizer/KafkaRangerAuthorizerGSSTest.java | 11 ++++++++++-
1 file changed, 10 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ranger/blob/eb77374d/plugin-kafka/src/test/java/org/apache/ranger/authorization/kafka/authorizer/KafkaRangerAuthorizerGSSTest.java
----------------------------------------------------------------------
diff --git a/plugin-kafka/src/test/java/org/apache/ranger/authorization/kafka/authorizer/KafkaRangerAuthorizerGSSTest.java b/plugin-kafka/src/test/java/org/apache/ranger/authorization/kafka/authorizer/KafkaRangerAuthorizerGSSTest.java
index d072a6f..096c000 100644
--- a/plugin-kafka/src/test/java/org/apache/ranger/authorization/kafka/authorizer/KafkaRangerAuthorizerGSSTest.java
+++ b/plugin-kafka/src/test/java/org/apache/ranger/authorization/kafka/authorizer/KafkaRangerAuthorizerGSSTest.java
@@ -54,6 +54,9 @@ import kafka.server.KafkaServerStartable;
import kafka.utils.ZKStringSerializer$;
import kafka.utils.ZkUtils;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+
/**
* A simple test that starts a Kafka broker, creates "test" and "dev" topics,
* sends a message to them and consumes it.
@@ -70,6 +73,8 @@ import kafka.utils.ZkUtils;
*/
public class KafkaRangerAuthorizerGSSTest {
+ private static final Log LOG = LogFactory.getLog(KafkaRangerAuthorizerGSSTest.class);
+
private static KafkaServerStartable kafkaServer;
private static TestingServer zkServer;
private static int port;
@@ -151,7 +156,7 @@ public class KafkaRangerAuthorizerGSSTest {
private static void configureKerby(String baseDir) throws Exception {
- //System.setProperty("sun.security.krb5.debug", "true");
+ System.setProperty("sun.security.krb5.debug", "true");
System.setProperty("java.security.krb5.conf", baseDir + "/target/krb5.conf");
kerbyServer = new SimpleKdcServer();
@@ -185,15 +190,19 @@ public class KafkaRangerAuthorizerGSSTest {
@org.junit.AfterClass
public static void cleanup() throws Exception {
+ LOG.info("Shutting down Kafka");
if (kafkaServer != null) {
kafkaServer.shutdown();
}
+ LOG.info("Shutting down ZK");
if (zkServer != null) {
zkServer.stop();
}
+ LOG.info("Shutting down Kerby");
if (kerbyServer != null) {
kerbyServer.stop();
}
+ LOG.info("Cleanup finished");
}
// The "public" group can write to and read from "test"