Hi everyone, I’d like to start a discussion about FLIP-583: Expose JobInfo on Source contexts [1]. Source connectors often need job metadata (job ID, job name) for authentication, distributed tracing, metrics labeling, and other usages. SinkV2 already exposes this via `InitContext.getJobInfo()`.
The current workarounds on the source side (e.g. parsing the job ID from metric group variables) are brittle/fragile and undiscoverable. The FLIP adds a `@PublicEvolving` default method `getJobInfo()` to `SourceReaderContext` and `SplitEnumeratorContext`, following the same pattern as already established in these interfaces. The runtime implementations delegate to `StreamingRuntimeContext` (reader side) and `OperatorCoordinator.Context` (enumerator side). Looking forward to your feedback. [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-583%3A+Expose+JobInfo+on+Source+contexts -- Kind regards, Aleksandr
