It was a silly mistake. Thanks for help. I really appreciate it. App output looks better now but only for a while. Starting from some point the only output from app is failure log and operator creation log. No output of aggregated list. For debug I started to write generated random number to file. I suspected that failure generator is serialized somehow and due to that from some point it is generating the same number. However output shows it's not the case. The application output is here - https://github.com/Matzz/apex-example/blob/master/stream.out Yarn log - https://raw.githubusercontent.com/Matzz/apex-example/master/logs
Regards, Mateusz pon., 18 cze 2018 o 16:25 Ambarish Pande <ambarish.pande2...@gmail.com> napisał(a): > Hi Mateusz, > > The property name should be "*apex.attr.CHECKPOINT_WINDOW_**COUNT*" > instead of aptest.attr.CHECKPOINT_WINDOW_COUNT. > > Thanks > Ambarish >
