[
https://issues.apache.org/jira/browse/FLINK-29227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601776#comment-17601776
]
jackylau commented on FLINK-29227:
----------------------------------
[~chesnay] yes, just need add disruptor to lib/. so i suggest add it into
flink/lib. Otherwise users need to be added to their projects.
And the current Flink project has declared this dependency in the parent POM.
And the disruptor is dependent on Log4J2 for async logger and personally i
believe it should be entered as well as log4j
> shoud package disruptor(com.lmax) to flink lib for aync logger when
> xxconnector using it.
> -----------------------------------------------------------------------------------------
>
> Key: FLINK-29227
> URL: https://issues.apache.org/jira/browse/FLINK-29227
> Project: Flink
> Issue Type: Bug
> Components: Build System
> Affects Versions: 1.17.0
> Reporter: jackylau
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.17.0
>
>
> when i develop xxConnector which dependecncy like this
> xxconnector -> log4j2 -> AsyncLoggerConfig (jar: disruptor(com.lmax))
> xconnector loaded by user(childFirst) classloader
> log4j2 which loaded by app classloader, which also make AsyncLoggerConfig
> loaded by app classloader, according to the principle of classloader. and the
> flink lib don't have disruptor, which cause ClassNotFound. Although, the
> disruptor jar exists in my xxconnector
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)