Hi Le,
I believe the issue is the bounded source[1]. Stateful Functions only
supports unbounded inputs.
Additionally, you can remove all the `synchronized` blocks from your code;
statefun handles all synchronization for you.
Seth
[1]
https://gist.github.com/flint-stone/cbc60f2d41507fdf33507ba99
Hello!
I'm getting an exception running a modified version of datastream/statefun
example. (See exception details that follow.) The example was adapted from
the original datastream example provided in statefun repo. I was trying to
play with the example by chaining two functions (with the 1st func