Hi, A JIRA ticket is raised to track this bug: BEAM-8307 <https://issues.apache.org/jira/browse/BEAM-8307>
I have raised a PR: https://github.com/apache/beam/pull/11581 to fix the issue. This PR takes care of using BeamSql with JdbcIO. I would be interested to contribute if any other IOs supported by Beam requires a similar fix like the one in this PR so that they can be used with BeamSql. What could be a cleaner approach, in general, to handle this for all the IOs? Also, what can be done to support BeamSql with User-Defined Logical Types? Should they be converted to one of the Beam SQL Types[1] before applying SqlTransform.query()? Should we expose an interface to provide Calcite RelDataType Mapping for User-Defined Logical Types? Let me know your thoughts. [1]: https://github.com/apache/beam/blob/b8aa8486f336df6fc9cf581f29040194edad3b87/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/utils/CalciteUtils.java#L43 Regards, Rahul
