useOldPlanner()就不会有这个问题。
张健
useOldPlanner()就不会有这个问题。
张健
useOldPlanner()就不会有这个问题。
张健
hi, Shubin Ruan
如果字段是可枚举的，应该是可以用这种模式写入的。
DataStream<> input = ...;
input.filter(...).addSink(sink1);
input.filter(...).addSink(sink2);
input.filter(...).addSink(sink3);
但这种一个是感觉不太灵活，当上报数据增加类型就要改代码。另一个是如果这个值枚举比较多，这样写起来也挺烦的。
--
张健
在 2020-10-30 17:19:56，"Shubin Ruan&q
hi，
我现在有个需求是一个source进来，然后根据数据里的字段 分发写入
clickhouse多张表中（比如用户行为事件，上报进来有多种，不同的事件写入不同的表中），我想用Flink的Jdbc
sink来做，但看接口貌似不能直接实现这样的功能。
这个是要自定义一个sink来做嘛？有没有什么简单的实现方式？
--
张健
大家好：
想问下目前 flink mysql sink想要实现按时间分库分表 有什么配置项可以使用嘛？
我目前的需求是数据源经过一个简单的etl处理写入到mysql中，供业务实时查询。由于业务场景只需要查询当天的数据（历史数据有另外的离线模块处理），所以想每天的数据单独写入一张表中（表名为xx_MMDD）这样。但目前Flink
JDBC sink是要指定表名的。请问下有什么简单的实现方案嘛？或者说对于我这样的场景有什么更好的实现方式嘛？
多谢。
--
张健
