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