after i create a stream in my cluster, a stream check transaction appears and never completes
#28.957 aberto em 28 de nov. de 2024
Métricas do repositório
- Stars
- (24.849 stars)
- Métricas de merge de PR
- (Mesclagem média 1d 1h) (4 fundiu PRs em 30d)
Description
1.版本：3.3.4.3
2.创建数据库语句：
create DATABASE test
BUFFER 256
CACHESIZE 32
CACHEMODEL 'both'
DURATION 1d
KEEP 3d
precision 'ms'
REPLICA 1
VGROUPS 2
SINGLE_STABLE 0;
3.创建超级表语句： CREATE STABLE test.t1 (ts timestamp, lng double, lat double, berth_id varchar(20), speed double) TAGS (device_no varchar(20), terminal_id varchar(20), type int);
4.创建两个流式计算 第一个流式计算 create stream if not exists berthsteam trigger MAX_DELAY 1s watermark 180s into t1.berthsteam TAGS(device_no varchar(20)) SUBTABLE(CONCAT('berthsteam-', device_no)) as select first(ts) as start_time, last(ts) as end_time ,berth_id,timediff(first(ts),last(ts) ,1s) as diff,type from t1.truck partition by tbname as device_no state_window(berth_id); 第二个流式计算 create stream if not exists trucksteam trigger max_delay 60s watermark 180s into t1.trucksteam tags(device_no varchar(20)) subtable(concat('trucksteam-', device_no)) as select _wstart as start_time ,max(speed) as max_speed,avg(speed) as avg_speed from t1.truck partition by tbname as device_no interval(1m)
5.执行一段时间会出现一个流检查事务
6.造成影响是对应库内，流式计算产生超级表没有更新流检查事务产生之后的数据，想请问一下这个是什么原因造成的？