-
Notifications
You must be signed in to change notification settings - Fork 4.5k
Closed
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.
Imported from Jira BEAM-2358. Original Jira may contain additional context.
Reported by: nicku33.