With implementation of one of the latest merge request (maybe !6 (merged) or !28 (merged)!33 (merged)), the benchmark for UC2 is not generating any messages to the output topic anymore.
Designs
Child items ...
Show closed items
Linked items 0
Link issues together to show that they're related.
Learn more.
It's also possible that this is not a real issue as the input records seem still to be processed. Maybe this problem also exists already longer. Nevertheless, we have to have a closer look on it.
With 9e0f3ef2 the Use Case creates an output again.
It removes .suppress(Suppressed.untilTimeLimit(this.windowSize, BufferConfig.unbounded()))
and a computation intensive peek.
With the peek it produced also some messages, but only a few.
Both functions were already included before, but maybe with Avro and the new Workload generator it may not function properly anymore.
With the new aligned data flow from titan, the suppress(Suppressed.untilTimeLimit(this.windowSize, BufferConfig.unbounded())) is no problem anymore and implementation generates many more output.