本人剛剛接觸flume，在運行時候遇到了問題，希望有大神能夠幫忙看看：
.conf 檔案代碼如下：（監聽/root/data/data.log 中的log輸入）
[code=css]configration file:[/code]
a1.sources = r1
a1.sinks = k1
a1.channels = c1
# Describe/configure the source
a1.sources.r1.type = exec
a1.sources.r1.command=tail -F /root/data/data.log
a1.sources.r1.shell=/bin/sh -c
# Describe the sink
a1.sinks.k1.type = logger
# Use a channel which buffers events in memory
a1.channels.c1.type = memory
# Bind the source and sink to the channel
a1.sources.r1.channels = c1
a1.sinks.k1.channel = c1
報錯 ：
2020-03-01 03:13:34,655 (conf-file-poller-0) [WARN - org.apache.flume.node.AbstractConfigurationProvider.getConfiguration(AbstractConfigurationProvider.java:138)] No configuration found for this host:$
log:
2020-03-01 03:13:34,385 (lifecycleSupervisor-1-0) [INFO - org.apache.flume.node.PollingPropertiesFileConfigurationProvider.start(PollingPropertiesFileConfigurationProvider.java:61)] Configuration provider starting
2020-03-01 03:13:34,424 (conf-file-poller-0) [INFO - org.apache.flume.node.PollingPropertiesFileConfigurationProvider$FileWatcherRunnable.run(PollingPropertiesFileConfigurationProvider.java:133)] Reloading configuration file:/usr/hdp/current/flume-server/conf/exec-memory-logger.conf
2020-03-01 03:13:34,554 (conf-file-poller-0) [INFO - org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty(FlumeConfiguration.java:933)] Added sinks: k1 Agent: a1
2020-03-01 03:13:34,554 (conf-file-poller-0) [INFO - org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty(FlumeConfiguration.java:1019)] Processing:k1
2020-03-01 03:13:34,554 (conf-file-poller-0) [INFO - org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty(FlumeConfiguration.java:1019)] Processing:k1
2020-03-01 03:13:34,633 (conf-file-poller-0) [INFO - org.apache.flume.conf.FlumeConfiguration.validateConfiguration(FlumeConfiguration.java:140)] Post-validation flume configuration contains configuration for agents: [a1]
2020-03-01 03:13:34,655 (conf-file-poller-0) [WARN - org.apache.flume.node.AbstractConfigurationProvider.getConfiguration(AbstractConfigurationProvider.java:138)] No configuration found for this host:$
uj5u.com熱心網友回復：
看看執行的命令轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/78100.html
標籤：分布式計算/Hadoop
下一篇：hadoop 腳本