You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by da...@apache.org on 2025/02/21 17:24:42 UTC
(beam) branch users/damccorm/maxConnections created (now 73e04b60d6d)
This is an automated email from the ASF dual-hosted git repository.
damccorm pushed a change to branch users/damccorm/maxConnections
in repository https://gitbox.apache.org/repos/asf/beam.git
at 73e04b60d6d Try limiting jdbcio max connections
This branch includes the following new commits:
new 73e04b60d6d Try limiting jdbcio max connections
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(beam) 01/01: Try limiting jdbcio max connections
Posted by da...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
damccorm pushed a commit to branch users/damccorm/maxConnections
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 73e04b60d6db62893bca7fcd2c3d9a361a1c8b3f
Author: Danny McCormick <da...@google.com>
AuthorDate: Fri Feb 21 12:24:35 2025 -0500
Try limiting jdbcio max connections
---
.../io/jdbc/src/test/java/org/apache/beam/sdk/io/jdbc/JdbcIOIT.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/sdks/java/io/jdbc/src/test/java/org/apache/beam/sdk/io/jdbc/JdbcIOIT.java b/sdks/java/io/jdbc/src/test/java/org/apache/beam/sdk/io/jdbc/JdbcIOIT.java
index 5f53d324300..07d94952ddb 100644
--- a/sdks/java/io/jdbc/src/test/java/org/apache/beam/sdk/io/jdbc/JdbcIOIT.java
+++ b/sdks/java/io/jdbc/src/test/java/org/apache/beam/sdk/io/jdbc/JdbcIOIT.java
@@ -210,7 +210,7 @@ public class JdbcIOIT {
.apply(ParDo.of(new TimeMonitor<>(NAMESPACE, "write_time")))
.apply(
JdbcIO.<TestRow>write()
- .withDataSourceConfiguration(JdbcIO.DataSourceConfiguration.create(dataSource))
+ .withDataSourceConfiguration(JdbcIO.DataSourceConfiguration.create(dataSource).withMaxConnections(4))
.withStatement(String.format("insert into %s values(?, ?)", tableName))
.withPreparedStatementSetter(new JdbcTestHelper.PrepareStatementFromTestRow()));
@@ -281,7 +281,7 @@ public class JdbcIOIT {
.apply(ParDo.of(new TimeMonitor<>(NAMESPACE, "write_time")))
.apply(
JdbcIO.<TestRow>write()
- .withDataSourceConfiguration(JdbcIO.DataSourceConfiguration.create(dataSource))
+ .withDataSourceConfiguration(JdbcIO.DataSourceConfiguration.create(dataSource).withMaxConnections(4))
.withStatement(String.format("insert into %s values(?, ?)", firstTableName))
.withAutoSharding()
.withPreparedStatementSetter(new JdbcTestHelper.PrepareStatementFromTestRow()));
@@ -421,7 +421,7 @@ public class JdbcIOIT {
*/
private static JdbcIO.Write<KV<Integer, String>> getJdbcWriteWithReturning(String tableName) {
return JdbcIO.<KV<Integer, String>>write()
- .withDataSourceConfiguration(JdbcIO.DataSourceConfiguration.create(dataSource))
+ .withDataSourceConfiguration(JdbcIO.DataSourceConfiguration.create(dataSource).withMaxConnections(4))
.withStatement(String.format("insert into %s values(?, ?) returning *", tableName))
.withPreparedStatementSetter(
(element, statement) -> {