You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Mark Liu (Jira)" <ji...@apache.org> on 2019/09/09 19:40:00 UTC

[jira] [Commented] (BEAM-8032) JdbcIO.readRows() throws exception when the statementPreparator is not provided for simple Select statement

    [ https://issues.apache.org/jira/browse/BEAM-8032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16926046#comment-16926046 ] 

Mark Liu commented on BEAM-8032:
--------------------------------

Is this issue on track for 2.16 release? (branch will be cut in 3 days) 

> JdbcIO.readRows() throws exception when the statementPreparator is not provided for simple Select statement
> -----------------------------------------------------------------------------------------------------------
>
>                 Key: BEAM-8032
>                 URL: https://issues.apache.org/jira/browse/BEAM-8032
>             Project: Beam
>          Issue Type: Bug
>          Components: io-java-jdbc
>    Affects Versions: 2.14.0
>            Reporter: Kishor Joshi
>            Assignee: Charith Ellawala
>            Priority: Major
>             Fix For: 2.16.0
>
>          Time Spent: 1h
>  Remaining Estimate: 0h
>
> I want to read table data with a query without parameters (select * from table_name). 
> As per my understanding, this should not require "StatementPreperator". 
> However, if I use the newly added "readRows" function, I get an exception that seems to force me to use the "StatementPreperator". 
> Stacktrace below.  
>  
> java.lang.IllegalArgumentException: statementPreparator can not be null
>         at org.apache.beam.vendor.guava.v20_0.com.google.common.base.Preconditions.checkArgument(Preconditions.java:122)
>         at org.apache.beam.sdk.io.jdbc.JdbcIO$Read.withStatementPreparator(JdbcIO.java:600)
>         at org.apache.beam.sdk.io.jdbc.JdbcIO$ReadRows.expand(JdbcIO.java:499)
>         at org.apache.beam.sdk.io.jdbc.JdbcIO$ReadRows.expand(JdbcIO.java:410)
>         at org.apache.beam.sdk.Pipeline.applyInternal(Pipeline.java:537)
>         at org.apache.beam.sdk.Pipeline.applyTransform(Pipeline.java:471)
>         at org.apache.beam.sdk.values.PBegin.apply(PBegin.java:44)
>         at com.nokia.csf.dfle.transforms.DfleRdbmsSource.expand(DfleRdbmsSource.java:34)
>         at com.nokia.csf.dfle.transforms.DfleRdbmsSource.expand(DfleRdbmsSource.java:10)
>         at org.apache.beam.sdk.Pipeline.applyInternal(Pipeline.java:537)
>         at org.apache.beam.sdk.Pipeline.applyTransform(Pipeline.java:488)
>         at org.apache.beam.sdk.values.PBegin.apply(PBegin.java:56)
>         at org.apache.beam.sdk.Pipeline.apply(Pipeline.java:182)



--
This message was sent by Atlassian Jira
(v8.3.2#803003)