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

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


The following commit(s) were added to refs/heads/release-2.74 by this push:
     new 9363afac10f update port for jdbc test (#38485) (#38491)
9363afac10f is described below

commit 9363afac10f9f7588beac5de96c4c565422fd1c5
Author: Derrick Williams <[email protected]>
AuthorDate: Wed May 13 16:33:04 2026 -0400

    update port for jdbc test (#38485) (#38491)
    
    * 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)
 

Reply via email to