Review Board 1.7.22


Flume-209: UDP source

Review Request #2380 - Created Oct. 13, 2011 and updated

Mingjie Lai
trunk
Flume-209
Reviewers
Flume
flume-git
It would be nice to have something listen on a specified udp port and convert each packet them into flume events. This could be useful for "sensors" or other simple devices on the network.
TestUdp is added and passed locally.
Review request changed
Updated (Oct. 13, 2011, 6:07 p.m.)
Updated to fix the issues raised by Jon's reviews. Thanks, Jon. 
Ship it!
Posted (Oct. 18, 2011, 5:12 p.m.)
lgtm.
Posted (Oct. 21, 2011, 2:08 a.m.)

   

  
mvn test -Dtest=TestUdpSource

This line seems to fail due to timeout.  On a good run it seems to finish in 5-10s but on a bad run it fails.  

My guess is that there is udp loss due to a full udp buffer. Maybe it has the delay in the sink side is the problem? (why not process right away, and put delays on the send side?)

It would great to figure out why.