Hi, Zach,
Glad that you pointed it out! Actually, the design description in SAMZA-552
has adopt a lot of flavors of high-watermark, late-arrivals, from
MillWheel. The terms used in the design doc maybe different since the terms
in the doc were used earlier than we discovered the MillWheel presenta
I'm curious - has anyone built any Samza-based systems that use any notion
of stream progress, e.g. low watermarks, punctuations, or heartbeats? These
are described in the stream-processing literature [1] [2] [3] and
implemented in MillWheel [4] and Dataflow [5] but I have not seen any
mention of t
Hey there,
I try to replay the hello-samza stuff with my docker image, but failed. :(
Could someone provide me a hint what I do wrong?
I have to admit, that I am not the biggest Java developer, therefore I might do
stupid mistakes… :)
My Steps: https://github.com/ChristianKniep/orchestra/tree/m
