(beam) branch master updated: update port for jdbc test (#38485)

[yh...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

Abacn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 13d36eb3b19 update port for jdbc test (#38485)
13d36eb3b19 is described below

commit 13d36eb3b1978360d4a471221c0dcd0151faa8b0
Author: Derrick Williams <de...@google.com>
AuthorDate: Wed May 13 15:01:13 2026 -0400

    update port for jdbc test (#38485)
    
    * increase timeout
    
    switch to minute :)
    
    * check post commit
    
    * try adding back nat for one test case
    
    * try getting port instead
    
    * revert time change
---
 .github/trigger_files/beam_PostCommit_XVR_Direct.json | 2 +-
 sdks/go/test/integration/io/xlang/jdbc/jdbc_test.go   | 4 +++-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/.github/trigger_files/beam_PostCommit_XVR_Direct.json b/.github/trigger_files/beam_PostCommit_XVR_Direct.json
index 73867c48355..702328d16d4 100644
--- a/.github/trigger_files/beam_PostCommit_XVR_Direct.json
+++ b/.github/trigger_files/beam_PostCommit_XVR_Direct.json
@@ -1,3 +1,3 @@
 {
-  "modification": 5
+  "modification": 1
 }
diff --git a/sdks/go/test/integration/io/xlang/jdbc/jdbc_test.go b/sdks/go/test/integration/io/xlang/jdbc/jdbc_test.go
index 4cd3c38a3bf..2ea84d42798 100644
--- a/sdks/go/test/integration/io/xlang/jdbc/jdbc_test.go
+++ b/sdks/go/test/integration/io/xlang/jdbc/jdbc_test.go
@@ -32,6 +32,7 @@ import (
 	"github.com/apache/beam/sdks/v2/go/test/integration/internal/containers"
 	_ "github.com/go-sql-driver/mysql"
 	_ "github.com/lib/pq"
+	"strings"
 	"github.com/testcontainers/testcontainers-go/wait"
 )
 
@@ -60,7 +61,8 @@ func setupTestContainer(ctx context.Context, t *testing.T, dbname, username, pas
 	hostname := "localhost"
 
 	dbURL := func(host string, port string) string {
-		return fmt.Sprintf("postgres://%s:%s@%s:%s/%s?sslmode=disable", username, password, host, port, dbname)
+		cleanPort := strings.Split(port, "/")[0]
+		return fmt.Sprintf("postgres://%s:%s@%s:%s/%s?sslmode=disable", username, password, host, cleanPort, dbname)
 	}
 	waitStrategy := wait.ForSQL(postgresPort, "postgres", dbURL).WithStartupTimeout(time.Second * 5)