Log message update.

apache · Jun 21, 2018 · fdcd39c · fdcd39c
1 parent d5a079d
commit fdcd39c
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...re/src/main/scala/org/apache/spark/sql/execution/datasources/v2/WriteToDataSourceV2.scala b/...re/src/main/scala/org/apache/spark/sql/execution/datasources/v2/WriteToDataSourceV2.scala
@@ -140,15 +140,15 @@ object DataWritingSparkTask extends Logging {
         dataWriter.commit()
       }
 
-      logInfo(s"Writer for stage $stageId, task $partId (TID $taskId) committed.")
+      logInfo(s"Writer for stage $stageId, part $partId (TID $taskId) committed.")
 
       msg
 
     })(catchBlock = {
       // If there is an error, abort this writer
-      logError(s"Writer for stage $stageId, task $partId (TID $taskId) is aborting.")
+      logError(s"Writer for stage $stageId, part $partId (TID $taskId) is aborting.")
       dataWriter.abort()
-      logError(s"Writer for stage $stageId, task $partId (TID $taskId) aborted.")
+      logError(s"Writer for stage $stageId, part $partId (TID $taskId) aborted.")
     })
   }
 }