search

aerospike / aerospike-client-java

Aerospike Java Client Library
Other
236 stars 212 forks source link

reactor query engine #152

Closed kptfh closed 4 years ago

BrianNichols commented 4 years ago

Why were aerospike-query-engine and aerospike-reactor-client added as dependencies in the main pom.xml?

kptfh commented 4 years ago

I need them in reactor-query-engine

BrianNichols commented 4 years ago

This pull request has been merged. It will appear in the next java client release.

Do you need reactor-query-engine to be released with every java client release?

kptfh commented 4 years ago

It's the best option

kptfh commented 4 years ago

will wait for release, so I can use this in reactive spring data

kptfh commented 4 years ago

Hi @BrianNichols. Still waiting for release of reactor query engine. Are there any obstacles?

BrianNichols commented 4 years ago

We are waiting on the other pull request (https://github.com/aerospike/aerospike-client-java/pull/154) to resolve merge conflicts with this pull request. Also, releases are roughly scheduled for once a month and the last release was Jan 3.

BrianNichols commented 4 years ago

reactor-client tests are failing. Not sure which pull request caused the failure, but this needs to be fixed before java client release.

Running com.aerospike.client.reactor.BatchReactorFailTest
SLF4J: No SLF4J providers were found.
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#noProviders for further details.
Tests run: 12, Failures: 4, Errors: 0, Skipped: 0, Time elapsed: 1.678 sec <<< FAILURE! - in com.aerospike.client.reactor.BatchReactorFailTest
shouldFailOnBatchGetSequence[eventLoopType=DIRECT_NIO](com.aerospike.client.reactor.BatchReactorFailTest)  Time elapsed: 0.329 sec  <<< FAILURE!
java.lang.AssertionError: expectation "expectError(Class)" failed (expected: onError(Timeout); actual: onNext(test:test:batchkey3:49fb2914d0d642dc30dc0a5421ff0b5b10d4748e:(gen:63),(exp:320793698),(bins:(batchbin:batchvalue3))))
    at reactor.test.DefaultStepVerifierBuilder.failPrefix(DefaultStepVerifierBuilder.java:2235)
    at reactor.test.DefaultStepVerifierBuilder.fail(DefaultStepVerifierBuilder.java:2231)
    at reactor.test.DefaultStepVerifierBuilder.lambda$expectError$6(DefaultStepVerifierBuilder.java:275)
    at reactor.test.DefaultStepVerifierBuilder$SignalEvent.test(DefaultStepVerifierBuilder.java:1973)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onSignal(DefaultStepVerifierBuilder.java:1326)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onExpectation(DefaultStepVerifierBuilder.java:1274)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onNext(DefaultStepVerifierBuilder.java:958)
    at reactor.core.publisher.FluxCreate$BufferAsyncSink.drain(FluxCreate.java:726)
    at reactor.core.publisher.FluxCreate$BufferAsyncSink.next(FluxCreate.java:657)
    at reactor.core.publisher.FluxCreate$SerializedSink.next(FluxCreate.java:151)
    at com.aerospike.client.reactor.listeners.ReactorRecordSequenceListener.onRecord(ReactorRecordSequenceListener.java:36)
    at com.aerospike.client.async.AsyncBatch$GetSequenceCommand.parseRow(AsyncBatch.java:362)
    at com.aerospike.client.async.AsyncMultiCommand.parseResult(AsyncMultiCommand.java:114)
    at com.aerospike.client.async.AsyncCommand.parseCommandResult(AsyncCommand.java:176)
    at com.aerospike.client.async.NioCommand.parseGroupBody(NioCommand.java:569)
    at com.aerospike.client.async.NioCommand.readMultiBody(NioCommand.java:508)
    at com.aerospike.client.async.NioCommand.readMultiHeader(NioCommand.java:500)
    at com.aerospike.client.async.NioCommand.read(NioCommand.java:412)
    at com.aerospike.client.async.NioCommand.processEvent(NioCommand.java:276)
    at com.aerospike.client.async.NioEventLoop.runCommands(NioEventLoop.java:205)
    at com.aerospike.client.async.NioEventLoop.run(NioEventLoop.java:163)
    at java.lang.Thread.run(Thread.java:748)
kptfh commented 4 years ago

Rebased and resolved conflicts. Locally all tests pass. Can you check it again?

kptfh commented 4 years ago

@BrianNichols just fixed failing test for multi-nodes configuration

BrianNichols commented 4 years ago

The reactor-client unit tests are still failing on a 2 node cluster. The exact steps to reproduce are below (docker is running):

$ cd aerospike-client-java
$ git checkout -b kptfh-feature/reacor-query-engine master
$ git pull git://github.com/kptfh/aerospike-client-java.git feature/reacor-query-engine
remote: Enumerating objects: 50, done.
remote: Counting objects: 100% (50/50), done.
remote: Compressing objects: 100% (7/7), done.
remote: Total 28 (delta 9), reused 28 (delta 9), pack-reused 0
Unpacking objects: 100% (28/28), done.
From git://github.com/kptfh/aerospike-client-java
 * branch            feature/reacor-query-engine -> FETCH_HEAD
Merge made by the 'recursive' strategy.
 extensions/query-engine/src/main/java/com/aerospike/helper/query/QueryEngine.java     |  3 ++
 extensions/query-engine/src/test/java/com/aerospike/helper/query/QualifierTests.java  |  2 +-
 .../reactor-client/src/test/java/com/aerospike/client/reactor/ReactorFailTest.java    | 69 ++++++++++++++++++++++++++----------------
 3 files changed, 47 insertions(+), 27 deletions(-)
$ mvn clean
...
$ mvn install
...
$ cd extensions/reactor-client
$ ./run_tests -h bn66
[INFO] Scanning for projects...
[INFO] 
[INFO] ---------------< com.aerospike:aerospike-reactor-client >---------------
[INFO] Building aerospike-reactor-client 4.4.8
[INFO] --------------------------------[ jar ]---------------------------------
[INFO] 
[INFO] --- maven-resources-plugin:2.6:resources (default-resources) @ aerospike-reactor-client ---
[INFO] Using 'UTF-8' encoding to copy filtered resources.
[INFO] skip non existing resourceDirectory /Users/bnichols/client-java/extensions/reactor-client/src/main/resources
[INFO] 
[INFO] --- maven-compiler-plugin:3.8.0:compile (default-compile) @ aerospike-reactor-client ---
[INFO] Nothing to compile - all classes are up to date
[INFO] 
[INFO] --- maven-resources-plugin:2.6:testResources (default-testResources) @ aerospike-reactor-client ---
[INFO] Using 'UTF-8' encoding to copy filtered resources.
[INFO] Copying 1 resource
[INFO] 
[INFO] --- maven-compiler-plugin:3.8.0:testCompile (default-testCompile) @ aerospike-reactor-client ---
[INFO] Nothing to compile - all classes are up to date
[INFO] 
[INFO] --- maven-surefire-plugin:2.18.1:test (default-test) @ aerospike-reactor-client ---
[INFO] Surefire report directory: /Users/bnichols/client-java/extensions/reactor-client/target/surefire-reports

-------------------------------------------------------
 T E S T S
-------------------------------------------------------
Running com.aerospike.client.reactor.BatchReactorFailTest
SLF4J: No SLF4J providers were found.
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#noProviders for further details.
Tests run: 12, Failures: 4, Errors: 0, Skipped: 0, Time elapsed: 1.692 sec <<< FAILURE! - in com.aerospike.client.reactor.BatchReactorFailTest
shouldFailOnBatchGetSequence[eventLoopType=DIRECT_NIO](com.aerospike.client.reactor.BatchReactorFailTest)  Time elapsed: 0.33 sec  <<< FAILURE!
java.lang.AssertionError: expectation "expectError(Class)" failed (expected: onError(Timeout); actual: onNext(test:test:batchkey1:71e94f431d840d953dfd3da62d69b9c32e145ae6:(gen:1),(exp:321129333),(bins:(batchbin:batchvalue1))))
    at reactor.test.DefaultStepVerifierBuilder.failPrefix(DefaultStepVerifierBuilder.java:2235)
    at reactor.test.DefaultStepVerifierBuilder.fail(DefaultStepVerifierBuilder.java:2231)
    at reactor.test.DefaultStepVerifierBuilder.lambda$expectError$6(DefaultStepVerifierBuilder.java:275)
    at reactor.test.DefaultStepVerifierBuilder$SignalEvent.test(DefaultStepVerifierBuilder.java:1973)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onSignal(DefaultStepVerifierBuilder.java:1326)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onExpectation(DefaultStepVerifierBuilder.java:1274)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onNext(DefaultStepVerifierBuilder.java:958)
    at reactor.core.publisher.FluxCreate$BufferAsyncSink.drain(FluxCreate.java:726)
    at reactor.core.publisher.FluxCreate$BufferAsyncSink.next(FluxCreate.java:657)
    at reactor.core.publisher.FluxCreate$SerializedSink.next(FluxCreate.java:151)
    at com.aerospike.client.reactor.listeners.ReactorRecordSequenceListener.onRecord(ReactorRecordSequenceListener.java:36)
    at com.aerospike.client.async.AsyncBatch$GetSequenceCommand.parseRow(AsyncBatch.java:362)
    at com.aerospike.client.async.AsyncMultiCommand.parseResult(AsyncMultiCommand.java:114)
    at com.aerospike.client.async.AsyncCommand.parseCommandResult(AsyncCommand.java:176)
    at com.aerospike.client.async.NioCommand.parseGroupBody(NioCommand.java:569)
    at com.aerospike.client.async.NioCommand.readMultiBody(NioCommand.java:508)
    at com.aerospike.client.async.NioCommand.readMultiHeader(NioCommand.java:500)
    at com.aerospike.client.async.NioCommand.read(NioCommand.java:412)
    at com.aerospike.client.async.NioCommand.processEvent(NioCommand.java:276)
    at com.aerospike.client.async.NioEventLoop.runCommands(NioEventLoop.java:205)
    at com.aerospike.client.async.NioEventLoop.run(NioEventLoop.java:163)
    at java.lang.Thread.run(Thread.java:748)

shouldFailOnBatchExistsSequence[eventLoopType=DIRECT_NIO](com.aerospike.client.reactor.BatchReactorFailTest)  Time elapsed: 0.029 sec  <<< FAILURE!
java.lang.AssertionError: expectation "expectError(Class)" failed (expected: onError(Timeout); actual: onNext(test:test:batchkey1:71e94f431d840d953dfd3da62d69b9c32e145ae6:(gen:2),(exp:321129333),(bins:(batchbin:batchvalue1))))
    at reactor.test.DefaultStepVerifierBuilder.failPrefix(DefaultStepVerifierBuilder.java:2235)
    at reactor.test.DefaultStepVerifierBuilder.fail(DefaultStepVerifierBuilder.java:2231)
    at reactor.test.DefaultStepVerifierBuilder.lambda$expectError$6(DefaultStepVerifierBuilder.java:275)
    at reactor.test.DefaultStepVerifierBuilder$SignalEvent.test(DefaultStepVerifierBuilder.java:1973)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onSignal(DefaultStepVerifierBuilder.java:1326)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onExpectation(DefaultStepVerifierBuilder.java:1274)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onNext(DefaultStepVerifierBuilder.java:958)
    at reactor.core.publisher.FluxCreate$BufferAsyncSink.drain(FluxCreate.java:726)
    at reactor.core.publisher.FluxCreate$BufferAsyncSink.next(FluxCreate.java:657)
    at reactor.core.publisher.FluxCreate$SerializedSink.next(FluxCreate.java:151)
    at com.aerospike.client.reactor.listeners.ReactorRecordSequenceListener.onRecord(ReactorRecordSequenceListener.java:36)
    at com.aerospike.client.async.AsyncBatch$GetSequenceCommand.parseRow(AsyncBatch.java:362)
    at com.aerospike.client.async.AsyncMultiCommand.parseResult(AsyncMultiCommand.java:114)
    at com.aerospike.client.async.AsyncCommand.parseCommandResult(AsyncCommand.java:176)
    at com.aerospike.client.async.NioCommand.parseGroupBody(NioCommand.java:569)
    at com.aerospike.client.async.NioCommand.readMultiBody(NioCommand.java:508)
    at com.aerospike.client.async.NioCommand.readMultiHeader(NioCommand.java:500)
    at com.aerospike.client.async.NioCommand.read(NioCommand.java:412)
    at com.aerospike.client.async.NioCommand.processEvent(NioCommand.java:276)
    at com.aerospike.client.async.NioEventLoop.runCommands(NioEventLoop.java:205)
    at com.aerospike.client.async.NioEventLoop.run(NioEventLoop.java:163)
    at java.lang.Thread.run(Thread.java:748)

shouldFailOnBatchGetSequence[eventLoopType=NETTY_NIO](com.aerospike.client.reactor.BatchReactorFailTest)  Time elapsed: 0.185 sec  <<< FAILURE!
java.lang.AssertionError: expectation "expectError(Class)" failed (expected: onError(Timeout); actual: onNext(test:test:batchkey1:71e94f431d840d953dfd3da62d69b9c32e145ae6:(gen:7),(exp:321129334),(bins:(batchbin:batchvalue1))))
    at reactor.test.DefaultStepVerifierBuilder.failPrefix(DefaultStepVerifierBuilder.java:2235)
    at reactor.test.DefaultStepVerifierBuilder.fail(DefaultStepVerifierBuilder.java:2231)
    at reactor.test.DefaultStepVerifierBuilder.lambda$expectError$6(DefaultStepVerifierBuilder.java:275)
    at reactor.test.DefaultStepVerifierBuilder$SignalEvent.test(DefaultStepVerifierBuilder.java:1973)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onSignal(DefaultStepVerifierBuilder.java:1326)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onExpectation(DefaultStepVerifierBuilder.java:1274)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onNext(DefaultStepVerifierBuilder.java:958)
    at reactor.core.publisher.FluxCreate$BufferAsyncSink.drain(FluxCreate.java:726)
    at reactor.core.publisher.FluxCreate$BufferAsyncSink.next(FluxCreate.java:657)
    at reactor.core.publisher.FluxCreate$SerializedSink.next(FluxCreate.java:151)
    at com.aerospike.client.reactor.listeners.ReactorRecordSequenceListener.onRecord(ReactorRecordSequenceListener.java:36)
    at com.aerospike.client.async.AsyncBatch$GetSequenceCommand.parseRow(AsyncBatch.java:362)
    at com.aerospike.client.async.AsyncMultiCommand.parseResult(AsyncMultiCommand.java:114)
    at com.aerospike.client.async.AsyncCommand.parseCommandResult(AsyncCommand.java:176)
    at com.aerospike.client.async.NettyCommand.readMultiHeader(NettyCommand.java:569)
    at com.aerospike.client.async.NettyCommand.read(NettyCommand.java:394)
    at com.aerospike.client.async.NettyCommand.access$200(NettyCommand.java:57)
    at com.aerospike.client.async.NettyCommand$InboundHandler.channelRead(NettyCommand.java:937)
    at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
    at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
    at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
    at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334)
    at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
    at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
    at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926)
    at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:134)
    at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:644)
    at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:579)
    at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:496)
    at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:458)
    at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858)
    at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:138)
    at java.lang.Thread.run(Thread.java:748)

