|
|
1min的滚动窗口：
table.exec.emit.early-fire.enabled=true;
table.exec.emit.early-fire.delay=10 s;
设置窗口定期trigger之后，参数不生效
查看执行计划：
{
"id": 6,
"type": "GroupWindowAggregate(groupBy=[mid, code, floor_id], window=[TumblingGroupWindow('w$, log_ts, 60000)], properties=[w$start, w$end, w$rowtime, w$proctime], select=[mid, code, floor_id, COUNT(*) AS pv, start('w$) AS w$start, end('w$) AS w$end, rowtime('w$) AS w$rowtime, proctime('w$) AS w$proctime], emit=[early delay 10000 millisecond])",
"pact": "Operator",
"contents": "GroupWindowAggregate(groupBy=[mid, code, floor_id], window=[TumblingGroupWindow('w$, log_ts, 60000)], properties=[w$start, w$end, w$rowtime, w$proctime], select=[mid, code, floor_id, COUNT(*) AS pv, start('w$) AS w$start, end('w$) AS w$end, rowtime('w$) AS w$rowtime, proctime('w$) AS w$proctime], emit=[early delay 10000 millisecond])",
"parallelism": 72,
"chaining_strategy": "ALWAYS",
"uid": "9tx/TSKD9GBbEnuTZOIRSA==",
"predecessors": [
{
"id": 4,
"ship_strategy": "HASH",
"side": "second"
}
]
},
可以确认已经设置成功，就不知道为啥没有定期trigger。
现在看起来像是watermark允许数据延迟设置的5min + 窗口 1min =6min之后才能看到结果
|
Locked
