Hi Izual,
Thanks for reporting this! I'm also forwarding this to the user mailing
list, as that is the more suitable place for this question.
I think the usability of the State Processor API in Scala is indeed
something that hasn’t been looked at closely yet.
On Tue, Jan 21, 2020 at 8:12 AM izua
Hi community,
When I use state in Scala, something makes confused, I followed these steps to
generate and read states:
a. implements the example[1] `CountWindowAverage` in Scala(exactly same), and
run jobA => that makes good.
b. execute `flink cancel -s ${JobID}` => savepoints was generated as