shouldFailOnBatchExistsSequence[eventLoopType=NETTY_NIO](com.aerospike.client.reactor.BatchReactorFailTest)  Time elapsed: 0.04 sec  <<< FAILURE!
java.lang.AssertionError: expectation "expectError(Class)" failed (expected: onError(Timeout); actual: onNext(test:test:batchkey1:71e94f431d840d953dfd3da62d69b9c32e145ae6:(gen:8),(exp:321129334),(bins:(batchbin:batchvalue1))))
    at reactor.test.DefaultStepVerifierBuilder.failPrefix(DefaultStepVerifierBuilder.java:2235)
    at reactor.test.DefaultStepVerifierBuilder.fail(DefaultStepVerifierBuilder.java:2231)
    at reactor.test.DefaultStepVerifierBuilder.lambda$expectError$6(DefaultStepVerifierBuilder.java:275)
    at reactor.test.DefaultStepVerifierBuilder$SignalEvent.test(DefaultStepVerifierBuilder.java:1973)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onSignal(DefaultStepVerifierBuilder.java:1326)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onExpectation(DefaultStepVerifierBuilder.java:1274)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onNext(DefaultStepVerifierBuilder.java:958)
    at reactor.core.publisher.FluxCreate$BufferAsyncSink.drain(FluxCreate.java:726)
    at reactor.core.publisher.FluxCreate$BufferAsyncSink.next(FluxCreate.java:657)
    at reactor.core.publisher.FluxCreate$SerializedSink.next(FluxCreate.java:151)
    at com.aerospike.client.reactor.listeners.ReactorRecordSequenceListener.onRecord(ReactorRecordSequenceListener.java:36)
    at com.aerospike.client.async.AsyncBatch$GetSequenceCommand.parseRow(AsyncBatch.java:362)
    at com.aerospike.client.async.AsyncMultiCommand.parseResult(AsyncMultiCommand.java:114)
    at com.aerospike.client.async.AsyncCommand.parseCommandResult(AsyncCommand.java:176)
    at com.aerospike.client.async.NettyCommand.readMultiHeader(NettyCommand.java:569)
    at com.aerospike.client.async.NettyCommand.read(NettyCommand.java:394)
    at com.aerospike.client.async.NettyCommand.access$200(NettyCommand.java:57)
    at com.aerospike.client.async.NettyCommand$InboundHandler.channelRead(NettyCommand.java:937)
    at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
    at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
    at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
    at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334)
    at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
    at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
    at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926)
    at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:134)
    at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:644)
    at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:579)
    at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:496)
    at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:458)
    at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858)
    at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:138)
    at java.lang.Thread.run(Thread.java:748)

