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 d767ca2..16a77d3 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
@@ -149,8 +149,8 @@ object UpdateDocument {
       } else {
         subidLocIpDoc = new BaseEdgeDocument()
         subidLocIpDoc.setKey(key)
-        subidLocIpDoc.setFrom("SUBSCRIBER/" + subId)
-        subidLocIpDoc.setTo("IP/" + ip)
+        subidLocIpDoc.setFrom("SUBSCRIBER/" + subId + "-" + vsysId)
+        subidLocIpDoc.setTo("IP/" + ip+ "-" + vsysId)
         subidLocIpDoc.addAttribute("SUBSCRIBER", subId)
         subidLocIpDoc.addAttribute("IP", ip)
         subidLocIpDoc.addAttribute("FIRST_FOUND_TIME", firstFoundTime)
@@ -293,8 +293,8 @@ object UpdateDocument {
       } else {
         fqdnLocIpDoc = new BaseEdgeDocument()
         fqdnLocIpDoc.setKey(key)
-        fqdnLocIpDoc.setFrom("FQDN/" + fqdn)
-        fqdnLocIpDoc.setTo("IP/" + serverIp)
+        fqdnLocIpDoc.setFrom("FQDN/" + fqdn+ "-" + vsysId)
+        fqdnLocIpDoc.setTo("IP/" + serverIp+ "-" + vsysId)
         fqdnLocIpDoc.addAttribute("FIRST_FOUND_TIME", firstFoundTime)
         fqdnLocIpDoc.addAttribute("LAST_FOUND_TIME", lastFoundTime)
         fqdnLocIpDoc.addAttribute("VSYS_ID", vsysId)