File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -153,7 +153,7 @@ private[continuous] class EpochCoordinator(
153153 // If not, add the epoch being currently processed to epochs waiting to be committed,
154154 // otherwise commit it.
155155 if (lastCommittedEpoch != epoch - 1 ) {
156- logDebug(s " Epoch $epoch has received commits from all partitions " +
156+ logDebug(s " Epoch $epoch has received commits from all partitions " +
157157 s " and is waiting for epoch ${epoch - 1 } to be committed first. " )
158158 epochsWaitingToBeCommitted.add(epoch)
159159 } else {
@@ -188,7 +188,7 @@ private[continuous] class EpochCoordinator(
188188 }
189189
190190 private def commitEpoch (epoch : Long , messages : Iterable [WriterCommitMessage ]): Unit = {
191- logDebug(s " Epoch $epoch has received commits from all partitions " +
191+ logDebug(s " Epoch $epoch has received commits from all partitions " +
192192 s " and is ready to be committed. Committing epoch $epoch. " )
193193 // Sequencing is important here. We must commit to the writer before recording the commit
194194 // in the query, or we will end up dropping the commit if we restart in the middle.
You can’t perform that action at this time.
0 commit comments