Github user manishgupta88 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2232#discussion_r185400079
--- Diff:
integration/spark-common/src/main/java/org/apache/carbondata/spark/dictionary/server/SecureDictionaryServer.java
---
@@ -63,7 +67,18 @@ private SecureDictionaryServer(SparkConf conf, String
host, int port) {
this.conf = conf;
this.host = host;
this.port = port;
- startServer();
+ try {
+ UserGroupInformation.getLoginUser().doAs(new
PrivilegedExceptionAction<Void>() {
+ @Override public Void run() throws Exception {
+ startServer();
+ return null;
+ }
+ });
+ } catch (IOException io) {
+ LOGGER.error(io, "Failed to Dictionary Server server in secure
mode");
+ } catch (InterruptedException ie) {
+ LOGGER.error(ie, "Failed to Dictionary Server server in secure
mode");
--- End diff --
Correct the error message in both the catch blocks
"Failed to start Dictionary Server in secure mode"
---