Running com.aerospike.client.reactor.BatchReactorTest
Tests run: 18, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.485 sec - in com.aerospike.client.reactor.BatchReactorTest
Running com.aerospike.client.reactor.CrudReactorFailTest
Tests run: 8, Failures: 6, Errors: 0, Skipped: 0, Time elapsed: 0.705 sec <<< FAILURE! - in com.aerospike.client.reactor.CrudReactorFailTest
shouldFailOnGet[eventLoopType=DIRECT_NIO](com.aerospike.client.reactor.CrudReactorFailTest)  Time elapsed: 0.061 sec  <<< FAILURE!
java.lang.AssertionError: expectation "expectError(Class)" failed (expected: onError(Timeout); actual: onNext(test:test:putgetkey1:694d1d686a9520d2443243afa899bf970151f50a:))
    at reactor.test.DefaultStepVerifierBuilder.failPrefix(DefaultStepVerifierBuilder.java:2235)
    at reactor.test.DefaultStepVerifierBuilder.fail(DefaultStepVerifierBuilder.java:2231)
    at reactor.test.DefaultStepVerifierBuilder.lambda$expectError$6(DefaultStepVerifierBuilder.java:275)
    at reactor.test.DefaultStepVerifierBuilder$SignalEvent.test(DefaultStepVerifierBuilder.java:1973)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onSignal(DefaultStepVerifierBuilder.java:1326)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onExpectation(DefaultStepVerifierBuilder.java:1274)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onNext(DefaultStepVerifierBuilder.java:958)
    at reactor.core.publisher.MonoCreate$DefaultMonoSink.success(MonoCreate.java:146)
    at com.aerospike.client.reactor.listeners.ReactorRecordListener.onSuccess(ReactorRecordListener.java:35)
    at com.aerospike.client.async.AsyncRead.onSuccess(AsyncRead.java:188)
    at com.aerospike.client.async.NioCommand.finish(NioCommand.java:723)
    at com.aerospike.client.async.NioCommand.readSingleBody(NioCommand.java:484)
    at com.aerospike.client.async.NioCommand.readSingleHeader(NioCommand.java:472)
    at com.aerospike.client.async.NioCommand.read(NioCommand.java:409)
    at com.aerospike.client.async.NioCommand.processEvent(NioCommand.java:276)
    at com.aerospike.client.async.NioEventLoop.runCommands(NioEventLoop.java:205)
    at com.aerospike.client.async.NioEventLoop.run(NioEventLoop.java:163)
    at java.lang.Thread.run(Thread.java:748)

