window agg early-fire 不生效

Wed, 16 Dec 2020 22:06:20 -0800 

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之后才能看到结果

回复