Google API Client Library version 1.23.0 causes runtime problems with Dataflow Java SDK #607

moandcompany · 2017-10-05T19:30:54Z

The new Google API Client Library, version 1.23.0, appears to cause problems with the Dataflow Java SDK when submitting and/or running jobs.

This appears to affect Dataflow Java SDKs in both major version families (e.g. 1.9.1, 2.0.0, and 2.1.0)

In some cases, these problems manifest as 404 HTTP errors when attempting to upload staging files

Exception in thread "main" org.apache.beam.sdk.Pipeline$PipelineExecutionException: java.io.IOException: Error executing batch GCS request :userprofile:run
at org.apache.beam.runners.direct.DirectRunner$DirectPipelineResult.waitUntilFinish(DirectRunner.java:322)
at org.apache.beam.runners.direct.DirectRunner$DirectPipelineResult.waitUntilFinish(DirectRunner.java:292)
at org.apache.beam.runners.direct.DirectRunner.run(DirectRunner.java:200)
at org.apache.beam.runners.direct.DirectRunner.run(DirectRunner.java:63)
(...)

Caused by: java.util.concurrent.ExecutionException: com.google.api.client.http.HttpResponseException: 404 Not Found
Not Found
at org.apache.beam.sdks.java.extensions.google.cloud.platform.core.repackaged.com.google.common.util.concurrent.AbstractFuture.getDoneValue(AbstractFuture.java:500)
at org.apache.beam.sdks.java.extensions.google.cloud.platform.core.repackaged.com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:479)
at org.apache.beam.sdks.java.extensions.google.cloud.platform.core.repackaged.com.google.common.util.concurrent.AbstractFuture$TrustedFuture.get(AbstractFuture.java:76)
at org.apache.beam.sdk.util.GcsUtil.executeBatches(GcsUtil.java:611)
at org.apache.beam.sdk.util.GcsUtil.getObjects(GcsUtil.java:358)
at org.apache.beam.sdk.extensions.gcp.storage.GcsFileSystem.matchNonGlobs(GcsFileSystem.java:217)
at org.apache.beam.sdk.extensions.gcp.storage.GcsFileSystem.match(GcsFileSystem.java:86)
(...)

Caused by: com.google.api.client.http.HttpResponseException: 404 Not Found
Not Found
at com.google.api.client.http.HttpRequest.execute(HttpRequest.java:1070)
at com.google.api.client.googleapis.batch.BatchRequest.execute(BatchRequest.java:241)
at org.apache.beam.sdk.util.GcsUtil$3.call(GcsUtil.java:604)
at org.apache.beam.sdk.util.GcsUtil$3.call(GcsUtil.java:602)
at org.apache.beam.sdks.java.extensions.google.cloud.platform.core.repackaged.com.google.common.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:111)
at org.apache.beam.sdks.java.extensions.google.cloud.platform.core.repackaged.com.google.common.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:58)

Workaround:
Pinning Google API Client Library dependencies to version 1.22.0 appears to avoid this issue

com.google.api-client:google-api-client:1.22.0

Gradle Example:

compile ('com.google.api-client:google-api-client:1.22.0') {
        force = true
    }

Maven Example:

<dependency>
  <groupId>com.google.api-client</groupId>
  <artifactId>google-api-client</artifactId>
  <version>[1.22.0]</version>
</dependency>

The text was updated successfully, but these errors were encountered:

polleyg · 2017-10-11T01:06:13Z

We've had the same problem. Except for us, it was with the the BigQuery API that we were bringing into our project. Removing it fixed it (Beam has a dependancy in it anyway).

pheromonez · 2017-10-11T04:27:12Z

We're also experiencing issues during file staging. Before the attempt to upload files is made, we receive this error:
WARNING: Request failed with code 409, performed 0 retries due to IOExceptions, performed 0 retries due to unsuccessful status codes, HTTP framework says request can be retried, (caller responsible for retrying): https://www.googleapis.com/storage/v1/b?predefinedAcl=projectPrivate&predefinedDefaultObjectAcl=projectPrivate&project=<project name omitted>

Accessing the HTTP resource specified will return JSON data, within which there is an error with message
Anonymous users does not have storage.buckets.list access to project <project number omitted>.

afcastano · 2017-10-11T09:58:51Z

We had the same issue and we can confirm that as @moandcompany suggest, this fixes it:

compile ('com.google.api-client:google-api-client:1.22.0') {
        force = true
    }

For the record, our stack trace is pretty similar. We are running 2.2.0 snapshot version of apache beam:

