From 77f97e424132299f8a5a561e28d178d066614864 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Knut=20Olav=20L=C3=B8ite?= Date: Thu, 10 Jul 2025 19:50:31 +0200 Subject: [PATCH 1/2] fix: increase max message size Increase the client-side hardcoded max message size to prevent errors if the server sends larger than expected messages. --- .../java/com/google/cloud/spanner/spi/v1/GapicSpannerRpc.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/google-cloud-spanner/src/main/java/com/google/cloud/spanner/spi/v1/GapicSpannerRpc.java b/google-cloud-spanner/src/main/java/com/google/cloud/spanner/spi/v1/GapicSpannerRpc.java index 5abf3ea98e..d3017afd61 100644 --- a/google-cloud-spanner/src/main/java/com/google/cloud/spanner/spi/v1/GapicSpannerRpc.java +++ b/google-cloud-spanner/src/main/java/com/google/cloud/spanner/spi/v1/GapicSpannerRpc.java @@ -224,7 +224,7 @@ public class GapicSpannerRpc implements SpannerRpc { PathTemplate.create("projects/{project}"); private static final PathTemplate OPERATION_NAME_TEMPLATE = PathTemplate.create("{database=projects/*/instances/*/databases/*}/operations/{operation}"); - private static final int MAX_MESSAGE_SIZE = 100 * 1024 * 1024; + private static final int MAX_MESSAGE_SIZE = 256 * 1024 * 1024; private static final int MAX_METADATA_SIZE = 32 * 1024; // bytes private static final String PROPERTY_TIMEOUT_SECONDS = "com.google.cloud.spanner.watchdogTimeoutSeconds"; From aabd5fc506324583a131dfd46ac014fa8b1783a5 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Knut=20Olav=20L=C3=B8ite?= Date: Thu, 10 Jul 2025 20:37:39 +0200 Subject: [PATCH 2/2] chore: re-add message size limits --- .../java/com/google/cloud/spanner/spi/v1/GapicSpannerRpc.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/google-cloud-spanner/src/main/java/com/google/cloud/spanner/spi/v1/GapicSpannerRpc.java b/google-cloud-spanner/src/main/java/com/google/cloud/spanner/spi/v1/GapicSpannerRpc.java index 3d2b84fa74..d3017afd61 100644 --- a/google-cloud-spanner/src/main/java/com/google/cloud/spanner/spi/v1/GapicSpannerRpc.java +++ b/google-cloud-spanner/src/main/java/com/google/cloud/spanner/spi/v1/GapicSpannerRpc.java @@ -344,6 +344,8 @@ public GapicSpannerRpc(final SpannerOptions options) { InstantiatingGrpcChannelProvider.newBuilder() .setChannelConfigurator(options.getChannelConfigurator()) .setEndpoint(options.getEndpoint()) + .setMaxInboundMessageSize(MAX_MESSAGE_SIZE) + .setMaxInboundMetadataSize(MAX_METADATA_SIZE) .setPoolSize(options.getNumChannels()) // Set a keepalive time of 120 seconds to help long running