[
https://issues.apache.org/jira/browse/FLINK-39428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18073079#comment-18073079
]
lizhiqiang edited comment on FLINK-39428 at 4/13/26 7:19 AM:
-------------------------------------------------------------
SplitFetcherManager class
{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}
There are still many other thread pools newly created by connecotr that need to
be modified
was (Author: JIRAUSER286148):
SplitFetcherManager class
{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)
