@@ -170,23 +170,23 @@ private[spark] class OutputCommitCoordinator(conf: SparkConf, isDriver: Boolean)
170
170
attemptNumber : Int ): Boolean = synchronized {
171
171
stageStates.get(stage) match {
172
172
case Some (state) if attemptFailed(state, stageAttempt, partition, attemptNumber) =>
173
- logInfo(s " Commit denied for stage= $stage/ $attemptNumber , partition= $partition: " +
173
+ logInfo(s " Commit denied for stage= $stage/ $stageAttempt , partition= $partition: " +
174
174
s " task attempt $attemptNumber already marked as failed. " )
175
175
false
176
176
case Some (state) =>
177
177
val existing = state.authorizedCommitters(partition)
178
178
if (existing == null ) {
179
- logDebug(s " Commit allowed for stage= $stage/ $attemptNumber , partition= $partition, " +
179
+ logDebug(s " Commit allowed for stage= $stage/ $stageAttempt , partition= $partition, " +
180
180
s " task attempt $attemptNumber" )
181
181
state.authorizedCommitters(partition) = TaskIdentifier (stageAttempt, attemptNumber)
182
182
true
183
183
} else {
184
- logDebug(s " Commit denied for stage= $stage/ $attemptNumber , partition= $partition: " +
184
+ logDebug(s " Commit denied for stage= $stage/ $stageAttempt , partition= $partition: " +
185
185
s " already committed by $existing" )
186
186
false
187
187
}
188
188
case None =>
189
- logDebug(s " Commit denied for stage= $stage/ $attemptNumber , partition= $partition: " +
189
+ logDebug(s " Commit denied for stage= $stage/ $stageAttempt , partition= $partition: " +
190
190
" stage already marked as completed." )
191
191
false
192
192
}
0 commit comments