extraction-framework icon indicating copy to clipboard operation
extraction-framework copied to clipboard

Hickup in event stream feeder resets stream time

Open kurzum opened this issue 6 years ago • 0 comments

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

kurzum avatar Jun 27 '19 11:06 kurzum