[Bug] Query service process record repeatedly

[Shadowell]

Search before asking

• I searched in the issues and found nothing similar.

Paimon version

Paimon 0.9

Compute Engine

Flink 1.18

Minimal reproduce step

1. Create paimon catelog
   CREATE CATALOG paimon WITH ( 'type'='paimon', 'warehouse'='file:/tmp/paimon' );
USE CATALOG paimon;
2. Create table and insert one record
   CREATE TABLE DIM (k INT, v STRING, PRIMARY KEY(k) NOT ENFORCED) WITH ('bucket' = '1', 'deletion-vectors.enabled' = 'true');
INSERT INTO DIM VALUES (1, 'a');
3. Call Query Service
   CALL sys.query_service('default.DIM', 1);
   
   

4. Insert another record
   INSERT INTO DIM VALUES (2, 'b');
   It shows records sent 4
   

What doesn't meet your expectations?

Records sent should consistent with table record count

Anything else?

No response

Are you willing to submit a PR?

• I'm willing to submit a PR!

[liyubin117]

Is there any progress?