Re: 关于flink cdc sql转出Stream流问题

[jsqf]

可以使用这种方式:
DataStream<RowData> dstream = tableEnv.toAppendStream(sourceTable,
RowData.class);



--
Sent from: http://apache-flink.147419.n8.nabble.com/