Thomas Groh

You're also getting the "`BigQueryIO.Write needs a GCS temp location to store temp files.`" error message? Your choice of runner and the arguments you're passing to exec don't look like...

You need to either programatically set the `tempLocation` (via `options.setTempLocation(String)`) or use the `PipelineOptionsFactory.fromArgs(args)` instead of `PipelineOptionsFactory.create()` to recieve the temp location from the command line. You've commented out the...

Can you provide more of a stack trace? My initial assumption is that you're using a value provider that doesn't have a value assigned to it, but I would need...

Values are only assigned if you're executing the pipeline with a value present in the options. That message isn't particularly useful, especially on the DirectPipelineRunner, but the issue is that...

You're executing via the `DirectPipelineRunner`, but you need to use the `TemplatingDataflowPipelineRunner` (which is also commented out)