0

I'm pretty new to Apache flink and stateful functions just trying some code.

I created a simple stateful greeting application using spring boot and included all necessary dependencies, created a fat jar.

I'm trying to run this jar on flink standalone cluster using the below command

./flink run -c org.apache.flink.statefun.flink.core.StatefulFunctionsJob ./statefun-example-1.0-SNAPSHOT-jar-with-dependencies.jar

I'm getting below exceptions enter image description here

Can anyone let me know what is this issue?

Thanks

Rams
  • 2,141
  • 5
  • 33
  • 59

1 Answers1

0

From the stack trace, it looks like you've got a value in the StateFun configuration that's an array instead of a string. If you have a configuration that's multi-valued, sometimes it just needs to be a comma-separated string, not an array.

kkrugler
  • 8,145
  • 6
  • 24
  • 18