Logstash Docker on GCP Cloud Run: Expected the service InnerService [FAILED] to be TERMINATED, but the service has FAILED

Elastic Stack Logstash
1

Continuing the discussion from Logstash Docker on GCP Cloud Run: Failed to find a usable hardware address from the network interfaces:
I have a similar use-case, running custom logstash container from gcloud-run with the below configuration but the container is unable to pull anything from the subscriber, all the access to service accounts have been provided.

input
{
   google_pubsub {
       project_id => "XXXXXXXX"
       topic => "topic1"
       subscription => "logstash-sub"
       include_metadata => true
       codec => "json"
   }

    output {
      elasticsearch {
        hosts => "${HOSTS}"
        user => "${USERNAME}" 
        password => "${PASSWORD}"  
        index => "${INDEX}"
        }
      stdout {
      }
    }`Preformatted text`

Logs:
  "textPayload": "java.lang.IllegalStateException: Expected the service InnerService [FAILED] to be RUNNING, but the service has FAILED\n\tat com.google.common.util.concurrent.AbstractService.checkCurrentState(AbstractService.java:381)\n\tat com.google.common.util.concurrent.AbstractService.awaitRunning(AbstractService.java:305)\n\tat com.google.api.core.AbstractApiService.awaitRunning(AbstractApiService.java:96)\n\tat com.google.cloud.pubsub.v1.Subscriber.startConnections(Subscriber.java:390)\n\tat com.google.cloud.pubsub.v1.Subscriber.startStreamingConnections(Subscriber.java:355)\n\tat com.google.cloud.pubsub.v1.Subscriber.access$200(Subscriber.java:93)\n\tat com.google.cloud.pubsub.v1.Subscriber$3.run(Subscriber.java:299)\n\tat java.base/java.lang.Thread.run(Thread.java:829)\nCaused by: java.lang.NoSuchMethodError: 'void com.google.common.util.concurrent.Futures.addCallback(com.google.common.util.concurrent.ListenableFuture, com.google.common.util.concurrent.FutureCallback)'\n\tat com.google.cloud.pubsub.v1.StreamingSubscriberConnection.initialize(StreamingSubscriberConnection.java:218)\n\tat com.google.cloud.pubsub.v1.StreamingSubscriberConnection.doStart(StreamingSubscriberConnection.java:110)\n\tat com.google.api.core.AbstractApiService$InnerService.doStart(AbstractApiService.java:148)\n\tat com.google.common.util.concurrent.AbstractService.startAsync(AbstractService.java:251)\n\tat com.google.api.core.AbstractApiService.startAsync(AbstractApiService.java:120)\n\tat com.google.cloud.pubsub.v1.Subscriber.startConnections(Subscriber.java:387)\n\t... 4 more",
    "insertId": "62a1ca8500045d3deeab2266",
    "resource": {
      "type": "cloud_run_revision",
2

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.