a1.sources = s1 a1.channels = c1 a1.sinks = k1 a1.sources.s1.type = spooldir a1.sources.s1.spoolDir = /opt/test/a1 a1.channels.c1.type = memory a1.channels.c1.capacity = 1000 a1.channels.c1.transactionCapacity = 100 a1.sinks.k1.type = hdfs a1.sinks.k1.hdfs.path = /flume/events/%Y-%m-%d/%H%M/%S a1.sinks.k1.hdfs.filePrefix = events- a1.sinks.k1.hdfs.round = true a1.sinks.k1.hdfs.roundValue = 10 a1.sinks.k1.hdfs.roundUnit = minute a1.sinks.k1.hdfs.useLocalTimeStamp = true a1.sources.s1.channels = c1 a1.sink.k1.channels = c1org.apache.flume.conf.configurationexception: no channel configured for sink
时间: 2023-11-15 08:04:18 浏览: 87
Flume的channel和sink.docx
这个错误是因为在Flume配置文件中,Sink的名称写错了。在最后一行中,应该是`a1.sinks.k1.channels`,而不是`a1.sink.k1.channels`。
将最后一行修改为以下内容即可:
```
a1.sinks.k1.channels = c1
```
然后重新启动Flume即可。
阅读全文