Apache Flink + StateFul 函数 + Sprint 启动 -ProgramInvocationException：答案

【问题标题】：Apache Flink + StateFul functions + Sprint boot -ProgramInvocationException:Apache Flink + StateFul 函数 + Sprint 启动 -ProgramInvocationException：
【发布时间】：2022-06-12 23:54:58
【问题描述】：

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

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

我正在尝试使用以下命令在 flink 独立集群上运行此 jar

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

我遇到了例外情况

谁能告诉我这是什么问题？

谢谢

【问题讨论】：

标签： java spring-boot apache-flink flink-stateful-functions apache-stateful-functions

【解决方案1】：

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

【讨论】：