[
https://issues.apache.org/jira/browse/NIFI-14295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pierre Villard resolved NIFI-14295.
-----------------------------------
Resolution: Feedback Received
Apache NiFi 1.x is no longer maintained and no new release is planned on the
1.x release line. Marking as resolved as part of a cleanup operation. Please
open a new one with an updated description if this is still relevant for NiFi
2.x.
> 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
> Priority: Major
>
> 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)
