[jira] [Comment Edited] (NIFI-6989) SiteToSiteReportingRecordSink reports error when no data is sent

["Matt Burgess (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/NIFI-6989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011326#comment-17011326 ] 

Matt Burgess edited comment on NIFI-6989 at 1/9/20 2:36 AM:
------------------------------------------------------------

And unfortunately, not calling complete() or cancel() causes a SocketTimeout on Raw connections which logs an error (but not a bulletin), looks like HTTP don't log or report anything (likely because nothing is sent over the wire)


was (Author: mattyb149):
And unfortunately, not calling complete() or cancel() causes a SocketTimeout on Raw connections, not sure yet what the effect is on HTTP connections.

> SiteToSiteReportingRecordSink reports error when no data is sent
> ----------------------------------------------------------------
>
>                 Key: NIFI-6989
>                 URL: https://issues.apache.org/jira/browse/NIFI-6989
>             Project: Apache NiFi
>          Issue Type: Bug
>            Reporter: Matt Burgess
>            Assignee: Matt Burgess
>            Priority: Major
>             Fix For: 1.11.0
>
>          Time Spent: 0.5h
>  Remaining Estimate: 0h
>
> If no data is transmitted during a transaction in SiteToSiteReportingRecordSink, the following error is thrown:
> Error during transmission of query results due to Failed to write metrics using record writer: Cannot confirm Transaction because state is TRANSACTION_STARTED; Transaction can only be confirmed when state is DATA_EXCHANGED: java.io.IOException: Failed to write metrics using record writer: Cannot confirm Transaction because state is TRANSACTION_STARTED; Transaction can only be confirmed when state is DATA_EXCHANGED
> java.io.IOException: Failed to write metrics using record writer: Cannot confirm Transaction because state is TRANSACTION_STARTED; Transaction can only be confirmed when state is DATA_EXCHANGED
> 	at org.apache.nifi.reporting.sink.SiteToSiteReportingRecordSink.sendData(SiteToSiteReportingRecordSink.java:172)
> 	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 	at java.lang.reflect.Method.invoke(Method.java:498)
> 	at org.apache.nifi.controller.service.StandardControllerServiceInvocationHandler.invoke(StandardControllerServiceInvocationHandler.java:87)
> This can be reproduced by using QueryNiFiReportingTask with a query that returns no rows (such as SELECT * FROM CONNECTION_STATUS WHERE 1=0) when Send Zero Results is false.
> The call to confirm() and complete() should only be done when a send() has occurred, so it needs to be moved inside the if-block above it.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)