From 4815ab73219033459f1857a60fe0ce905e68ae19 Mon Sep 17 00:00:00 2001 From: Newnius Date: Mon, 4 May 2020 15:20:47 +0800 Subject: [PATCH] update --- src/job_manager.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/job_manager.go b/src/job_manager.go index c14348e..c9bcacb 100644 --- a/src/job_manager.go +++ b/src/job_manager.go @@ -116,7 +116,8 @@ func (jm *JobManager) start() { v.Set("network", network) v.Set("should_wait", "1") v.Set("output_dir", "/tmp/") - v.Set("hdfs_dir", "http://hdfs-master:50070/user/yao/output/"+jm.job.Name) + v.Set("hdfs_address", "http://192.168.100.104:50070/") + v.Set("hdfs_dir", "/user/yao/output/"+jm.job.Name) v.Set("gpu_mem", strconv.Itoa(jm.job.Tasks[i].MemoryGPU)) resp, err := doRequest("POST", "http://"+jm.resources[i].ClientHost+":8000/create", strings.NewReader(v.Encode()), "application/x-www-form-urlencoded", "")