apache flume自动关闭

at0kjp5o 于 2021-06-04 发布在 Flume

关注(0)|答案(1)|浏览(491)

我用的是flume 1.8.0，它自动关机，有人能帮我吗。
在Java8上运行
java_opts=“-server-xms4g-xmx4g”在flume的flume ng中配置
使用以下命令启动flume./bin/flume ng agent--conf conf--conf file./conf/flume-conf-postgresql.properties--name dfm topostgres stream&
关机前记录
2018年1月19日08:07:48914错误[pollablesourcerunner-customdbflumesource-s6]（com.ca.devops.dfm.db.dbcustomsource.customdbflumesource。process:200)-事务id:dfmsilo620180119130160，-异常java.lang.interruptedexception:sleep interrupted 2018年1月19日08:07:48，914信息[pollablesourcerunner-customdbflumesource-s6]（com.ca.devops.dfm.db.dbcustomsource.customdbflumesource。process:207)-事务id:dfmsilo620180119130160，-进程结束于2018年1月19日08:12:48915 info[代理关闭挂钩]（org.apache.flume.node.pollingpropertiesfileconfigurationprovider）。stop:84)-配置提供程序正在停止

flume flume-ng

来源：https://stackoverflow.com/questions/48346452/apache-flume-shutdown-automaticaly

1条答案

按热度按时间

n53p2ov01#

如果flume检测到配置文件发生更改，它将尝试重新加载其配置。
您在评论中引用的行： org.apache.flume.node.PollingPropertiesFileConfigurationProvider$FileWatcherRunnable.run:127) - Checking file:./conf/flume-conf-postgresql.properties for changes 表示这可能相关（通过logger.debug（）调用记录以上内容）
不过，我要补充一点，如果我 touch(1) 然后我看到配置文件记录了一次重新加载，但它没有退出： 26 Feb 2018 15:16:35,785 INFO [conf-file-poller-0] (org.apache.flume.node.PollingPropertiesFileConfigurationProvider$FileWatcherRunnable.run:134) - Reloading configuration file:/etc/opt/flume/conf/flume.conf 所以，不管是什么改变了文件，都是引入了一个错误？如果是这种情况，您应该看到另一个日志条目记录为错误，指示实际问题。
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);
}

赞(0）回复(0）举报 2021-06-04

我来回答

apache flume自动关闭

1条答案

相关问题

热门标签

最新问答