Kishor Joshi created BEAM-8032:
----------------------------------
Summary: 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
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)
