[
https://issues.apache.org/jira/browse/GEODE-4172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317124#comment-16317124
]
ASF GitHub Bot commented on GEODE-4172:
---------------------------------------
jhuynh1 closed pull request #1222: GEODE-4172:
Failure-CqPerfUsingPoolDUnitTest.testMatchingCQsWithMulti…
URL: https://github.com/apache/geode/pull/1222
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign pull request (from a fork), the diff is supplied
below (as it won't show otherwise due to GitHub magic):
diff --git
a/geode-core/src/test/java/org/apache/geode/cache/query/cq/dunit/CqQueryTestListener.java
b/geode-core/src/test/java/org/apache/geode/cache/query/cq/dunit/CqQueryTestListener.java
index d77e677682..66462f2344 100644
---
a/geode-core/src/test/java/org/apache/geode/cache/query/cq/dunit/CqQueryTestListener.java
+++
b/geode-core/src/test/java/org/apache/geode/cache/query/cq/dunit/CqQueryTestListener.java
@@ -392,7 +392,7 @@ public void waitForEvents(final int creates, final int
updates, final int delete
final int totalEvents) {
// Wait for expected events to arrive
try {
- Awaitility.await().atMost(5, TimeUnit.SECONDS).until(() -> {
+ Awaitility.await().atMost(10, TimeUnit.SECONDS).until(() -> {
if ((creates > 0 && creates != this.getCreateEventCount())
|| (updates > 0 && updates != this.getUpdateEventCount())
|| (deletes > 0 && deletes != this.getDeleteEventCount())
diff --git
a/geode-cq/src/test/java/org/apache/geode/cache/query/cq/dunit/CqPerfDUnitTest.java
b/geode-cq/src/test/java/org/apache/geode/cache/query/cq/dunit/CqPerfDUnitTest.java
index e2255f6a7e..923b2f0748 100644
---
a/geode-cq/src/test/java/org/apache/geode/cache/query/cq/dunit/CqPerfDUnitTest.java
+++
b/geode-cq/src/test/java/org/apache/geode/cache/query/cq/dunit/CqPerfDUnitTest.java
@@ -671,11 +671,6 @@ public void testMatchingCQWithMultipleClients() throws
Exception {
cqDUnitTest.closeServer(server);
}
- /**
- * Test for CQ Fail over.
- *
- * @throws Exception
- */
@Test
public void testMatchingCQsWithMultipleServers() throws Exception {
final Host host = Host.getHost(0);
@@ -723,18 +718,12 @@ public void testMatchingCQsWithMultipleServers() throws
Exception {
CqQueryDUnitTest.KEY + i);
}
- Wait.pause(1 * 1000);
-
cqDUnitTest.createServer(server2, ports[0]);
-
final int port2 = server2.invoke(() ->
CqQueryDUnitTest.getCacheServerPort());
System.out
.println("### Port on which server1 running : " + port1 + " Server2
running : " + port2);
- Wait.pause(3 * 1000);
-
-
// UPDATE - 1.
for (int k = 0; k < numCQs; k++) {
cqDUnitTest.clearCQListenerEvents(client1,
"testMatchingCQsWithMultipleServers_" + k);
@@ -761,7 +750,6 @@ public void testMatchingCQsWithMultipleServers() throws
Exception {
int[] resultsCnt = new int[] {10, 1, 2};
-
for (int i = 0; i < numCQs; i++) {
cqDUnitTest.validateCQ(client1, "testMatchingCQsWithMultipleServers_" +
i,
CqQueryDUnitTest.noTest, resultsCnt[i], resultsCnt[i],
CqQueryDUnitTest.noTest);
@@ -770,68 +758,66 @@ public void testMatchingCQsWithMultipleServers() throws
Exception {
CqQueryDUnitTest.noTest, resultsCnt[i], resultsCnt[i],
CqQueryDUnitTest.noTest);
}
- // Close server1.
- cqDUnitTest.closeServer(server1);
-
- // Fail over should happen.
- Wait.pause(5 * 1000);
+ cqDUnitTest.closeClient(client2);
+ cqDUnitTest.closeServer(server2);
+ }
- validateMatchingCqs(server2, numCQs, cqDUnitTest.cqs[0], 1 *
clients.length);
- for (int i = 0; i < numCQs; i++) {
- cqDUnitTest.validateCQ(client1, "testMatchingCQsWithMultipleServers_" +
i,
- CqQueryDUnitTest.noTest, resultsCnt[i], resultsCnt[i],
CqQueryDUnitTest.noTest);
+ @Test
+ public void testFailOverMatchingCQsWithMultipleServers() throws Exception {
+ final Host host = Host.getHost(0);
+ VM server1 = host.getVM(0);
+ VM server2 = host.getVM(1);
+ VM client1 = host.getVM(2);
+ VM client2 = host.getVM(3);
- cqDUnitTest.validateCQ(client2, "testMatchingCQsWithMultipleServers_" +
i,
- CqQueryDUnitTest.noTest, resultsCnt[i], resultsCnt[i],
CqQueryDUnitTest.noTest);
- }
+ cqDUnitTest.createServer(server1);
- // UPDATE - 2
- for (int k = 0; k < numCQs; k++) {
- cqDUnitTest.clearCQListenerEvents(client1,
"testMatchingCQsWithMultipleServers_" + k);
- cqDUnitTest.clearCQListenerEvents(client2,
"testMatchingCQsWithMultipleServers_" + k);
- }
+ VM clients[] = new VM[] {client1, client2};
- cqDUnitTest.createValues(server2, cqDUnitTest.regions[0], 10);
- cqDUnitTest.createValues(server2, cqDUnitTest.regions[1], 10);
+ final int port1 = server1.invoke(() ->
CqQueryDUnitTest.getCacheServerPort());
+ final String host0 = NetworkUtils.getServerHostName(server1.getHost());
+ // Create client.
+ // Create client with redundancyLevel -1
- // Wait for cq1. on region[0]
- for (int i = 1; i <= resultsCnt[0]; i++) {
- cqDUnitTest.waitForUpdated(client1,
"testMatchingCQsWithMultipleServers_0",
- CqQueryDUnitTest.KEY + i);
- cqDUnitTest.waitForUpdated(client2,
"testMatchingCQsWithMultipleServers_0",
- CqQueryDUnitTest.KEY + i);
- }
+ final int[] ports = AvailablePortHelper.getRandomAvailableTCPPorts(1);
- // Wait for cq3. on region[1]
- {
- cqDUnitTest.waitForUpdated(client1,
"testMatchingCQsWithMultipleServers_2",
- CqQueryDUnitTest.KEY + "4");
- cqDUnitTest.waitForUpdated(client2,
"testMatchingCQsWithMultipleServers_2",
- CqQueryDUnitTest.KEY + "4");
- }
+ cqDUnitTest.createClient(client1, new int[] {port1, ports[0]}, host0,
"-1");
+ cqDUnitTest.createClient(client2, new int[] {port1, ports[0]}, host0,
"-1");
+ int numCQs = 3;
for (int i = 0; i < numCQs; i++) {
- cqDUnitTest.validateCQ(client1, "testMatchingCQsWithMultipleServers_" +
i,
- CqQueryDUnitTest.noTest, resultsCnt[i], resultsCnt[i] * 2,
CqQueryDUnitTest.noTest);
+ cqDUnitTest.createCQ(client1, "testMatchingCQsWithMultipleServers_" + i,
cqDUnitTest.cqs[i]);
+ cqDUnitTest.executeCQ(client1, "testMatchingCQsWithMultipleServers_" +
i, false, null);
- cqDUnitTest.validateCQ(client2, "testMatchingCQsWithMultipleServers_" +
i,
- CqQueryDUnitTest.noTest, resultsCnt[i], resultsCnt[i] * 2,
CqQueryDUnitTest.noTest);
+ cqDUnitTest.createCQ(client2, "testMatchingCQsWithMultipleServers_" + i,
cqDUnitTest.cqs[i]);
+ cqDUnitTest.executeCQ(client2, "testMatchingCQsWithMultipleServers_" +
i, false, null);
}
+ validateMatchingCqs(server1, numCQs, cqDUnitTest.cqs[0], 1 *
clients.length);
+ validateMatchingCqs(server1, numCQs, cqDUnitTest.cqs[1], 1 *
clients.length);
+
+
+ cqDUnitTest.createServer(server2, ports[0]);
+
+ // Close server1.
+ cqDUnitTest.closeServer(server1);
+
+ validateMatchingCqs(server2, numCQs, cqDUnitTest.cqs[0], clients.length);
// Close.
cqDUnitTest.closeClient(client1);
- validateMatchingCqs(server2, numCQs, cqDUnitTest.cqs[0], 1 *
(clients.length - 1));
+ validateMatchingCqs(server2, numCQs, cqDUnitTest.cqs[0], (clients.length -
1));
cqDUnitTest.closeClient(client2);
cqDUnitTest.closeServer(server2);
}
+
/**
* Test for CQ Fail over.
*
diff --git
a/geode-cq/src/test/java/org/apache/geode/cache/query/cq/dunit/CqPerfUsingPoolDUnitTest.java
b/geode-cq/src/test/java/org/apache/geode/cache/query/cq/dunit/CqPerfUsingPoolDUnitTest.java
index c05d5314a1..9d9d37df39 100644
---
a/geode-cq/src/test/java/org/apache/geode/cache/query/cq/dunit/CqPerfUsingPoolDUnitTest.java
+++
b/geode-cq/src/test/java/org/apache/geode/cache/query/cq/dunit/CqPerfUsingPoolDUnitTest.java
@@ -21,7 +21,9 @@
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
+import java.util.concurrent.TimeUnit;
+import org.awaitility.Awaitility;
import org.junit.Ignore;
import org.junit.Test;
import org.junit.experimental.categories.Category;
@@ -719,9 +721,6 @@ public void testMatchingCQsWithMultipleServers() throws
Exception {
cqDUnitTest.createPool(client2, poolName2, new String[] {host0, host0},
new int[] {port1, ports[0]});
- // cqDUnitTest.createClient(client1, new int[] {port1, ports[0]}, host0,
"-1");
- // cqDUnitTest.createClient(client2, new int[] {port1, ports[0]}, host0,
"-1");
-
int numCQs = 3;
for (int i = 0; i < numCQs; i++) {
@@ -737,7 +736,6 @@ public void testMatchingCQsWithMultipleServers() throws
Exception {
validateMatchingCqs(server1, numCQs, cqDUnitTest.cqs[0], 1 *
clients.length);
validateMatchingCqs(server1, numCQs, cqDUnitTest.cqs[1], 1 *
clients.length);
- Wait.pause(1 * 1000);
// CREATE.
cqDUnitTest.createValues(server1, cqDUnitTest.regions[0], 10);
@@ -748,8 +746,6 @@ public void testMatchingCQsWithMultipleServers() throws
Exception {
CqQueryUsingPoolDUnitTest.KEY + i);
}
- Wait.pause(1 * 1000);
-
cqDUnitTest.createServer(server2, ports[0]);
@@ -757,8 +753,6 @@ public void testMatchingCQsWithMultipleServers() throws
Exception {
System.out
.println("### Port on which server1 running : " + port1 + " Server2
running : " + port2);
- Wait.pause(3 * 1000);
-
// UPDATE - 1.
for (int k = 0; k < numCQs; k++) {
@@ -797,63 +791,61 @@ public void testMatchingCQsWithMultipleServers() throws
Exception {
// Close server1.
cqDUnitTest.closeServer(server1);
+ // Close.
+ cqDUnitTest.closeClient(client1);
- // Fail over should happen.
- Wait.pause(5 * 1000);
-
- validateMatchingCqs(server2, numCQs, cqDUnitTest.cqs[0], 1 *
clients.length);
-
- for (int i = 0; i < numCQs; i++) {
- cqDUnitTest.validateCQ(client1, "testMatchingCQsWithMultipleServers_" +
i,
- CqQueryUsingPoolDUnitTest.noTest, resultsCnt[i], resultsCnt[i],
- CqQueryUsingPoolDUnitTest.noTest);
+ validateMatchingCqs(server2, numCQs, cqDUnitTest.cqs[0], 1 *
(clients.length - 1));
- cqDUnitTest.validateCQ(client2, "testMatchingCQsWithMultipleServers_" +
i,
- CqQueryUsingPoolDUnitTest.noTest, resultsCnt[i], resultsCnt[i],
- CqQueryUsingPoolDUnitTest.noTest);
- }
+ cqDUnitTest.closeClient(client2);
+ cqDUnitTest.closeServer(server2);
+ }
- // UPDATE - 2
- for (int k = 0; k < numCQs; k++) {
- cqDUnitTest.clearCQListenerEvents(client1,
"testMatchingCQsWithMultipleServers_" + k);
- cqDUnitTest.clearCQListenerEvents(client2,
"testMatchingCQsWithMultipleServers_" + k);
- }
+ @Test
+ public void testFailOverForMatchingCQsWithMultipleServers() throws Exception
{
+ final Host host = Host.getHost(0);
+ VM server1 = host.getVM(0);
+ VM server2 = host.getVM(1);
+ VM client1 = host.getVM(2);
+ VM client2 = host.getVM(3);
+ VM clients[] = new VM[] {client1, client2};
- cqDUnitTest.createValues(server2, cqDUnitTest.regions[0], 10);
- cqDUnitTest.createValues(server2, cqDUnitTest.regions[1], 10);
+ cqDUnitTest.createServer(server1);
+ final String host0 = NetworkUtils.getServerHostName(server1.getHost());
+ final int port1 = server1.invoke(() ->
CqQueryUsingPoolDUnitTest.getCacheServerPort());
+ final int[] ports = AvailablePortHelper.getRandomAvailableTCPPorts(1);
- // Wait for cq1. on region[0]
- for (int i = 1; i <= resultsCnt[0]; i++) {
- cqDUnitTest.waitForUpdated(client1,
"testMatchingCQsWithMultipleServers_0",
- CqQueryUsingPoolDUnitTest.KEY + i);
- cqDUnitTest.waitForUpdated(client2,
"testMatchingCQsWithMultipleServers_0",
- CqQueryUsingPoolDUnitTest.KEY + i);
- }
+ // Create client with redundancyLevel -1
+ String poolName1 = "testClientWithFeederAndCQ1";
+ String poolName2 = "testClientWithFeederAndCQ2";
- // Wait for cq3. on region[1]
- {
- cqDUnitTest.waitForUpdated(client1,
"testMatchingCQsWithMultipleServers_2",
- CqQueryUsingPoolDUnitTest.KEY + "4");
- cqDUnitTest.waitForUpdated(client2,
"testMatchingCQsWithMultipleServers_2",
- CqQueryUsingPoolDUnitTest.KEY + "4");
- }
+ cqDUnitTest.createPool(client1, poolName1, new String[] {host0, host0},
+ new int[] {port1, ports[0]});
+ cqDUnitTest.createPool(client2, poolName2, new String[] {host0, host0},
+ new int[] {port1, ports[0]});
+ int numCQs = 3;
for (int i = 0; i < numCQs; i++) {
- cqDUnitTest.validateCQ(client1, "testMatchingCQsWithMultipleServers_" +
i,
- CqQueryUsingPoolDUnitTest.noTest, resultsCnt[i], resultsCnt[i] * 2,
- CqQueryUsingPoolDUnitTest.noTest);
+ cqDUnitTest.createCQ(client1, poolName1,
"testMatchingCQsWithMultipleServers_" + i,
+ cqDUnitTest.cqs[i]);
+ cqDUnitTest.executeCQ(client1, "testMatchingCQsWithMultipleServers_" +
i, false, null);
- cqDUnitTest.validateCQ(client2, "testMatchingCQsWithMultipleServers_" +
i,
- CqQueryUsingPoolDUnitTest.noTest, resultsCnt[i], resultsCnt[i] * 2,
- CqQueryUsingPoolDUnitTest.noTest);
+ cqDUnitTest.createCQ(client2, poolName2,
"testMatchingCQsWithMultipleServers_" + i,
+ cqDUnitTest.cqs[i]);
+ cqDUnitTest.executeCQ(client2, "testMatchingCQsWithMultipleServers_" +
i, false, null);
}
+ cqDUnitTest.createServer(server2, ports[0]);
- // Close.
+ // Close server1.
+ cqDUnitTest.closeServer(server1);
+
+ // Fail over should happen.
+ validateMatchingCqs(server2, numCQs, cqDUnitTest.cqs[0], clients.length);
cqDUnitTest.closeClient(client1);
+ // server2 cq's should still be in the matching map
validateMatchingCqs(server2, numCQs, cqDUnitTest.cqs[0], 1 *
(clients.length - 1));
cqDUnitTest.closeClient(client2);
@@ -961,15 +953,19 @@ public void run2() throws CacheException {
}
Map matchedCqMap = cqService.getMatchingCqMap();
- assertEquals("The number of matched cq is not as expected.", mapSize,
matchedCqMap.size());
+ Awaitility.await().atMost(10, TimeUnit.SECONDS)
+ .until(() -> assertEquals("The number of matched cq is not as
expected.", mapSize,
+ matchedCqMap.size()));
if (query != null) {
if (!matchedCqMap.containsKey(query)) {
fail("Query not found in the matched cq map. Query:" + query);
}
Collection cqs = (Collection) matchedCqMap.get(query);
- assertEquals("Number of matched cqs are not equal to the expected
matched cqs", numCqSize,
- cqs.size());
+ Awaitility.await().atMost(5, TimeUnit.SECONDS)
+ .until(() -> assertEquals(
+ "Number of matched cqs are not equal to the expected matched
cqs", numCqSize,
+ cqs.size()));
}
}
});
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
> GEODE-4172 : [CI failure]
> org.apache.geode.cache.query.cq.dunit.CqPerfUsingPoolDUnitTest -
> testMatchingCQsWithMultipleServers
> -----------------------------------------------------------------------------------------------------------------------------
>
> Key: GEODE-4172
> URL: https://issues.apache.org/jira/browse/GEODE-4172
> Project: Geode
> Issue Type: Bug
> Components: cq
> Reporter: nabarun
>
> Stacktrace
> {noformat}
> org.apache.geode.test.dunit.RMIException: While invoking
> org.apache.geode.cache.query.cq.dunit.CqPerfUsingPoolDUnitTest$10.run in VM 1
> running on Host 3580a85a1bde with 4 VMs
> at org.apache.geode.test.dunit.VM.invoke(VM.java:393)
> at org.apache.geode.test.dunit.VM.invoke(VM.java:363)
> at org.apache.geode.test.dunit.VM.invoke(VM.java:308)
> at
> org.apache.geode.cache.query.cq.dunit.CqPerfUsingPoolDUnitTest.validateMatchingCqs(CqPerfUsingPoolDUnitTest.java:952)
> at
> org.apache.geode.cache.query.cq.dunit.CqPerfUsingPoolDUnitTest.testMatchingCQsWithMultipleServers(CqPerfUsingPoolDUnitTest.java:804)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:498)
> at
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
> at
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> at
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
> at
> org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> at
> org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
> at
> org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
> at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
> at org.junit.rules.RunRules.evaluate(RunRules.java:20)
> at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
> at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
> at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
> at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
> at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
> at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
> at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
> at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
> at
> org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
> at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
> at
> org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:114)
> at
> org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:57)
> at
> org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:66)
> at
> org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:51)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:498)
> at
> org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
> at
> org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
> at
> org.gradle.internal.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
> at
> org.gradle.internal.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
> at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
> at
> org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:109)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:498)
> at
> org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
> at
> org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
> at
> org.gradle.internal.remote.internal.hub.MessageHubBackedObjectConnection$DispatchWrapper.dispatch(MessageHubBackedObjectConnection.java:147)
> at
> org.gradle.internal.remote.internal.hub.MessageHubBackedObjectConnection$DispatchWrapper.dispatch(MessageHubBackedObjectConnection.java:129)
> at
> org.gradle.internal.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:404)
> at
> org.gradle.internal.concurrent.ExecutorPolicy$CatchAndRecordFailures.onExecute(ExecutorPolicy.java:63)
> at
> org.gradle.internal.concurrent.StoppableExecutorImpl$1.run(StoppableExecutorImpl.java:46)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> at java.lang.Thread.run(Thread.java:748)
> Caused by: java.lang.AssertionError: Number of matched cqs are not equal to
> the expected matched cqs expected:<2> but was:<1>
> at org.junit.Assert.fail(Assert.java:88)
> at org.junit.Assert.failNotEquals(Assert.java:834)
> at org.junit.Assert.assertEquals(Assert.java:645)
> at
> org.apache.geode.cache.query.cq.dunit.CqPerfUsingPoolDUnitTest$10.run2(CqPerfUsingPoolDUnitTest.java:971)
> at
> org.apache.geode.cache30.CacheSerializableRunnable.run(CacheSerializableRunnable.java:55)
> at sun.reflect.GeneratedMethodAccessor6.invoke(Unknown Source)
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:498)
> at hydra.MethExecutor.executeObject(MethExecutor.java:244)
> at
> org.apache.geode.test.dunit.standalone.RemoteDUnitVM.executeMethodOnObject(RemoteDUnitVM.java:70)
> at sun.reflect.GeneratedMethodAccessor5.invoke(Unknown Source)
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:498)
> at sun.rmi.server.UnicastServerRef.dispatch(UnicastServerRef.java:357)
> at sun.rmi.transport.Transport$1.run(Transport.java:200)
> at sun.rmi.transport.Transport$1.run(Transport.java:197)
> at java.security.AccessController.doPrivileged(Native Method)
> at sun.rmi.transport.Transport.serviceCall(Transport.java:196)
> at
> sun.rmi.transport.tcp.TCPTransport.handleMessages(TCPTransport.java:568)
> at
> sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run0(TCPTransport.java:826)
> at
> sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.lambda$run$0(TCPTransport.java:683)
> at java.security.AccessController.doPrivileged(Native Method)
> at
> sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run(TCPTransport.java:682)
> ... 3 more
> {noformat}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
