环境信息
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。
环境信息
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。