Hi Arnaud!
In 0.9.0, the streaming API does not forward accumulators.
In the next version, it will, and it will actually update them live so that
you can retrieve continuously updating accumulators of a streaming job in
your client, and in the web frontend.
We merged the first part for that on W
Hello,
I’m struggling with this simple issue for hours now : I am unable to get the
accumulator result of a streaming context result, the accumulator map in the
JobExecutionResult is always empty.
Simple test code (directly inspired from the documentation) :
My source =
public static clas