在 Scala 中初始化 Apache Beam 测试管道失败

Question

当我尝试 运行 测试管道时，它引发错误

这里是创建测试管道的源代码：

val p: TestPipeline = TestPipeline.create()

这里是错误：

java.lang.IllegalStateException: Is your TestPipeline declaration missing a @Rule annotation? Usage: @Rule public final transient TestPipeline pipeline = TestPipeline.create();

Answer 1

我已经通过以下代码解决了问题：

val p: TestPipeline = TestPipeline.create().enableAbandonedNodeEnforcement(false)