[ 
https://issues.apache.org/jira/browse/FLINK-29835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17644772#comment-17644772
 ] 

Matthias Pohl commented on FLINK-29835:
---------------------------------------

2x in a single build:
* 
[https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=43794&view=logs&j=87489130-75dc-54e4-1f45-80c30aa367a3&t=73da6d75-f30d-5d5a-acbe-487a9dcff678&l=16857]
* 
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=43794&view=logs&j=fb37c667-81b7-5c22-dd91-846535e99a97&t=39a035c3-c65e-573c-fb66-104c66c28912&l=13613

> NoClassDefFoundError in PulsarSourceUnorderedE2ECase
> ----------------------------------------------------
>
>                 Key: FLINK-29835
>                 URL: https://issues.apache.org/jira/browse/FLINK-29835
>             Project: Flink
>          Issue Type: Bug
>          Components: Connectors / Pulsar, Runtime / Coordination
>    Affects Versions: 1.16.0, 1.17.0, 1.15.3
>            Reporter: Matthias Pohl
>            Priority: Critical
>              Labels: test-stability
>         Attachments: 
> PulsarSourceUnorderedE2ECase.testSavepoint.FileNotFoundException.log
>
>
> [This 
> build|https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=42680&view=logs&j=87489130-75dc-54e4-1f45-80c30aa367a3&t=73da6d75-f30d-5d5a-acbe-487a9dcff678&l=16001]
>  failed in {{PulsarSourceUnorderedE2ECase.testSavepoint}} due to some job 
> timeout.
> The logs reveal {{{}NoClassDefFoundErrors{}}}:
> {code:java}
> 2022-11-14 15:36:59,696 WARN  
> org.apache.pulsar.shade.org.asynchttpclient.DefaultAsyncHttpClient [] - 
> Unexpected error on ChannelManager close
> java.lang.NoClassDefFoundError: 
> org/apache/pulsar/shade/io/netty/util/concurrent/DefaultPromise$1
>      at 
> org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:499)
>  ~[?:?]
>      at 
> org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
>  ~[?:?]
>      at 
> org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:609)
>  ~[?:?]
>      at 
> org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:117)
>  ~[?:?]
>      at 
> org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor.ensureThreadStarted(SingleThreadEventExecutor.java:970)
>  ~[?:?]
>      at 
> org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor.shutdownGracefully(SingleThreadEventExecutor.java:661)
>  ~[?:?]
>      at 
> org.apache.pulsar.shade.io.netty.util.concurrent.MultithreadEventExecutorGroup.shutdownGracefully(MultithreadEventExecutorGroup.java:163)
>  ~[?:?]
>      at 
> org.apache.pulsar.shade.org.asynchttpclient.netty.channel.ChannelManager.close(ChannelManager.java:307)
>  ~[?:?]
>      at 
> org.apache.pulsar.shade.org.asynchttpclient.DefaultAsyncHttpClient.close(DefaultAsyncHttpClient.java:120)
>  ~[?:?]
>      at 
> org.apache.pulsar.client.admin.internal.http.AsyncHttpConnector.close(AsyncHttpConnector.java:346)
>  ~[?:?]
>      at 
> org.apache.pulsar.client.admin.internal.PulsarAdminImpl.close(PulsarAdminImpl.java:490)
>  ~[?:?]
>      at 
> org.apache.flink.connector.pulsar.source.enumerator.PulsarSourceEnumerator.close(PulsarSourceEnumerator.java:172)
>  ~[?:?]
>      at org.apache.flink.util.IOUtils.closeAll(IOUtils.java:255) 
> ~[flink-dist-1.17-SNAPSHOT.jar:1.17-SNAPSHOT]
>      at 
> org.apache.flink.runtime.source.coordinator.SourceCoordinator.close(SourceCoordinator.java:265)
>  ~[flink-dist-1.17-SNAPSHOT.jar:1.17-SNAPSHOT]
>      at 
> org.apache.flink.runtime.operators.coordination.ComponentClosingUtils.lambda$closeAsyncWithTimeout$0(ComponentClosingUtils.java:76)
>  ~[flink-dist-1.17-SNAPSHOT.jar:1.17-SNAPSHOT]
>      at java.lang.Thread.run(Thread.java:750) [?:1.8.0_342]
> Caused by: java.lang.ClassNotFoundException: 
> org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise$1
>      at java.net.URLClassLoader.findClass(URLClassLoader.java:387) 
> ~[?:1.8.0_342]
>      at java.lang.ClassLoader.loadClass(ClassLoader.java:418) ~[?:1.8.0_342]
>      at 
> org.apache.flink.util.FlinkUserCodeClassLoader.loadClassWithoutExceptionHandling(FlinkUserCodeClassLoader.java:67)
>  ~[flink-dist-1.17-SNAPSHOT.jar:1.17-SNAPSHOT]
>      at 
> org.apache.flink.util.ChildFirstClassLoader.loadClassWithoutExceptionHandling(ChildFirstClassLoader.java:74)
>  ~[flink-dist-1.17-SNAPSHOT.jar:1.17-SNAPSHOT]
>      at 
> org.apache.flink.util.FlinkUserCodeClassLoader.loadClass(FlinkUserCodeClassLoader.java:51)
>  ~[flink-dist-1.17-SNAPSHOT.jar:1.17-SNAPSHOT]
>      at java.lang.ClassLoader.loadClass(ClassLoader.java:351) ~[?:1.8.0_342]
>      ... 16 more {code}
> Outdated:
> -The issue seems to be related to the BlobServer failing to provide some 
> artifacts ({{{}java.io.FileNotFoundException{}}}) that consequently causes 
> classes not being found.-
>  



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

Reply via email to