MINOR: Fix comment about AbstractFetcherThread.handlePartitionsWithError
Reviewers: Stanislav Kozlovski<stanislav_kozlovski@outlook.com>, William Hammond<william.t.hammond@gmail.com>, Chia-Ping Tsai<chia7712@gmail.com>
@@ -306,7 +306,7 @@ abstract class AbstractFetcherThread(name: String,
inLock(partitionMapLock) {
partitionsWithError ++= partitionStates.partitionSet.asScala
// there is an error occurred while fetching partitions, sleep a while
- // note that `ReplicaFetcherThread.handlePartitionsWithError` will also introduce the same delay for every
+ // note that `AbstractFetcherThread.handlePartitionsWithError` will also introduce the same delay for every
// partition with error effectively doubling the delay. It would be good to improve this.
partitionMapCond.await(fetchBackOffMs, TimeUnit.MILLISECONDS)
}
