fix(lookup): fix a compilation error after switch to pubsub package

Signed-off-by: Jiyong Huang <huangjy@emqx.io>

internal/plugin/portable/test/portable_rule_test.go

@@ -24,7 +24,7 @@ import (
 	"github.com/lf-edge/ekuiper/internal/plugin/portable/runtime"
 	"github.com/lf-edge/ekuiper/internal/processor"
 	"github.com/lf-edge/ekuiper/internal/topo"
-	"github.com/lf-edge/ekuiper/internal/topo/memory"
+	"github.com/lf-edge/ekuiper/internal/topo/memory/pubsub"
 	"github.com/lf-edge/ekuiper/internal/topo/planner"
 	"github.com/lf-edge/ekuiper/internal/topo/topotest"
 	"github.com/lf-edge/ekuiper/pkg/api"
@@ -111,7 +111,7 @@ func TestSourceAndFunc(t *testing.T) {
 			continue
 		}
 		var mm [][]map[string]interface{}
-		ch := memory.CreateSub("cache", nil, fmt.Sprintf("cache%d", i+1), 10)
+		ch := pubsub.CreateSub("cache", nil, fmt.Sprintf("cache%d", i+1), 10)
 		ctx, cancel := context.WithTimeout(context.Background(), 10000*time.Second)
 		go func(ctx context.Context) {
 			select {