This is an automated email from the ASF dual-hosted git repository. apilloud pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit 9de4bd93fb496c9b5e7c0c1cab3690e617bc2943 Merge: 16911c5 df8912d Author: Andrew Pilloud <[email protected]> AuthorDate: Mon Nov 15 18:01:59 2021 -0800 Merge pull request #15915: [beam-12737] add API to handle failed rows in the collection due to sql query runtime error .../beam/sdk/extensions/sql/SqlTransform.java | 15 +- .../sdk/extensions/sql/impl/rel/BeamCalcRel.java | 82 ++++++++-- .../sdk/extensions/sql/impl/rel/BeamRelNode.java | 9 ++ .../extensions/sql/impl/rel/BeamSqlRelUtils.java | 40 ++++- .../sdk/extensions/sql/error/BeamSqlErrorTest.java | 167 +++++++++++++++++++++ .../sdk/extensions/sql/error/CalculatePrice.java | 35 +++++ .../beam/sdk/extensions/sql/error/CastUdf.java | 31 ++++ 7 files changed, 358 insertions(+), 21 deletions(-)
