[jira] [Assigned] (IOTDB-6007) Pipe meet error in sender restart after scaleout

["陈哲涵 (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/IOTDB-6007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

陈哲涵 reassigned IOTDB-6007:
--------------------------

    Assignee:     (was: 陈哲涵)

> Pipe meet error in sender restart after scaleout
> ------------------------------------------------
>
>                 Key: IOTDB-6007
>                 URL: https://issues.apache.org/jira/browse/IOTDB-6007
>             Project: Apache IoTDB
>          Issue Type: Bug
>            Reporter: 陈哲涵
>            Priority: Major
>         Attachments: receiver_logs.zip, sender_logs.zip
>
>
> 发送端Pipe扩容后，发送端重启后Pipe停止，重新开启Pipe也不传数据。开启另一个Pipe后开始传数据。
> 在 https://issues.apache.org/jira/browse/IOTDB-6003 中发送端重启后不停止，且可以传数据。可能为重启后实现不稳定。
> 日志见附件
> 复现步骤：
> （发送端）create pipe p2 with connector ('connector' = 'iotdb_thrift_connector', 'connector.ip' = 'localhost', 'connector.port' = '6670')
> （发送端）start pipe p2
> （发送端）扩容
> （发送端）使用 Benchmark 写入 2500000 个点
> （接收端）select count(*) from root. ** group by level = 1 # Value: 2500000
> （发送端）create pipe p3 with connector ('connector' = 'iotdb_thrift_connector', 'connector.ip' = 'localhost', 'connector.port' = '6670')
> （发送端）insert into root.sg1.d2(time, at1) values (now(), 1)
> （发送端）stop pipe p2
> （发送端）start pipe p3
> （接收端）select count(*) from root. ** group by level = 1 # Value: 2500000， 1
> （发送端）重启所有节点
> （发送端）start pipe p3 # 之前为stop状态
> （发送端）insert into root.sg1.d2(time, at1) values (now(), 2)
> （接收端）select count(*) from root. ** group by level = 1 # Value: 2500000， 1，后者应为2
> （发送端）create pipe p4 with connector ('connector' = 'iotdb_thrift_connector', 'connector.ip' = 'localhost', 'connector.port' = '6670')
> （发送端）start pipe p4
> （接收端）select count(*) from root. ** group by level = 1 # Value: 2500000， 2



--
This message was sent by Atlassian Jira
(v8.20.10#820010)