diff --git a/probe/endpoint/reporter.go b/probe/endpoint/reporter.go
index d76f655f3..99c3742e2 100644
--- a/probe/endpoint/reporter.go
+++ b/probe/endpoint/reporter.go
@@ -158,7 +158,9 @@ func (r *Reporter) Report() (report.Report, error) {
 				e.DestPort,
 			}
 
-			r.addConnection(&rpt, tuple, "", extraNodeInfo, extraNodeInfo)
+			fromNodeInfo[process.PID] = strconv.Itoa(e.Pid)
+			fromNodeInfo[report.HostNodeID] = hostNodeID
+
 		})
 	}