[INIT-6549] Add client-side synchronous snapshot queries to the Flink CLI - #3466

Open

Yiyu Tian (yiyutian1) wants to merge 6 commits into

mainfrom

flink-sync-snapshot-query

Commits on Aug 21, 2026

[INIT-6549] Add confluent query for client-side synchronous snapshot queries
Yiyu Tian (yiyutian1)
committed
9707001

Commits on Aug 25, 2026

Address PR review comments and add unit tests for internal/query

Yiyu Tian (yiyutian1)
and
Claude (claude)
committed
bb7ccca

Commits on Aug 26, 2026

Address review feedback: drain-loop race, append-only signal, nil-deref, dead guard

Yiyu Tian (yiyutian1)
and
Claude (claude)
committed
a4889e4
Retrigger CI: unrelated proxy.golang.org network flake in Alpine build job
Yiyu Tian (yiyutian1)
committed
3ba5eb3

Commits on Aug 28, 2026

Close PRD gaps: snapshot mode, engine field, --file, --catalog/--cluster

Yiyu Tian (yiyutian1)
and
Claude (claude)
committed
08c3d69

Commits on Sep 2, 2026

Add integration tests for confluent query

Yiyu Tian (yiyutian1)
and
Claude (claude)
committed
ee486a3