[
https://issues.apache.org/jira/browse/BEAM-8032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Charith Ellawala reassigned BEAM-8032:
--------------------------------------
Assignee: Charith Ellawala
> 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
> Time Spent: 10m
> 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)
