Dataflow setting Controller Service Account

Question

I try to set up controller service account for Dataflow. In my dataflow options I have:

options.setGcpCredential(GoogleCredentials.fromStream(new FileInputStream("key.json")).createScoped(someArrays)); 
options.setServiceAccount("[e-mail]");

But I'm getting:

WARNING: Request failed with code 403, 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://dataflow.googleapis.com/v1b3/projects/MYPROJECT/locations/MYLOCATION/jobs
Exception in thread "main" java.lang.RuntimeException: Failed to create a workflow job: (CODE): Current user cannot act as service account "[e-mail]. Causes: (CODE): Current user cannot act as service account "[e-mail].
    at org.apache.beam.runners.dataflow.DataflowRunner.run(DataflowRunner.java:791)
    at org.apache.beam.runners.dataflow.DataflowRunner.run(DataflowRunner.java:173)
    at org.apache.beam.sdk.Pipeline.run(Pipeline.java:311)
    at org.apache.beam.sdk.Pipeline.run(Pipeline.java:297)

...

Caused by: com.google.api.client.googleapis.json.GoogleJsonResponseException: 403 Forbidden
{
  "code" : 403,
  "errors" : [ {
    "domain" : "global",
    "message" : "(CODE): Current user cannot act as service account [e-mail]. Causes: (CODE): Current user cannot act as service account [e-mail].",
    "reason" : "forbidden"
  } ],
  "message" : "(CODE): Current user cannot act as service account [e-mail]. Causes: (CODE): Current user cannot act as service account [e-mail].",
  "status" : "PERMISSION_DENIED"
}

Am I missing some Roles or permissions?

Answer 1

Maybe someone is going to find it helpful:

• For controller it was: Dataflow Worker and Storage Object Admin (that was found in Google's documentation).

• For executor it was: Service Account User.