Chamikara Jayalath

Probably someone from Dataflow streaming team should take a quick look as well. @scwhittle will you be able to check ?

Run PostCommit_Java_Dataflow

Run PostCommit_Java_DataflowV2

Thanks Sam. I think we can merge this when tests pass. LGTM. Based on an offline discussion with Daniel, we'll be adding a transform override in a follow-up PR to...

This failure might be related ? https://ci-beam.apache.org/job/beam_PreCommit_Java_GCP_IO_Direct_Phrase/2/testReport/junit/org.apache.beam.sdk.io.gcp.pubsublite/ReadWriteIT/testReadWrite/

Run PostCommit_Java_Dataflow

Run Java_GCP_IO_Direct PreCommit

Pls fix spotless. @@ -18,7 +18,6 @@ 17:22:48 package·org.apache.beam.sdk.io.gcp.pubsublite.internal; 17:22:48 17:22:48 import·static·org.junit.Assert.assertEquals; 17:22:48 -import·static·org.junit.Assert.assertThrows; 17:22:48 import·static·org.mockito.Mockito.verify;

Will check. Thanks.

Thanks for looking @Abacn.