extraction-framework
extraction-framework copied to clipboard
Hickup in event stream feeder resets stream time
https://github.com/dbpedia/extraction-framework/blob/live-deployed/live/src/main/java/org/dbpedia/extraction/live/feeder/EventStreamsFeeder.java
if AKKA stream fails, the initial time is used, not latestProcessDate, cascading in maxLine exceeded Illegal state exception.
There was an attempt to fix this, but it is unclear whether this works.
Fix was in this line: https://github.com/dbpedia/extraction-framework/blob/live-deployed/live/src/main/scala/org/dbpedia/extraction/live/feeder/EventStreamsHelper.scala#L101