Skip to content

Commit

Permalink
fix namenode.host
Browse files Browse the repository at this point in the history
  • Loading branch information
jetoile committed Sep 3, 2017
1 parent 4419a71 commit de52ccf
Show file tree
Hide file tree
Showing 19 changed files with 19 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -38,6 +38,7 @@ hive.test.table.name=test_table


# HDFS
hdfs.namenode.host=localhost
hdfs.namenode.port=20112
hdfs.namenode.http.port=50070
hdfs.temp.dir=/tmp/embedded_hdfs
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@ hive.test.table.name=test_table


# HDFS
hdfs.namenode.host=localhost
hdfs.namenode.port=20112
hdfs.namenode.http.port=50070
hdfs.temp.dir=/tmp/embedded_hdfs
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@ hive.test.table.name=test_table


# HDFS
hdfs.namenode.host=localhost
hdfs.namenode.port=20112
hdfs.namenode.http.port=50070
hdfs.temp.dir=/tmp/embedded_hdfs
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -38,6 +38,7 @@ hive.test.table.name=test_table


# HDFS
hdfs.namenode.host=localhost
hdfs.namenode.port=20112
hdfs.namenode.http.port=50070
hdfs.temp.dir=/tmp/embedded_hdfs
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -124,7 +124,7 @@ private HiveConf buildHiveConf() {
WindowsLibsUtils.setHadoopHome();

HiveConf hiveConf = new HiveConf();
hiveConf.set("fs.defaultFS", "hdfs://localhost:20112");
hiveConf.set("fs.defaultFS", "hdfs://" + configuration.getString(HadoopUnitConfig.HDFS_NAMENODE_HOST_KEY) + ":" + configuration.getInt(HadoopUnitConfig.HDFS_NAMENODE_PORT_KEY));
// hiveConf.set(HiveConf.ConfVars.HIVE_TXN_MANAGER.varname, "org.apache.hadoop.hive.ql.lockmgr.DbTxnManager");
// hiveConf.set(HiveConf.ConfVars.HIVE_COMPACTOR_INITIATOR_ON.varname, "true");
// hiveConf.set(HiveConf.ConfVars.HIVE_COMPACTOR_WORKER_THREADS.varname, "5");
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -151,7 +151,7 @@ private HiveConf buildHiveConf() {
WindowsLibsUtils.setHadoopHome();

HiveConf hiveConf = new HiveConf();
hiveConf.set("fs.defaultFS", "hdfs://localhost:20112");
hiveConf.set("fs.defaultFS", "hdfs://" + configuration.getString(HadoopUnitConfig.HDFS_NAMENODE_HOST_KEY) + ":" + configuration.getInt(HadoopUnitConfig.HDFS_NAMENODE_PORT_KEY));
// hiveConf.set(HiveConf.ConfVars.HIVE_TXN_MANAGER.varname, "org.apache.hadoop.hive.ql.lockmgr.DbTxnManager");
// hiveConf.set(HiveConf.ConfVars.HIVE_COMPACTOR_INITIATOR_ON.varname, "true");
// hiveConf.set(HiveConf.ConfVars.HIVE_COMPACTOR_WORKER_THREADS.varname, "5");
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@ hive.test.table.name=test_table


# HDFS
hdfs.namenode.host=localhost
hdfs.namenode.port=20112
hdfs.namenode.http.port=50070
hdfs.temp.dir=/tmp/embedded_hdfs
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@ hive.test.table.name=test_table


# HDFS
hdfs.namenode.host=localhost
hdfs.namenode.port=20112
hdfs.namenode.http.port=50070
hdfs.temp.dir=/tmp/embedded_hdfs
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@ hive.test.table.name=test_table


# HDFS
hdfs.namenode.host=localhost
hdfs.namenode.port=20112
hdfs.namenode.http.port=50070
hdfs.temp.dir=/tmp/embedded_hdfs
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@ hive.test.table.name=test_table


# HDFS
hdfs.namenode.host=localhost
hdfs.namenode.port=20112
hdfs.namenode.http.port=50070
hdfs.temp.dir=/tmp/embedded_hdfs
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@ hive.test.table.name=test_table


# HDFS
hdfs.namenode.host=localhost
hdfs.namenode.port=20112
hdfs.namenode.http.port=50070
hdfs.temp.dir=/tmp/embedded_hdfs
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -38,6 +38,7 @@ hive.test.table.name=test_table


# HDFS
hdfs.namenode.host=localhost
hdfs.namenode.port=20112
hdfs.namenode.http.port=50070
hdfs.temp.dir=/tmp/embedded_hdfs
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@ hive.test.table.name=test_table


# HDFS
hdfs.namenode.host=localhost
hdfs.namenode.port=20112
hdfs.namenode.http.port=50070
hdfs.temp.dir=/tmp/embedded_hdfs
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -38,6 +38,7 @@ hive.test.table.name=test_table


# HDFS
hdfs.namenode.host=localhost
hdfs.namenode.port=20112
hdfs.namenode.http.port=50070
hdfs.temp.dir=/tmp/embedded_hdfs
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@ hive.test.table.name=test_table


# HDFS
hdfs.namenode.host=localhost
hdfs.namenode.port=20112
hdfs.namenode.http.port=50070
hdfs.temp.dir=/tmp/embedded_hdfs
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@ hive.test.table.name=test_table


# HDFS
hdfs.namenode.host=localhost
hdfs.namenode.port=20112
hdfs.namenode.http.port=50070
hdfs.temp.dir=/tmp/embedded_hdfs
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@ hive.test.table.name=test_table


# HDFS
hdfs.namenode.host=localhost
hdfs.namenode.port=20112
hdfs.namenode.http.port=50070
hdfs.temp.dir=/tmp/embedded_hdfs
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@ hive.test.table.name=test_table


# HDFS
hdfs.namenode.host=localhost
hdfs.namenode.port=20112
hdfs.namenode.http.port=50070
hdfs.temp.dir=/tmp/embedded_hdfs
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@ hive.test.table.name=test_table


# HDFS
hdfs.namenode.host=localhost
hdfs.namenode.port=20112
hdfs.namenode.http.port=50070
hdfs.temp.dir=/tmp/embedded_hdfs
Expand Down

0 comments on commit de52ccf

Please sign in to comment.