|
|
@@ -48,7 +48,6 @@ class HDFSWriter(Writer):
|
|
|
self.config_parser.get(self.plugin_type, HDFS_WRITER_PARAMETER_WRITE_MODE) or 'append'
|
|
|
self.parameter[HDFS_WRITER_PARAMETER_FIELD_DELIMITER] = \
|
|
|
self.config_parser.get(self.plugin_type, HDFS_WRITER_PARAMETER_FIELD_DELIMITER).replace("\\t", "\t") or '\t'
|
|
|
- self.parameter['kerberosPrincipal'] = 'hdfs@LIXIAOYUN.COM'
|
|
|
self.get_file_name()
|
|
|
|
|
|
def get_file_name(self):
|
