diff --git a/iothub/netbase/hook_base.go b/iothub/netbase/hook_base.go
index cd25af3..f0aad85 100644
--- a/iothub/netbase/hook_base.go
+++ b/iothub/netbase/hook_base.go
@@ -88,6 +88,7 @@ func CreateSubTableField(productId, ty string, fields map[string]interface{}) {
 	for key, value := range fields {
 		group.Add(1)
 		go func(key string, value any) {
+            defer group.Done()
 			if key == "ts" {
 				return
 			}