diff --git a/pkg/pipeline/sink/uploader/uploader.go b/pkg/pipeline/sink/uploader/uploader.go
index a50e0df8..c5b05644 100644
--- a/pkg/pipeline/sink/uploader/uploader.go
+++ b/pkg/pipeline/sink/uploader/uploader.go
@@ -83,14 +83,14 @@ func (u *remoteUploader) Upload(localFilepath, storageFilepath string, outputTyp
 	location, size, err := u.upload(localFilepath, storageFilepath, outputType)
 	elapsed := time.Since(start).Milliseconds()
 	if err == nil {
-		u.monitor.IncUploadCountFailure(fileType, float64(elapsed))
+		u.monitor.IncUploadCountSuccess(fileType, float64(elapsed))
 		if deleteAfterUpload {
 			_ = os.Remove(localFilepath)
 		}
 
 		return location, size, nil
 	}
-	u.monitor.IncUploadCountSuccess(fileType, float64(elapsed))
+	u.monitor.IncUploadCountFailure(fileType, float64(elapsed))
 
 	if u.backup != "" {
 		stat, err := os.Stat(localFilepath)