Skip to content

Commit 935cf34

Browse files
committed
DefaultReactiveResultSetIT raise METADATA_SCHEMA_REQUEST_TIMEOUT?
1 parent faeda6e commit 935cf34

File tree

1 file changed

+10
-1
lines changed

1 file changed

+10
-1
lines changed

integration-tests/src/test/java/com/datastax/oss/driver/core/cql/reactive/DefaultReactiveResultSetIT.java

Lines changed: 10 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,12 +34,14 @@
3434
import com.datastax.oss.driver.api.testinfra.ccm.CcmRule;
3535
import com.datastax.oss.driver.api.testinfra.ccm.SchemaChangeSynchronizer;
3636
import com.datastax.oss.driver.api.testinfra.session.SessionRule;
37+
import com.datastax.oss.driver.api.testinfra.session.SessionUtils;
3738
import com.datastax.oss.driver.categories.ParallelizableTests;
3839
import com.datastax.oss.driver.internal.core.cql.EmptyColumnDefinitions;
3940
import com.tngtech.java.junit.dataprovider.DataProvider;
4041
import com.tngtech.java.junit.dataprovider.DataProviderRunner;
4142
import edu.umd.cs.findbugs.annotations.NonNull;
4243
import io.reactivex.Flowable;
44+
import java.time.Duration;
4345
import java.util.LinkedHashSet;
4446
import java.util.List;
4547
import java.util.Set;
@@ -58,7 +60,14 @@ public class DefaultReactiveResultSetIT {
5860

5961
private static CcmRule ccmRule = CcmRule.getInstance();
6062

61-
private static SessionRule<CqlSession> sessionRule = SessionRule.builder(ccmRule).build();
63+
private static SessionRule<CqlSession> sessionRule =
64+
SessionRule.builder(ccmRule)
65+
.withConfigLoader(
66+
SessionUtils.configLoaderBuilder()
67+
.withDuration(
68+
DefaultDriverOption.METADATA_SCHEMA_REQUEST_TIMEOUT, Duration.ofSeconds(20))
69+
.build())
70+
.build();
6271

6372
@ClassRule public static TestRule chain = RuleChain.outerRule(ccmRule).around(sessionRule);
6473

0 commit comments

Comments
 (0)