diff --git a/crates/flow-client/src/client.rs b/crates/flow-client/src/client.rs index 1a0b64525e..c4c30cc698 100644 --- a/crates/flow-client/src/client.rs +++ b/crates/flow-client/src/client.rs @@ -68,24 +68,24 @@ impl Client { user_access_token: Option, user_refresh_token: Option, ) -> Self { - // Test whether a fresh set of Gazette clients solves the timeout issue - let router = gazette::Router::new("local"); - - let journal_client = gazette::journal::Client::new( - String::new(), - gazette::Metadata::default(), - router.clone(), - ); - let shard_client = gazette::shard::Client::new( - String::new(), - gazette::Metadata::default(), - router.clone(), - ); + // // Test whether a fresh set of Gazette clients solves the timeout issue + // let router = gazette::Router::new("local"); + + // let journal_client = gazette::journal::Client::new( + // String::new(), + // gazette::Metadata::default(), + // router.clone(), + // ); + // let shard_client = gazette::shard::Client::new( + // String::new(), + // gazette::Metadata::default(), + // router.clone(), + // ); Self { user_access_token: user_access_token.or(self.user_access_token), user_refresh_token: user_refresh_token.or(self.user_refresh_token), - journal_client, - shard_client, + // journal_client, + // shard_client, ..self } } diff --git a/crates/gazette/src/lib.rs b/crates/gazette/src/lib.rs index 5ed060f0b4..43a6b80a1a 100644 --- a/crates/gazette/src/lib.rs +++ b/crates/gazette/src/lib.rs @@ -87,6 +87,7 @@ pub async fn dial_channel(endpoint: &str) -> Result { .connect_timeout(Duration::from_secs(5)) .keep_alive_timeout(Duration::from_secs(120)) .keep_alive_while_idle(true) + .initial_connection_window_size(i32::MAX as u32) .tls_config( tonic::transport::ClientTlsConfig::new() .with_native_roots()