File tree Expand file tree Collapse file tree 1 file changed +10
-1
lines changed
integration-tests/src/test/java/com/datastax/oss/driver/core/cql/reactive Expand file tree Collapse file tree 1 file changed +10
-1
lines changed Original file line number Diff line number Diff line change 3434import com .datastax .oss .driver .api .testinfra .ccm .CcmRule ;
3535import com .datastax .oss .driver .api .testinfra .ccm .SchemaChangeSynchronizer ;
3636import com .datastax .oss .driver .api .testinfra .session .SessionRule ;
37+ import com .datastax .oss .driver .api .testinfra .session .SessionUtils ;
3738import com .datastax .oss .driver .categories .ParallelizableTests ;
3839import com .datastax .oss .driver .internal .core .cql .EmptyColumnDefinitions ;
3940import com .tngtech .java .junit .dataprovider .DataProvider ;
4041import com .tngtech .java .junit .dataprovider .DataProviderRunner ;
4142import edu .umd .cs .findbugs .annotations .NonNull ;
4243import io .reactivex .Flowable ;
44+ import java .time .Duration ;
4345import java .util .LinkedHashSet ;
4446import java .util .List ;
4547import 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
You can’t perform that action at this time.
0 commit comments