Skip to content

Commit 149948b

Browse files
committed
Fixed mistake
1 parent 14630aa commit 149948b

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

external/kafka/src/main/scala/org/apache/spark/streaming/kafka/ReliableKafkaReceiver.scala

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -227,8 +227,9 @@ class ReliableKafkaReceiver[
227227

228228
ZkUtils.updatePersistentPath(zkClient, zkPath, offset.toString)
229229
} catch {
230-
case e: Exception => logWarning(s"Exception during commit offset $offset for topic" +
231-
s"${topicAndPart.topic}, partition ${topicAndPart.partition}", t)
230+
case e: Exception =>
231+
logWarning(s"Exception during commit offset $offset for topic" +
232+
s"${topicAndPart.topic}, partition ${topicAndPart.partition}", e)
232233
}
233234

234235
logInfo(s"Committed offset $offset for topic ${topicAndPart.topic}, " +

0 commit comments

Comments
 (0)