----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/2380/#review2731 -----------------------------------------------------------
flume-core/src/test/java/com/cloudera/flume/handlers/socket/TestUdpSource.java <https://reviews.apache.org/r/2380/#comment6147> 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. - jmhsieh On 2011-10-13 18:07:50, Mingjie Lai wrote: > > ----------------------------------------------------------- > This is an automatically generated e-mail. To reply, visit: > https://reviews.apache.org/r/2380/ > ----------------------------------------------------------- > > (Updated 2011-10-13 18:07:50) > > > Review request for Flume. > > > Summary > ------- > > 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. > > > This addresses bug Flume-209. > https://issues.apache.org/jira/browse/Flume-209 > > > Diffs > ----- > > flume-core/src/main/java/com/cloudera/flume/conf/SourceFactoryImpl.java > ed7b111 > flume-core/src/main/java/com/cloudera/flume/handlers/socket/UdpSource.java > PRE-CREATION > > flume-core/src/test/java/com/cloudera/flume/handlers/socket/TestUdpSource.java > PRE-CREATION > > Diff: https://reviews.apache.org/r/2380/diff > > > Testing > ------- > > TestUdp is added and passed locally. > > > Thanks, > > Mingjie > >
