Hi I have very limited knowledge about Apache Beam and I'm facing a
strange problem when starting job in Dataflow using Go SDK. First I get this
debug message (I see more of such Splits) PB Split:
instruction_id:"process_bundle-2455586051109757402-4328"
desired_splits:{key:"ptransform-11" value:{fraction_of_remainder:0.5
allowed_split_points:0 allowed_split_points:1 estimated_input_elements:1}}
And just after this debug message there is an error github.com
github.com/apache/beam/sdks/[email protected]/go/pkg/beam/core/runtime/harness/harness.go:432
" message: "unable to split process_bundle-2455586051109757402-4328:
failed to split DataSource (at index: 1) at requested splits: {[0 1]}"
After this error whole jobs crashes. Is this likely a problem in my in my
pipeline or a bug in Dataflow and/or Beam? Thanks in advance -- Paweł
