aggregate connections working - debugging cancellation memory issue

Author: kaidaguerre

fdw.go

@@ -347,7 +347,7 @@ func goFdwAbortCallback() {
 			// DO NOT call FdwError or we will recurse
 		}
 	}()
-	log.Printf("[TRACE] goFdwAbortCallback")
+	log.Printf("[WARN] goFdwAbortCallback")
 	if pluginHub, err := hub.GetHub(); err == nil {
 		pluginHub.Abort()
 	}

hub/hub.go

@@ -243,7 +243,7 @@ func (h *Hub) Close() {
 
 // Abort shuts down currently running queries
 func (h *Hub) Abort() {
-	log.Printf("[TRACE] Hub Abort")
+	log.Printf("[WARN] Hub Abort")
 	// for all running iterators
 	for _, iter := range h.runningIterators {
 		// read the scan metadata from the iterator and add to our stack