Hello Calcite Team,

 

I  have a requirement to query multiple data sources in single SQL query, I
saw Calcite was providing this with JDBC adaptor, So here I found some
challenges while execution like, 

 

1.      This execution (like join etc.) was happening over the memory, So
this will cause OOM when big data execution.

2.      I saw their was spark option also, If we enable this option
execution will happen over spark?

3.      If 2nd yes when I am trying with that option I am getting exception
like,

Caused by: java.lang.NullPointerException

       at CalciteProgram162944.bind(Unknown Source)

       at
org.apache.calcite.jdbc.CalcitePrepare$CalciteSignature.enumerable(CalcitePr
epare.java:355)

       at
org.apache.calcite.jdbc.CalciteConnectionImpl.enumerable(CalciteConnectionIm
pl.java:314)

       at
org.apache.calcite.jdbc.CalciteMetaImpl._createIterable(CalciteMetaImpl.java
:506)

       at
org.apache.calcite.jdbc.CalciteMetaImpl.createIterable(CalciteMetaImpl.java:
497)

       at
org.apache.calcite.avatica.AvaticaResultSet.execute(AvaticaResultSet.java:18
2)

       at
org.apache.calcite.jdbc.CalciteResultSet.execute(CalciteResultSet.java:64)

       at
org.apache.calcite.jdbc.CalciteResultSet.execute(CalciteResultSet.java:43)

       at
org.apache.calcite.avatica.AvaticaConnection$1.execute(AvaticaConnection.jav
a:667)

       at
org.apache.calcite.jdbc.CalciteMetaImpl.prepareAndExecute(CalciteMetaImpl.ja
va:566)

       at
org.apache.calcite.avatica.AvaticaConnection.prepareAndExecuteInternal(Avati
caConnection.java:675)

       at
org.apache.calcite.avatica.AvaticaStatement.executeInternal(AvaticaStatement
.java:156)

   ... 2 more

 

 

4.      And please let me know how to overcome OOM when big data execution.

 

Thanks and Regards

Ajay Babu Maguluri.

Reply via email to