看下你的 Flink 版本是多少，如果是高版本的话，社区有提供 DataStream 的 HBase Sink。
Best， LakeShen. Zorro <liebin...@gmail.com> 于2021年5月31日周一 下午2:41写道： > 由于你的DDL是变化的，无法提前预知所有字段，所以首先可以确定的是这个场景无法使用Flink SQL解决。 > > 如果使用DataStream解决的话是可行的，唯一可能存在的问题就是目前社区没有提供DataStream的HBase sink。 > 如果你需要在DataStream中使用HBase sink的话，可能需要你自定义一个HBase sink或者基于社区的HBase SQL > connector做一些更改。不过这些更改是需要在Java代码层面的。 > > 至于其他的处理逻辑可以用pyFlink很方便的改写。 > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/
