feat: lower maxInflightRequest setting so that connection pool can scale up more efficiently. (#2993)

yirutang · web-flow · commit 38e5837dda2d · 2025-07-01T15:51:46.000-07:00
* Update WriteToDefaultStream.java

* Change to a working builder method

* fix syntax error

* include missing import

* int to long

* add explaination.
diff --git a/samples/snippets/src/main/java/com/example/bigquerystorage/WriteToDefaultStream.java b/samples/snippets/src/main/java/com/example/bigquerystorage/WriteToDefaultStream.java
@@ -20,6 +20,7 @@
 import com.google.api.core.ApiFuture;
 import com.google.api.core.ApiFutureCallback;
 import com.google.api.core.ApiFutures;
+import com.google.api.gax.batching.FlowControlSettings;
 import com.google.api.gax.core.FixedExecutorProvider;
 import com.google.api.gax.retrying.RetrySettings;
 import com.google.cloud.bigquery.BigQuery;
@@ -184,6 +185,9 @@ private JsonStreamWriter createStreamWriter(String tableName)
                   .setChannelsPerCpu(2)
                   .build())
           .setEnableConnectionPool(true)
+          // This will allow connection pool to scale up better. 
+          .setFlowControlSettings(
+              FlowControlSettings.newBuilder().setMaxOutstandingElementCount(100L).build())
           // If value is missing in json and there is a default value configured on bigquery
           // column, apply the default value to the missing value field.
           .setDefaultMissingValueInterpretation(
