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: [email protected]
For additional commands, e-mail: [email protected]