Skip to content
This repository was archived by the owner on May 9, 2024. It is now read-only.

Commit c21d7c4

Browse files
committed
Add log message on rate update
1 parent 24db6fc commit c21d7c4

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

streaming/src/main/scala/org/apache/spark/streaming/receiver/ReceiverSupervisorImpl.scala

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -77,8 +77,10 @@ private[streaming] class ReceiverSupervisorImpl(
7777
case CleanupOldBlocks(threshTime) =>
7878
logDebug("Received delete old batch signal")
7979
cleanupOldBlocks(threshTime)
80-
case RateLimitUpdate(eps) =>
80+
case RateLimitUpdate(eps) => {
8181
blockGenerator.updateRate(eps.toInt)
82+
logDebug(s"Received update for $streamId : $eps")
83+
}
8284
}
8385
})
8486

0 commit comments

Comments
 (0)