[ https://issues.apache.org/jira/browse/BEAM-8032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16913054#comment-16913054 ]
Ismaël Mejía commented on BEAM-8032: ------------------------------------ [~charithke] can you please take a look? > 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 > Priority: Major > > 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)