[Pulsar Sql] The number of query result records of pulsar SQL is less than that sent by producer

[xuesongxs]

Describe the bug Pulsar version 2.6.2

The number of query result records of pulsar SQL is less than that sent by producer. 1、Producer sends 7 records； 2、Pulsar SQL only queries 4 records； sql: select * from XXX;

3、Topic has no subscription；

[mattisonchao]

Could you provide a simple example to describe this problem in detail? @xuesongxs

[xuesongxs]

Could you provide a simple example to describe this problem in detail? @xuesongxs

@mattisonchao The producer sent seven records to topic, but only four records were found by pulsar SQL, Look at the picture above.

[chgxtony]

I have the same problem

[MarvinCai]

@xuesongxs have you checked with pulsar-admin topics stats <topic-name> or bookkeeper shell ledger to make sure entries do exist in BookKeeper? If not filtering by publish_time then default behavior is read all entries in a topic, the connector won't filter out or swallow any entry.

[xuesongxs]

pulsar-admin topics stats

I have checked with pulsar-admin topics stats ，indeed, the number of records found by pulsar SQL is less than the number of records written by the producer.

[codelipenghui]

The issue had no activity for 30 days, mark with Stale label.

[huxiyu]

me too, v3.0.x