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

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Affects Version/s: 2.14.0
• Fix Version/s: 2.16.0
• Component/s: io-java-jdbc
• Assignee: Charith Ellawala
• Reporter: Kishor Joshi
• Created: 22/Aug/19 06:25
• Updated: 16/May/20 14:09
• Resolved: 11/Sep/19 16:46

Description

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)

Issue Links

• links to: GitHub Pull Request #9425