Diego Garcia Teba created NIFI-14295:
----------------------------------------
Summary: Problem calling to PubSub regional endpoints
Key: NIFI-14295
URL: https://issues.apache.org/jira/browse/NIFI-14295
Project: Apache NiFi
Issue Type: Bug
Affects Versions: 1.25.0
Reporter: Diego Garcia Teba
Hi,
Using the PublishGCPubSub tool we are having problems for publishing data into
PubSub using regional endpoints. We are using for example
us-central1-pubsub.googleapis.com:443 instead of pubsub.googleapis.com:443.
We are receiving the following problem.
{quote}{{025-02-20 09:20:28,829 ERROR [Timer-Driven Process Thread-6]
o.a.n.p.g.pubsub.publish.FlowFileResult Failed to reconcile PubSub send
operation status}}
{{java.util.concurrent.ExecutionException:
com.google.api.gax.rpc.UnauthenticatedException:
io.grpc.StatusRuntimeException: UNAUTHENTICATED: Request had invalid
authentication credentials. Expected OAuth 2 access token, login cookie or
other valid authentication credential. See
[https://developers.google.com/identity/sign-in/web/devconsole-project].}}
{{ at
com.google.common.util.concurrent.AbstractFuture.getDoneValue(AbstractFuture.java:592)}}
{{ at
com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:571)}}
{{ at
com.google.common.util.concurrent.AbstractFuture$TrustedFuture.get(AbstractFuture.java:111)}}
{{ at
com.google.common.util.concurrent.ForwardingFuture.get(ForwardingFuture.java:67)}}
{{ at
org.apache.nifi.processors.gcp.pubsub.publish.FlowFileResult.reconcile(FlowFileResult.java:63)}}
{{ at
org.apache.nifi.processors.gcp.pubsub.PublishGCPubSub.finishBatch(PublishGCPubSub.java:419)}}
{{ at
org.apache.nifi.processors.gcp.pubsub.PublishGCPubSub.onTriggerFlowFileStrategy(PublishGCPubSub.java:338)}}
{{ at
org.apache.nifi.processors.gcp.pubsub.PublishGCPubSub.onTrigger(PublishGCPubSub.java:300)}}
{{ at
org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)}}
{{ at
org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1361)}}
{{ at
org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:247)}}
{{ at
org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:102)}}
{{ at org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.java:110)}}
{{ at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)}}
{{ at
java.base/java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305)}}
{{ at
java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305)}}
{{ at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)}}
{{ at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)}}
{{ at java.base/java.lang.Thread.run(Thread.java:829)}}
{{Caused by: com.google.api.gax.rpc.UnauthenticatedException:
io.grpc.StatusRuntimeException: UNAUTHENTICATED: Request had invalid
authentication credentials. Expected OAuth 2 access token, login cookie or
other valid authentication credential. See
[https://developers.google.com/identity/sign-in/web/devconsole-project].}}
{{ at
com.google.api.gax.rpc.ApiExceptionFactory.createException(ApiExceptionFactory.java:116)}}
{{ at
com.google.api.gax.rpc.ApiExceptionFactory.createException(ApiExceptionFactory.java:41)}}
{{ at
com.google.api.gax.grpc.GrpcApiExceptionFactory.create(GrpcApiExceptionFactory.java:86)}}
{{ at
com.google.api.gax.grpc.GrpcApiExceptionFactory.create(GrpcApiExceptionFactory.java:66)}}
{{ at
com.google.api.gax.grpc.GrpcExceptionCallable$ExceptionTransformingFuture.onFailure(GrpcExceptionCallable.java:97)}}
{{ at com.google.api.core.ApiFutures$1.onFailure(ApiFutures.java:84)}}
{{ at
com.google.common.util.concurrent.Futures$CallbackListener.run(Futures.java:1127)}}
{{ at
com.google.common.util.concurrent.DirectExecutor.execute(DirectExecutor.java:31)}}
{{ at
com.google.common.util.concurrent.AbstractFuture.executeListener(AbstractFuture.java:1286)}}
{{ at
com.google.common.util.concurrent.AbstractFuture.complete(AbstractFuture.java:1055)}}
{{ at
com.google.common.util.concurrent.AbstractFuture.setException(AbstractFuture.java:807)}}
{{ at
io.grpc.stub.ClientCalls$GrpcFuture.setException(ClientCalls.java:568)}}
{{ at
io.grpc.stub.ClientCalls$UnaryStreamToFuture.onClose(ClientCalls.java:538)}}
{{ at
io.grpc.PartialForwardingClientCallListener.onClose(PartialForwardingClientCallListener.java:39)}}
{{ at
io.grpc.ForwardingClientCallListener.onClose(ForwardingClientCallListener.java:23)}}
{{ at
io.grpc.ForwardingClientCallListener$SimpleForwardingClientCallListener.onClose(ForwardingClientCallListener.java:40)}}
{{ at
com.google.api.gax.grpc.ChannelPool$ReleasingClientCall$1.onClose(ChannelPool.java:546)}}
{{ at
io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:567)}}
{{ at
io.grpc.internal.ClientCallImpl.access$300(ClientCallImpl.java:71)}}
{{ at
io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInternal(ClientCallImpl.java:735)}}
{{ at
io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInContext(ClientCallImpl.java:716)}}
{{ at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)}}
{{ at
io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:133)}}
{{ at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)}}
{{ at
java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)}}
{{ at
java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)}}
{{ ... 3 common frames omitted}}
{{Caused by: io.grpc.StatusRuntimeException: UNAUTHENTICATED: Request had
invalid authentication credentials. Expected OAuth 2 access token, login cookie
or other valid authentication credential. See
[https://developers.google.com/identity/sign-in/web/devconsole-project].}}
{{ at io.grpc.Status.asRuntimeException(Status.java:537)}}
{{ ... 17 common frames omitted}}
{{2025-02-20 09:20:28,908 INFO [Timer-Driven Process Thread-10]
o.a.n.r.p.s.SocketFlowFileServerProtocol
SocketFlowFileServerProtocol[CommsID=27cc202f-3f49-4a72-9314-33f0c889294a]
Successfully received
[StandardFlowFileRecord[uuid=eac9299f-b8e4-4a45-b87d-9a8922a50302,claim=StandardContentClaim
[resourceClaim=StandardResourceClaim[id=1740043223808-7264, container=default,
section=96], offset=957706,
length=10381],offset=0,name=65688edf-29bf-4e1d-b59f-5bdfdb9bd036,size=1038}}
{quote}
{{Could you help us to solve this problem?}}
Thanks.
Diego
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
