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) } }