Hi all, we are building a source connector using the new source API and we are trying to provide new splits on request (extending the handleSplitRequest method from SplitEnumerator). When we run the source the task manager fails after reading few splits, with the error:

Have records for a split that was not registered

. However split addition is performed through the context and ideally the splits should be registered. Anyone is perhaps incurred in a similar issue? If so, are there any attention points that we must consider in trying to debug this issue?

You’d probably get more help in the dev mailing list