[jira] [Commented] (FLINK-13731) flink sql support window with alignment
[
https://issues.apache.org/jira/browse/FLINK-13731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336441#comment-17336441
]
Flink Jira Bot commented on FLINK-13731:
This issue was labeled "stale-major" 7 ago and has not received any updates so
it is being deprioritized. If this ticket is actually Major, please raise the
priority and ask a committer to assign you the issue or revive the public
discussion.
> flink sql support window with alignment
> ---
>
> Key: FLINK-13731
> URL: https://issues.apache.org/jira/browse/FLINK-13731
> Project: Flink
> Issue Type: Improvement
> Components: Table SQL / API
>Affects Versions: 1.9.0
>Reporter: zzsmdfj
>Priority: Major
> Labels: stale-major
>
> for now, sql:
> {code:java}
> // code placeholder
> SELECT COUNT(*) GROUP BY TUMBLE(pt, interval '1' DAY, time '08:00:00')
> {code}
> not supported in flink sql, when rowtime is processTime, the window is
> assigned by UTC time, it is not correct day window when i was in specified
> time zone.
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Commented] (FLINK-13731) flink sql support window with alignment
[
https://issues.apache.org/jira/browse/FLINK-13731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17328339#comment-17328339
]
Flink Jira Bot commented on FLINK-13731:
This major issue is unassigned and itself and all of its Sub-Tasks have not
been updated for 30 days. So, it has been labeled "stale-major". If this ticket
is indeed "major", please either assign yourself or give an update. Afterwards,
please remove the label. In 7 days the issue will be deprioritized.
> flink sql support window with alignment
> ---
>
> Key: FLINK-13731
> URL: https://issues.apache.org/jira/browse/FLINK-13731
> Project: Flink
> Issue Type: Improvement
> Components: Table SQL / API
>Affects Versions: 1.9.0
>Reporter: zzsmdfj
>Priority: Major
> Labels: stale-major
>
> for now, sql:
> {code:java}
> // code placeholder
> SELECT COUNT(*) GROUP BY TUMBLE(pt, interval '1' DAY, time '08:00:00')
> {code}
> not supported in flink sql, when rowtime is processTime, the window is
> assigned by UTC time, it is not correct day window when i was in specified
> time zone.
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Commented] (FLINK-13731) flink sql support window with alignment
[
https://issues.apache.org/jira/browse/FLINK-13731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16910177#comment-16910177
]
Jark Wu commented on FLINK-13731:
-
Hi, I think proctime attribute should return a timestamp with local time zone,
so the TUMBLE(pt, interval '1' DAY) can align with the session time zone.
In the other hand, I'm also fine with supporting TUMBLE(dateTime, interval,
time), as this is supported in Calcite and useful when we want the window start
time is from "00:20".
> flink sql support window with alignment
> ---
>
> Key: FLINK-13731
> URL: https://issues.apache.org/jira/browse/FLINK-13731
> Project: Flink
> Issue Type: Improvement
> Components: Table SQL / API
>Affects Versions: 1.9.0
>Reporter: zzsmdfj
>Priority: Major
>
> for now, sql:
> {code:java}
> // code placeholder
> SELECT COUNT(*) GROUP BY TUMBLE(pt, interval '1' DAY, time '08:00:00')
> {code}
> not supported in flink sql, when rowtime is processTime, the window is
> assigned by UTC time, it is not correct day window when i was in specified
> time zone.
>
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
[jira] [Commented] (FLINK-13731) flink sql support window with alignment
[
https://issues.apache.org/jira/browse/FLINK-13731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16910158#comment-16910158
]
zzsmdfj commented on FLINK-13731:
-
[~jark] at alibaba(or in blink), how you handle with it ? I would appreciate it
if you give some advices.
> flink sql support window with alignment
> ---
>
> Key: FLINK-13731
> URL: https://issues.apache.org/jira/browse/FLINK-13731
> Project: Flink
> Issue Type: Improvement
> Components: Table SQL / API
>Affects Versions: 1.9.0
>Reporter: zzsmdfj
>Priority: Major
>
> for now, sql:
> {code:java}
> // code placeholder
> SELECT COUNT(*) GROUP BY TUMBLE(pt, interval '1' DAY, time '08:00:00')
> {code}
> not supported in flink sql, when rowtime is processTime, the window is
> assigned by UTC time, it is not correct day window when i was in specified
> time zone.
>
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
[jira] [Commented] (FLINK-13731) flink sql support window with alignment
[
https://issues.apache.org/jira/browse/FLINK-13731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16910154#comment-16910154
]
zzsmdfj commented on FLINK-13731:
-
[~GatsbyNewton] , when rowTime is processTime, I not sure. In fact, I am not
clear why we not support window with alignment(calcite support for this
feature). get more operands from groupExpr in LogicalWindowAggregateRule, then
pass into case class TumblingGroupWindow or SlidingGroupWindow. is it right way
to this?
> flink sql support window with alignment
> ---
>
> Key: FLINK-13731
> URL: https://issues.apache.org/jira/browse/FLINK-13731
> Project: Flink
> Issue Type: Improvement
> Components: Table SQL / API
>Affects Versions: 1.9.0
>Reporter: zzsmdfj
>Priority: Major
>
> for now, sql:
> {code:java}
> // code placeholder
> SELECT COUNT(*) GROUP BY TUMBLE(pt, interval '1' DAY, time '08:00:00')
> {code}
> not supported in flink sql, when rowtime is processTime, the window is
> assigned by UTC time, it is not correct day window when i was in specified
> time zone.
>
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
[jira] [Commented] (FLINK-13731) flink sql support window with alignment
[
https://issues.apache.org/jira/browse/FLINK-13731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16910014#comment-16910014
]
Jimmy Wong commented on FLINK-13731:
Hi [~zhaoshijie], I think you can convert the timestamp with UDF, but I don't
have a try.
> flink sql support window with alignment
> ---
>
> Key: FLINK-13731
> URL: https://issues.apache.org/jira/browse/FLINK-13731
> Project: Flink
> Issue Type: Improvement
> Components: Table SQL / API
>Affects Versions: 1.9.0
>Reporter: zzsmdfj
>Priority: Major
>
> for now, sql:
> {code:java}
> // code placeholder
> SELECT COUNT(*) GROUP BY TUMBLE(pt, interval '1' DAY, time '08:00:00')
> {code}
> not supported in flink sql, when rowtime is processTime, the window is
> assigned by UTC time, it is not correct day window when i was in specified
> time zone.
>
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
[jira] [Commented] (FLINK-13731) flink sql support window with alignment
[
https://issues.apache.org/jira/browse/FLINK-13731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16907845#comment-16907845
]
Jark Wu commented on FLINK-13731:
-
Yes. It only works for event time.
> flink sql support window with alignment
> ---
>
> Key: FLINK-13731
> URL: https://issues.apache.org/jira/browse/FLINK-13731
> Project: Flink
> Issue Type: Improvement
> Components: Table SQL / API
>Affects Versions: 1.9.0
>Reporter: zzsmdfj
>Priority: Major
>
> for now, sql:
> {code:java}
> // code placeholder
> SELECT COUNT(*) GROUP BY TUMBLE(pt, interval '1' DAY, time '08:00:00')
> {code}
> not supported in flink sql, when rowtime is processTime, the window is
> assigned by UTC time, it is not correct day window when i was in specified
> time zone.
>
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
[jira] [Commented] (FLINK-13731) flink sql support window with alignment
[
https://issues.apache.org/jira/browse/FLINK-13731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16907836#comment-16907836
]
zzsmdfj commented on FLINK-13731:
-
Thank you for your reply ! [~jark] I'm not sure where convert the timestamp if
rowtime is processTime ? if rowtime is eventTime, it may work.
> flink sql support window with alignment
> ---
>
> Key: FLINK-13731
> URL: https://issues.apache.org/jira/browse/FLINK-13731
> Project: Flink
> Issue Type: Improvement
> Components: Table SQL / API
>Affects Versions: 1.9.0
>Reporter: zzsmdfj
>Priority: Major
>
> for now, sql:
> {code:java}
> // code placeholder
> SELECT COUNT(*) GROUP BY TUMBLE(pt, interval '1' DAY, time '08:00:00')
> {code}
> not supported in flink sql, when rowtime is processTime, the window is
> assigned by UTC time, it is not correct day window when i was in specified
> time zone.
>
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
[jira] [Commented] (FLINK-13731) flink sql support window with alignment
[
https://issues.apache.org/jira/browse/FLINK-13731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16907815#comment-16907815
]
Jark Wu commented on FLINK-13731:
-
Hi [~zhaoshijie], for a workaround, you can convert the timestamp to a unix
timestamp (by +/- offset according your local time zone).
> flink sql support window with alignment
> ---
>
> Key: FLINK-13731
> URL: https://issues.apache.org/jira/browse/FLINK-13731
> Project: Flink
> Issue Type: Improvement
> Components: Table SQL / API
>Affects Versions: 1.9.0
>Reporter: zzsmdfj
>Priority: Major
>
> for now, sql:
> {code:java}
> // code placeholder
> SELECT COUNT(*) GROUP BY TUMBLE(pt, interval '1' DAY, time '08:00:00')
> {code}
> not supported in flink sql, when rowtime is processTime, the window is
> assigned by UTC time, it is not correct day window when i was in specified
> time zone.
>
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
