tabres.PackageMap

src/jy/pretreated/analystep.go

@@ -6,6 +6,7 @@ package pretreated
 import (
 	"encoding/json"
 	"jy/util"
+
 	//"log"
 	"strings"
 
@@ -193,8 +194,6 @@ func processTableResult(tabres *TableResult, block *util.Block, job *util.Job) {
 								Key:   tk,
 								Value: tvv.Value,
 							})
-						}else if tabres.KvTags[tk] == nil{
-							block.TableKV.KvTags[tk] = tv
 						}
 					}
 				}

src/jy/pretreated/analytable.go

@@ -515,6 +515,9 @@ func (table *Table) MergerToTableresult() {
 			package1 := table.TableResult.PackageMap.Map[k]
 			if package1 == nil {
 				table.TableResult.PackageMap.AddKey(k, v)
+				if vvv,ok:= v.(*u.BlockPackage);ok{
+					MergeKvTags(table.TableResult.KvTags,vvv.TableKV.KvTags)
+				}
 			} else {
 				bp := package1.(*u.BlockPackage)
 				if bp.TableKV == nil {