shouldFailOnPut[eventLoopType=DIRECT_NIO](com.aerospike.client.reactor.CrudReactorFailTest)  Time elapsed: 0.064 sec  <<< FAILURE!
java.lang.AssertionError: expectation "expectError(Class)" failed (expected: onError(Timeout); actual: onNext(test:test:putgetkey1:694d1d686a9520d2443243afa899bf970151f50a))
    at reactor.test.DefaultStepVerifierBuilder.failPrefix(DefaultStepVerifierBuilder.java:2235)
    at reactor.test.DefaultStepVerifierBuilder.fail(DefaultStepVerifierBuilder.java:2231)
    at reactor.test.DefaultStepVerifierBuilder.lambda$expectError$6(DefaultStepVerifierBuilder.java:275)
    at reactor.test.DefaultStepVerifierBuilder$SignalEvent.test(DefaultStepVerifierBuilder.java:1973)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onSignal(DefaultStepVerifierBuilder.java:1326)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onExpectation(DefaultStepVerifierBuilder.java:1274)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onNext(DefaultStepVerifierBuilder.java:958)
    at reactor.core.publisher.MonoCreate$DefaultMonoSink.success(MonoCreate.java:146)
    at com.aerospike.client.reactor.listeners.ReactorWriteListener.onSuccess(ReactorWriteListener.java:34)
    at com.aerospike.client.async.AsyncWrite.onSuccess(AsyncWrite.java:99)
    at com.aerospike.client.async.NioCommand.finish(NioCommand.java:723)
    at com.aerospike.client.async.NioCommand.readSingleBody(NioCommand.java:484)
    at com.aerospike.client.async.NioCommand.readSingleHeader(NioCommand.java:472)
    at com.aerospike.client.async.NioCommand.read(NioCommand.java:409)
    at com.aerospike.client.async.NioCommand.processEvent(NioCommand.java:276)
    at com.aerospike.client.async.NioEventLoop.runCommands(NioEventLoop.java:205)
    at com.aerospike.client.async.NioEventLoop.run(NioEventLoop.java:163)
    at java.lang.Thread.run(Thread.java:748)

