我在jira回复了下,我感觉还是能配置化好一些,那个liwei貌似现在加了个basicDate这个太单一了。

Jingsong Li <jingsongl...@gmail.com> 于2021年11月4日周四 下午12:18写道:

> 你可以自定义个partition.time-extractor.class来自己解析
>
> Flink应该搞个对应的partition.time-extractor.kind来默认支持你的需求。
> 建了个JIRA: https://issues.apache.org/jira/browse/FLINK-24758
>
> Best,
> Jingsong
>
> On Thu, Nov 4, 2021 at 11:47 AM yidan zhao <hinobl...@gmail.com> wrote:
> >
> > 如题,我当前是select date_format(xxx, 'yyyyMMdd') as dt...
> >
> > partition.time-extractor.timestamp-pattern是$dt $hour:00:00这样。
> >
> > 但是这样会导致报错,貌似这个地方必须是 yyyy-MM-dd hh:mm:ss这种吗。
>
>
>
> --
> Best, Jingsong Lee
>

回复