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(
116
116
logDebug(" Stored events with seq:" + seq)
117
117
j += 1
118
118
}
119
- logDebug(" Sending ack for: " + seq)
119
+ logDebug(" Sending ack for sequence number : " + seq)
120
120
// Send an ack to Flume so that Flume discards the events from its channels.
121
121
client.ack(seq)
122
122
logDebug(" Ack sent for sequence number: " + seq)
123
123
} catch {
124
124
case e : Exception =>
125
125
try {
126
126
// Let Flume know that the events need to be pushed back into the channel.
127
+ logDebug(" Sending nack for sequence number: " + seq)
127
128
client.nack(seq) // If the agent is down, even this could fail and throw
129
+ logDebug(" Nack sent for sequence number: " + seq)
128
130
} catch {
129
131
case e : Exception => logError(
130
132
" Sending Nack also failed. A Flume agent is down." )
You can’t perform that action at this time.
0 commit comments