Rahul Patwari created BEAM-8307:
-----------------------------------
Summary: Support for Logical types introduced by JdbcIO Transform
in SqlTransform
Key: BEAM-8307
URL: https://issues.apache.org/jira/browse/BEAM-8307
Project: Beam
Issue Type: Bug
Components: dsl-sql
Affects Versions: 2.15.0
Reporter: Rahul Patwari
Assignee: Rahul Patwari
An exception is thrown when SqlTransform is used with JdcIO. PFA - a file which
contains the Exception StackTrace.
Schema of the Source Table:
_CREATE TABLE actor (_
_actor_id SMALLINT UNSIGNED NOT NULL AUTO_INCREMENT,_
_first_name VARCHAR(45) NOT NULL,_
_last_name VARCHAR(45) NOT NULL,_
_last_update TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE
CURRENT_TIMESTAMP,_
_PRIMARY KEY (actor_id),_
_KEY idx_actor_last_name (last_name)_
_)ENGINE=InnoDB DEFAULT CHARSET=utf8;_
Many of the Jdbc Types are converted to Logical_Types in Beam.
Refer:
[https://github.com/apache/beam/blob/113461a4275eb28a101e416897ccd607aa51f83f/sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/SchemaUtil.java#L102]
The initial observation is that this code:
[https://github.com/apache/beam/blob/113461a4275eb28a101e416897ccd607aa51f83f/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/utils/CalciteUtils.java#L207]
is returning null.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
