YolandaMDavis edited a comment 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: us...@infra.apache.org With regards, Apache Git Services
