damccorm opened a new issue, #21433: URL: https://github.com/apache/beam/issues/21433
Currently, we can't use the logical types defined in [java JDBC IO](https://github.com/apache/beam/blob/master/sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/LogicalTypes.java) in XLang pipelines for JDBC IO in Go SDK as it throws the following error: ``` unmarshalling coder jFYvjSCanTRowCoder_length_prefixed_windowed unmarshalling coder jFYvjSCanTRowCoder_length_prefixed cannot convert schema field role_name to field caused by: unknown logical type: beam:logical_type:javasdk:v1 ``` This is the structure of table and its corresponding struct: ``` // roles=> CREATE TABLE roles( // role_id serial PRIMARY KEY, // role_name VARCHAR (255) UNIQUE // ); type JdbcTestRow struct { Role_id int32 `beam:"role_id"` Role_name string `beam:"role_name"` } ``` Similar error seems to be appearing on Python SDK pipeline based on this stack overflow question: ([https://stackoverflow.com/questions/68758361/error-beamlogical-typejavasdkv1-while-using-apache-beam-io-jdbc-readfromjdbc](https://stackoverflow.com/questions/68758361/error-beamlogical-typejavasdkv1-while-using-apache-beam-io-jdbc-readfromjdbc)) Imported from Jira [BEAM-13717](https://issues.apache.org/jira/browse/BEAM-13717). Original Jira may contain additional context. Reported by: riteshghorse. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
