support decode schemaless

Signed-off-by: yisaer <disxiaofei@163.com>
lf-edge · Dec 14, 2023 · 6c5e4ec · 6c5e4ec
1 parent 9824671
commit 6c5e4ec
Showing 1 changed file with 1 addition and 5 deletions.
diff --git a/internal/topo/planner/planner.go b/internal/topo/planner/planner.go
@@ -286,11 +286,7 @@ func transformSourceNode(t *DataSourcePlan, mockSourcesProp map[string]map[strin
 				return nil, err
 			}
 		}
-		schema := t.streamFields
-		if t.isSchemaless {
-			schema = nil
-		}
-		srcNode := node.NewSourceNode(string(t.name), t.streamStmt.StreamType, pp, t.streamStmt.Options, options.SendError, schema)
+		srcNode := node.NewSourceNode(string(t.name), t.streamStmt.StreamType, pp, t.streamStmt.Options, options.SendError, t.streamFields)
 		if isMock {
 			srcNode.SetProps(mockSourceConf)
 		}