Details
-
Bug
-
Status: Open
-
P2
-
Resolution: Unresolved
-
None
-
None
-
Patch
Description
https://beam.apache.org/documentation/pipelines/test-your-pipeline/ has
public void testCountWords() throws Exception { Pipeline p = TestPipeline.create();
but this results in
Exception in thread "main" java.lang.IllegalStateException: Is your TestPipeline declaration missing a @Rule annotation? Usage: @Rule public final transient TestPipeline pipeline = TestPipeline.Create(); at org.apache.beam.sdk.repackaged.com.google.common.base.Preconditions.checkState(Preconditions.java:444) at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:299) at BasicPipelineTest.run(BasicPipelineTest.java:42) at Main.main(Main.java:25)
In the github example
it's written as:
public TestPipeline p = TestPipeline.create().enableAbandonedNodeEnforcement(false);
I'm using 2.0.0 from the maven repo.