[
https://issues.apache.org/jira/browse/FLINK-9962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564337#comment-16564337
]
Bowen Li commented on FLINK-9962:
---------------------------------
[~fhueske] Sounds good
Besides, after reading code, it also seems to me that both BucketingSink and
StreamingFileSink rolls their bucket paths based on only system time
(processing time), not event time. It causes problems especially when users
backfill data and want the correct dir structures corresponding to their
historical data timestamp. What do you think of this use case? Is there any
workaround or any plan to support event time bucket path rolling?
> allow users to specify TimeZone in DateTimeBucketer
> ---------------------------------------------------
>
> Key: FLINK-9962
> URL: https://issues.apache.org/jira/browse/FLINK-9962
> Project: Flink
> Issue Type: Improvement
> Components: Streaming Connectors
> Affects Versions: 1.5.1, 1.6.0
> Reporter: Bowen Li
> Assignee: Bowen Li
> Priority: Major
> Fix For: 1.7.0
>
>
> Currently {{DateTimeBucketer}} will return a bucket path by using local
> timezone. We should add a {{timezone}} constructor param to allow users to
> specify a timezone.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
