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.
展开
收起
1
条回答
写回答
写回答
-
云邪：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
2019-07-17 23:28:14赞同 展开评论 打赏
问答分类：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
