Default datastore instance inside dataflow job

Question

I am trying to call Google datastore inside dataflow job I am getting null instance

datastore = DatastoreOptions.getDefaultInstance().getService();

Answer 1

Try putting this code in the main function not inside dataflow Pipline.

Answer 2

This could probably be a credential issue. Could you try this,

Credentials credentials = context.getPipelineOptions().as(GcpOptions.class).getGcpCredential();

Datastore datastore = DatastoreOptions.newBuilder().setCredentials(credentials).build().getService();