修改ip池数据linkInfo设置方式tsg-v2210

1 files changed, 4 insertions, 1 deletions

diff --git a/ip-learning-spark/src/main/scala/cn/ac/iie/service/update/UpdateDocument.scala b/ip-learning-spark/src/main/scala/cn/ac/iie/service/update/UpdateDocument.scala
index 7821ee2..2bd7732 100644
--- a/ip-learning-spark/src/main/scala/cn/ac/iie/service/update/UpdateDocument.scala
+++ b/ip-learning-spark/src/main/scala/cn/ac/iie/service/update/UpdateDocument.scala
@@ -25,6 +25,7 @@ object UpdateDocument {
     } finally {
       arangoManger.clean()
       SparkSessionUtil.closeSpark()
+      System.exit(0)
     }
   }
 
@@ -38,6 +39,7 @@ object UpdateDocument {
     } finally {
       arangoManger.clean()
       SparkSessionUtil.closeSpark()
+      System.exit(0)
     }
   }
 
@@ -49,6 +51,7 @@ object UpdateDocument {
     } finally {
       arangoManger.clean()
       SparkSessionUtil.closeSpark()
+      System.exit(0)
     }
   }
 
@@ -253,7 +256,7 @@ object UpdateDocument {
         ipDoc.addAttribute("SERVER_BYTES_SUM", sepAttributeTuple._2)
         ipDoc.addAttribute("CLIENT_SESSION_COUNT", sepAttributeTuple._3)
         ipDoc.addAttribute("CLIENT_BYTES_SUM", sepAttributeTuple._4)
-        ipDoc.addAttribute("COMMON_LINK_INFO", "")
+        ipDoc.addAttribute("COMMON_LINK_INFO", linkInfo)
         ipDoc.addAttribute("VSYS_ID", vsysId)
       }
     }