AMBARI-24750: Fix NPE when trying to set loglevel in logsearch (#81)

apache · Oct 14, 2022 · 677c4ca · 677c4ca
1 parent ebcda71
commit 677c4ca
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...r/src/main/java/org/apache/ambari/logsearch/config/zookeeper/LogLevelFilterManagerZK.java b/...r/src/main/java/org/apache/ambari/logsearch/config/zookeeper/LogLevelFilterManagerZK.java
@@ -87,7 +87,8 @@ public void setLogLevelFilters(String clusterName, LogLevelFilterMap filters) th
     for (Map.Entry<String, LogLevelFilter> e : filters.getFilter().entrySet()) {
       String nodePath = String.format("/%s/loglevelfilter/%s", clusterName, e.getKey());
       String logLevelFilterJson = gson.toJson(e.getValue());
-      String currentLogLevelFilterJson = new String(serverCache.getCurrentData(nodePath).getData());
+      ChildData childData = serverCache.getCurrentData(nodePath);
+      String currentLogLevelFilterJson = childData != null ? new String(childData.getData()) : null;
       if (!logLevelFilterJson.equals(currentLogLevelFilterJson)) {
         client.setData().forPath(nodePath, logLevelFilterJson.getBytes());
         logger.info("Set log level filter for the log " + e.getKey() + " for cluster " + clusterName);