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", "")