diff options
| author |   Guobiao Mo <guobiaomo@chinamobile.com> | 2019-05-14 10:47:26 -0700 |
|---|---|---|
| committer | Guobiao Mo <guobiaomo@chinamobile.com> | 2019-05-14 10:47:26 -0700 |
| commit | feb7edda8a996bd6378947e51d010591989288e1 (patch) | |
| tree | e5eb4539d613378568af5c437d238a6e0dc8169f /components/datalake-handler/feeder/src/main/java/org | |
| parent | 3208e0c943742fef5e6692202063dba4e8ab96fd (diff) | |
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>
Diffstat (limited to 'components/datalake-handler/feeder/src/main/java/org')
| -rw-r--r-- | components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/HdfsService.java | 6 |
1 files changed, 4 insertions, 2 deletions
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); |