coniferous-cmd opened a new issue, #17994:
URL: https://github.com/apache/iotdb/issues/17994
环境信息
IoTDB 版本：2.0.8
部署方式：单机
测试环境：同一台机器部署两套 IoTDB
源端：127.0.0.1:6667
目标端：127.0.0.1:6668
SQL Dialect：Tree
Pipe 配置
CREATE PIPE A2B_COMPRESSION
WITH SOURCE (
'source'= 'iotdb-source',
'realtime.mode' = 'stream',
'path' = 'root.s1_5w.**',
'inclusion' = 'all'
)
WITH SINK (
'sink' = 'iotdb-thrift-async-sink',
'node-urls' = '127.0.0.1:6668',
'compressor' = 'snappy,lz4'
);
Pipe 创建成功后执行：
SHOW PIPES;
状态显示：
status=RUNNING
realtime.enable=true
realtime.mode=stream
remainingEventCount=0
复现步骤
启动两套 IoTDB 2.0.8 实例。
在源端（6667）创建并启动 Pipe。
向源端写入数据：
INSERT INTO root.s1_5w.d1(time, v1)
VALUES (1750000000000, 123);
立即在目标端（6668）查询数据。
实际现象
目标端无法立即查询到新写入的数据。
执行：FLUSH;
之后，目标端能够立即查询到刚刚写入的数据。
期望现象
当 Pipe 配置：
realtime.mode=stream
时，新写入的数据应当实时同步到目标端，而不需要手动执行 FLUSH。
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
