[
https://issues.apache.org/jira/browse/BEAM-9814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17136043#comment-17136043
]
Beam JIRA Bot commented on BEAM-9814:
-------------------------------------
This issue is assigned but has not received an update in 30 days so it has been
labeled "stale-assigned". If you are still working on the issue, please give an
update and remove the label. If you are no longer working on the issue, please
unassign so someone else may work on it. In 7 days the issue will be
automatically unassigned.
> 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: sdk-java-core
> Affects Versions: 2.19.0
> Reporter: Ruixue Liao
> Assignee: Reuven Lax
> Priority: P2
> Labels: stale-assigned
>
> The output row from transform function uses the input row schema to verify
> which causes error. Ex:
> {code}
> .apply(MapElements.via(
> new SimpleFunction<Row, Row>() \{
> @Override
> public Row apply(Row line) {
> return Row.withSchema(newSchema).addValues("a", 1,
> "b").build();
> }
> }));
> {code}
> 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)
