在 Flink 中测试有状态的 UDF答案

【问题标题】：Testing stateful UDFs in Flink在 Flink 中测试有状态的 UDF
【发布时间】：2021-10-19 07:29:59
【问题描述】：

我正在尝试按照文档在我的 Scala Flink 应用程序中测试一些有状态的 UDF：

https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/dev/datastream/testing/#unit-testing-stateful-or-timely-udfs--custom-operators

基于该链接，我已将以下依赖项添加到 build.sbt 文件中：

"org.apache.flink" %% "flink-test-utils" %  flinkVersion % Test,
"org.apache.flink" %% "flink-runtime" %  flinkVersion % Test,
"org.apache.flink" %% "flink-streaming-java" % flinkVersion % Test

但是，我仍然无法访问所需的实用程序类，例如 OneInputStreamOperatorTestHarness（找不到该类）。

仅供参考，我项目中的 scala 版本是 2.12.11，而 Flink 是 v1.13.2。难道我做错了什么？我找不到这些课程的任何原因？也许文档不正确？

【问题讨论】：

标签： scala apache-flink

【解决方案1】：

我将tests 分类器添加到build.sbt 文件中的flink-streaming-java 依赖项，现在它可以工作了：

"org.apache.flink" %% "flink-streaming-java" % flinkVersion % Test classifier "tests"

【讨论】：