<startNativeTransport>true</startNativeTransport>
<logLevel>INFO</logLevel>
<loadAfterFirstStart>false</loadAfterFirstStart>
- <yaml>
- broadcast_rpc_address: 127.0.0.1
- </yaml>
<systemPropertyVariables>
- <java.net.preferIPv4Stack>true</java.net.preferIPv4Stack>
+ <cassandra.jmx.local.port>${cassandra.jmxPort}</cassandra.jmx.local.port>
</systemPropertyVariables>
-
+ <yaml><![CDATA[rpc_address: 127.0.0.1
+broadcast_rpc_address: 127.0.0.1
+listen_address: 127.0.0.1
+auto_snapshot: false
+snapshot_before_compaction: false
+num_tokens: 1
+]]></yaml>
</configuration>
</execution>
<execution>
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
);
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( )
;
}