Search before asking
Paimon version
master @ 4af1470
Compute Engine
Flink
Minimal reproduce step
CALL sys.query_service('db.tbl', 1) on a fixed-bucket primary key table.
- Run a lookup join against that table so the client caches the service address.
- Cancel the query service job, then keep looking up the same keys.
QueryExecutorOperator.initializeState() keeps the KvQueryServer in a local variable (line 89), so close() (line 128) closes only query and ioManager and never shuts the server down.
What doesn't meet your expectations?
Expected: the client cannot reach the stopped service and re-resolves its address.
Actual: the leaked server keeps listening and answers from the already closed LocalTableQuery, whose lookup() returns null without throwing; KvServerHandler wraps that null in a normal KvResponse. KvQueryClient forces an address refresh only on UnknownPartitionBucketException or ConnectException, so the lookup join misses every key with no error.
Anything else?
RemoteLookupJoinITCase.ServiceProxy.close() shows the intended order: server.shutdown() then query.close().
Are you willing to submit a PR?
Search before asking
Paimon version
master @ 4af1470
Compute Engine
Flink
Minimal reproduce step
CALL sys.query_service('db.tbl', 1)on a fixed-bucket primary key table.QueryExecutorOperator.initializeState()keeps theKvQueryServerin a local variable (line 89), soclose()(line 128) closes onlyqueryandioManagerand never shuts the server down.What doesn't meet your expectations?
Expected: the client cannot reach the stopped service and re-resolves its address.
Actual: the leaked server keeps listening and answers from the already closed
LocalTableQuery, whoselookup()returns null without throwing;KvServerHandlerwraps that null in a normalKvResponse.KvQueryClientforces an address refresh only onUnknownPartitionBucketExceptionorConnectException, so the lookup join misses every key with no error.Anything else?
RemoteLookupJoinITCase.ServiceProxy.close()shows the intended order:server.shutdown()thenquery.close().Are you willing to submit a PR?