java.io.IOException: Error executing batch GCS request
        at org.apache.beam.sdk.util.GcsUtil.executeBatches(GcsUtil.java:603)
        at org.apache.beam.sdk.util.GcsUtil.getObjects(GcsUtil.java:342)
        at org.apache.beam.sdk.extensions.gcp.storage.GcsFileSystem.matchNonGlobs(GcsFileSystem.java:217)
        at org.apache.beam.sdk.extensions.gcp.storage.GcsFileSystem.match(GcsFileSystem.java:86)
        at org.apache.beam.sdk.io.FileSystems.match(FileSystems.java:125)
        at org.apache.beam.sdk.io.FileSystems.matchSingleFileSpec(FileSystems.java:190)
        at org.apache.beam.runners.dataflow.util.PackageUtil.alreadyStaged(PackageUtil.java:159)
        at org.apache.beam.runners.dataflow.util.PackageUtil.stagePackageSynchronously(PackageUtil.java:188)
        at org.apache.beam.runners.dataflow.util.PackageUtil.access$000(PackageUtil.java:69)
        at org.apache.beam.runners.dataflow.util.PackageUtil$2.call(PackageUtil.java:176)
        at org.apache.beam.runners.dataflow.util.PackageUtil$2.call(PackageUtil.java:173)
        at org.apache.beam.runners.dataflow.repackaged.com.google.common.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:111)
        at org.apache.beam.runners.dataflow.repackaged.com.google.common.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:58)
        at org.apache.beam.runners.dataflow.repackaged.com.google.common.util.concurrent.TrustedListenableFutureTask.run(TrustedListenableFutureTask.java:75)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        at java.lang.Thread.run(Thread.java:748)
Caused by: java.util.concurrent.ExecutionException: com.google.api.client.http.HttpResponseException: 404 Not Found
Not Found
        at org.apache.beam.sdks.java.extensions.google.cloud.platform.core.repackaged.com.google.common.util.concurrent.AbstractFuture.getDoneValue(AbstractFuture.java:500)
        at org.apache.beam.sdks.java.extensions.google.cloud.platform.core.repackaged.com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:459)
        at org.apache.beam.sdks.java.extensions.google.cloud.platform.core.repackaged.com.google.common.util.concurrent.AbstractFuture$TrustedFuture.get(AbstractFuture.java:76)
        at org.apache.beam.sdk.util.GcsUtil.executeBatches(GcsUtil.java:595)
        ... 16 more

zinuzoid · 2017-10-16T04:59:32Z

I got similar problem. Here's the API response.

Caused by: com.google.api.client.googleapis.json.GoogleJsonResponseException: 400 Bad Request
{
  "code" : 400,
  "errors" : [ {
    "domain" : "global",
    "message" : "(249a6f2653c550b0): The workflow was automatically rejected by the service because it may trigger an identified bug in the SDK.\nBug details: com.google.api-client:google-api-client library version 1.23.0 is not supported..\nContact [email protected] for further help. Please use this identifier in your communication: 67379331.",
    "reason" : "badRequest"
  } ],
  "message" : "(249a6f2653c550b0): The workflow was automatically rejected by the service because it may trigger an identified bug in the SDK.\nBug details: com.google.api-client:google-api-client library version 1.23.0 is not supported..\nContact [email protected] for further help. Please use this identifier in your communication: 67379331.",
  "status" : "INVALID_ARGUMENT"
}

lukecwik · 2017-10-16T16:54:45Z

Google added support to reject jobs from being created with this issue to prevent users from starting malformed jobs.

frew · 2017-11-14T00:13:29Z

The root cause for the 404's is outlined at googleapis/google-api-java-client#1073. Hilariously, you can't get to the error rejecting the job for bad dependencies until you've cleared up the staging problem (in our case by upgrading to com.google.apis:google-api-services-storage:v1-rev115-1.23.0 ). Is there another problem that's causing the job rejection? We're being forced to 1.23.0 by a bug in another Google API so this puts us between a rock and a hard place because lol @ Java versioning on Maven.

Jdban · 2017-12-04T19:18:00Z

+1 happening to us too. Is there any suggested remedy?

moandcompany · 2017-12-12T01:34:16Z

The Cloud Dataflow team has added a page on Dataflow SDK and Worker Dependencies that identifies the google-api-client 1.22.0 version requirement (Java)

Jdban · 2017-12-12T15:54:53Z

The Cloud Dataflow team has added a page on Dataflow SDK and Worker Dependencies that identifies the google-api-client 1.22.0 version requirement (Java)

That is a useful link, but not really a solution for those of us like @frew who need to use google-api-client 1.23.0 due to a bug in another library

sgri · 2018-01-16T12:25:34Z

I also have this issue

ghost · 2018-01-29T01:53:06Z

any updates? Im running into this issue

alan-ma-umg · 2018-02-26T05:23:44Z

same here. apache beam 2.3.0 with dataflowrunner having the same 404 error. A permanent fix would be ideal.

Thanks.

dsquier · 2018-03-09T16:08:00Z

We encountered this as well. We're on Scio 0.5.5-beta1 and attempted to force the version to 1.2.2 using Overrides never worked. However, explicitly adding this library with a force() did work, i.e.,

"com.google.api-client" % "google-api-client" % "1.22.0" force()

gfengster · 2018-03-30T14:29:56Z

