[
https://issues.apache.org/jira/browse/FLINK-39428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18073079#comment-18073079
]
lizhiqiang commented on FLINK-39428:
------------------------------------
{code:java}
this.executors = Executors.newCachedThreadPool( r -> new Thread(r,
THREAD_NAME_PREFIX + taskThreadName)); {code}
change to
{code:java}
// TODO
JobID jobID = JobID.fromHexString(MDC.getMDCAdapter().get(MdcUtils.JOB_ID));
this.executors = MdcUtils.scopeToJob(jobID,Executors.newCachedThreadPool(r ->
new Thread(r, THREAD_NAME_PREFIX + taskThreadName)));{code}
> MDC is missing for some thread pools
> ------------------------------------
>
> Key: FLINK-39428
> URL: https://issues.apache.org/jira/browse/FLINK-39428
> Project: Flink
> Issue Type: Improvement
> Components: Connectors / Common
> Affects Versions: 2.2.0, 2.1.1
> Environment: flink 2.2 + flink cdc 3.6
> Reporter: lizhiqiang
> Priority: Minor
> Attachments: image-2026-04-13-15-13-31-719.png
>
>
> !image-2026-04-13-15-13-31-719.png!
> [https://nightlies.apache.org/flink/flink-docs-release-2.2/docs/deployment/advanced/logging/]
>
>
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
