java - 在 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)