I'm wondering if you're selecting an unsupported data type. The exception being thrown looks like it could happen if that were the case. The supported types are in the Java doc. https://github.com/apache/lucene-solr/blob/releases/lucene-solr/6.0.0/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/JDBCStream.java
Joel Bernstein http://joelsolr.blogspot.com/ On Wed, Jun 22, 2016 at 11:46 PM, Hui Liu <h...@opentext.com> wrote: > Hi, > > > > I have Solr 6.0.0 installed on my PC (windows 7), I was > experimenting with ‘Streaming Expression’ by using Oracle jdbc as the > stream source, following is the http command I am using: > > > > http://localhost:8988/solr/document5/stream?expr=jdbc(connection= > "jdbc:oracle:thin:qa_docrep/ > abc...@lit-racq01-scan.qa.gxsonline.net:1521/qlgdb",sql="SELECT > document_id,sender_msg_dest,recip_msg_dest,document_type,document_key,sender_bu_id,recip_bu_id,date_created > FROM tg_document WHERE rownum < 5",sort="document_id > asc",driver="oracle.jdbc.driver.OracleDriver") > > > > I can access this Oracle db from my PC via regular JDBC > connection. I did put Oracle jdbc driver jar ‘ojdbc14.jar’ (same jar used > in my regular jdbc code) under Solr/server/lib dir and restarted Solr > cloud. Below is the error from solr.log (got a null pointer error); I am > merely trying to get the data returned from Oracle table, I have not tried > to index them in the Solr yet, attached is the shema.xml and solrconfig.xml > for this collection ‘document5’; does anyone know what am I missing? thanks > for any help! > > > > Regards, > > Hui Liu > > > > Error from Solr.log: > > ===================== > > 2016-06-23 03:17:34.413 INFO (qtp1389647288-19) [c:document5 s:shard2 > r:core_node2 x:document5_shard2_replica1] o.a.s.c.S.Request > [document5_shard2_replica1] webapp=/solr path=/stream > params={expr=jdbc(connection%3D"jdbc:oracle:thin:qa_docrep/ > abc...@lit-racq01-scan.qa.gxsonline.net:1521/qlgdb",sql%3D"SELECT+document_id,sender_msg_dest,recip_msg_dest,document_type,document_key,sender_bu_id,recip_bu_id+FROM+tg_document+WHERE+rownum+<+5",sort%3D"document_id+asc",driver%3D"oracle.jdbc.OracleDriver")} > status=0 QTime=0 > > 2016-06-23 03:17:37.588 ERROR (qtp1389647288-19) [c:document5 s:shard2 > r:core_node2 x:document5_shard2_replica1] o.a.s.c.s.i.s.ExceptionStream > java.lang.NullPointerException > > at > org.apache.solr.client.solrj.io.stream.JDBCStream.read(JDBCStream.java:305) > > at > org.apache.solr.client.solrj.io.stream.ExceptionStream.read(ExceptionStream.java:64) > > at > org.apache.solr.handler.StreamHandler$TimerStream.read(StreamHandler.java:374) > > at > org.apache.solr.response.TextResponseWriter.writeTupleStream(TextResponseWriter.java:305) > > at > org.apache.solr.response.TextResponseWriter.writeVal(TextResponseWriter.java:167) > > at > org.apache.solr.response.JSONWriter.writeNamedListAsMapWithDups(JSONResponseWriter.java:183) > > at > org.apache.solr.response.JSONWriter.writeNamedList(JSONResponseWriter.java:299) > > at > org.apache.solr.response.JSONWriter.writeResponse(JSONResponseWriter.java:95) > > at > org.apache.solr.response.JSONResponseWriter.write(JSONResponseWriter.java:60) > > at > org.apache.solr.response.QueryResponseWriterUtil.writeQueryResponse(QueryResponseWriterUtil.java:65) > > at > org.apache.solr.servlet.HttpSolrCall.writeResponse(HttpSolrCall.java:725) > > at > org.apache.solr.servlet.HttpSolrCall.call(HttpSolrCall.java:469) > > at > org.apache.solr.servlet.SolrDispatchFilter.doFilter(SolrDispatchFilter.java:229) > > at > org.apache.solr.servlet.SolrDispatchFilter.doFilter(SolrDispatchFilter.java:184) > > at > org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1668) > > at > org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:581) > > at > org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:143) > > at > org.eclipse.jetty.security.SecurityHandler.handle(SecurityHandler.java:548) > > at > org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:226) > > at > org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1160) > > at > org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:511) > > at > org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:185) > > at > org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1092) > > at > org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141) > > at > org.eclipse.jetty.server.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:213) > > at > org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:119) > > at > org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:134) > > at org.eclipse.jetty.server.Server.handle(Server.java:518) > > at > org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:308) > > at > org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:244) > > at > org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:273) > > at > org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:95) > > at > org.eclipse.jetty.io.SelectChannelEndPoint$2.run(SelectChannelEndPoint.java:93) > > at > org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.produceAndRun(ExecuteProduceConsume.java:246) > > at > org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.run(ExecuteProduceConsume.java:156) > > at > org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:654) > > at > org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:572) > > at java.lang.Thread.run(Thread.java:745) > > > > 2016-06-23 03:17:37.589 ERROR (qtp1389647288-19) [c:document5 s:shard2 > r:core_node2 x:document5_shard2_replica1] o.a.s.s.HttpSolrCall > null:java.lang.RuntimeException: java.lang.AbstractMethodError: Method > oracle/jdbc/driver/T4CStatement.isClosed()Z is abstract > > at > org.apache.solr.servlet.HttpSolrCall.sendError(HttpSolrCall.java:605) > > at > org.apache.solr.servlet.HttpSolrCall.call(HttpSolrCall.java:475) > > at > org.apache.solr.servlet.SolrDispatchFilter.doFilter(SolrDispatchFilter.java:229) > > at > org.apache.solr.servlet.SolrDispatchFilter.doFilter(SolrDispatchFilter.java:184) > > at > org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1668) > > at > org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:581) > > at > org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:143) > > at > org.eclipse.jetty.security.SecurityHandler.handle(SecurityHandler.java:548) > > at > org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:226) > > at > org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1160) > > at > org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:511) > > at > org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:185) > > at > org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1092) > > at > org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141) > > at > org.eclipse.jetty.server.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:213) > > at > org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:119) > > at > org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:134) > > at org.eclipse.jetty.server.Server.handle(Server.java:518) > > at > org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:308) > > at > org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:244) > > at > org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:273) > > at > org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:95) > > at > org.eclipse.jetty.io.SelectChannelEndPoint$2.run(SelectChannelEndPoint.java:93) > > at > org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.produceAndRun(ExecuteProduceConsume.java:246) > > at > org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.run(ExecuteProduceConsume.java:156) > > at > org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:654) > > at > org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:572) > > at java.lang.Thread.run(Thread.java:745) > > Caused by: java.lang.AbstractMethodError: Method > oracle/jdbc/driver/T4CStatement.isClosed()Z is abstract > > at > oracle.jdbc.driver.T4CStatement.isClosed(T4CStatement.java) > > at > org.apache.solr.client.solrj.io.stream.JDBCStream.close(JDBCStream.java:287) > > at > org.apache.solr.client.solrj.io.stream.ExceptionStream.close(ExceptionStream.java:79) > > at > org.apache.solr.handler.StreamHandler$TimerStream.close(StreamHandler.java:357) > > at > org.apache.solr.response.TextResponseWriter.writeTupleStream(TextResponseWriter.java:317) > > at > org.apache.solr.response.TextResponseWriter.writeVal(TextResponseWriter.java:167) > > at > org.apache.solr.response.JSONWriter.writeNamedListAsMapWithDups(JSONResponseWriter.java:183) > > at > org.apache.solr.response.JSONWriter.writeNamedList(JSONResponseWriter.java:299) > > at > org.apache.solr.response.JSONWriter.writeResponse(JSONResponseWriter.java:95) > > at > org.apache.solr.response.JSONResponseWriter.write(JSONResponseWriter.java:60) > > at > org.apache.solr.response.QueryResponseWriterUtil.writeQueryResponse(QueryResponseWriterUtil.java:65) > > at > org.apache.solr.servlet.HttpSolrCall.writeResponse(HttpSolrCall.java:725) > > at > org.apache.solr.servlet.HttpSolrCall.call(HttpSolrCall.java:469) > > ... 26 more > > > > 2016-06-23 03:17:37.590 WARN (qtp1389647288-19) [c:document5 s:shard2 > r:core_node2 x:document5_shard2_replica1] o.e.j.s.ServletHandler Error for > /solr/document5/stream > > java.lang.AbstractMethodError: Method > oracle/jdbc/driver/T4CStatement.isClosed()Z is abstract > > at > oracle.jdbc.driver.T4CStatement.isClosed(T4CStatement.java) > > at > org.apache.solr.client.solrj.io.stream.JDBCStream.close(JDBCStream.java:287) > > at > org.apache.solr.client.solrj.io.stream.ExceptionStream.close(ExceptionStream.java:79) > > at > org.apache.solr.handler.StreamHandler$TimerStream.close(StreamHandler.java:357) > > at > org.apache.solr.response.TextResponseWriter.writeTupleStream(TextResponseWriter.java:317) > > at > org.apache.solr.response.TextResponseWriter.writeVal(TextResponseWriter.java:167) > > at > org.apache.solr.response.JSONWriter.writeNamedListAsMapWithDups(JSONResponseWriter.java:183) > > at > org.apache.solr.response.JSONWriter.writeNamedList(JSONResponseWriter.java:299) > > at > org.apache.solr.response.JSONWriter.writeResponse(JSONResponseWriter.java:95) > > at > org.apache.solr.response.JSONResponseWriter.write(JSONResponseWriter.java:60) > > at > org.apache.solr.response.QueryResponseWriterUtil.writeQueryResponse(QueryResponseWriterUtil.java:65) > > at > org.apache.solr.servlet.HttpSolrCall.writeResponse(HttpSolrCall.java:725) > > at > org.apache.solr.servlet.HttpSolrCall.call(HttpSolrCall.java:469) > > at > org.apache.solr.servlet.SolrDispatchFilter.doFilter(SolrDispatchFilter.java:229) > > at > org.apache.solr.servlet.SolrDispatchFilter.doFilter(SolrDispatchFilter.java:184) > > at > org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1668) > > at > org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:581) > > at > org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:143) > > at > org.eclipse.jetty.security.SecurityHandler.handle(SecurityHandler.java:548) > > at > org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:226) > > at > org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1160) > > at > org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:511) > > at > org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:185) > > at > org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1092) > > at > org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141) > > at > org.eclipse.jetty.server.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:213) > > at > org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:119) > > at > org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:134) > > at org.eclipse.jetty.server.Server.handle(Server.java:518) > > at > org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:308) > > at > org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:244) > > at > org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:273) > > at > org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:95) > > at > org.eclipse.jetty.io.SelectChannelEndPoint$2.run(SelectChannelEndPoint.java:93) > > at > org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.produceAndRun(ExecuteProduceConsume.java:246) > > at > org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.run(ExecuteProduceConsume.java:156) > > at > org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:654) > > at > org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:572) > > at java.lang.Thread.run(Thread.java:745) >
