在Flink中测试有状态UDF

Question

我正在尝试在我的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的版本是1.13.2。我做错了什么吗？我找不到这些类的原因是什么？也许文档是不正确的？

Answer 1

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

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