You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@geode.apache.org by Jakov Varenina <ja...@est.tech> on 2020/07/06 13:50:32 UTC
Non-persistent parallel gateway sender on non-persistent region
(collocated with persistent region)
Hi all,
We are trying to setup non-persistent parallel gateway sender (‘sender’)
on a non-persistent partitioned region (‘part_a’). This works OK.
But when this same region ‘part_a’ is colocated with another persistent
region (‘_part_hidden’), Geode throws an exception:
Exception in thread "main"
org.apache.geode.internal.cache.wan.GatewaySenderException: Non
persistent gateway sender sender can not be attached to persistent
region /_part_hidden
at
org.apache.geode.internal.cache.wan.parallel.ParallelGatewaySenderQueue.addShadowPartitionedRegionForUserPR(ParallelGatewaySenderQueue.java:461)
at
org.apache.geode.internal.cache.wan.parallel.ParallelGatewaySenderQueue.addShadowPartitionedRegionForUserPR(ParallelGatewaySenderQueue.java:451)
at
org.apache.geode.internal.cache.wan.parallel.ParallelGatewaySenderEventProcessor.addShadowPartitionedRegionForUserPR(ParallelGatewaySenderEventProcessor.java:191)
at
org.apache.geode.internal.cache.wan.parallel.ConcurrentParallelGatewaySenderQueue.addShadowPartitionedRegionForUserPR(ConcurrentParallelGatewaySenderQueue.java:177)
at
org.apache.geode.internal.cache.PartitionedRegion.postCreateRegion(PartitionedRegion.java:1174)
at
org.apache.geode.internal.cache.GemFireCacheImpl.createVMRegion(GemFireCacheImpl.java:3010)
at
org.apache.geode.internal.cache.GemFireCacheImpl.basicCreateRegion(GemFireCacheImpl.java:2869)
at
org.apache.geode.internal.cache.xmlcache.RegionCreation.createRoot(RegionCreation.java:237)
at
org.apache.geode.internal.cache.xmlcache.CacheCreation.initializeRegions(CacheCreation.java:658)
at
org.apache.geode.internal.cache.xmlcache.CacheCreation.create(CacheCreation.java:592)
at
org.apache.geode.internal.cache.xmlcache.CacheXmlParser.create(CacheXmlParser.java:338)
at
org.apache.geode.internal.cache.GemFireCacheImpl.loadCacheXml(GemFireCacheImpl.java:4081)
at
org.apache.geode.internal.cache.GemFireCacheImpl.initializeDeclarativeCache(GemFireCacheImpl.java:1535)
at
org.apache.geode.internal.cache.GemFireCacheImpl.initialize(GemFireCacheImpl.java:1374)
at
org.apache.geode.internal.cache.InternalCacheBuilder.create(InternalCacheBuilder.java:191)
at
org.apache.geode.internal.cache.InternalCacheBuilder.create(InternalCacheBuilder.java:158)
at
org.apache.geode.cache.CacheFactory.create(CacheFactory.java:142)
at
org.apache.geode.distributed.internal.DefaultServerLauncherCacheProvider.createCache(DefaultServerLauncherCacheProvider.java:52)
at
org.apache.geode.distributed.ServerLauncher.createCache(ServerLauncher.java:894)
at
org.apache.geode.distributed.ServerLauncher.start(ServerLauncher.java:809)
at
org.apache.geode.distributed.ServerLauncher.run(ServerLauncher.java:739)
at
org.apache.geode.distributed.ServerLauncher.main(ServerLauncher.java:256)
This is cache.xml used:
<?xml version="1.0" encoding="UTF-8"?><cache
xmlns="http://geode.apache.org/schema/cache"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://geode.apache.org/schema/cache
http://geode.apache.org/schema/cache/cache-1.0.xsd"
version="1.0"
copy-on-read="true">
<!-- Topology information fragment -->
<gateway-sender id="sender"
parallel="true"
enable-persistence="false"
remote-distributed-system-id="4"/>
<gateway-sender id="sender_persistent"
parallel="true"
enable-persistence="true"
remote-distributed-system-id="4"/>
<pdx read-serialized="true" persistent="true" />
<region name="_part_hidden" refid="PARTITION_REDUNDANT_PERSISTENT">
<region-attributes>
<partition-attributes redundant-copies="1">
<partition-resolver>
<class-name>org.apache.geode.cache.util.StringPrefixPartitionResolver
</class-name>
</partition-resolver>
</partition-attributes>
</region-attributes>
</region>
<region name="part_a" refid="PARTITION_REDUNDANT">
<region-attributes gateway-sender-ids="sender" >
<partition-attributes colocated-with="_part_hidden"
redundant-copies="1">
<partition-resolver>
<class-name>org.apache.geode.cache.util.StringPrefixPartitionResolver
</class-name>
</partition-resolver>
</partition-attributes>
</region-attributes>
</region>
<region name="part_b" refid="PARTITION_REDUNDANT_PERSISTENT">
<region-attributes gateway-sender-ids="sender_persistent">
<partition-attributes colocated-with="_part_hidden"
redundant-copies="1">
<partition-resolver>
<class-name>org.apache.geode.cache.util.StringPrefixPartitionResolver
</class-name>
</partition-resolver>
</partition-attributes>
</region-attributes>
</region>
</cache>
There is nothing explicitly said about this in documentation, and It is
not clear why this is not allowed.
Non-persistent parallel gateway sender is attached only to
non-persistent region ‘part_a’ (and not to persistent region
‘_part_hidden’) .
Why is this not allowed by Geode? Is there any way around this issue?
Geode version: 1.12, 1.11
BRs,
Jakov
Re: Non-persistent parallel gateway sender on non-persistent region
(collocated with persistent region)
Posted by Jakov Varenina <ja...@est.tech>.
Hi Barrett,
We have suspected that this could be bug, and it is great that you
confirmed it and this quickly created a fix.
Thank you very much for your effort!
BRs,
Jakov
On 16. 07. 2020. 21:39, Barrett Oglesby wrote:
> I think you've found a bug in this scenario. The ParallelGatewaySenderQueue.addShadowPartitionedRegionForUserPR method currently compares the data policy of the input region's leader region with the sender's persistence policy. It assumes the input region and the leader region have the same data policy. In this scenario, that is not the case. The input region is 'part_a' which is not persistent, and the leader region is '_part_hidden' which is persistent. The sender is 'sender' which is not persistent. So, instead of comparing the data policy of 'part_a' to the sender which would succeed since they are both not persistent, it compares the data policy of '_part_hidden' to the sender which fails since one is persistent and one is not.
>
> I made a small change to ParallelGatewaySenderQueue.addShadowPartitionedRegionForUserPR to address the issue. I'll file a JIRA and run CI on it to see if it is a valid change. I'll also add a test for this scenario.
>
> ________________________________
> From: Jakov Varenina <ja...@est.tech>
> Sent: Friday, July 10, 2020 3:34 AM
> To: dev@geode.apache.org <de...@geode.apache.org>
> Subject: Re: Non-persistent parallel gateway sender on non-persistent region (collocated with persistent region)
>
> Hi devs,
>
> just a kind reminder. We would be really grateful if you could take look
> at question in below mail.
>
> BRs,
>
> Jakov
>
> On 06. 07. 2020. 15:50, Jakov Varenina wrote:
>> Hi all,
>>
>>
>> We are trying to setup non-persistent parallel gateway sender
>> (‘sender’) on a non-persistent partitioned region (‘part_a’). This
>> works OK.
>> But when this same region ‘part_a’ is colocated with another
>> persistent region (‘_part_hidden’), Geode throws an exception:
>>
>> Exception in thread "main"
>> org.apache.geode.internal.cache.wan.GatewaySenderException: Non
>> persistent gateway sender sender can not be attached to persistent
>> region /_part_hidden
>> at
>> org.apache.geode.internal.cache.wan.parallel.ParallelGatewaySenderQueue.addShadowPartitionedRegionForUserPR(ParallelGatewaySenderQueue.java:461)
>> at
>> org.apache.geode.internal.cache.wan.parallel.ParallelGatewaySenderQueue.addShadowPartitionedRegionForUserPR(ParallelGatewaySenderQueue.java:451)
>> at
>> org.apache.geode.internal.cache.wan.parallel.ParallelGatewaySenderEventProcessor.addShadowPartitionedRegionForUserPR(ParallelGatewaySenderEventProcessor.java:191)
>> at
>> org.apache.geode.internal.cache.wan.parallel.ConcurrentParallelGatewaySenderQueue.addShadowPartitionedRegionForUserPR(ConcurrentParallelGatewaySenderQueue.java:177)
>> at
>> org.apache.geode.internal.cache.PartitionedRegion.postCreateRegion(PartitionedRegion.java:1174)
>> at
>> org.apache.geode.internal.cache.GemFireCacheImpl.createVMRegion(GemFireCacheImpl.java:3010)
>> at
>> org.apache.geode.internal.cache.GemFireCacheImpl.basicCreateRegion(GemFireCacheImpl.java:2869)
>> at
>> org.apache.geode.internal.cache.xmlcache.RegionCreation.createRoot(RegionCreation.java:237)
>> at
>> org.apache.geode.internal.cache.xmlcache.CacheCreation.initializeRegions(CacheCreation.java:658)
>> at
>> org.apache.geode.internal.cache.xmlcache.CacheCreation.create(CacheCreation.java:592)
>> at
>> org.apache.geode.internal.cache.xmlcache.CacheXmlParser.create(CacheXmlParser.java:338)
>> at
>> org.apache.geode.internal.cache.GemFireCacheImpl.loadCacheXml(GemFireCacheImpl.java:4081)
>> at
>> org.apache.geode.internal.cache.GemFireCacheImpl.initializeDeclarativeCache(GemFireCacheImpl.java:1535)
>> at
>> org.apache.geode.internal.cache.GemFireCacheImpl.initialize(GemFireCacheImpl.java:1374)
>> at
>> org.apache.geode.internal.cache.InternalCacheBuilder.create(InternalCacheBuilder.java:191)
>> at
>> org.apache.geode.internal.cache.InternalCacheBuilder.create(InternalCacheBuilder.java:158)
>> at
>> org.apache.geode.cache.CacheFactory.create(CacheFactory.java:142)
>> at
>> org.apache.geode.distributed.internal.DefaultServerLauncherCacheProvider.createCache(DefaultServerLauncherCacheProvider.java:52)
>> at
>> org.apache.geode.distributed.ServerLauncher.createCache(ServerLauncher.java:894)
>> at
>> org.apache.geode.distributed.ServerLauncher.start(ServerLauncher.java:809)
>> at
>> org.apache.geode.distributed.ServerLauncher.run(ServerLauncher.java:739)
>> at
>> org.apache.geode.distributed.ServerLauncher.main(ServerLauncher.java:256)
>>
>>
>> This is cache.xml used:
>>
>> <?xml version="1.0" encoding="UTF-8"?><cache
>> xmlns="https://nam04.safelinks.protection.outlook.com/?url=http%3A%2F%2Fgeode.apache.org%2Fschema%2Fcache&data=02%7C01%7Cboglesby%40vmware.com%7C6b93b4396d44490cb36c08d824bce120%7Cb39138ca3cee4b4aa4d6cd83d9dd62f0%7C0%7C0%7C637299740942592531&sdata=sJIqN%2BcbftenSAKI3SDiZSgQiuLrq98UrdZbASDo3gY%3D&reserved=0"
>> xmlns:xsi="https://nam04.safelinks.protection.outlook.com/?url=http%3A%2F%2Fwww.w3.org%2F2001%2FXMLSchema-instance&data=02%7C01%7Cboglesby%40vmware.com%7C6b93b4396d44490cb36c08d824bce120%7Cb39138ca3cee4b4aa4d6cd83d9dd62f0%7C0%7C0%7C637299740942602529&sdata=zJMmMidL%2FfvXEXo0DQyiX%2BYRtsXYXtqUWpZExFU5qlM%3D&reserved=0"
>> xsi:schemaLocation="https://nam04.safelinks.protection.outlook.com/?url=http%3A%2F%2Fgeode.apache.org%2Fschema%2Fcache&data=02%7C01%7Cboglesby%40vmware.com%7C6b93b4396d44490cb36c08d824bce120%7Cb39138ca3cee4b4aa4d6cd83d9dd62f0%7C0%7C0%7C637299740942602529&sdata=zcekjpOQd75tJCds0Qv4JbQbU7aWUFT%2FpiGKQu3yfGY%3D&reserved=0
>> https://nam04.safelinks.protection.outlook.com/?url=http%3A%2F%2Fgeode.apache.org%2Fschema%2Fcache%2Fcache-1.0.xsd&data=02%7C01%7Cboglesby%40vmware.com%7C6b93b4396d44490cb36c08d824bce120%7Cb39138ca3cee4b4aa4d6cd83d9dd62f0%7C0%7C0%7C637299740942602529&sdata=1nKYVuz5R5%2BpWXMT0JJ%2FIcQLdB66kKju7T4DeVkn2qc%3D&reserved=0"
>> version="1.0"
>> copy-on-read="true">
>> <!-- Topology information fragment -->
>> <gateway-sender id="sender"
>> parallel="true"
>> enable-persistence="false"
>> remote-distributed-system-id="4"/>
>> <gateway-sender id="sender_persistent"
>> parallel="true"
>> enable-persistence="true"
>> remote-distributed-system-id="4"/>
>> <pdx read-serialized="true" persistent="true" />
>> <region name="_part_hidden" refid="PARTITION_REDUNDANT_PERSISTENT">
>> <region-attributes>
>> <partition-attributes redundant-copies="1">
>> <partition-resolver>
>> <class-name>org.apache.geode.cache.util.StringPrefixPartitionResolver
>> </class-name>
>> </partition-resolver>
>> </partition-attributes>
>> </region-attributes>
>> </region>
>> <region name="part_a" refid="PARTITION_REDUNDANT">
>> <region-attributes gateway-sender-ids="sender" >
>> <partition-attributes colocated-with="_part_hidden"
>> redundant-copies="1">
>> <partition-resolver>
>> <class-name>org.apache.geode.cache.util.StringPrefixPartitionResolver
>> </class-name>
>> </partition-resolver>
>> </partition-attributes>
>> </region-attributes>
>> </region>
>> <region name="part_b" refid="PARTITION_REDUNDANT_PERSISTENT">
>> <region-attributes gateway-sender-ids="sender_persistent">
>> <partition-attributes colocated-with="_part_hidden"
>> redundant-copies="1">
>> <partition-resolver>
>> <class-name>org.apache.geode.cache.util.StringPrefixPartitionResolver
>> </class-name>
>> </partition-resolver>
>> </partition-attributes>
>> </region-attributes>
>> </region>
>> </cache>
>>
>>
>> There is nothing explicitly said about this in documentation, and It
>> is not clear why this is not allowed.
>> Non-persistent parallel gateway sender is attached only to
>> non-persistent region ‘part_a’ (and not to persistent region
>> ‘_part_hidden’) .
>>
>> Why is this not allowed by Geode? Is there any way around this issue?
>>
>> Geode version: 1.12, 1.11
>>
>> BRs,
>>
>> Jakov
>>
Re: Non-persistent parallel gateway sender on non-persistent region
(collocated with persistent region)
Posted by Barrett Oglesby <bo...@vmware.com>.
I think you've found a bug in this scenario. The ParallelGatewaySenderQueue.addShadowPartitionedRegionForUserPR method currently compares the data policy of the input region's leader region with the sender's persistence policy. It assumes the input region and the leader region have the same data policy. In this scenario, that is not the case. The input region is 'part_a' which is not persistent, and the leader region is '_part_hidden' which is persistent. The sender is 'sender' which is not persistent. So, instead of comparing the data policy of 'part_a' to the sender which would succeed since they are both not persistent, it compares the data policy of '_part_hidden' to the sender which fails since one is persistent and one is not.
I made a small change to ParallelGatewaySenderQueue.addShadowPartitionedRegionForUserPR to address the issue. I'll file a JIRA and run CI on it to see if it is a valid change. I'll also add a test for this scenario.
________________________________
From: Jakov Varenina <ja...@est.tech>
Sent: Friday, July 10, 2020 3:34 AM
To: dev@geode.apache.org <de...@geode.apache.org>
Subject: Re: Non-persistent parallel gateway sender on non-persistent region (collocated with persistent region)
Hi devs,
just a kind reminder. We would be really grateful if you could take look
at question in below mail.
BRs,
Jakov
On 06. 07. 2020. 15:50, Jakov Varenina wrote:
> Hi all,
>
>
> We are trying to setup non-persistent parallel gateway sender
> (‘sender’) on a non-persistent partitioned region (‘part_a’). This
> works OK.
> But when this same region ‘part_a’ is colocated with another
> persistent region (‘_part_hidden’), Geode throws an exception:
>
> Exception in thread "main"
> org.apache.geode.internal.cache.wan.GatewaySenderException: Non
> persistent gateway sender sender can not be attached to persistent
> region /_part_hidden
> at
> org.apache.geode.internal.cache.wan.parallel.ParallelGatewaySenderQueue.addShadowPartitionedRegionForUserPR(ParallelGatewaySenderQueue.java:461)
> at
> org.apache.geode.internal.cache.wan.parallel.ParallelGatewaySenderQueue.addShadowPartitionedRegionForUserPR(ParallelGatewaySenderQueue.java:451)
> at
> org.apache.geode.internal.cache.wan.parallel.ParallelGatewaySenderEventProcessor.addShadowPartitionedRegionForUserPR(ParallelGatewaySenderEventProcessor.java:191)
> at
> org.apache.geode.internal.cache.wan.parallel.ConcurrentParallelGatewaySenderQueue.addShadowPartitionedRegionForUserPR(ConcurrentParallelGatewaySenderQueue.java:177)
> at
> org.apache.geode.internal.cache.PartitionedRegion.postCreateRegion(PartitionedRegion.java:1174)
> at
> org.apache.geode.internal.cache.GemFireCacheImpl.createVMRegion(GemFireCacheImpl.java:3010)
> at
> org.apache.geode.internal.cache.GemFireCacheImpl.basicCreateRegion(GemFireCacheImpl.java:2869)
> at
> org.apache.geode.internal.cache.xmlcache.RegionCreation.createRoot(RegionCreation.java:237)
> at
> org.apache.geode.internal.cache.xmlcache.CacheCreation.initializeRegions(CacheCreation.java:658)
> at
> org.apache.geode.internal.cache.xmlcache.CacheCreation.create(CacheCreation.java:592)
> at
> org.apache.geode.internal.cache.xmlcache.CacheXmlParser.create(CacheXmlParser.java:338)
> at
> org.apache.geode.internal.cache.GemFireCacheImpl.loadCacheXml(GemFireCacheImpl.java:4081)
> at
> org.apache.geode.internal.cache.GemFireCacheImpl.initializeDeclarativeCache(GemFireCacheImpl.java:1535)
> at
> org.apache.geode.internal.cache.GemFireCacheImpl.initialize(GemFireCacheImpl.java:1374)
> at
> org.apache.geode.internal.cache.InternalCacheBuilder.create(InternalCacheBuilder.java:191)
> at
> org.apache.geode.internal.cache.InternalCacheBuilder.create(InternalCacheBuilder.java:158)
> at
> org.apache.geode.cache.CacheFactory.create(CacheFactory.java:142)
> at
> org.apache.geode.distributed.internal.DefaultServerLauncherCacheProvider.createCache(DefaultServerLauncherCacheProvider.java:52)
> at
> org.apache.geode.distributed.ServerLauncher.createCache(ServerLauncher.java:894)
> at
> org.apache.geode.distributed.ServerLauncher.start(ServerLauncher.java:809)
> at
> org.apache.geode.distributed.ServerLauncher.run(ServerLauncher.java:739)
> at
> org.apache.geode.distributed.ServerLauncher.main(ServerLauncher.java:256)
>
>
> This is cache.xml used:
>
> <?xml version="1.0" encoding="UTF-8"?><cache
> xmlns="https://nam04.safelinks.protection.outlook.com/?url=http%3A%2F%2Fgeode.apache.org%2Fschema%2Fcache&data=02%7C01%7Cboglesby%40vmware.com%7C6b93b4396d44490cb36c08d824bce120%7Cb39138ca3cee4b4aa4d6cd83d9dd62f0%7C0%7C0%7C637299740942592531&sdata=sJIqN%2BcbftenSAKI3SDiZSgQiuLrq98UrdZbASDo3gY%3D&reserved=0"
> xmlns:xsi="https://nam04.safelinks.protection.outlook.com/?url=http%3A%2F%2Fwww.w3.org%2F2001%2FXMLSchema-instance&data=02%7C01%7Cboglesby%40vmware.com%7C6b93b4396d44490cb36c08d824bce120%7Cb39138ca3cee4b4aa4d6cd83d9dd62f0%7C0%7C0%7C637299740942602529&sdata=zJMmMidL%2FfvXEXo0DQyiX%2BYRtsXYXtqUWpZExFU5qlM%3D&reserved=0"
> xsi:schemaLocation="https://nam04.safelinks.protection.outlook.com/?url=http%3A%2F%2Fgeode.apache.org%2Fschema%2Fcache&data=02%7C01%7Cboglesby%40vmware.com%7C6b93b4396d44490cb36c08d824bce120%7Cb39138ca3cee4b4aa4d6cd83d9dd62f0%7C0%7C0%7C637299740942602529&sdata=zcekjpOQd75tJCds0Qv4JbQbU7aWUFT%2FpiGKQu3yfGY%3D&reserved=0
> https://nam04.safelinks.protection.outlook.com/?url=http%3A%2F%2Fgeode.apache.org%2Fschema%2Fcache%2Fcache-1.0.xsd&data=02%7C01%7Cboglesby%40vmware.com%7C6b93b4396d44490cb36c08d824bce120%7Cb39138ca3cee4b4aa4d6cd83d9dd62f0%7C0%7C0%7C637299740942602529&sdata=1nKYVuz5R5%2BpWXMT0JJ%2FIcQLdB66kKju7T4DeVkn2qc%3D&reserved=0"
> version="1.0"
> copy-on-read="true">
> <!-- Topology information fragment -->
> <gateway-sender id="sender"
> parallel="true"
> enable-persistence="false"
> remote-distributed-system-id="4"/>
> <gateway-sender id="sender_persistent"
> parallel="true"
> enable-persistence="true"
> remote-distributed-system-id="4"/>
> <pdx read-serialized="true" persistent="true" />
> <region name="_part_hidden" refid="PARTITION_REDUNDANT_PERSISTENT">
> <region-attributes>
> <partition-attributes redundant-copies="1">
> <partition-resolver>
> <class-name>org.apache.geode.cache.util.StringPrefixPartitionResolver
> </class-name>
> </partition-resolver>
> </partition-attributes>
> </region-attributes>
> </region>
> <region name="part_a" refid="PARTITION_REDUNDANT">
> <region-attributes gateway-sender-ids="sender" >
> <partition-attributes colocated-with="_part_hidden"
> redundant-copies="1">
> <partition-resolver>
> <class-name>org.apache.geode.cache.util.StringPrefixPartitionResolver
> </class-name>
> </partition-resolver>
> </partition-attributes>
> </region-attributes>
> </region>
> <region name="part_b" refid="PARTITION_REDUNDANT_PERSISTENT">
> <region-attributes gateway-sender-ids="sender_persistent">
> <partition-attributes colocated-with="_part_hidden"
> redundant-copies="1">
> <partition-resolver>
> <class-name>org.apache.geode.cache.util.StringPrefixPartitionResolver
> </class-name>
> </partition-resolver>
> </partition-attributes>
> </region-attributes>
> </region>
> </cache>
>
>
> There is nothing explicitly said about this in documentation, and It
> is not clear why this is not allowed.
> Non-persistent parallel gateway sender is attached only to
> non-persistent region ‘part_a’ (and not to persistent region
> ‘_part_hidden’) .
>
> Why is this not allowed by Geode? Is there any way around this issue?
>
> Geode version: 1.12, 1.11
>
> BRs,
>
> Jakov
>
Re: Non-persistent parallel gateway sender on non-persistent region
(collocated with persistent region)
Posted by Jakov Varenina <ja...@est.tech>.
Hi devs,
just a kind reminder. We would be really grateful if you could take look
at question in below mail.
BRs,
Jakov
On 06. 07. 2020. 15:50, Jakov Varenina wrote:
> Hi all,
>
>
> We are trying to setup non-persistent parallel gateway sender
> (‘sender’) on a non-persistent partitioned region (‘part_a’). This
> works OK.
> But when this same region ‘part_a’ is colocated with another
> persistent region (‘_part_hidden’), Geode throws an exception:
>
> Exception in thread "main"
> org.apache.geode.internal.cache.wan.GatewaySenderException: Non
> persistent gateway sender sender can not be attached to persistent
> region /_part_hidden
> at
> org.apache.geode.internal.cache.wan.parallel.ParallelGatewaySenderQueue.addShadowPartitionedRegionForUserPR(ParallelGatewaySenderQueue.java:461)
> at
> org.apache.geode.internal.cache.wan.parallel.ParallelGatewaySenderQueue.addShadowPartitionedRegionForUserPR(ParallelGatewaySenderQueue.java:451)
> at
> org.apache.geode.internal.cache.wan.parallel.ParallelGatewaySenderEventProcessor.addShadowPartitionedRegionForUserPR(ParallelGatewaySenderEventProcessor.java:191)
> at
> org.apache.geode.internal.cache.wan.parallel.ConcurrentParallelGatewaySenderQueue.addShadowPartitionedRegionForUserPR(ConcurrentParallelGatewaySenderQueue.java:177)
> at
> org.apache.geode.internal.cache.PartitionedRegion.postCreateRegion(PartitionedRegion.java:1174)
> at
> org.apache.geode.internal.cache.GemFireCacheImpl.createVMRegion(GemFireCacheImpl.java:3010)
> at
> org.apache.geode.internal.cache.GemFireCacheImpl.basicCreateRegion(GemFireCacheImpl.java:2869)
> at
> org.apache.geode.internal.cache.xmlcache.RegionCreation.createRoot(RegionCreation.java:237)
> at
> org.apache.geode.internal.cache.xmlcache.CacheCreation.initializeRegions(CacheCreation.java:658)
> at
> org.apache.geode.internal.cache.xmlcache.CacheCreation.create(CacheCreation.java:592)
> at
> org.apache.geode.internal.cache.xmlcache.CacheXmlParser.create(CacheXmlParser.java:338)
> at
> org.apache.geode.internal.cache.GemFireCacheImpl.loadCacheXml(GemFireCacheImpl.java:4081)
> at
> org.apache.geode.internal.cache.GemFireCacheImpl.initializeDeclarativeCache(GemFireCacheImpl.java:1535)
> at
> org.apache.geode.internal.cache.GemFireCacheImpl.initialize(GemFireCacheImpl.java:1374)
> at
> org.apache.geode.internal.cache.InternalCacheBuilder.create(InternalCacheBuilder.java:191)
> at
> org.apache.geode.internal.cache.InternalCacheBuilder.create(InternalCacheBuilder.java:158)
> at
> org.apache.geode.cache.CacheFactory.create(CacheFactory.java:142)
> at
> org.apache.geode.distributed.internal.DefaultServerLauncherCacheProvider.createCache(DefaultServerLauncherCacheProvider.java:52)
> at
> org.apache.geode.distributed.ServerLauncher.createCache(ServerLauncher.java:894)
> at
> org.apache.geode.distributed.ServerLauncher.start(ServerLauncher.java:809)
> at
> org.apache.geode.distributed.ServerLauncher.run(ServerLauncher.java:739)
> at
> org.apache.geode.distributed.ServerLauncher.main(ServerLauncher.java:256)
>
>
> This is cache.xml used:
>
> <?xml version="1.0" encoding="UTF-8"?><cache
> xmlns="http://geode.apache.org/schema/cache"
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xsi:schemaLocation="http://geode.apache.org/schema/cache
> http://geode.apache.org/schema/cache/cache-1.0.xsd"
> version="1.0"
> copy-on-read="true">
> <!-- Topology information fragment -->
> <gateway-sender id="sender"
> parallel="true"
> enable-persistence="false"
> remote-distributed-system-id="4"/>
> <gateway-sender id="sender_persistent"
> parallel="true"
> enable-persistence="true"
> remote-distributed-system-id="4"/>
> <pdx read-serialized="true" persistent="true" />
> <region name="_part_hidden" refid="PARTITION_REDUNDANT_PERSISTENT">
> <region-attributes>
> <partition-attributes redundant-copies="1">
> <partition-resolver>
> <class-name>org.apache.geode.cache.util.StringPrefixPartitionResolver
> </class-name>
> </partition-resolver>
> </partition-attributes>
> </region-attributes>
> </region>
> <region name="part_a" refid="PARTITION_REDUNDANT">
> <region-attributes gateway-sender-ids="sender" >
> <partition-attributes colocated-with="_part_hidden"
> redundant-copies="1">
> <partition-resolver>
> <class-name>org.apache.geode.cache.util.StringPrefixPartitionResolver
> </class-name>
> </partition-resolver>
> </partition-attributes>
> </region-attributes>
> </region>
> <region name="part_b" refid="PARTITION_REDUNDANT_PERSISTENT">
> <region-attributes gateway-sender-ids="sender_persistent">
> <partition-attributes colocated-with="_part_hidden"
> redundant-copies="1">
> <partition-resolver>
> <class-name>org.apache.geode.cache.util.StringPrefixPartitionResolver
> </class-name>
> </partition-resolver>
> </partition-attributes>
> </region-attributes>
> </region>
> </cache>
>
>
> There is nothing explicitly said about this in documentation, and It
> is not clear why this is not allowed.
> Non-persistent parallel gateway sender is attached only to
> non-persistent region ‘part_a’ (and not to persistent region
> ‘_part_hidden’) .
>
> Why is this not allowed by Geode? Is there any way around this issue?
>
> Geode version: 1.12, 1.11
>
> BRs,
>
> Jakov
>