forked from colinmarc/hdfs
-
Notifications
You must be signed in to change notification settings - Fork 0
/
conf_test.go
36 lines (27 loc) · 953 Bytes
/
conf_test.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
package hdfs
import (
"os"
"testing"
"github.com/stretchr/testify/assert"
)
func TestConfFallback(t *testing.T) {
os.Setenv("HADOOP_HOME", "test") // This will resolve to test/conf.
os.Setenv("HADOOP_CONF_DIR", "test/conf2")
confNamenodes := []string{"namenode1:8020", "namenode2:8020"}
conf2Namenodes := []string{"namenode3:8020"}
conf3Namenodes := []string{"namenode4:8020"}
conf := LoadHadoopConf("test/conf3")
nns, err := conf.Namenodes()
assert.Nil(t, err)
assert.EqualValues(t, conf3Namenodes, nns, "loading via specified path (test/conf3)")
conf = LoadHadoopConf("")
nns, err = conf.Namenodes()
assert.Nil(t, err)
assert.EqualValues(t, conf2Namenodes, nns, "loading via HADOOP_CONF_DIR (test/conf2)")
os.Unsetenv("HADOOP_CONF_DIR")
conf = LoadHadoopConf("")
nns, err = conf.Namenodes()
assert.Nil(t, err)
assert.EqualValues(t, confNamenodes, nns, "loading via HADOOP_HOME (test/conf)")
os.Unsetenv("HADOOP_HOME")
}