shouldFailOnGetHeader[eventLoopType=DIRECT_NIO](com.aerospike.client.reactor.CrudReactorFailTest)  Time elapsed: 0.053 sec  <<< FAILURE!
java.lang.AssertionError: expectation "expectError(Class)" failed (expected: onError(Timeout); actual: onNext(test:test:putgetkey1:694d1d686a9520d2443243afa899bf970151f50a:(gen:1),(exp:321129335),(bins:null)))
    at reactor.test.DefaultStepVerifierBuilder.failPrefix(DefaultStepVerifierBuilder.java:2235)
    at reactor.test.DefaultStepVerifierBuilder.fail(DefaultStepVerifierBuilder.java:2231)
    at reactor.test.DefaultStepVerifierBuilder.lambda$expectError$6(DefaultStepVerifierBuilder.java:275)
    at reactor.test.DefaultStepVerifierBuilder$SignalEvent.test(DefaultStepVerifierBuilder.java:1973)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onSignal(DefaultStepVerifierBuilder.java:1326)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onExpectation(DefaultStepVerifierBuilder.java:1274)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onNext(DefaultStepVerifierBuilder.java:958)
    at reactor.core.publisher.MonoCreate$DefaultMonoSink.success(MonoCreate.java:146)
    at com.aerospike.client.reactor.listeners.ReactorRecordListener.onSuccess(ReactorRecordListener.java:35)
    at com.aerospike.client.async.AsyncReadHeader.onSuccess(AsyncReadHeader.java:89)
    at com.aerospike.client.async.NioCommand.finish(NioCommand.java:723)
    at com.aerospike.client.async.NioCommand.readSingleBody(NioCommand.java:484)
    at com.aerospike.client.async.NioCommand.readSingleHeader(NioCommand.java:472)
    at com.aerospike.client.async.NioCommand.read(NioCommand.java:409)
    at com.aerospike.client.async.NioCommand.processEvent(NioCommand.java:276)
    at com.aerospike.client.async.NioEventLoop.runCommands(NioEventLoop.java:205)
    at com.aerospike.client.async.NioEventLoop.run(NioEventLoop.java:163)
    at java.lang.Thread.run(Thread.java:748)

shouldFailOnGet[eventLoopType=NETTY_NIO](com.aerospike.client.reactor.CrudReactorFailTest)  Time elapsed: 0.077 sec  <<< FAILURE!
java.lang.AssertionError: expectation "expectError(Class)" failed (expected: onError(Timeout); actual: onNext(test:test:putgetkey1:694d1d686a9520d2443243afa899bf970151f50a:(gen:1),(exp:321129335),(bins:(putgetbin:value))))
    at reactor.test.DefaultStepVerifierBuilder.failPrefix(DefaultStepVerifierBuilder.java:2235)
    at reactor.test.DefaultStepVerifierBuilder.fail(DefaultStepVerifierBuilder.java:2231)
    at reactor.test.DefaultStepVerifierBuilder.lambda$expectError$6(DefaultStepVerifierBuilder.java:275)
    at reactor.test.DefaultStepVerifierBuilder$SignalEvent.test(DefaultStepVerifierBuilder.java:1973)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onSignal(DefaultStepVerifierBuilder.java:1326)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onExpectation(DefaultStepVerifierBuilder.java:1274)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onNext(DefaultStepVerifierBuilder.java:958)
    at reactor.core.publisher.MonoCreate$DefaultMonoSink.success(MonoCreate.java:146)
    at com.aerospike.client.reactor.listeners.ReactorRecordListener.onSuccess(ReactorRecordListener.java:35)
    at com.aerospike.client.async.AsyncRead.onSuccess(AsyncRead.java:188)
    at com.aerospike.client.async.NettyCommand.finish(NettyCommand.java:735)
    at com.aerospike.client.async.NettyCommand.parseSingleBody(NettyCommand.java:519)
    at com.aerospike.client.async.NettyCommand.readSingleHeader(NettyCommand.java:499)
    at com.aerospike.client.async.NettyCommand.read(NettyCommand.java:391)
    at com.aerospike.client.async.NettyCommand.access$200(NettyCommand.java:57)
    at com.aerospike.client.async.NettyCommand$InboundHandler.channelRead(NettyCommand.java:937)
    at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
    at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
    at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
    at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334)
    at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
    at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
    at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926)
    at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:134)
    at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:644)
    at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:579)
    at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:496)
    at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:458)
    at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858)
    at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:138)
    at java.lang.Thread.run(Thread.java:748)

