CODEWITHSUNDEEP
javascalapipelineapache-beam
Saeed Mohtasham
Saeed Mohtasham

Reputation: 1955

Initializing Apache Beam Test Pipeline in Scala fails

When I try to run a test pipeline it raise an error

here is the source code to create the test pipeline:

val p: TestPipeline = TestPipeline.create()

and here is the error :

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

Upvotes: 6

Views: 2220

Answers (1)

Saeed Mohtasham
Saeed Mohtasham

Reputation: 1955

I have solve the problem by following code : 

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

Upvotes: 12

Related Questions