[jira] [Assigned] (FLINK-40270) Make source fetcher and coordinator threads job-attributable (MDC + thread names)

["Roman Khachatryan (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-40270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Roman Khachatryan reassigned FLINK-40270:
-----------------------------------------

    Assignee: Aleksandr Savonin

> Make source fetcher and coordinator threads job-attributable (MDC + thread names)
> ---------------------------------------------------------------------------------
>
>                 Key: FLINK-40270
>                 URL: https://issues.apache.org/jira/browse/FLINK-40270
>             Project: Flink
>          Issue Type: Sub-task
>          Components: API / Core, Connectors / Common, Runtime / Coordination
>            Reporter: Aleksandr Savonin
>            Assignee: Aleksandr Savonin
>            Priority: Major
>
> On a session / multi-tenant TaskManager, source threads are not attributable to a job:
>  # SplitFetcherManager's fetcher threads don't inherit the task thread's SLF4J MDC, so every connector SplitReader logs with an empty flink-job-id. the "Source Data Fetcher for ..." thread name has no job identity either.
>  # SourceCoordinatorContext's worker executor is not job-scoped, so callAsync work such as periodic file-split scans logs without flink-job-id.
>  # The "SourceCoordinator-" thread name is identical for two jobs using the same source operator name.
> Building on FLINK-39776 (JobInfo on source contexts).



--
This message was sent by Atlassian Jira
(v8.20.10#820010)