我试图用flume读取一个syslog，使用morpline将其分成几个部分，并用delimiter''将结果写入hdfs，但我不知道如何将'grok'的输出重定向到sink。
谢谢！！
这是我的变形线文件：
morphlines:[{id:morphline1

commands : [
  {               
    readLine {
      charset : UTF-8
    }
  }

  {
    grok {
      dictionaryFiles : [/grok-dictionaries]
      expressions : {
        message : """<%{POSINT:priority}>%{SYSLOGTIMESTAMP:timestamp} %{SYSLOGHOST:hostname} %{DATA:program}(?:\[%{POSINT:pid}\])?: %{GREEDYDATA:msg}"""
      }
    }
  }

]

} ]