Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Can't use java logical types defined in Java JDBC IO in XLang JDBC pipeline for Go and Python #21433

Open
damccorm opened this issue Jun 4, 2022 · 1 comment

Comments

@damccorm
Copy link
Contributor

damccorm commented Jun 4, 2022

Currently, we can't use the logical types defined in java JDBC IO 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)

Imported from Jira BEAM-13717. Original Jira may contain additional context.
Reported by: riteshghorse.

@Abacn
Copy link
Contributor

Abacn commented Jun 9, 2023

Logical types are now support on Python (char/varchar/binary/varbinary/decimal/timestamp), go support is not yet planned

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

No branches or pull requests

2 participants