[chg]异常捕获

src/main/java/com/viontech/match/runner/ILM.java

@@ -16,6 +16,7 @@ import org.springframework.beans.factory.annotation.Value;
 import org.springframework.boot.CommandLineRunner;
 import org.springframework.stereotype.Component;
 
+import java.io.IOException;
 import java.util.Collections;
 import java.util.HashMap;
 import java.util.Map;
@@ -42,21 +43,25 @@ public class ILM implements CommandLineRunner {
 
     @Override
     public void run(String... args) throws Exception {
-        Map<String, Phase> phases = new HashMap<>();
-        Map<String, LifecycleAction> setPriorityAction = new HashMap<>();
-        setPriorityAction.put(SetPriorityAction.NAME, new SetPriorityAction(100));
-        phases.put("hot", new Phase("hot", TimeValue.ZERO, setPriorityAction));
-
-        Map<String, LifecycleAction> deleteActions =
-                Collections.singletonMap(DeleteAction.NAME, new DeleteAction());
-        phases.put("delete", new Phase("delete",
-                new TimeValue(deleteAfterDays, TimeUnit.DAYS), deleteActions));
-
-        LifecyclePolicy policy = new LifecyclePolicy(LIFECYCLE_NAME, phases);
-        PutLifecyclePolicyRequest lifecyclePolicyRequest = new PutLifecyclePolicyRequest(policy);
-        AcknowledgedResponse acknowledgedResponse = restHighLevelClient.indexLifecycle().putLifecyclePolicy(lifecyclePolicyRequest, RequestOptions.DEFAULT);
-        if (acknowledgedResponse.isAcknowledged()) {
-            log.info(LIFECYCLE_NAME + "生命周期创建完成");
+        try {
+            Map<String, Phase> phases = new HashMap<>();
+            Map<String, LifecycleAction> setPriorityAction = new HashMap<>();
+            setPriorityAction.put(SetPriorityAction.NAME, new SetPriorityAction(100));
+            phases.put("hot", new Phase("hot", TimeValue.ZERO, setPriorityAction));
+
+            Map<String, LifecycleAction> deleteActions =
+                    Collections.singletonMap(DeleteAction.NAME, new DeleteAction());
+            phases.put("delete", new Phase("delete",
+                    new TimeValue(deleteAfterDays, TimeUnit.DAYS), deleteActions));
+
+            LifecyclePolicy policy = new LifecyclePolicy(LIFECYCLE_NAME, phases);
+            PutLifecyclePolicyRequest lifecyclePolicyRequest = new PutLifecyclePolicyRequest(policy);
+            AcknowledgedResponse acknowledgedResponse = restHighLevelClient.indexLifecycle().putLifecyclePolicy(lifecyclePolicyRequest, RequestOptions.DEFAULT);
+            if (acknowledgedResponse.isAcknowledged()) {
+                log.info(LIFECYCLE_NAME + "生命周期创建完成");
+            }
+        } catch (Exception e) {
+            log.error("生命周期创建异常", e);
         }
     }
 }