wcmolin commented on pull request #170:
URL: https://github.com/apache/flink-statefun/pull/170#issuecomment-720859241
Hi @tzulitai
Thanks for your suggestion!
I used two examples :
- `statefun-state-processor-example`
- `statefun-greeter-example`
When I change the `state.backend: jobmanager` to `state.backend: rocksdb`
in the `flink-conf.yaml` , I can run the example normally and get the correct
output.
Send two messages to kafka:
```
{"who": "bar"}
{"who": "foo"}
```
Output in `greetings` topic:
```
{
"who": "bar",
"greeting": "Happy to see you once again bar ! 😲"
}
{
"who": "foo",
"greeting": "Hello at the 5-th time foo 🙌"
}
```
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
