开发者社区 问答 正文

Blink streaming 不支持print(), 那为什么又有这样的api呢 val sql1 = "SELECT a, c FROM sourceTable" tEnv.sqlQuery(sql1).print() // org.apache.flink.table.api.TableException: collect is not supported.

转自钉钉群21789141:Blink streaming 不支持print(), 那为什么又有这样的api呢

val sql1 = "SELECT a, c FROM sourceTable"
tEnv.sqlQuery(sql1).print()
// org.apache.flink.table.api.TableException: collect is not supported.

展开
收起
赵慧@ApacheFlink中文社区 2019-02-14 15:20:45 3915 分享 版权
1 条回答
写回答
取消 提交回答