(converter) Adding some logging around the simple processing track to investigate an issue with the converter stalling

This commit is contained in:
Viktor Lofgren 2025-01-26 12:02:00 +01:00
parent 2b9d2985ba
commit db99242db2

View File

@ -194,6 +194,9 @@ public class DomainProcessor {
@Override
public Iterator<ProcessedDocument> getDocumentsStream() {
return iteratorFactory.create((taskConsumer) -> {
logger.info("Simple Processing: {}", domain);
while (dataStream.hasNext())
{
if (!(dataStream.next() instanceof CrawledDocument doc))
@ -218,6 +221,8 @@ public class DomainProcessor {
return processedDoc;
});
}
logger.info("Finished Simple Processing: {}", domain);
});
}