Hi Dawid!
I have filed a bug for a related issue to this thread:
https://jira.apache.org/jira/browse/FLINK-12105 (TUMBLE INTERVAL value
errors out for 100 or more value).
How should we go about supporting MONTH and YEAR? If you have ideas please
let me know, I will be happy to work with you to
btw the max DAY window that is allowed is 99 days. After that it blows up
here:
https://github.com/apache/calcite/blob/master/core/src/main/java/org/apache/calcite/sql/SqlIntervalQualifier.java#L371
"SQL validation failed. From line 12, column 19 to line 12, column 36:
Interval field value 100
Dawid,
After the above change my SQL (that uses TUMBLE(rowtime, INTERVAL '1'
MONTH)) fails with an error now:
*(testing with org.apache.flink:flink-table_2.11:jar:1.7.1:compile now)*
org.apache.flink.table.api.TableException: *Only constant window intervals
with millisecond resolution are
Thanks Dawid! Can you please point me to a jira which tracked the fix?
Thanks!
Vinod
On Thu, Mar 28, 2019 at 12:46 PM Dawid Wysakowicz
wrote:
> It should be fixed since version 1.6.3.
> Best,
> Dawid
>
>
> [1]
>
Doh! Sorry about that! :)
Thanks again!
On Thu, Mar 28, 2019 at 12:49 PM Dawid Wysakowicz
wrote:
> I did ;) but here is the link one more time:
> https://issues.apache.org/jira/browse/FLINK-11017?jql=project%20%3D%20FLINK%20AND%20text%20~%20Month
>
> On Thu, 28 Mar 2019, 20:48 Vinod Mehra,
I did ;) but here is the link one more time:
https://issues.apache.org/jira/browse/FLINK-11017?jql=project%20%3D%20FLINK%20AND%20text%20~%20Month
On Thu, 28 Mar 2019, 20:48 Vinod Mehra, wrote:
> Thanks Dawid! Can you please point me to a jira which tracked the fix?
>
> Thanks!
> Vinod
>
> On
It should be fixed since version 1.6.3.
Best,
Dawid
[1]
https://issues.apache.org/jira/browse/FLINK-11017?jql=project%20%3D%20FLINK%20AND%20text%20~%20Month
On Thu, 28 Mar 2019, 19:32 Vinod Mehra, wrote:
> Hi All!
>
> We are using: org.apache.flink:flink-table_2.11:jar:1.4.2:compile
>
>
Hi All!
We are using: org.apache.flink:flink-table_2.11:jar:1.4.2:compile
SELECT
COALESCE(user_id, -1) AS user_id,
count(id) AS count_per_window,
sum(amount) AS charge_amount_per_window,
TUMBLE_START(rowtime, INTERVAL '2' YEAR) AS twindow_start,
TUMBLE_END(rowtime, INTERVAL '2' YEAR)
