zhiqiangzhao created FLUME-3074:
-----------------------------------

             Summary: format error happened on windows when kafka sink is used
                 Key: FLUME-3074
                 URL: https://issues.apache.org/jira/browse/FLUME-3074
             Project: Flume
          Issue Type: Bug
          Components: Sinks+Sources
    Affects Versions: 1.7.0
         Environment: windows 10
            Reporter: zhiqiangzhao


When I use kafka sink to push logs from windows path to kafka server, I meet 
the  format error as follows

I think  it is because windows path was  parsed in linux style。

17 三月 2017 11:54:29,476 ERROR [SinkRunner-PollingRunner-DefaultSinkProcessor] 
(org.apache.flume.SinkRunner$PollingRunner.run:158)  - Unable to deliver event. 
Exception follows.
org.apache.flume.EventDeliveryException: Failed to publish events
        at org.apache.flume.sink.kafka.KafkaSink.process(KafkaSink.java:252)
        at 
org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:67)
        at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:145)
        at java.lang.Thread.run(Thread.java:745)
Caused by: org.apache.flume.EventDeliveryException: Non integer partition id 
specified
        at org.apache.flume.sink.kafka.KafkaSink.process(KafkaSink.java:214)
        ... 3 more
Caused by: java.lang.NumberFormatException: For input string: 
"C:\Users\smart\Desktop\source\23.txt"
        at 
java.lang.NumberFormatException.forInputString(NumberFormatException.java:65)
        at java.lang.Integer.parseInt(Integer.java:580)
        at java.lang.Integer.parseInt(Integer.java:615)
        at org.apache.flume.sink.kafka.KafkaSink.process(KafkaSink.java:202)
        ... 3 more



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Reply via email to