shouldFailOnPut[eventLoopType=NETTY_NIO](com.aerospike.client.reactor.CrudReactorFailTest)  Time elapsed: 0.05 sec  <<< FAILURE!
java.lang.AssertionError: expectation "expectError(Class)" failed (expected: onError(Timeout); actual: onNext(test:test:putgetkey1:694d1d686a9520d2443243afa899bf970151f50a))
    at reactor.test.DefaultStepVerifierBuilder.failPrefix(DefaultStepVerifierBuilder.java:2235)
    at reactor.test.DefaultStepVerifierBuilder.fail(DefaultStepVerifierBuilder.java:2231)
    at reactor.test.DefaultStepVerifierBuilder.lambda$expectError$6(DefaultStepVerifierBuilder.java:275)
    at reactor.test.DefaultStepVerifierBuilder$SignalEvent.test(DefaultStepVerifierBuilder.java:1973)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onSignal(DefaultStepVerifierBuilder.java:1326)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onExpectation(DefaultStepVerifierBuilder.java:1274)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onNext(DefaultStepVerifierBuilder.java:958)
    at reactor.core.publisher.MonoCreate$DefaultMonoSink.success(MonoCreate.java:146)
    at com.aerospike.client.reactor.listeners.ReactorWriteListener.onSuccess(ReactorWriteListener.java:34)
    at com.aerospike.client.async.AsyncWrite.onSuccess(AsyncWrite.java:99)
    at com.aerospike.client.async.NettyCommand.finish(NettyCommand.java:735)
    at com.aerospike.client.async.NettyCommand.parseSingleBody(NettyCommand.java:519)
    at com.aerospike.client.async.NettyCommand.readSingleHeader(NettyCommand.java:499)
    at com.aerospike.client.async.NettyCommand.read(NettyCommand.java:391)
    at com.aerospike.client.async.NettyCommand.access$200(NettyCommand.java:57)
    at com.aerospike.client.async.NettyCommand$InboundHandler.channelRead(NettyCommand.java:937)
    at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
    at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
    at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
    at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334)
    at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
    at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
    at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926)
    at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:134)
    at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:644)
    at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:579)
    at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:496)
    at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:458)
    at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858)
    at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:138)
    at java.lang.Thread.run(Thread.java:748)

shouldFailOnGetHeader[eventLoopType=NETTY_NIO](com.aerospike.client.reactor.CrudReactorFailTest)  Time elapsed: 0.064 sec  <<< FAILURE!
java.lang.AssertionError: expectation "expectError(Class)" failed (expected: onError(Timeout); actual: onNext(test:test:putgetkey1:694d1d686a9520d2443243afa899bf970151f50a:(gen:2),(exp:321129336),(bins:null)))
    at reactor.test.DefaultStepVerifierBuilder.failPrefix(DefaultStepVerifierBuilder.java:2235)
    at reactor.test.DefaultStepVerifierBuilder.fail(DefaultStepVerifierBuilder.java:2231)
    at reactor.test.DefaultStepVerifierBuilder.lambda$expectError$6(DefaultStepVerifierBuilder.java:275)
    at reactor.test.DefaultStepVerifierBuilder$SignalEvent.test(DefaultStepVerifierBuilder.java:1973)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onSignal(DefaultStepVerifierBuilder.java:1326)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onExpectation(DefaultStepVerifierBuilder.java:1274)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onNext(DefaultStepVerifierBuilder.java:958)
    at reactor.core.publisher.MonoCreate$DefaultMonoSink.success(MonoCreate.java:146)
    at com.aerospike.client.reactor.listeners.ReactorRecordListener.onSuccess(ReactorRecordListener.java:35)
    at com.aerospike.client.async.AsyncReadHeader.onSuccess(AsyncReadHeader.java:89)
    at com.aerospike.client.async.NettyCommand.finish(NettyCommand.java:735)
    at com.aerospike.client.async.NettyCommand.parseSingleBody(NettyCommand.java:519)
    at com.aerospike.client.async.NettyCommand.readSingleHeader(NettyCommand.java:499)
    at com.aerospike.client.async.NettyCommand.read(NettyCommand.java:391)
    at com.aerospike.client.async.NettyCommand.access$200(NettyCommand.java:57)
    at com.aerospike.client.async.NettyCommand$InboundHandler.channelRead(NettyCommand.java:937)
    at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
    at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
    at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
    at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334)
    at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
    at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
    at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926)
    at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:134)
    at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:644)
    at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:579)
    at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:496)
    at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:458)
    at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858)
    at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:138)
    at java.lang.Thread.run(Thread.java:748)

