Eventstore: Exception: failed to handle event because complete TF position required (Parameter 'committedEvent')

Created on 13 Jan 2021 · 3Comments · Source: EventStore/EventStore

Describe the bug

Projection may fault after periodically with exception:

{"@t":"2020-12-09T10:30:55.4407703Z","@mt":"The '{projection}' projection faulted due to '{e}'","@l":"Error","projection":"myprojection","e":"The heading subscription failed to handle an event-996553a5-fca4-4f53-b9c3-bebe300720d2:sampleevent@163301 because complete TF position required (Parameter 'committedEvent')","SourceContext":"EventStore.Projections.Core.Services.Management.ProjectionManager","ProcessId":5448,"ThreadId":23}

To Reproduce
Steps to reproduce the behavior:

Create a projection with code:

fromAll().when({ "sampleevent" : function(state,event) { emit("myprojection", "EventLtIdAdded",{ LtId: event.body.LtdId, Id: event.body.AggregateId }) } } );

Add events that will be handle by this custom projection

Expected behavior
Projection should not fault.

Actual behavior
Custom Projection faults unexpectedly and require the projection to be reset to resume operations.

EventStore details
20.6.1

Operating system:

Windows Server 2016

customer initiated kinbug

Source

avish0694

👍1

Most helpful comment

Reproduction steps:

Create the following two projections:

fromStream('foo')
.when({
        $any: function (state, event) {
            if (event.data)
            {
                linkTo("bar", event);
            }
        }
    }
);

fromAll().when(
{
    $init: function() {
        return { events: [] };
    },
    "baz" : function(state, event){
        state.events.push(event);
    }
});

Write an event to stream foo with event type baz
The second projection will fault with the reported error.

It seems that this issue is caused by reading linked events from $all, as this doesn't occur if you use fromStreams.

hayley-jean on 2 Feb 2021

👍2 🎉1

All 3 comments

Reproduction steps:

Create the following two projections:

fromStream('foo')
.when({
        $any: function (state, event) {
            if (event.data)
            {
                linkTo("bar", event);
            }
        }
    }
);

fromAll().when(
{
    $init: function() {
        return { events: [] };
    },
    "baz" : function(state, event){
        state.events.push(event);
    }
});