[camel-kafka-connector] branch master updated: Create timeout when creating Cassandra's test table

[orpiske]

This is an automated email from the ASF dual-hosted git repository.

orpiske pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git


The following commit(s) were added to refs/heads/master by this push:
     new 9f95613  Create timeout when creating Cassandra's test table
9f95613 is described below

commit 9f9561302ebd9a2997294c57c79b13cd15fe1bb9
Author: Otavio Rodolfo Piske <opi...@redhat.com>
AuthorDate: Fri Jan 8 15:19:22 2021 +0100

    Create timeout when creating Cassandra's test table
---
 .../camel/kafkaconnector/cassandra/clients/dao/TestDataDao.java   | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git 
a/tests/itests-cassandra/src/test/java/org/apache/camel/kafkaconnector/cassandra/clients/dao/TestDataDao.java
 
b/tests/itests-cassandra/src/test/java/org/apache/camel/kafkaconnector/cassandra/clients/dao/TestDataDao.java
index ea8de7a..14c15dc 100644
--- 
a/tests/itests-cassandra/src/test/java/org/apache/camel/kafkaconnector/cassandra/clients/dao/TestDataDao.java
+++ 
b/tests/itests-cassandra/src/test/java/org/apache/camel/kafkaconnector/cassandra/clients/dao/TestDataDao.java
@@ -17,6 +17,7 @@
 
 package org.apache.camel.kafkaconnector.cassandra.clients.dao;
 
+import java.time.Duration;
 import java.util.HashMap;
 import java.util.Iterator;
 import java.util.List;
@@ -26,6 +27,7 @@ import java.util.function.Consumer;
 import com.datastax.oss.driver.api.core.CqlSession;
 import com.datastax.oss.driver.api.core.cql.ResultSet;
 import com.datastax.oss.driver.api.core.cql.Row;
+import com.datastax.oss.driver.api.core.cql.SimpleStatement;
 import com.datastax.oss.driver.api.core.type.DataTypes;
 import com.datastax.oss.driver.api.querybuilder.SchemaBuilder;
 import org.slf4j.Logger;
@@ -72,11 +74,11 @@ public class TestDataDao {
     }
 
     public void createTable() {
-        String statement = SchemaBuilder.createTable(TABLE_NAME)
+        SimpleStatement statement = SchemaBuilder.createTable(TABLE_NAME)
                 .withPartitionKey("id", DataTypes.TIMEUUID)
                 .withClusteringColumn("text", DataTypes.TEXT)
-                .asCql();
-
+                .builder()
+                .setTimeout(Duration.ofSeconds(10)).build();
 
         LOG.info("Executing create table {}", statement);