From db12a53de87c0a712e40edb3bc6191d9c3d6c395 Mon Sep 17 00:00:00 2001 From: Abhishek Modi Date: Wed, 17 Aug 2022 16:13:50 +0530 Subject: [PATCH] Grpc read timeout fix (#857) * Fixing gRPC read timeout * Fixing UTs --- .../hadoop/fs/gcs/GoogleHadoopFileSystemConfigurationTest.java | 2 +- .../cloud/hadoop/gcsio/GoogleCloudStorageReadOptions.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/gcs/src/test/java/com/google/cloud/hadoop/fs/gcs/GoogleHadoopFileSystemConfigurationTest.java b/gcs/src/test/java/com/google/cloud/hadoop/fs/gcs/GoogleHadoopFileSystemConfigurationTest.java index 4f95ef62c2..323aad90e6 100644 --- a/gcs/src/test/java/com/google/cloud/hadoop/fs/gcs/GoogleHadoopFileSystemConfigurationTest.java +++ b/gcs/src/test/java/com/google/cloud/hadoop/fs/gcs/GoogleHadoopFileSystemConfigurationTest.java @@ -82,7 +82,7 @@ public class GoogleHadoopFileSystemConfigurationTest { put("fs.gs.grpc.checksums.enable", false); put("fs.gs.grpc.enable", false); put("fs.gs.grpc.checkinterval.timeout.ms", 1_000L); - put("fs.gs.grpc.read.timeout.ms", 30_000L); + put("fs.gs.grpc.read.timeout.ms", 3600_000L); put("fs.gs.grpc.read.message.timeout.ms", 3_000L); put("fs.gs.grpc.read.zerocopy.enable", true); put("fs.gs.grpc.directpath.enable", true); diff --git a/gcsio/src/main/java/com/google/cloud/hadoop/gcsio/GoogleCloudStorageReadOptions.java b/gcsio/src/main/java/com/google/cloud/hadoop/gcsio/GoogleCloudStorageReadOptions.java index d4ef457aa5..20575eb8bb 100644 --- a/gcsio/src/main/java/com/google/cloud/hadoop/gcsio/GoogleCloudStorageReadOptions.java +++ b/gcsio/src/main/java/com/google/cloud/hadoop/gcsio/GoogleCloudStorageReadOptions.java @@ -45,7 +45,7 @@ public enum Fadvise { public static final Fadvise DEFAULT_FADVISE = Fadvise.AUTO; public static final long DEFAULT_MIN_RANGE_REQUEST_SIZE = 2 * 1024 * 1024; public static final boolean DEFAULT_GRPC_CHECKSUMS_ENABLED = false; - public static final long DEFAULT_GRPC_READ_TIMEOUT_MILLIS = 30 * 1000; + public static final long DEFAULT_GRPC_READ_TIMEOUT_MILLIS = 3600 * 1000; public static final boolean DEFAULT_GRPC_READ_ZEROCOPY_ENABLED = true; public static final long DEFAULT_GRPC_READ_MESSAGE_TIMEOUT_MILLIS = 3 * 1000;