你可以自定义个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
