[ISSUE #975]when close consumer, return directly

apache · Dec 19, 2022 · 896a8a3 · 896a8a3
1 parent f56a2db
commit 896a8a3
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/internal/trace.go b/internal/trace.go
@@ -382,6 +382,7 @@ func (td *traceDispatcher) process() {
 				runtime.Gosched()
 			}
 			rlog.Info(fmt.Sprintf("------end trace send %v %v", td.input, td.batchCh), nil)
+			return
 		}
 	}
 }