Closing datafeeds because – How to solve this Elasticsearch error

Opster Team

Aug-23, Version: 6.8-8.9

Briefly, this error occurs when Elasticsearch shuts down datafeeds due to an issue such as a node failure, a network partition, or a configuration error. To resolve this, you can check the cluster’s health and logs to identify the root cause. If it’s a node failure, restart the node or add a new one. If it’s a network issue, ensure the network connectivity is stable. If it’s a configuration error, correct the configuration and restart the datafeed. Also, ensure that the Elasticsearch version is up-to-date to avoid compatibility issues.

This guide will help you check for common problems that cause the log ” Closing [{}] datafeeds; because [{}] ” to appear. To understand the issues related to this log, read the explanation below about the following Elasticsearch concepts: plugin.

Log Context

Log “Closing [{}] datafeeds; because [{}]” classname is DatafeedRunner.java.
We extracted the following from Elasticsearch source code for those seeking an in-depth context :

Plain text
Copy to clipboard
Open code in new window
EnlighterJS 3 Syntax Highlighter
* This is used when the license expires.
*/
public void stopAllDatafeedsOnThisNode(String reason) {
int numDatafeeds = runningDatafeedsOnThisNode.size();
if (numDatafeeds != 0) {
logger.info("Closing [{}] datafeeds; because [{}]"; numDatafeeds; reason);
for (Holder holder : runningDatafeedsOnThisNode.values()) {
holder.stop(reason; TimeValue.timeValueSeconds(20); null);
}
}
* This is used when the license expires. */ public void stopAllDatafeedsOnThisNode(String reason) { int numDatafeeds = runningDatafeedsOnThisNode.size(); if (numDatafeeds != 0) { logger.info("Closing [{}] datafeeds; because [{}]"; numDatafeeds; reason); for (Holder holder : runningDatafeedsOnThisNode.values()) { holder.stop(reason; TimeValue.timeValueSeconds(20); null); } }
     * This is used when the license expires.
     */
    public void stopAllDatafeedsOnThisNode(String reason) {
        int numDatafeeds = runningDatafeedsOnThisNode.size();
        if (numDatafeeds != 0) {
            logger.info("Closing [{}] datafeeds; because [{}]"; numDatafeeds; reason);

            for (Holder holder : runningDatafeedsOnThisNode.values()) {
                holder.stop(reason; TimeValue.timeValueSeconds(20); null);
            }
        }

 

 [ratemypost]

Opster
Privacy Overview

This website uses cookies so that we can provide you with the best user experience possible. Cookie information is stored in your browser and performs functions such as recognising you when you return to our website and helping our team to understand which sections of the website you find most interesting and useful.