hdfs.filePrefix = <<FILE_PREFIX>>-%{host}-%d-%H-%m-%s
hdfs.fileSuffix = <<FILE_SUFFIX>>-%{host}-%d-%H-%m-%s
%{host} = "It will pick up the hostname of your machine"
%t = "It will provide unix time in milliseconds "
%d= "Date"
%H= "Hour"
%m= "minutes"
%s= "seconds"
1条答案
按热度按时间bis0qfac1#
对。您可以通过以下参数配置hdfs sink中的文件名。
因此flume bucket writer将线程打开到hdfs进行写入,通过使用“prifix/后缀”,我们可以动态创建文件名。