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.-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文

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.

赵慧 2019-02-14 15:20:45 1549

转自钉钉群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.
API 流计算
分享到
取消 提交回答
全部回答(1)
  • 赵慧
    2019-07-17 23:28:14

    云邪:Table.print 目前只能在batch模式下使用,如果要在streaming模式下用print的话,需要先将Table转成DataStream, table.toAppendStream[Row].print()

    问:嗯,那这个和flink是一样的
    tEnv.getConfig.setSubsectionOptimization(true)
    这个设置为true会有什么功能呢

    云邪: 分段优化功能,用来支持多sink的。 可以先看下这个文档 https://github.com/apache/flink/blame/blink/docs/dev/table/multiple_tablesink_optimization.md

    0 0
大数据
使用钉钉扫一扫加入圈子
+ 订阅

大数据计算实践乐园,近距离学习前沿技术

推荐文章
相似问题
推荐课程