Hi,
I execute the sql on 1.13.5 and the result is correct but no result show on
1.14.0 and 1.14.2.
sql:
SELECT window_start, window_end, COUNT(*)
FROM TABLE(
TUMBLE(TABLE `origin`.`queue_3_ads_ccops_sdn_vrs_result`,
DESCRIPTOR(datatime), INTERVAL '5' MINUTES)
) GROUP BY window_start, windo
I change to
watermark for `datatime` as `datatime` - interval '1' second
or
watermark for `datatime` as `datatime`
but is still not work.
At 2021-12-23 15:16:20, "Yun Gao" wrote:
Hi Caiyi,
The window need to be finalized with watermark[1]. I noticed that the watermark
defined
Hi
Flink 1.14.0 Scala 2.12
I'm using flink sql interval join ability, here is my table schema and sql
create table `queue_3_ads_ccops_perf_o_ebs_volume_capacity` ( `dtEventTime`
timestamp(3), `dtEventTimeStamp` bigint, `sourceid` string, `cluster_name`
string, `poolname` string, `storage_pool
Hi
Flink 1.14.0 Scala 2.12
I'm using flink sql interval join ability, here is my table schema and sql
create table `queue_3_ads_ccops_perf_o_ebs_volume_capacity` ( `dtEventTime`
timestamp(3), `dtEventTimeStamp` bigint, `sourceid` string, `cluster_name`
string, `poolname` string, `storage_pool
Hi
Flink 1.14.0 Scala 2.12
I'm using flink sql interval join ability, here is my table schema and sql
create table `queue_3_ads_ccops_perf_o_ebs_volume_capacity` ( `dtEventTime`
timestamp(3), `dtEventTimeStamp` bigint, `sourceid` string, `cluster_name`
string, `poolname` string, `storage_pool
