浏览代码

fix #1507 skit flush when using cluster runner

Shinsuke Sugaya 7 年之前
父节点
当前提交
ce4ddda567
共有 1 个文件被更改,包括 7 次插入5 次删除
  1. 7 5
      src/main/java/org/codelibs/fess/es/client/FessEsClient.java

+ 7 - 5
src/main/java/org/codelibs/fess/es/client/FessEsClient.java

@@ -629,11 +629,13 @@ public class FessEsClient implements Client {
     @Override
     @PreDestroy
     public void close() {
-        try {
-            client.admin().indices().prepareFlush().setForce(true).execute()
-                    .actionGet(ComponentUtil.getFessConfig().getIndexIndicesTimeout());
-        } catch (final Exception e) {
-            logger.warn("Failed to flush indices.", e);
+        if (runner != null) {
+            try {
+                client.admin().indices().prepareFlush().setForce(true).execute()
+                        .actionGet(ComponentUtil.getFessConfig().getIndexIndicesTimeout());
+            } catch (final Exception e) {
+                logger.warn("Failed to flush indices.", e);
+            }
         }
         try {
             client.close();