I have the same problem. Google forces moving out of storage@v1. Add

com.google.apis
google-api-services-storage
v1-rev115-1.23.0

The runtime error becomes
Exception in thread "main" org.apache.beam.sdk.Pipeline$PipelineExecutionException: java.lang.NoClassDefFoundError: com/google/api/gax/rpc/HeaderProvider
It looks libraries conflict across Google's infrastructure libraries. Horrible.

andrewcassidy · 2018-05-02T23:42:28Z

@dsquier omg thank you. I was battling dependencyOverrides for a while and didn't think about force.

pabloazurduy · 2018-05-23T20:58:36Z

I was redirected here from google because I was using the bigquery-client library and the same error appeared. Does anybody found a workaround to this issue?
I've tried (without success)

    <dependency>
      <groupId>com.google.cloud</groupId>
      <artifactId>google-cloud-bigquery</artifactId>
      <version>0.21.0-beta</version>
    </dependency>

pievis · 2018-06-06T15:46:33Z

After analyzing my dependencies and checking the error, I was able to fix this by forcing the version of google-api-services-dataflow to v1b3-rev221-1.22.0 (and of course setting google-api-client to version 1.22.0)

Only setting google-api-client to the old version wasn't enough for me since I had the following error thrown:


java.io.IOException: Error executing batch GCS request
        at org.apache.beam.sdk.util.GcsUtil.executeBatches(GcsUt

when trying to compile my dataflow template

vinnybod · 2018-06-26T22:15:03Z

For anyone else still seeing issues like this, check out the version numbers here and make sure you aren't importing a conflicting dependency.

labianchin · 2018-08-13T11:41:54Z

Now Beam 2.5.0 depends on google-api-client:1.23.0, see https://cloud.google.com/dataflow/docs/concepts/sdk-worker-dependencies. Is this still an issue?

medb mentioned this issue Oct 28, 2017

com.google.api.client not shaded in GCS Connector fat jar GoogleCloudDataproc/hadoop-connectors#72

Closed

moandcompany mentioned this issue Jan 6, 2018

Issues submitting Dataflow jobs with v1.23.0 googleapis/google-api-java-client#1073

Closed

honnix mentioned this issue May 17, 2018

downgrade bigquery lib spotify/flo#74

Merged

andrewsmartin mentioned this issue May 24, 2018

Add google-api-client dep override in scio-tensorflow spotify/scio#1180

Closed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Google API Client Library version 1.23.0 causes runtime problems with Dataflow Java SDK #607

Google API Client Library version 1.23.0 causes runtime problems with Dataflow Java SDK #607

moandcompany commented Oct 5, 2017 •

edited

Loading

polleyg commented Oct 11, 2017 •

edited

Loading

pheromonez commented Oct 11, 2017

afcastano commented Oct 11, 2017 •

edited

Loading

zinuzoid commented Oct 16, 2017

lukecwik commented Oct 16, 2017

frew commented Nov 14, 2017

Jdban commented Dec 4, 2017

moandcompany commented Dec 12, 2017

Jdban commented Dec 12, 2017

sgri commented Jan 16, 2018

ghost commented Jan 29, 2018 •

edited by ghost

Loading

alan-ma-umg commented Feb 26, 2018

dsquier commented Mar 9, 2018

gfengster commented Mar 30, 2018

andrewcassidy commented May 2, 2018

pabloazurduy commented May 23, 2018 •

edited

Loading

pievis commented Jun 6, 2018

vinnybod commented Jun 26, 2018

labianchin commented Aug 13, 2018

Google API Client Library version 1.23.0 causes runtime problems with Dataflow Java SDK #607

Google API Client Library version 1.23.0 causes runtime problems with Dataflow Java SDK #607

Comments

moandcompany commented Oct 5, 2017 • edited Loading

polleyg commented Oct 11, 2017 • edited Loading

pheromonez commented Oct 11, 2017

afcastano commented Oct 11, 2017 • edited Loading

zinuzoid commented Oct 16, 2017

lukecwik commented Oct 16, 2017

frew commented Nov 14, 2017

Jdban commented Dec 4, 2017

moandcompany commented Dec 12, 2017

Jdban commented Dec 12, 2017

sgri commented Jan 16, 2018

ghost commented Jan 29, 2018 • edited by ghost Loading

alan-ma-umg commented Feb 26, 2018

dsquier commented Mar 9, 2018

gfengster commented Mar 30, 2018

andrewcassidy commented May 2, 2018

pabloazurduy commented May 23, 2018 • edited Loading

pievis commented Jun 6, 2018

vinnybod commented Jun 26, 2018

labianchin commented Aug 13, 2018

moandcompany commented Oct 5, 2017 •

edited

Loading

polleyg commented Oct 11, 2017 •

edited

Loading

afcastano commented Oct 11, 2017 •

edited

Loading

ghost commented Jan 29, 2018 •

edited by ghost

Loading

pabloazurduy commented May 23, 2018 •

edited

Loading