[Bug] 1.3.3版本 数据订阅 以及 mqtt 问题
- Ngôn ngữ chính
- Java
- Star
- 6.4k
- Fork
- 1.2k
- Merge trung bình
- 1 ngày 23 giờ
- Pull request đã merge (30 ngày)
- 115
Mô tả
### Search before asking
- [x] I searched in the [issues](https://github.com/apache/iotdb/issues) and found nothing similar.
### Version
1.3.3版本的数据订阅功能失效。
mqtt服务器的订阅功能失效。
### Describe the bug and provide the minimal reproduce step
1、使用java连接iotdb,订阅主题ytStatus
2、使用mqtt发送100消息

3、./start-cli进入后台。查看消息,可以看到已经添加到序列中。

4、问题出现:ytStatus主题的消费者未能消费掉我mqtt发送的消息。

4.1:如果取消订阅ytStatus,在订阅ytStatus。就可以可以打印出
ystem.out.println("getColumnNames:=============================== " + next.getColumnNames());
System.out.println("deviceId:=========" + next.getTablet().deviceId);
System.out.println("timestamps:=======" + next.getTablet().timestamps);
System.out.println("values:===========" + next.getTablet().values);
System.out.println("getColumnTypes:=============================== " + next.getColumnTypes());
也就是在第一次订阅后,才会后效果。后面无论采用什么样的方式(mqtt\insert timesericer () ()这两种方法)向序列中添加测量点。都不会订阅到。
### What did you expect to see?
2个问题:
1、1.3.3版本的 订阅模式只有在第一次订阅的时候,才会有效果。后面无论怎么添加数据都不能在实时的订阅到。
2、可以向iotdb发送mqtt协议的报文(iotdb内置了mqtt服务器)。但是不能监听iotdb接受的mqtt报文。
只能发布到时间序列里面。
不能订阅iotdb内置的mqtt服务器所接受的报文,舍弃了mqtt原有的订阅功能。
### What did you see instead?
希望作者可以解决掉问题。
### Anything else?
_No response_
### Are you willing to submit a PR?
- [X] I'm willing to submit a PR!
Hướng dẫn đóng góp
Hướng nghiên cứu
Bắt đầu bằng cách tái hiện báo cáo với một client Java đã subscribe ytStatus, MQTT publish 100 message và dùng ./start-cli để kiểm tra sequence đã được insert. So sánh lần subscribe đầu tiên với việc cancel rồi subscribe lại, bao gồm các insert qua MQTT, timeseries và insert path được báo cáo. Được xem là hoàn tất khi các subscription nhận ổn định các message vừa được chấp nhận, bao gồm cả các message được IoTDB's built-in MQTT server nhận.
Do mô hình lập chỉ mục viết ra từ nội dung của issue.
Đánh giá
- Công nghệ
- java
- Lĩnh vực
- databases
- Loại issue
- Lỗi
- Độ khó
- 4/5
- Thời gian dự kiến
- 3-5 ngày
- Mức độ hoạt động
- Đình trệ
- Độ rõ ràng
- Khá rõ ràng
- Mức phù hợp với người mới
- 30/100