From: Guobiao Mo <guobiaomo@chinamobile.com>
Date: Tue, 14 May 2019 17:47:26 +0000 (-0700)
Subject: Set HDFS user
X-Git-Tag: 2.0.0~137^2
X-Git-Url: https://gerrit.onap.org/r/gitweb?a=commitdiff_plain;h=feb7edda8a996bd6378947e51d010591989288e1;p=dcaegen2%2Fservices.git

Set HDFS user

Use DB.login as HDFS write user.

Issue-ID: DCAEGEN2-1498
Change-Id: I59ee83472595b1fc79e9562b68f4178e7fbd920b
Signed-off-by: Guobiao Mo <guobiaomo@chinamobile.com>
---

diff --git a/components/datalake-handler/feeder/src/assembly/scripts/init_db.sql b/components/datalake-handler/feeder/src/assembly/scripts/init_db.sql
index 04299e6d..2884c3e7 100644
--- a/components/datalake-handler/feeder/src/assembly/scripts/init_db.sql
+++ b/components/datalake-handler/feeder/src/assembly/scripts/init_db.sql
@@ -82,7 +82,7 @@ insert into db (`name`,`host`,`login`,`pass`,`database_name`) values ('Couchbase
 insert into db (`name`,`host`) values ('Elasticsearch','dl_es');
 insert into db (`name`,`host`,`port`,`database_name`) values ('MongoDB','dl_mongodb',27017,'datalake');
 insert into db (`name`,`host`) values ('Druid','dl_druid');
-insert into db (`name`,`host`) values ('HDFS','dlhdfs');
+insert into db (`name`,`host`,`login`) values ('HDFS','dlhdfs','dl');
 
 
 -- in production, default enabled should be off
diff --git a/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/HdfsService.java b/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/HdfsService.java
index e8d29106..edbc6757 100644
--- a/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/HdfsService.java
+++ b/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/HdfsService.java
@@ -140,8 +140,10 @@ public class HdfsService {
 
 			String hdfsuri = String.format("hdfs://%s:%s", hdfs.getHost(), port);
 			hdfsConfig.set("fs.defaultFS", hdfsuri);
-
-			log.info("Connecting to -- {}", hdfsuri);
+			//hdfsConfig.set("hadoop.job.ugi", hdfs.getLogin());
+			System.setProperty("HADOOP_USER_NAME", hdfs.getLogin());
+			
+			log.info("Connecting to -- {} as {}", hdfsuri, hdfs.getLogin());
 
 			fileSystem = FileSystem.get(hdfsConfig);