[
https://issues.apache.org/jira/browse/FLUME-209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13132284#comment-13132284
]
[email protected] commented on FLUME-209:
-----------------------------------------------------
-----------------------------------------------------------
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:
bq.
bq. -----------------------------------------------------------
bq. This is an automatically generated e-mail. To reply, visit:
bq. https://reviews.apache.org/r/2380/
bq. -----------------------------------------------------------
bq.
bq. (Updated 2011-10-13 18:07:50)
bq.
bq.
bq. Review request for Flume.
bq.
bq.
bq. Summary
bq. -------
bq.
bq. 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.
bq.
bq.
bq. This addresses bug Flume-209.
bq. https://issues.apache.org/jira/browse/Flume-209
bq.
bq.
bq. Diffs
bq. -----
bq.
bq. flume-core/src/main/java/com/cloudera/flume/conf/SourceFactoryImpl.java
ed7b111
bq.
flume-core/src/main/java/com/cloudera/flume/handlers/socket/UdpSource.java
PRE-CREATION
bq.
flume-core/src/test/java/com/cloudera/flume/handlers/socket/TestUdpSource.java
PRE-CREATION
bq.
bq. Diff: https://reviews.apache.org/r/2380/diff
bq.
bq.
bq. Testing
bq. -------
bq.
bq. TestUdp is added and passed locally.
bq.
bq.
bq. Thanks,
bq.
bq. Mingjie
bq.
bq.
> Raw UDP Packet source.
> ----------------------
>
> Key: FLUME-209
> URL: https://issues.apache.org/jira/browse/FLUME-209
> Project: Flume
> Issue Type: New Feature
> Components: Easy, Sinks+Sources
> Reporter: Jonathan Hsieh
>
> 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 is probably just a simplification of syslogudp.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators:
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
