Fix bugs

maplejuice/resource_manager.go

@@ -439,6 +439,12 @@ func (rm *ResourceManager) processJuiceJob(job Job) error {
 	// Step 6: integrate the results and write into sdfs
 	// Put the results into sdfs
 	filename := IntermediateFileDir + job.DestFile
+	f, err := os.OpenFile(filename, os.O_APPEND|os.O_CREATE|os.O_WRONLY, 0644)
+	if err != nil {
+		log.Println(rm.logFlag, "processJuiceJob", "Fail to open local", job.DestFile, err)
+		return err
+	}
+	defer f.Close()
 	err = rm.sdfs.Put(filename, job.DestFile)
 	if err != nil {
 		log.Println(rm.logFlag, "processJuiceJob", "Fail to put file into sdfs", err)