[
https://issues.apache.org/jira/browse/KAFKA-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yeva Byzek updated KAFKA-6288:
------------------------------
Description:
KAFKA-6087 introduced support for scanning relative symlinks in the plugin
path. However, if a relative symlink points to a target that doesn't exist,
then scanning the plugin path is interrupted. The consequence is that the
unscanned connectors in the plugin path may effectively not usable.
Desired behavior is that the symlink is skipped and scanning the plugin path
continues.
Example of error message:
{noformat}
[2017-11-30 20:19:26,226] ERROR Could not get listing for plugin path:
/usr/share/java. Ignoring.
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:170)
java.nio.file.NoSuchFileException: /usr/share/java/name.jar
at
sun.nio.fs.UnixException.translateToIOException(UnixException.java:86)
at sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:102)
at sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:107)
at sun.nio.fs.UnixPath.toRealPath(UnixPath.java:837)
at
org.apache.kafka.connect.runtime.isolation.PluginUtils.pluginUrls(PluginUtils.java:241)
at
org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.registerPlugin(DelegatingClassLoader.java:181)
at
org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:153)
at
org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:47)
at
org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:70)
{noformat}
was:
KAFKA-6087 introduced support for scanning relative symlinks in the plugin
path. However, if a relative symlink points to a target that doesn't exist,
then scanning the plugin path is interrupted.
Desired behavior is that the symlink is skipped and scanning the plugin path
continues.
Example of error message:
{noformat}
[2017-11-30 20:19:26,226] ERROR Could not get listing for plugin path:
/usr/share/java. Ignoring.
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:170)
java.nio.file.NoSuchFileException: /usr/share/java/name.jar
at
sun.nio.fs.UnixException.translateToIOException(UnixException.java:86)
at sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:102)
at sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:107)
at sun.nio.fs.UnixPath.toRealPath(UnixPath.java:837)
at
org.apache.kafka.connect.runtime.isolation.PluginUtils.pluginUrls(PluginUtils.java:241)
at
org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.registerPlugin(DelegatingClassLoader.java:181)
at
org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:153)
at
org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:47)
at
org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:70)
{noformat}
> Broken symlink interrupts scanning the plugin path
> --------------------------------------------------
>
> Key: KAFKA-6288
> URL: https://issues.apache.org/jira/browse/KAFKA-6288
> Project: Kafka
> Issue Type: Bug
> Components: KafkaConnect
> Affects Versions: 1.0.0
> Reporter: Yeva Byzek
> Assignee: Konstantine Karantasis
>
> KAFKA-6087 introduced support for scanning relative symlinks in the plugin
> path. However, if a relative symlink points to a target that doesn't exist,
> then scanning the plugin path is interrupted. The consequence is that the
> unscanned connectors in the plugin path may effectively not usable.
> Desired behavior is that the symlink is skipped and scanning the plugin path
> continues.
> Example of error message:
> {noformat}
> [2017-11-30 20:19:26,226] ERROR Could not get listing for plugin path:
> /usr/share/java. Ignoring.
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:170)
> java.nio.file.NoSuchFileException: /usr/share/java/name.jar
> at
> sun.nio.fs.UnixException.translateToIOException(UnixException.java:86)
> at sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:102)
> at sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:107)
> at sun.nio.fs.UnixPath.toRealPath(UnixPath.java:837)
> at
> org.apache.kafka.connect.runtime.isolation.PluginUtils.pluginUrls(PluginUtils.java:241)
> at
> org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.registerPlugin(DelegatingClassLoader.java:181)
> at
> org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:153)
> at
> org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:47)
> at
> org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:70)
> {noformat}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
