time-windowed joins and tumbling windows

2020-03-10 Thread Vinod Mehra
Hi! We are testing the following 3 way time windowed join to keep the retained state size small. Using joins for the first time here. It works in unit tests but we are not able to get expected results in production. We are still troubleshooting this issue. Can you please help us review this in cas

Re: time-windowed joins and tumbling windows

2020-03-13 Thread Vinod Mehra
3, 2020 at 3:56 PM Vinod Mehra wrote: > Thanks Timo for responding back! Answers below: > > > 1) Which planner are you using? > > We are using Flink 1.8 and using the default planner > (org.apache.flink.table.calcite.FlinkPlannerImpl) > from: org.apache.flink:flink-table-pl

[jira] [Created] (FLINK-12105) TUMBLE INTERVAL value errors out for 100 or more value

2019-04-03 Thread Vinod Mehra (JIRA)
Vinod Mehra created FLINK-12105: --- Summary: TUMBLE INTERVAL value errors out for 100 or more value Key: FLINK-12105 URL: https://issues.apache.org/jira/browse/FLINK-12105 Project: Flink Issue