[X] I searched in the issues and found nothing similar.
Paimon version
Paimon 0.9
Compute Engine
Flink 1.18
Minimal reproduce step
Create paimon catelog
CREATE CATALOG paimon WITH ( 'type'='paimon', 'warehouse'='file:/tmp/paimon' ); USE CATALOG paimon;
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');
Call Query Service
CALL sys.query_service('default.DIM', 1);
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
liyubin117
commented
10 hours ago
Search before asking
Paimon version
Paimon 0.9
Compute Engine
Flink 1.18
Minimal reproduce step
CREATE CATALOG paimon WITH ( 'type'='paimon', 'warehouse'='file:/tmp/paimon' );USE CATALOG paimon;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');CALL sys.query_service('default.DIM', 1);INSERT INTO DIM VALUES (2, 'b');It shows records sent 4What doesn't meet your expectations?
Records sent should consistent with table record count
Anything else?
No response
Are you willing to submit a PR?