diff options
Diffstat (limited to 'archiva-modules/metadata/metadata-store-provider/metadata-store-cassandra/src')
2 files changed, 5 insertions, 2 deletions
diff --git a/archiva-modules/metadata/metadata-store-provider/metadata-store-cassandra/src/main/resources/default-archiva-cassandra.properties b/archiva-modules/metadata/metadata-store-provider/metadata-store-cassandra/src/main/resources/default-archiva-cassandra.properties index 220e501a2..ec4beb342 100644 --- a/archiva-modules/metadata/metadata-store-provider/metadata-store-cassandra/src/main/resources/default-archiva-cassandra.properties +++ b/archiva-modules/metadata/metadata-store-provider/metadata-store-cassandra/src/main/resources/default-archiva-cassandra.properties @@ -24,6 +24,6 @@ cassandra.writeConsistencyLevel=QUORUM cassandra.replicationFactor=1 cassandra.keyspace.name=ArchivaKeySpace cassandra.cluster.name=archiva -cassandra.driverTimeoutMs=20000 +cassandra.driverTimeoutMs=60000 archiva.cassandra.configuration.file=./archiva-cassandra.properties
\ No newline at end of file diff --git a/archiva-modules/metadata/metadata-store-provider/metadata-store-cassandra/src/test/java/org/apache/archiva/metadata/repository/cassandra/CassandraMetadataRepositoryTest.java b/archiva-modules/metadata/metadata-store-provider/metadata-store-cassandra/src/test/java/org/apache/archiva/metadata/repository/cassandra/CassandraMetadataRepositoryTest.java index 71636efb4..ccdb3039f 100644 --- a/archiva-modules/metadata/metadata-store-provider/metadata-store-cassandra/src/test/java/org/apache/archiva/metadata/repository/cassandra/CassandraMetadataRepositoryTest.java +++ b/archiva-modules/metadata/metadata-store-provider/metadata-store-cassandra/src/test/java/org/apache/archiva/metadata/repository/cassandra/CassandraMetadataRepositoryTest.java @@ -191,8 +191,11 @@ public class CassandraMetadataRepositoryTest ); CompletableFuture.allOf( tables.stream( ).map( table -> session.executeAsync( truncate( table ).build( ) ) ) .map( CompletionStage::toCompletableFuture ).collect( Collectors.toList( ) ).toArray( new CompletableFuture[0] ) ) - .thenAccept( ( c ) -> { + .whenComplete( ( c, e ) -> { if ( clearedFlag != null ) clearedFlag.set( true ); + if (e!=null) { + System.err.println( "TRUNCATE ERROR DETECTED: " + e.getMessage( ) ); + } } ).get( ) ; } |