Emin created NIFI-13268:
---------------------------
Summary: 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
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)