Running com.aerospike.client.reactor.CrudReactorTest
Tests run: 10, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.219 sec - in com.aerospike.client.reactor.CrudReactorTest
Running com.aerospike.client.reactor.OperateReactorFailTest
Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.613 sec - in com.aerospike.client.reactor.OperateReactorFailTest
Running com.aerospike.client.reactor.OperateReactorTest
Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.076 sec - in com.aerospike.client.reactor.OperateReactorTest
Running com.aerospike.client.reactor.QueryReactorFailTest
Tests run: 2, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 0.103 sec <<< FAILURE! - in com.aerospike.client.reactor.QueryReactorFailTest
shouldFailQuery[eventLoopType=NETTY_NIO](com.aerospike.client.reactor.QueryReactorFailTest)  Time elapsed: 0.06 sec  <<< FAILURE!
java.lang.AssertionError: expectation "expectError(Class)" failed (expected error of type: Timeout; actual type: com.aerospike.client.AerospikeException: Error 201,1,1,1,5,BC36F695D290C00 172.16.70.185 3010: Index not found)
    at reactor.test.DefaultStepVerifierBuilder.failPrefix(DefaultStepVerifierBuilder.java:2235)
    at reactor.test.DefaultStepVerifierBuilder.fail(DefaultStepVerifierBuilder.java:2231)
    at reactor.test.DefaultStepVerifierBuilder.lambda$expectError$6(DefaultStepVerifierBuilder.java:279)
    at reactor.test.DefaultStepVerifierBuilder$SignalEvent.test(DefaultStepVerifierBuilder.java:1973)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onSignal(DefaultStepVerifierBuilder.java:1326)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onExpectation(DefaultStepVerifierBuilder.java:1274)
    at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onError(DefaultStepVerifierBuilder.java:941)
    at reactor.core.publisher.FluxCreate$BaseSink.error(FluxCreate.java:423)
    at reactor.core.publisher.FluxCreate$BufferAsyncSink.drain(FluxCreate.java:714)
    at reactor.core.publisher.FluxCreate$BufferAsyncSink.error(FluxCreate.java:665)
    at reactor.core.publisher.FluxCreate$SerializedSink.drainLoop(FluxCreate.java:216)
    at reactor.core.publisher.FluxCreate$SerializedSink.drain(FluxCreate.java:197)
    at reactor.core.publisher.FluxCreate$SerializedSink.error(FluxCreate.java:179)
    at com.aerospike.client.reactor.listeners.ReactorRecordSequenceListener.onFailure(ReactorRecordSequenceListener.java:44)
    at com.aerospike.client.async.AsyncQueryExecutor.onFailure(AsyncQueryExecutor.java:67)
    at com.aerospike.client.async.AsyncMultiExecutor.childFailure(AsyncMultiExecutor.java:166)
    at com.aerospike.client.async.AsyncMultiCommand.onFailure(AsyncMultiCommand.java:189)
    at com.aerospike.client.async.NettyCommand.notifyFailure(NettyCommand.java:876)
    at com.aerospike.client.async.NettyCommand.onApplicationError(NettyCommand.java:862)
    at com.aerospike.client.async.NettyCommand$InboundHandler.exceptionCaught(NettyCommand.java:974)
    at io.netty.channel.AbstractChannelHandlerContext.invokeExceptionCaught(AbstractChannelHandlerContext.java:285)
    at io.netty.channel.AbstractChannelHandlerContext.notifyHandlerException(AbstractChannelHandlerContext.java:850)
    at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:364)
    at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
    at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
    at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334)
    at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
    at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
    at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926)
    at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:134)
    at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:644)
    at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:579)
    at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:496)
    at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:458)
    at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858)
    at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:138)
    at java.lang.Thread.run(Thread.java:748)

Running com.aerospike.client.reactor.QueryReactorTest
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.206 sec - in com.aerospike.client.reactor.QueryReactorTest
Running com.aerospike.client.reactor.ReactorIndexTest
Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 10.581 sec - in com.aerospike.client.reactor.ReactorIndexTest
Running com.aerospike.client.reactor.ReactorInfoTest
Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.028 sec - in com.aerospike.client.reactor.ReactorInfoTest
Running com.aerospike.client.reactor.ScanReactorFailTest
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.278 sec - in com.aerospike.client.reactor.ScanReactorFailTest
Running com.aerospike.client.reactor.ScanReactorTest
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.913 sec - in com.aerospike.client.reactor.ScanReactorTest
Running com.aerospike.client.reactor.UdfReactorFailTest
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.243 sec - in com.aerospike.client.reactor.UdfReactorFailTest
Running com.aerospike.client.reactor.UdfReactorTest
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.038 sec - in com.aerospike.client.reactor.UdfReactorTest

Results :

