fix: lookup table problems

go.mod

@@ -26,7 +26,7 @@ require (
 	github.com/keepeye/logrus-filename v0.0.0-20190711075016-ce01a4391dd1
 	github.com/klauspost/compress v1.17.7
 	github.com/lestrrat-go/file-rotatelogs v2.4.0+incompatible
-	github.com/lf-edge/ekuiper/contract/v2 v2.0.0-alpha.2
+	github.com/lf-edge/ekuiper/contract/v2 v2.0.0-alpha.3
 	github.com/mitchellh/mapstructure v1.5.0
 	github.com/mochi-mqtt/server/v2 v2.6.4
 	github.com/modern-go/reflect2 v1.0.2

internal/topo/node/lookup_node.go

@@ -87,12 +87,15 @@ func NewLookupNode(ctx api.StreamContext, name string, isBytesLookup bool, field
 		if (sc.PayloadFormat == "" && sc.PayloadField != "") || (sc.PayloadFormat != "" && sc.PayloadField == "") {
 			return nil, fmt.Errorf("payloadFormat and payloadField must set together")
 		}
-		sch := make(map[string]*ast.JsonStreamField, len(fields))
-		for _, field := range fields {
-			sch[field] = nil
-		}
-		if sc.PayloadField != "" {
-			sch[sc.PayloadField] = nil
+		var sch map[string]*ast.JsonStreamField
+		if len(fields) > 0 {
+			sch = make(map[string]*ast.JsonStreamField, len(fields))
+			for _, field := range fields {
+				sch[field] = nil
+			}
+			if sc.PayloadField != "" {
+				sch[sc.PayloadField] = nil
+			}
 		}
 
 		decoder, err := converter.GetOrCreateConverter(ctx, srcOptions.FORMAT, srcOptions.SCHEMAID, sch, props)

pkg/nng/sock.go

@@ -146,7 +146,7 @@
 	if s.Socket != nil && s.connected.Load() {
 		return s.Socket.Send(data)
 	}
-	return errorx.NewIOErr(`neuron connection is not established`)
+	return errorx.NewIOErr(`nng connection is not established`)
 }
 
 var _ modules.Connection = &Sock{}