nifi-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From GitBox <...@apache.org>
Subject [GitHub] [nifi] YolandaMDavis commented on issue #3826: NIFI-6780: Add QueryNiFiReportingTask, RecordSinkService, S2S and DB impls
Date Fri, 18 Oct 2019 14:53:04 GMT
YolandaMDavis commented on issue #3826: NIFI-6780: Add QueryNiFiReportingTask, RecordSinkService,
S2S and DB impls
URL: https://github.com/apache/nifi/pull/3826#issuecomment-543782887
 
 
   @mattyb149 I ran into an exception when I attempted to query the CONNECTION_STATUS_PREDICTIONS
table when predictions were not enabled.  Exception is below:
   
   `QueryNiFiReportingTask[id=df116dbf-016d-1000-29b8-156a35b5fe7f] Error during transmission
of query results due to Could not obtain next record from ResultSet: java.io.IOException:
Could n
   ot obtain next record from ResultSet
   java.io.IOException: Could not obtain next record from ResultSet
           at org.apache.nifi.serialization.record.ResultSetRecordSet.next(ResultSetRecordSet.java:98)
           at org.apache.nifi.record.sink.db.DatabaseRecordSink.sendData(DatabaseRecordSink.java:252)
           at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
           at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
           at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
           at java.base/java.lang.reflect.Method.invoke(Method.java:566)
           at org.apache.nifi.controller.service.StandardControllerServiceInvocationHandler.invoke(StandardControllerServiceInvocationHandler.java:87)
           at com.sun.proxy.$Proxy125.sendData(Unknown Source)
           at org.apache.nifi.reporting.sql.QueryNiFiReportingTask.onTrigger(QueryNiFiReportingTask.java:119)
           at org.apache.nifi.controller.tasks.ReportingTaskWrapper.run(ReportingTaskWrapper.java:44)
           at org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.java:110)
           at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
           at java.base/java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305)
           at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305)
           at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
           at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
           at java.base/java.lang.Thread.run(Thread.java:834)
   Caused by: java.sql.SQLException: java.lang.NullPointerException
           at org.apache.calcite.avatica.util.PositionedCursor$ArrayGetter.getObject(PositionedCursor.java:65)
           at org.apache.calcite.avatica.util.AbstractCursor$AccessorImpl.getObject(AbstractCursor.java:359)
           at org.apache.calcite.avatica.AvaticaResultSet.getObject(AvaticaResultSet.java:393)
           at org.apache.nifi.serialization.record.ResultSetRecordSet.createRecord(ResultSetRecordSet.java:119)
           at org.apache.nifi.serialization.record.ResultSetRecordSet.next(ResultSetRecordSet.java:91)
           ... 16 common frames omitted
   Caused by: java.lang.NullPointerException: null
           at org.apache.calcite.avatica.util.PositionedCursor$ArrayGetter.getObject(PositionedCursor.java:62)
   `
   Recommend checking for the existence of this table first if possible and having an exception
that aligns with the fact that the table is missing.

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services

Mime
View raw message