Hi,

Is it possible to go in there with a debugger and see where exactly the code is 
invoking the ClassLoader?

Best,
Aljoscha

> On 8. Dec 2017, at 14:13, romain.jln <romain....@gmail.com> wrote:
> 
> Hi,
> 
> FYI, I edited my message on the Nabble archive website because I realised I
> sent the wrong stack trace at first (but I don't know if you've noticed the
> modification). The first one was actually related to a custom Sink function
> that sends data to the Eventhub (not sure whether they are related issues or
> not)
> 
> The one related to the source is the following:
> 
> Exception in thread "Thread-2" java.lang.NoClassDefFoundError:
> com/microsoft/azure/eventhubs/MessageReceiver$10 
>        at
> com.microsoft.azure.eventhubs.MessageReceiver.scheduleLinkCloseTimeout(MessageReceiver.java:574)
>  
>        at
> com.microsoft.azure.eventhubs.MessageReceiver.onClose(MessageReceiver.java:641)
>  
>        at
> com.microsoft.azure.eventhubs.ClientEntity.close(ClientEntity.java:78) 
>        at
> com.microsoft.azure.eventhubs.PartitionReceiver.onClose(PartitionReceiver.java:391)
>  
>        at
> com.microsoft.azure.eventhubs.ClientEntity.close(ClientEntity.java:78) 
>        at
> com.microsoft.azure.eventhubs.ClientEntity.closeSync(ClientEntity.java:93) 
>        at
> commons.source.azure.eventhub.PartitionPoller.shutdown(PartitionPoller.java:80)
>  
>        at
> commons.source.azure.eventhub.PartitionPoller.run(PartitionPoller.java:55) 
> Caused by: java.lang.ClassNotFoundException:
> com.microsoft.azure.eventhubs.MessageReceiver$10 
>        at java.net.URLClassLoader.findClass(URLClassLoader.java:381) 
>        at java.lang.ClassLoader.loadClass(ClassLoader.java:424) 
>        at java.lang.ClassLoader.loadClass(ClassLoader.java:357) 
>        ... 8 more 
> 
> 
> I don't know if I exactly understand what you mean by " trying to use the
> Thread Context ClassLoader" (I do not have a deep knowledge related to
> ClassLoader) but I am not calling explicitly any method on the Thread
> Context ClassLoader and by going through the different methods of the stack
> trace I did not notice any neither.
> 
> As I was explaining at first, within the source I basically create a thread
> that is constantly polling messages from the Eventhub (like the
> KafkaConsummerThread is doing with kafka) using Microsoft library. Under the
> hood, Microsoft uses some threadPoolExecutor and the proton library.
> 
> The whole source works fine except that I get those ClassNotFoundException
> from time to time with no real apparent reason.
> 
> I use Flink Version: 1.3.2
> 
> Best,
> Romain
> 
> 
> 
> --
> Sent from: 
> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Reply via email to