[jira] [Created] (BEAM-9814) Error occurred when transforming from row to a new row without setCoder

[Ruixue Liao (Jira)]

Ruixue Liao created BEAM-9814:
---------------------------------

             Summary: Error occurred when transforming from row to a new row 
without setCoder
                 Key: BEAM-9814
                 URL: https://issues.apache.org/jira/browse/BEAM-9814
             Project: Beam
          Issue Type: Bug
          Components: beam-model
    Affects Versions: 2.19.0
            Reporter: Ruixue Liao


The output row from transform function uses the input row schema to verify 
which causes error. Ex:

{{        .apply(MapElements.via(
                new SimpleFunction<Row, Row>() \{
                    @Override
                    public Row apply(Row line) {
                        return Row.withSchema(newSchema).addValues("a", 1, 
"b").build();
                    }
                }));}}

{{Got error when the output row schema is not the same as the input row.}}

Need to add {{.setCoder(RowCoder.of(newSchema))}} after the transform function 
to make it work. {{}}

{{Related link: 
[https://stackoverflow.com/questions/61236972/beam-sql-udf-to-split-one-column-into-multiple-columns]}}



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