Details
-
Bug
-
Status: Resolved
-
P1
-
Resolution: Fixed
-
None
-
None
Description
transform unexpectedly with no env id: external_1SqlTransform(beam:external:java:sql:v1)/BeamAggregationRel_34/Group.CombineFieldsByFields/ToKvs/toRow: spec { } inputs { key: "org.apache.beam.sdk.values.PCollection.<init>:402#3d93cb799b3970be" value: "external_1SqlTransform(beam:external:java:sql:v1)/BeamCalcRel_33/ParDo(Calc)/ParMultiDo(Calc).output" } outputs { key: "org.apache.beam.sdk.values.PCollection.<init>:402#3d93cb799b3970be" value: "external_1SqlTransform(beam:external:java:sql:v1)/BeamCalcRel_33/ParDo(Calc)/ParMultiDo(Calc).output" } unique_name: "SqlTransform(beam:external:java:sql:v1)/BeamAggregationRel_34/Group.CombineFieldsByFields/ToKvs/toRow"
Seems like somehow Sql expansion produces a sub-transform that does not have environment ID set.
This passes for Beam 2.27.0 so should be due to a recent change.
Brian, are you aware of any recent change that could have resulted in this breakage ?