[
https://issues.apache.org/jira/browse/BEAM-10470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17157719#comment-17157719
]
Kenneth Knowles commented on BEAM-10470:
----------------------------------------
[~amaliujia] [~apilloud] [~robinyqiu]
The line of the NPE is the direct runner job dereferencing a not-nullable field
{{state}}:
https://github.com/apache/beam/blob/b14c0910350933357a104b03c78abbf6afdb7513/runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectRunner.java#L341
Some line around here has to be returning null to set this to null, if I
understand the code correctly:
https://github.com/apache/beam/blob/b14c0910350933357a104b03c78abbf6afdb7513/runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectRunner.java#L326
I don't know what this could have to do with JdbcDriver.
> Failure / flake in JdbcDriverTest.testInternalConnect_unbounded_limit
> ---------------------------------------------------------------------
>
> Key: BEAM-10470
> URL: https://issues.apache.org/jira/browse/BEAM-10470
> Project: Beam
> Issue Type: Bug
> Components: dsl-sql
> Reporter: Kenneth Knowles
> Priority: P1
> Labels: flake
>
> https://ci-beam.apache.org/job/beam_PreCommit_Java_Commit/12326/testReport/junit/org.apache.beam.sdk.extensions.sql.impl/JdbcDriverTest/testInternalConnect_unbounded_limit/
> {code}
> java.sql.SQLException: Error while executing SQL "SELECT * FROM test LIMIT
> 1": null
> at
> org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.avatica.Helper.createException(Helper.java:56)
> at
> org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.avatica.Helper.createException(Helper.java:41)
> at
> org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.avatica.AvaticaStatement.executeInternal(AvaticaStatement.java:163)
> at
> org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.avatica.AvaticaStatement.executeQuery(AvaticaStatement.java:227)
> at
> org.apache.beam.sdk.extensions.sql.impl.JdbcDriverTest.testInternalConnect_unbounded_limit(JdbcDriverTest.java:442)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at ...
> Caused by: java.lang.NullPointerException
> at
> org.apache.beam.runners.direct.DirectRunner$DirectPipelineResult.waitUntilFinish(DirectRunner.java:341)
> at
> org.apache.beam.sdk.extensions.sql.impl.rel.BeamEnumerableConverter.limitRun(BeamEnumerableConverter.java:188)
> at
> org.apache.beam.sdk.extensions.sql.impl.rel.BeamEnumerableConverter.limitCollect(BeamEnumerableConverter.java:253)
> at
> org.apache.beam.sdk.extensions.sql.impl.rel.BeamEnumerableConverter.toEnumerable(BeamEnumerableConverter.java:167)
> at
> org.apache.beam.sdk.extensions.sql.impl.rel.BeamEnumerableConverter.toEnumerable(BeamEnumerableConverter.java:119)
> at Baz.bind(Unknown Source)
> at
> org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.jdbc.CalcitePrepare$CalciteSignature.enumerable(CalcitePrepare.java:355)
> at
> org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.jdbc.CalciteConnectionImpl.enumerable(CalciteConnectionImpl.java:314)
> at
> org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.jdbc.CalciteMetaImpl._createIterable(CalciteMetaImpl.java:506)
> at
> org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.jdbc.CalciteMetaImpl.createIterable(CalciteMetaImpl.java:497)
> at
> org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.avatica.AvaticaResultSet.execute(AvaticaResultSet.java:182)
> at
> org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.jdbc.CalciteResultSet.execute(CalciteResultSet.java:64)
> at
> org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.jdbc.CalciteResultSet.execute(CalciteResultSet.java:43)
> at
> org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.avatica.AvaticaConnection$1.execute(AvaticaConnection.java:667)
> at
> org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.jdbc.CalciteMetaImpl.prepareAndExecute(CalciteMetaImpl.java:566)
> at
> org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.avatica.AvaticaConnection.prepareAndExecuteInternal(AvaticaConnection.java:675)
> at
> org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.avatica.AvaticaStatement.executeInternal(AvaticaStatement.java:156)
> ... 52 more
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
