[
https://issues.apache.org/jira/browse/NIFI-13268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Witt reassigned NIFI-13268:
-------------------------------
Assignee: Joe Witt (was: Peter Turcsanyi)
> ConsumeGCPPubSub Stopped Working with M3
> ----------------------------------------
>
> Key: NIFI-13268
> URL: https://issues.apache.org/jira/browse/NIFI-13268
> Project: Apache NiFi
> Issue Type: Bug
> Reporter: Emin
> Assignee: Joe Witt
> Priority: Major
>
> After updating from 1.26 to 2.0.0M3, getting the following for
> `ConsumeGCPPubSub`
>
> {{nifi-1 | 2024-05-18 23:00:02,157 INFO [NiFi Web Server-405]
> o.a.n.c.s.StandardProcessScheduler Running once
> ConsumeGCPubSub[id=890ffc25-018f-1000-f9bc-b29966db3fc6] nifi-1 | 2024-05-18
> 23:00:02,158 INFO [NiFi Web Server-405]
> o.a.n.controller.StandardProcessorNode Starting
> ConsumeGCPubSub[id=890ffc25-018f-1000-f9bc-b29966db3fc6] nifi-1 | 2024-05-18
> 23:00:02,170 ERROR [Timer-Driven Process Thread-1]
> o.a.n.p.gcp.pubsub.ConsumeGCPubSub
> ConsumeGCPubSub[id=890ffc25-018f-1000-f9bc-b29966db3fc6] Failed to properly
> initialize Processor. If still scheduled to run, NiFi will attempt to
> initialize and run the Processor again after the 'Administrative Yield
> Duration' has elapsed. Failure is due to java.util.ServiceConfigurationError:
> io.grpc.ManagedChannelProvider:
> io.grpc.netty.shaded.io.grpc.netty.UdsNettyChannelProvider Unable to get
> public no-arg constructor nifi-1 | java.util.ServiceConfigurationError:
> io.grpc.ManagedChannelProvider:
> io.grpc.netty.shaded.io.grpc.netty.UdsNettyChannelProvider Unable to get
> public no-arg constructor nifi-1 | at
> java.base/java.util.ServiceLoader.fail(ServiceLoader.java:586) nifi-1 | at
> java.base/java.util.ServiceLoader.getConstructor(ServiceLoader.java:679)
> nifi-1 | at
> java.base/java.util.ServiceLoader$LazyClassPathLookupIterator.hasNextService(ServiceLoader.java:1240)
> nifi-1 | at
> java.base/java.util.ServiceLoader$LazyClassPathLookupIterator.hasNext(ServiceLoader.java:1273)
> nifi-1 | at
> java.base/java.util.ServiceLoader$2.hasNext(ServiceLoader.java:1309) nifi-1 |
> at java.base/java.util.ServiceLoader$3.hasNext(ServiceLoader.java:1393)
> nifi-1 | at io.grpc.ServiceProviders.loadAll(ServiceProviders.java:67) nifi-1
> | at
> io.grpc.ManagedChannelRegistry.getDefaultRegistry(ManagedChannelRegistry.java:101)
> nifi-1 | at
> io.grpc.ManagedChannelProvider.provider(ManagedChannelProvider.java:43)
> nifi-1 | at
> io.grpc.ManagedChannelBuilder.forAddress(ManagedChannelBuilder.java:44)
> nifi-1 | at
> com.google.api.gax.grpc.InstantiatingGrpcChannelProvider.createSingleChannel(InstantiatingGrpcChannelProvider.java:404)
> nifi-1 | at com.google.api.gax.grpc.ChannelPool.<init>(ChannelPool.java:107)
> nifi-1 | at com.google.api.gax.grpc.ChannelPool.create(ChannelPool.java:85)
> nifi-1 | at
> com.google.api.gax.grpc.InstantiatingGrpcChannelProvider.createChannel(InstantiatingGrpcChannelProvider.java:243)
> nifi-1 | at
> com.google.api.gax.grpc.InstantiatingGrpcChannelProvider.getTransportChannel(InstantiatingGrpcChannelProvider.java:237)
> nifi-1 | at
> com.google.api.gax.rpc.ClientContext.create(ClientContext.java:230) nifi-1 |
> at
> com.google.cloud.pubsub.v1.stub.GrpcSubscriberStub.create(GrpcSubscriberStub.java:287)
> nifi-1 | at
> org.apache.nifi.processors.gcp.pubsub.ConsumeGCPubSub.getSubscriber(ConsumeGCPubSub.java:286)
> nifi-1 | at
> org.apache.nifi.processors.gcp.pubsub.ConsumeGCPubSub.onScheduled(ConsumeGCPubSub.java:134)
> nifi-1 | at
> java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103)
> nifi-1 | at java.base/java.lang.reflect.Method.invoke(Method.java:580)
> nifi-1 | at
> org.apache.nifi.util.ReflectionUtils.invokeMethodsWithAnnotations(ReflectionUtils.java:145)
> nifi-1 | at
> org.apache.nifi.util.ReflectionUtils.invokeMethodsWithAnnotations(ReflectionUtils.java:133)
> nifi-1 | at
> org.apache.nifi.util.ReflectionUtils.invokeMethodsWithAnnotations(ReflectionUtils.java:78)
> nifi-1 | at
> org.apache.nifi.util.ReflectionUtils.invokeMethodsWithAnnotation(ReflectionUtils.java:55)
> nifi-1 | at
> org.apache.nifi.controller.StandardProcessorNode.lambda$initiateStart$10(StandardProcessorNode.java:1668)
> nifi-1 | at org.apache.nifi.engine.FlowEngine$3.call(FlowEngine.java:123)
> nifi-1 | at
> java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317) nifi-1 |
> at
> java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
> nifi-1 | at
> java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
> nifi-1 | at
> java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
> nifi-1 | at java.base/java.lang.Thread.run(Thread.java:1583) nifi-1 | Caused
> by: java.lang.NoClassDefFoundError: io/grpc/internal/ObjectPool nifi-1 | at
> java.base/java.lang.Class.getDeclaredConstructors0(Native Method) nifi-1 | at
> java.base/java.lang.Class.privateGetDeclaredConstructors(Class.java:3549)
> nifi-1 | at java.base/java.lang.Class.getConstructor0(Class.java:3754) nifi-1
> | at java.base/java.lang.Class.getConstructor(Class.java:2442) nifi-1 | at
> java.base/java.util.ServiceLoader$1.run(ServiceLoader.java:666) nifi-1 | at
> java.base/java.util.ServiceLoader$1.run(ServiceLoader.java:663) nifi-1 | at
> java.base/java.security.AccessController.doPrivileged(AccessController.java:571)
> nifi-1 | at
> java.base/java.util.ServiceLoader.getConstructor(ServiceLoader.java:674)
> nifi-1 | ... 30 common frames omitted nifi-1 | Caused by:
> java.lang.ClassNotFoundException: io.grpc.internal.ObjectPool nifi-1 | at
> java.base/java.net.URLClassLoader.findClass(URLClassLoader.java:445) nifi-1 |
> at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:593) nifi-1 |
> at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:526) nifi-1 |
> ... 38 common frames omitted nifi-1 | 2024-05-18 23:00:02,171 INFO
> [Timer-Driven Process Thread-1] o.a.n.controller.StandardProcessorNode
> ConsumeGCPubSub[id=890ffc25-018f-1000-f9bc-b29966db3fc6] has completely
> stopped. Completing any associated Futures.}}
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
