Skip to content

Commit 4f8b779

Browse files
refactor: remove default inbound message size
1 parent 8ee25c6 commit 4f8b779

File tree

2 files changed

+1
-10
lines changed

2 files changed

+1
-10
lines changed

src/test/java/com/influxdb/v3/client/internal/FlightSqlClientTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -360,7 +360,7 @@ void concatCallOptions() throws Exception {
360360
callOptions = flightSqlClient.concatCallOptions(grpcCallOption.getCallOptions(), headerCallOption);
361361
Assertions.assertThat(callOptions).isNotNull();
362362
// This equals to 4 because we always have a default maxInboundMessageSize
363-
Assertions.assertThat(callOptions.length).isEqualTo(4);
363+
Assertions.assertThat(callOptions.length).isEqualTo(3);
364364
}
365365
}
366366

src/test/java/com/influxdb/v3/client/query/QueryOptionsTest.java

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -206,15 +206,6 @@ void setGrpcCallOption() {
206206

207207
}
208208

209-
@Test
210-
void grpcCallOptionDefaultOptions() {
211-
QueryOptions queryOptions = new QueryOptions("test");
212-
queryOptions.setGrpcCallOption(new GrpcCallOptions.Builder().build());
213-
Assertions.assertThat(queryOptions.grpcCallOption()).isNotNull();
214-
Assertions.assertThat(queryOptions.grpcCallOption()
215-
.getMaxInboundMessageSize()).isEqualTo(Integer.MAX_VALUE);
216-
}
217-
218209
@Test
219210
void grpcCallOption() {
220211
Executor executor = Executors.newSingleThreadExecutor();

0 commit comments

Comments
 (0)