apache beam seems to not be running the tests

To run it, you have to run it by pipeline.run(). Add it in your test method as the following and try again please.

    public void testPrintFunctionDoesNotMutateData () {
        Object genericObject = new Object();
        PCollection<Object> collection = pipeline



CLICK HERE to find out more related problems solutions.

Leave a Comment

Your email address will not be published.

Scroll to Top