Pierre Villard created NIFI-15229:
-------------------------------------
Summary: ConsumeAzureEventHub - Exception
java.lang.UnsatisfiedLinkError: failed to load the required native library
Key: NIFI-15229
URL: https://issues.apache.org/jira/browse/NIFI-15229
Project: Apache NiFi
Issue Type: Bug
Components: Extensions
Affects Versions: 2.7.0
Reporter: Pierre Villard
Assignee: Pierre Villard
Fix For: 2.7.0
Commit from NIFI-15199 bumped io.projectreactor.netty:reactor-netty-http to
1.3.0. That release now eagerly initializes Netty’s HTTP/3 QUIC support, which
requires native libraries NiFi does not ship. Every Azure Blob checkpoint call
from ConsumeAzureEventHub therefore throws java.lang.NoClassDefFoundError:
reactor.netty.http.client.HttpClientSecure.
{code:java}
ConsumeAzureEventHub[id=5d6fb1d3-019a-1000-ffff-ffffb2454981] Processing
halted: yielding [1 sec]: java.lang.NoClassDefFoundError: Could not initialize
class reactor.netty.http.client.HttpClientSecure
- Caused by: java.lang.ExceptionInInitializerError: Exception
java.lang.UnsatisfiedLinkError: failed to load the required native library [in
thread "Timer-Driven Process Thread-3"]
java.lang.NoClassDefFoundError: Could not initialize class
reactor.netty.http.client.HttpClientSecure
at
reactor.netty.http.client.HttpClientConnect$MonoHttpConnect.lambda$subscribe$0(HttpClientConnect.java:226)
at reactor.core.publisher.MonoCreate.subscribe(MonoCreate.java:61)
at reactor.core.publisher.FluxRetryWhen.subscribe(FluxRetryWhen.java:81)
at
reactor.core.publisher.MonoRetryWhen.subscribeOrReturn(MonoRetryWhen.java:46)
at
reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:63)
at
reactor.netty.http.client.HttpClientConnect$MonoHttpConnect.subscribe(HttpClientConnect.java:300)
at
reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:53)
at reactor.core.publisher.Mono.subscribe(Mono.java:4576)
at
reactor.core.publisher.FluxFlatMap.trySubscribeScalarMap(FluxFlatMap.java:205)
at
reactor.core.publisher.MonoFlatMap.subscribeOrReturn(MonoFlatMap.java:53)
at
reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:63)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:53)
at reactor.core.publisher.Mono.subscribe(Mono.java:4576)
at
reactor.core.publisher.FluxFlatMap.trySubscribeScalarMap(FluxFlatMap.java:205)
at
reactor.core.publisher.MonoFlatMap.subscribeOrReturn(MonoFlatMap.java:53)
at
reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:63)
at
reactor.core.publisher.MonoDeferContextual.subscribe(MonoDeferContextual.java:55)
at reactor.core.publisher.Mono.subscribe(Mono.java:4576)
at reactor.core.publisher.Mono.block(Mono.java:1778)
at
org.apache.nifi.processors.azure.eventhub.position.LegacyBlobStorageEventPositionProvider.containerExists(LegacyBlobStorageEventPositionProvider.java:145)
at
org.apache.nifi.processors.azure.eventhub.position.LegacyBlobStorageEventPositionProvider.getInitialPartitionEventPosition(LegacyBlobStorageEventPositionProvider.java:72)
at
org.apache.nifi.processors.azure.eventhub.ConsumeAzureEventHub.getLegacyPartitionEventPosition(ConsumeAzureEventHub.java:859)
at
org.apache.nifi.processors.azure.eventhub.ConsumeAzureEventHub.createClient(ConsumeAzureEventHub.java:574)
at
org.apache.nifi.processors.azure.eventhub.ConsumeAzureEventHub.onTrigger(ConsumeAzureEventHub.java:524)
at
org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1274)
at
org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:229)
at
org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:102)
at org.apache.nifi.engine.FlowEngine.lambda$wrap$1(FlowEngine.java:105)
at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572)
at
java.base/java.util.concurrent.FutureTask.runAndReset(FutureTask.java:358)
at
java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
at java.base/java.lang.Thread.run(Thread.java:1583)
Caused by: java.lang.ExceptionInInitializerError: Exception
java.lang.UnsatisfiedLinkError: failed to load the required native library [in
thread "Timer-Driven Process Thread-3"]
at io.netty.handler.codec.quic.Quic.ensureAvailability(Quic.java:87)
at
io.netty.handler.codec.quic.QuicheQuicSslContext.<init>(QuicheQuicSslContext.java:160)
at
io.netty.handler.codec.quic.QuicSslContextBuilder.build(QuicSslContextBuilder.java:404)
at
reactor.netty.http.Http3SslContextSpec.sslContext(Http3SslContextSpec.java:105)
at reactor.netty.tcp.SslProvider.<init>(SslProvider.java:343)
at reactor.netty.tcp.SslProvider$Build.build(SslProvider.java:650)
at
reactor.netty.http.client.HttpClientSecure.<clinit>(HttpClientSecure.java:82)
... 35 more
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
