Переглянути джерело

Trying to tune cassandra tests

pull/62/head
Martin Stockhammer 2 роки тому
джерело
коміт
7c4835ba14

+ 8
- 5
archiva-modules/metadata/metadata-store-provider/metadata-store-cassandra/pom.xml Переглянути файл

<startNativeTransport>true</startNativeTransport> <startNativeTransport>true</startNativeTransport>
<logLevel>INFO</logLevel> <logLevel>INFO</logLevel>
<loadAfterFirstStart>false</loadAfterFirstStart> <loadAfterFirstStart>false</loadAfterFirstStart>
<yaml>
broadcast_rpc_address: 127.0.0.1
</yaml>
<systemPropertyVariables> <systemPropertyVariables>
<java.net.preferIPv4Stack>true</java.net.preferIPv4Stack>
<cassandra.jmx.local.port>${cassandra.jmxPort}</cassandra.jmx.local.port>
</systemPropertyVariables> </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> </configuration>
</execution> </execution>
<execution> <execution>

+ 1
- 1
archiva-modules/metadata/metadata-store-provider/metadata-store-cassandra/src/main/resources/default-archiva-cassandra.properties Переглянути файл

cassandra.replicationFactor=1 cassandra.replicationFactor=1
cassandra.keyspace.name=ArchivaKeySpace cassandra.keyspace.name=ArchivaKeySpace
cassandra.cluster.name=archiva cassandra.cluster.name=archiva
cassandra.driverTimeoutMs=20000
cassandra.driverTimeoutMs=60000


archiva.cassandra.configuration.file=./archiva-cassandra.properties archiva.cassandra.configuration.file=./archiva-cassandra.properties

+ 4
- 1
archiva-modules/metadata/metadata-store-provider/metadata-store-cassandra/src/test/java/org/apache/archiva/metadata/repository/cassandra/CassandraMetadataRepositoryTest.java Переглянути файл

); );
CompletableFuture.allOf( tables.stream( ).map( table -> session.executeAsync( truncate( table ).build( ) ) ) CompletableFuture.allOf( tables.stream( ).map( table -> session.executeAsync( truncate( table ).build( ) ) )
.map( CompletionStage::toCompletableFuture ).collect( Collectors.toList( ) ).toArray( new CompletableFuture[0] ) ) .map( CompletionStage::toCompletableFuture ).collect( Collectors.toList( ) ).toArray( new CompletableFuture[0] ) )
.thenAccept( ( c ) -> {
.whenComplete( ( c, e ) -> {
if ( clearedFlag != null ) clearedFlag.set( true ); if ( clearedFlag != null ) clearedFlag.set( true );
if (e!=null) {
System.err.println( "TRUNCATE ERROR DETECTED: " + e.getMessage( ) );
}
} ).get( ) } ).get( )
; ;
} }

Завантаження…
Відмінити
Зберегти