Apache + StateFul函数+ Sprint引导-ProgramInvocationException：

Question

我对Apache和有状态函数非常陌生，只是尝试了一些代码。

我使用spring引导创建了一个简单的有状态问候应用程序，并包含了所有必要的依赖项，创建了一个胖jar。

我试图使用下面的命令在flink独立集群上运行这个jar

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

我在例外情况下

​

有人能告诉我这是什么问题吗？

谢谢

Answer 1

从堆栈跟踪来看，您在StateFun配置中有一个值，它是一个数组而不是一个字符串。如果您的配置是多值的，有时它只需要是逗号分隔的字符串，而不是数组。