diff --git a/plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/JdbcPageSink.java b/plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/JdbcPageSink.java index 188a1cfb44f6..2ef6a25383f2 100644 --- a/plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/JdbcPageSink.java +++ b/plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/JdbcPageSink.java @@ -106,6 +106,7 @@ public JdbcPageSink(ConnectorSession session, JdbcOutputTableHandle handle, Jdbc throw new TrinoException(JDBC_ERROR, e); } + // Making batch size configurable allows performance tuning for insert/write-heavy workloads over multiple connections. this.maxBatchSize = getWriteBatchSize(session); }