chore: add e2e test for udsource java sdk

Signed-off-by: Keran Yang <[email protected]>

test/udsource-e2e/testdata/simple-source-java.yaml

@@ -0,0 +1,21 @@
+apiVersion: numaflow.numaproj.io/v1alpha1
+kind: Pipeline
+metadata:
+  name: simple-source
+spec:
+  vertices:
+    - name: in
+      source:
+        udsource:
+          container:
+            # A simple user-defined source for e2e testing
+            # See https://github.com/numaproj/numaflow-java/tree/main/examples/src/main/java/io/numaproj/numaflow/examples/source/simple
+            image: quay.io/numaio/numaflow-java/source-simple-source:v0.5.1
+      limits:
+        readBatchSize: 2
+    - name: out
+      sink:
+        log: {}
+  edges:
+    - from: in
+      to: out

test/udsource-e2e/udsource_test.go

@@ -19,6 +19,7 @@ limitations under the License.
 package e2e
 
 import (
+	"fmt"
 	"testing"
 
 	"github.com/stretchr/testify/suite"
@@ -30,8 +31,16 @@ type UserDefinedSourceSuite struct {
 	E2ESuite
 }
 
-func (s *UserDefinedSourceSuite) TestSimpleSource() {
-	w := s.Given().Pipeline("@testdata/simple-source.yaml").
+func (s *UserDefinedSourceSuite) TestSimpleSourceGo() {
+	s.testSimpleSource("go")
+}
+
+func (s *UserDefinedSourceSuite) TestSimpleSourceJava() {
+	s.testSimpleSource("java")
+}
+
+func (s *UserDefinedSourceSuite) testSimpleSource(lang string) {
+	w := s.Given().Pipeline(fmt.Sprintf("@testdata/simple-source-%s.yaml", lang)).
 		When().
 		CreatePipelineAndWait()
 	defer w.DeletePipelineAndWait()