我试着在我的Scala Flink应用程序中测试一些有状态udf:
https://nightlies.apache.org/flink/flink文档-释放- 1.13 -/- docs/dev/datastream/testing/# unit-testing-stateful-or-timely-udfs——自定义算子
基于该链接，我在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。我做错了什么吗?为什么我找不到这些课程?也许文件是不正确的?
我将tests分类器添加到build.sbt文件中的flink-streaming-java依赖项中，现在它可以工作了:
"org.apache.flink" %% "flink-streaming-java" % flinkVersion % Test classifier "tests"