阿帕奇水槽自动关闭

Question

我正在使用 flume 1.8.0，它会自动关闭，任何人都可以帮助我。

1. 在 JAVA 8 上运行
2. JAVA_OPTS=“-服务器 -Xms4g -Xmx4g” 配置在水槽中
3. 使用以下命令启动 flume ./bin/flume-ng agent --conf conf --conf-file ./conf/flume-conf-postgresql.properties --name dfm-topostgres-stream

关机前登录

2018年1月19日08:07:48，914错误[PollableSourceRunner-CustomDBFlumeSource-S6](com . ca . devo PS . DFM . db . dbcustomsource . CustomDBFlumeSource . process:200)-事务id: DFMSILO620180119130160，-异常java.lang.InterruptedException:睡眠中断2018年1月19日08:07:48，914信息[pollablesourcer

Answer 1

如果检测到配置文件的更改，Flume将尝试重新加载其配置。

你在评论中引用的那句话:

org.apache.flume.node.PollingPropertiesFileConfigurationProvider$FileWatcherRunnable。运行：127）-正在检查文件：./conf/flume conf postgresql。更改的属性

表示这可能是相关的（上面是通过logger.debug（）调用记录的）

不过，我应该补充一点，如果我只是触摸（1）配置文件，那么我会看到它记录重新加载，但它不会退出：

26 Feb 2018 15：16：35，785 INFO [conf-file-poller-0] （org.apache.flume.node.PollingPropertiesFileConfigurationProvider$FileWatcherRunnable.run：134） - 重新加载配置文件：/etc/opt/flume/conf/flume.conf

因此，可能更改文件的任何内容都会引入错误？如果是这种情况，您应该会看到另一个日志条目记录为ERROR，表明实际问题。

pollingpropertiesfileconfigurationprovider . Java:

try {
  eventBus.post(getConfiguration());
} catch (Exception e) {
  LOGGER.error("Failed to load configuration data. Exception follows.",
      e);
} catch (NoClassDefFoundError e) {
  LOGGER.error("Failed to start agent because dependencies were not " +
      "found in classpath. Error follows.", e);
} catch (Throwable t) {
  // caught because the caller does not handle or log Throwables
  LOGGER.error("Unhandled error", t);
}