[
https://issues.apache.org/jira/browse/GEODE-7270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16943267#comment-16943267
]
Barrett Oglesby commented on GEODE-7270:
----------------------------------------
The test is not waiting long enough for the locator exchange.
It starts 3 locators in 3 different distributed systems, then verifies each
site knows about the other.
It does this by comparing its known locators to the exchanged ones.
It gets the exchanged locator info like:
{noformat}
Map<Integer, Set<DistributionLocatorId>> allSiteMetaData = ((InternalLocator)
locator).getLocatorMembershipListener().getAllLocatorsInfo();
{noformat}
Then it iterates the known locators does and attempts to stream them:
{noformat}
for (Map.Entry<Integer, Set<InetSocketAddress>> entry :
dsIdToLocatorAddresses.entrySet()) {
Set<DistributionLocatorId> foundLocatorIds =
allSiteMetaData.get(entry.getKey());
final Set<InetSocketAddress> foundLocators = foundLocatorIds.stream()
{noformat}
If the allSiteMetaData doesn't contain the entry for the key yet, it fails with
an NPE.
Here is the output from the test:
Locators vm0 and vm1 start and vm1 exchanges locator information with vm0:
{noformat}
[vm0] [info 2019/10/02 17:10:58.909 GMT <RMI TCP Connection(2)-172.17.0.25>
tid=0x20] Listening on port 22506 bound on address localhost/127.0.0.1
[vm1] [info 2019/10/02 17:10:59.046 GMT <RMI TCP Connection(2)-172.17.0.25>
tid=0x20] Listening on port 27503 bound on address localhost/127.0.0.1
[vm1] [info 2019/10/02 17:10:59.201 GMT <WAN Locator Discovery Thread1>
tid=0x102] Locator discovery task exchanged locator information
localhost[27503] with localhost[22506]: {1=[localhost[22506]],
2=[localhost[27503]]}.
{noformat}
Locator vm2 starts, but before it exchanges locator information with vm0 and
vm1, vm0 throws the NPE:
{noformat}
[vm2] [info 2019/10/02 17:10:59.231 GMT <RMI TCP Connection(2)-172.17.0.25>
tid=0x20] Listening on port 21253 bound on address localhost/127.0.0.1
[vm0] [info 2019/10/02 17:10:59.423 GMT <RMI TCP Connection(2)-172.17.0.25>
tid=0x20] Got result: EXCEPTION_OCCURRED
[vm0] java.lang.NullPointerException
[vm0] at
org.apache.geode.internal.cache.wan.WANTestBase.lambda$checkAllSiteMetaData$21(WANTestBase.java:3027)
[vm0] at
org.awaitility.core.AssertionCondition$1.eval(AssertionCondition.java:55)
[vm0] at
org.awaitility.core.ConditionAwaiter$ConditionPoller.call(ConditionAwaiter.java:192)
[vm0] at
org.awaitility.core.ConditionAwaiter$ConditionPoller.call(ConditionAwaiter.java:179)
[vm0] at java.util.concurrent.FutureTask.run(FutureTask.java:266)
[vm0] at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
[vm0] at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
[vm0] at java.lang.Thread.run(Thread.java:748)
{noformat}
Then vm2 exchanges locator information with vm0 and vm1:
{noformat}
[vm2] [info 2019/10/02 17:10:59.452 GMT <WAN Locator Discovery Thread1>
tid=0x14e] Locator discovery task exchanged locator information
localhost[21253] with localhost[27503]: {1=[localhost[22506]],
2=[localhost[27503]], 3=[localhost[21253]]}.
{noformat}
The output should look like below. I added the logging for
WANTestBase.checkAllSiteMetaData. In this test, both vm1 and vm2 exchanged
locator information before checkAllSiteMetaData was invoked.
{noformat}
[vm0] [info 2019/10/02 17:30:45.590 PDT <RMI TCP Connection(1)-127.0.0.1>
tid=0x12] Listening on port 22500 bound on address localhost/127.0.0.1
[vm1] [info 2019/10/02 17:30:46.602 PDT <RMI TCP Connection(1)-127.0.0.1>
tid=0x12] Listening on port 27499 bound on address localhost/127.0.0.1
[vm1] [info 2019/10/02 17:30:47.020 PDT <WAN Locator Discovery Thread1>
tid=0x2d] Locator discovery task exchanged locator information localhost[27499]
with localhost[22500]: {1=[localhost[22500]], 2=[localhost[27499]]}.
[vm2] [info 2019/10/02 17:30:47.654 PDT <RMI TCP Connection(1)-127.0.0.1>
tid=0x12] Listening on port 21250 bound on address localhost/127.0.0.1
[vm2] [info 2019/10/02 17:30:48.043 PDT <WAN Locator Discovery Thread1>
tid=0x2d] Locator discovery task exchanged locator information localhost[21250]
with localhost[27499]: {1=[localhost[22500]], 2=[localhost[27499]],
3=[localhost[21250]]}.
[vm0] [info 2019/10/02 17:30:48.171 PDT <awaitility-thread> tid=0x31]
WANTestBase.checkAllSiteMetaData allSiteMetaData={1=[localhost[22500]],
2=[localhost[27499]], 3=[localhost[21250]]}
[vm1] [info 2019/10/02 17:30:48.296 PDT <awaitility-thread> tid=0x32]
WANTestBase.checkAllSiteMetaData allSiteMetaData={1=[localhost[22500]],
2=[localhost[27499]], 3=[localhost[21250]]}
[vm2] [info 2019/10/02 17:30:48.422 PDT <awaitility-thread> tid=0x32]
WANTestBase.checkAllSiteMetaData allSiteMetaData={1=[localhost[22500]],
2=[localhost[27499]], 3=[localhost[21250]]}
{noformat}
> WanAutoDiscoveryDUnitTest. test_TK_Recognises_LN_AND_NY
> -------------------------------------------------------
>
> Key: GEODE-7270
> URL: https://issues.apache.org/jira/browse/GEODE-7270
> Project: Geode
> Issue Type: Bug
> Components: tests
> Reporter: Mark Hanson
> Priority: Major
>
> WanAutoDiscoveryDUnitTest. test_TK_Recognises_LN_AND_NY failed with a Null
> Pointer Exception.
> [https://concourse.apachegeode-ci.info/teams/main/pipelines/apache-develop-main/jobs/DistributedTestOpenJDK8/builds/1138]
> =-=-=-=-=-=-=-=-=-=-=-=-=-=-= Test Results URI
> =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
> http://files.apachegeode-ci.info/builds/apache-develop-main/1.11.0-SNAPSHOT.0174/test-results/distributedTest/1570043011/
> =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
> Test report artifacts from this job are available at:
> [http://files.apachegeode-ci.info/builds/apache-develop-main/1.11.0-SNAPSHOT.0174/test-artifacts/1570043011/distributedtestfiles-OpenJDK8-1.11.0-SNAPSHOT.0174.tgz]
>
> {noformat}
> org.apache.geode.test.dunit.RMIException: While invoking
> org.apache.geode.internal.cache.wan.misc.WanAutoDiscoveryDUnitTest$$Lambda$172/1647741944.run
> in VM 0 running on Host 1cafba0ee536 with 8 VMs
> at org.apache.geode.test.dunit.VM.executeMethodOnObject(VM.java:579)
> at org.apache.geode.test.dunit.VM.invoke(VM.java:406)
> at
> org.apache.geode.internal.cache.wan.misc.WanAutoDiscoveryDUnitTest.test_TK_Recognises_LN_AND_NY(WanAutoDiscoveryDUnitTest.java:228)
> 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.JUnitTestClassExecutor.runTestClass(JUnitTestClassExecutor.java:110)
> at
> org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:58)
> at
> org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:38)
> at
> org.gradle.api.internal.tasks.testing.junit.AbstractJUnitTestClassProcessor.processTestClass(AbstractJUnitTestClassProcessor.java:62)
> 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:118)
> 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:175)
> at
> org.gradle.internal.remote.internal.hub.MessageHubBackedObjectConnection$DispatchWrapper.dispatch(MessageHubBackedObjectConnection.java:157)
> 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.ManagedExecutorImpl$1.run(ManagedExecutorImpl.java:46)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> at
> org.gradle.internal.concurrent.ThreadFactoryImpl$ManagedThreadRunnable.run(ThreadFactoryImpl.java:55)
> at java.lang.Thread.run(Thread.java:748)
> Caused by: java.lang.NullPointerException
> at
> org.apache.geode.internal.cache.wan.WANTestBase.lambda$checkAllSiteMetaData$21(WANTestBase.java:3027)
> at
> org.awaitility.core.AssertionCondition$1.eval(AssertionCondition.java:55)
> at
> org.awaitility.core.ConditionAwaiter$ConditionPoller.call(ConditionAwaiter.java:192)
> at
> org.awaitility.core.ConditionAwaiter$ConditionPoller.call(ConditionAwaiter.java:179)
> at java.util.concurrent.FutureTask.run(FutureTask.java:266)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> ... 1 more {noformat}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