Failed tests: 
  BatchReactorFailTest.shouldFailOnBatchExistsSequence[eventLoopType=DIRECT_NIO] expectation "expectError(Class)" failed (expected: onError(Timeout); actual: onNext(test:test:batchkey1:71e94f431d840d953dfd3da62d69b9c32e145ae6:(gen:2),(exp:321129333),(bins:(batchbin:batchvalue1))))
  BatchReactorFailTest.shouldFailOnBatchExistsSequence[eventLoopType=NETTY_NIO] expectation "expectError(Class)" failed (expected: onError(Timeout); actual: onNext(test:test:batchkey1:71e94f431d840d953dfd3da62d69b9c32e145ae6:(gen:8),(exp:321129334),(bins:(batchbin:batchvalue1))))
  BatchReactorFailTest.shouldFailOnBatchGetSequence[eventLoopType=DIRECT_NIO] expectation "expectError(Class)" failed (expected: onError(Timeout); actual: onNext(test:test:batchkey1:71e94f431d840d953dfd3da62d69b9c32e145ae6:(gen:1),(exp:321129333),(bins:(batchbin:batchvalue1))))
  BatchReactorFailTest.shouldFailOnBatchGetSequence[eventLoopType=NETTY_NIO] expectation "expectError(Class)" failed (expected: onError(Timeout); actual: onNext(test:test:batchkey1:71e94f431d840d953dfd3da62d69b9c32e145ae6:(gen:7),(exp:321129334),(bins:(batchbin:batchvalue1))))
  CrudReactorFailTest.shouldFailOnGetHeader[eventLoopType=DIRECT_NIO] expectation "expectError(Class)" failed (expected: onError(Timeout); actual: onNext(test:test:putgetkey1:694d1d686a9520d2443243afa899bf970151f50a:(gen:1),(exp:321129335),(bins:null)))
  CrudReactorFailTest.shouldFailOnGetHeader[eventLoopType=NETTY_NIO] expectation "expectError(Class)" failed (expected: onError(Timeout); actual: onNext(test:test:putgetkey1:694d1d686a9520d2443243afa899bf970151f50a:(gen:2),(exp:321129336),(bins:null)))
  CrudReactorFailTest.shouldFailOnGet[eventLoopType=DIRECT_NIO] expectation "expectError(Class)" failed (expected: onError(Timeout); actual: onNext(test:test:putgetkey1:694d1d686a9520d2443243afa899bf970151f50a:))
  CrudReactorFailTest.shouldFailOnGet[eventLoopType=NETTY_NIO] expectation "expectError(Class)" failed (expected: onError(Timeout); actual: onNext(test:test:putgetkey1:694d1d686a9520d2443243afa899bf970151f50a:(gen:1),(exp:321129335),(bins:(putgetbin:value))))
  CrudReactorFailTest.shouldFailOnPut[eventLoopType=DIRECT_NIO] expectation "expectError(Class)" failed (expected: onError(Timeout); actual: onNext(test:test:putgetkey1:694d1d686a9520d2443243afa899bf970151f50a))
  CrudReactorFailTest.shouldFailOnPut[eventLoopType=NETTY_NIO] expectation "expectError(Class)" failed (expected: onError(Timeout); actual: onNext(test:test:putgetkey1:694d1d686a9520d2443243afa899bf970151f50a))
  QueryReactorFailTest.shouldFailQuery[eventLoopType=NETTY_NIO] expectation "expectError(Class)" failed (expected error of type: Timeout; actual type: com.aerospike.client.AerospikeException: Error 201,1,1,1,5,BC36F695D290C00 172.16.70.185 3010: Index not found)

Tests run: 78, Failures: 11, Errors: 0, Skipped: 0

[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time:  24.568 s
[INFO] Finished at: 2020-02-04T10:35:56-08:00
[INFO] ------------------------------------------------------------------------
kptfh commented 4 years ago

Is there a simple way how to setup two nodes cluster? Maybe you have appropriate docker image with two nodes cluster?

BrianNichols commented 4 years ago

Here are some ways to create clusters.

1) Docker: https://hub.docker.com/_/aerospike

Execute 2 docker runs with different names:

docker run -tid --name aerospike1 -p 3000:3000 -p 3001:3001 -p 3002:3002 -p 3003:3003 aerospike/aerospike-server
docker run -tid --name aerospike2 -p 6000:3000 -p 6001:3001 -p 6002:3002 -p 6003:3003 aerospike/aerospike-server

Get IP address of each node:

docker exec -ti aerospike1 asinfo -v service
172.17.0.2:3000
docker exec -ti aerospike2 asinfo -v service
172.17.0.3:3000

Run an asinfo -v tip to form cluster:

docker exec -ti aerospike1 asinfo -v 'tip:host=172.17.0.3;port=3002'

2) Google Cloud: https://console.cloud.google.com/marketplace/details/aerospike-prod/aerospike-ee-4

You will need to have a valid base64 feature key for entry on their webpage. base64 feature key example:

base64 /etc/aerospike/features.conf -w 0
BrianNichols commented 4 years ago

There is an extraneous backquote in the docker command (docker`). The backquote needs to be removed.

Also, the docker instructions have been tested under Linux and MacOS, but not Windows. Can you try under Linux or MacOS?

-Brian

On Mon, Feb 10, 2020 at 2:35 AM Sergii Karpenko notifications@github.com wrote:

got:

C:\Users\skarpenko>docker` exec -ti aerospike1 asinfo -v 'tip:host=172.17.0.4;port=3002' error Error: Invalid command 'port=3002'

while using 1 approach with docker

— You are receiving this because you were mentioned. Reply to this email directly, view it on GitHub https://github.com/aerospike/aerospike-client-java/pull/152?email_source=notifications&email_token=AANOB6Q4OKFXX7OXFLEJIYTRCEUVXA5CNFSM4KDCJSIKYY3PNVWWK3TUL52HS4DFVREXG43VMVBW63LNMVXHJKTDN5WW2ZLOORPWSZGOELIAJVY#issuecomment-584058071, or unsubscribe https://github.com/notifications/unsubscribe-auth/AANOB6SCDUF4RFJXTT2ATSLRCEUVXANCNFSM4KDCJSIA .

-- Brian Nichols

kptfh commented 4 years ago

I managed to successfully run command on Windows when replaced ' with " docker exec -ti aerospike1 asinfo -v "tip:host=172.17.0.3;port=3002" Do you seed client with both hosts?

I have doubts if it's correct way to build cluster. Aerospike nodes see each other in docker network but client is able to communicate with only one node. Tried to seed client with both nodes but client's logic use only the first one as a seed.

I find a bug in my test and fixed it but seems that I can't efficiently test it on two nodes cluster.

volmarl commented 4 years ago

On the Docker 2 nodes question, this blog post may be able to help.

The basic config will only work within containers. Meaning your client application would also have to be running on its own container.

If you want to run a client from host machine to communicate with the container network running on the same machine then you would need to run docker with --net=host option for each container and use different ports for each node in your aerospike.conf. You could also try the method described in the second half of the blog.

BrianNichols commented 4 years ago

Unit tests still fail on 2 node cluster. Follow advice by @volmarl for testing.

Java client was released anyway. Provide unit test fixes in a new pull request. This pull request is closed.