Skip to content

Commit

Permalink
Increase gRPC max message size, clean test.
Browse files Browse the repository at this point in the history
  • Loading branch information
fmassot committed Jul 13, 2023
1 parent 9ba0f26 commit 67a0d0f
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 11 deletions.
10 changes: 0 additions & 10 deletions quickwit/quickwit-indexing/src/source/http_source.rs
Original file line number Diff line number Diff line change
Expand Up @@ -354,16 +354,6 @@ mod tests {
assert_eq!(parse_node_idx("kafka_node_020"), 20);
}

#[test]
fn test_gh_archive_uri_expand() {
let uri = "https://data.gharchive.org/{2015..2024}-{01..13}-{01..32}-{0..24}.json.gz";
let uris = expand_uris(uri);
for uri in uris {
println!("{}", uri);
}
panic!("test")
}

#[test]
fn test_uri_expand() {
let uri = "http://localhost:3000/{00..2}-{0..3}.json";
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -49,6 +49,8 @@ use crate::{
SplitMetadata,
};

pub const GRPC_MAX_MESSAGE_SIZE: usize = 20 * 1024 * 1024;

// URI describing in a generic way the metastore services resource present in the cluster (=
// discovered by Quickwit gossip). This value is used to build the URI of `MetastoreGrpcClient` and
// is only useful for debugging.
Expand Down Expand Up @@ -82,7 +84,8 @@ impl MetastoreGrpcClient {
let underlying = MetastoreApiServiceClient::with_interceptor(
balance_channel.clone(),
SpanContextInterceptor,
);
)
.max_decoding_message_size(GRPC_MAX_MESSAGE_SIZE);
let uri = QuickwitUri::from_well_formed(GRPC_METASTORE_BASE_URI);
Ok(Self {
underlying,
Expand Down

0 comments on commit 67a0d0f

Please sign in to comment.