[IOTDB-5990] Pipe unexpectedly stop when an aligned device is piped

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: Core/Others
• Labels: pull-request-available
• Assignee: Unassigned
• Reporter: 马子坤
• Created: 12/Jun/23 10:44
• Updated: 17/Jun/23 23:20

Description

接收端未创建device，用pipe同步aligned device会导致pipe自动停止

日志见附件

复现步骤：

insert into root.sg1.d1(time, at1) aligned values (now(), 1);

create pipe p1 with collector ('collector.pattern'='root.sg1.d1') with connector ('connector'='iotdb_thrift_connector','connector.ip'='127.0.0.1','connector.port'='6668');

start pipe p1;

create pipe p2 with connector ('connector'='iotdb_thrift_connector','connector.ip'='127.0.0.1','connector.port'='6668');

start pipe p2;

insert into root.sg1.d2(time, at1) aligned values (now(), 2);

show pipes;

// 接收端查不到d2这个device，不断show pipes，会发现两个pipe均变成STOPPED。此后手动start两个pipe，也不同步d1的实时数据了

Issue Links

• links to: GitHub Pull Request #10137
• links to: GitHub Pull Request #10202