You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flume.apache.org by "leihongyang (Jira)" <ji...@apache.org> on 2020/05/21 07:38:00 UTC

[jira] [Created] (FLUME-3367) HDFS sink append support is not working

leihongyang created FLUME-3367:
----------------------------------

             Summary: HDFS sink append support is not working
                 Key: FLUME-3367
                 URL: https://issues.apache.org/jira/browse/FLUME-3367
             Project: Flume
          Issue Type: Bug
          Components: Sinks+Sources
    Affects Versions: 1.9.0
            Reporter: leihongyang


HDFS sink append support is not working!

The context obtained from the configuration is incorrect,

for example *HDFSDataStream.java line 78.*

NOW: 

       {color:#FF0000}if (conf.getBoolean("hdfs.append.support", false) == true && hdfs.isFile(dstPath)){color}

this  "conf" is new Configuration(), not Context, *this value will always be false.*

So here should be:

       {color:#FF0000}context.getBoolean("hdfs.append.support", false){color}

This problem also exists in other DataStream.java



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@flume.apache.org
For additional commands, e-mail: issues-help@flume.apache.org