NullPointerException in DirectRunner waitUntilFinish

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