diff --git a/internal/jar/jar.go b/internal/jar/jar.go
index 54fad6c..5686a18 100644
--- a/internal/jar/jar.go
+++ b/internal/jar/jar.go
@@ -40,6 +40,7 @@ func (JarFile *JarFile) Upload(flinkClient *api.Client) (fileName string, err er
 	if resp.Status != "success" {
 		err = errors.New("jar upload was not success")
 	}
+	JarFile.filePath = fileName
 	return
 }
 
diff --git a/internal/managed_job/run.go b/internal/managed_job/run.go
index 3236abd..efb4ad1 100644
--- a/internal/managed_job/run.go
+++ b/internal/managed_job/run.go
@@ -18,11 +18,14 @@ func (job *ManagedJob) upload() error {
 		return err
 	}
 	fileName, err := jarFile.Upload(job.client)
-	jarFile.Delete()
 	if err != nil {
 		lc.Logger.Debug("[main] error on upload jar", zap.Error(err))
 		return err
 	}
+	err = jarFile.Delete()
+	if err != nil {
+		lc.Logger.Debug("[main] error on delete jar", zap.Error(err))
+	}
 	lc.Logger.Debug("[main] after upload jar", zap.Any("upload-jar-resp", fileName))
 
 	job.def.Status.JarId = &fileName