[jira] [Created] (BEAM-11614) sql_taxi examples fails on HEAD due to "transform unexpectedly with no env id"

["Chamikara Madhusanka Jayalath (Jira)" <ji...@apache.org>]

Chamikara Madhusanka Jayalath created BEAM-11614:
----------------------------------------------------

             Summary: sql_taxi examples fails on HEAD due to "transform unexpectedly with no env id"
                 Key: BEAM-11614
                 URL: https://issues.apache.org/jira/browse/BEAM-11614
             Project: Beam
          Issue Type: Bug
          Components: cross-language
            Reporter: Chamikara Madhusanka Jayalath
            Assignee: Brian Hulette


For example, [https://pantheon.corp.google.com/dataflow/jobs/us-central1/2021-01-11_21_50_55-8290792779966349848?project=google.com:clouddfe]

 

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 ?



--
This message was sent by Atlassian Jira
(v8.3.4#803005)