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)