This one is weird. A DoFn I wrote: - stateful - used plenty in a streaming pipeline - direct and dataflow runners - works fine
Now: - new batch pipeline - @DoFn.Setup method not called - direct runner works properly (logs from setup method are output) - dataflow runner simply doesn't call the setup method Is this possibly a Beam misuse? Javadoc for DoFn.Setup doesn't hint at anything, so I'm suspecting Dataflow bug? Jacob
