File tree Expand file tree Collapse file tree 1 file changed +3
-1
lines changed
external/flume/src/main/scala/org/apache/spark/streaming/flume Expand file tree Collapse file tree 1 file changed +3
-1
lines changed Original file line number Diff line number Diff line change @@ -116,15 +116,17 @@ private[streaming] class FlumePollingReceiver(
116116 logDebug(" Stored events with seq:" + seq)
117117 j += 1
118118 }
119- logDebug(" Sending ack for: " + seq)
119+ logDebug(" Sending ack for sequence number : " + seq)
120120 // Send an ack to Flume so that Flume discards the events from its channels.
121121 client.ack(seq)
122122 logDebug(" Ack sent for sequence number: " + seq)
123123 } catch {
124124 case e : Exception =>
125125 try {
126126 // Let Flume know that the events need to be pushed back into the channel.
127+ logDebug(" Sending nack for sequence number: " + seq)
127128 client.nack(seq) // If the agent is down, even this could fail and throw
129+ logDebug(" Nack sent for sequence number: " + seq)
128130 } catch {
129131 case e : Exception => logError(
130132 " Sending Nack also failed. A Flume agent is down." )
You can’t perform that action at this time.
0 commit comments