网站首页
编程语言
数据库
系统相关
其他分享
编程问答
sipDataInfo
2024-06-21
flinksql API StreamTableEnvironment StreamStatementSet应用
1.问题描述在应用flink实时消费kafka数据多端中,一般会使用flink原生的addsink或flinkSQL利用SqlDialect,比如消费kafka数据实时写入hive和kafka一般用两种方式:第一种方式是写入hive利用SqlDialect,写入kafka利用flink的旁路输出流+原生addSink第二种方式是写入hive和kafka都利用S