summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--ip-learning-spark/src/main/scala/cn/ac/iie/service/update/UpdateDocument.scala5
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)
}
}