Consumer aggregation flow: Data Output State transaction signing fails intemittently

[shukpa]

Description

• During the ConsumerAggregationFlow the DataOutputState transaction signing with the Host fails unexpectedly
• Host node throws error during SignTransactionFlow
• RewardsState for provider is still created

Steps to reproduce

• Request a consumer aggregation flow for a data type
• trigger the request again after the first successful one

in=O=ConsumerC, L=Chicago, C=US, session_id=d19879b9-dd8f-47c1-b2ce-f0448b8f607c, session_timestamp=2022-01-20T17:39:21.600Z, thread-id=154}
net.corda.core.flows.UnexpectedFlowEndException: Counter-flow errored
        at Received unexpected counter-flow exception from peer O=ConsumerC, L=Chicago, C=US.() ~[?:?]
        at net.corda.node.services.statemachine.FlowStateMachineImpl.fillInLocalStackTrace(FlowStateMachineImpl.kt:244) ~[corda-node-4.7.jar:?]
        at net.corda.node.services.statemachine.FlowStateMachineImpl.processEventsUntilFlowIsResumed(FlowStateMachineImpl.kt:225) ~[corda-node-4.7.jar:?]
        at net.corda.node.services.statemachine.FlowStateMachineImpl.suspend(FlowStateMachineImpl.kt:574) ~[corda-node-4.7.jar:?]
        at net.corda.node.services.statemachine.FlowSessionImpl.receive(FlowSessionImpl.kt:67) ~[corda-node-4.7.jar:?]
        at net.corda.node.services.statemachine.FlowSessionImpl.receive(FlowSessionImpl.kt:71) ~[corda-node-4.7.jar:?]
        at net.corda.core.flows.ReceiveTransactionFlow.call(ReceiveTransactionFlow.kt:103) ~[corda-core-4.7.jar:?]
        at net.corda.core.flows.ReceiveTransactionFlow.call(ReceiveTransactionFlow.kt:31) ~[corda-core-4.7.jar:?]
        at net.corda.node.services.statemachine.FlowStateMachineImpl.subFlow(FlowStateMachineImpl.kt:417) ~[corda-node-4.7.jar:?]
        at net.corda.core.flows.FlowLogic.subFlow(FlowLogic.kt:409) ~[corda-core-4.7.jar:?]
        at net.corda.core.flows.SignTransactionFlow.call(CollectSignaturesFlow.kt:277) ~[corda-core-4.7.jar:?]
        at net.corda.core.flows.SignTransactionFlow.call(CollectSignaturesFlow.kt:261) ~[corda-core-4.7.jar:?]
        at net.corda.node.services.statemachine.FlowStateMachineImpl.subFlow(FlowStateMachineImpl.kt:417) ~[corda-node-4.7.jar:?]
        at net.corda.core.flows.FlowLogic.subFlow(FlowLogic.kt:409) ~[corda-core-4.7.jar:?]
        at com.protocol180.aggregator.flow.ConsumerAggregationFlowResponder.call(ConsumerAggregationFlow.kt:177) ~[?:?]
        at com.protocol180.aggregator.flow.ConsumerAggregationFlowResponder.call(ConsumerAggregationFlow.kt:106) ~[?:?]