Hi All - I am looking to implement and test 'Exactly-Once' semantics using Apache Beam and Spark Runner (using a locally installed spark). I have come up with the pipeline but looking for expertise advice on how to test the scenario in a proper way. Appreciate your inputs.
Thanks. -- Thanks, Praveen K Viswanathan
