[
https://issues.apache.org/jira/browse/NIFI-15229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Handermann updated NIFI-15229:
------------------------------------
Affects Version/s: (was: 2.7.0)
> 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
> Reporter: Pierre Villard
> Assignee: Pierre Villard
> Priority: Major
> Fix For: 2.7.0
>
> Time Spent: 50m
> Remaining Estimate: 0h
>
> 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)
