pingInterval != null) {
pf.setPingInterval(pingInterval);
}
pf.create(poolName);
You'll get a pool called DEFAULT and another called Group2Pool,
Thanks,
Barry Oglesby
On Tue, Dec 5, 2017 at 3:45 AM, Vahram Aharonyan
wrote:
> HI Jens,
>
>
>
> Please see the snippets of code we ha
hput?
I'd like to see the configuration as well as the stats for all three sites.
Thanks,
Barry Oglesby
On Thu, Jan 11, 2018 at 12:35 PM, Xu, Nan wrote:
> Not sure I follow, understand the replication is async, but I only
> publish to 1 dc with 1.5k/sec, how come other 2 dc have differ
he latest Geode develop code. What version are
you running?
Thanks,
Barry Oglesby
On Fri, Jan 12, 2018 at 11:46 AM, Bruce Schuchardt
wrote:
> This shouldn't normally cause a hang. The code that handles receipt of
> tcp/ip messages reads the message's "reply processor" ide
you have SSL enabled. I'll
change my test to use both of those and see if I can reproduce the hang.
Thanks,
Barry Oglesby
On Fri, Jan 19, 2018 at 9:33 AM, Dan Smith wrote:
> Hi Vahram,
>
> Well, it's definitely getting corrupted on reading the function arguments
> base
the getMessage method, when the
Connection sendFailureReply method is called, the dm is null, so no reply
is sent. When setFailure is invoked properly, the dm is not null, and the
reply is sent. I'm not really sure when/how the dm is set, but setFailure
method has to be invoked for this code to
ed as well?
Also, if we're thinking about this kind of idea, maybe its time to revisit
WAN GII?
Thanks,
Barry Oglesby
On Thu, Jan 18, 2018 at 12:37 PM, Xu, Nan wrote:
> that certainly helps. For us, the sender not started because some
> configuration issues. But in prod, if somehow the
adID=1;sequenceID=0]]
Thanks,
Barry Oglesby
On Wed, Jan 24, 2018 at 10:30 AM, Dan Smith wrote:
> Hi Oliver,
>
> The server won't get an acknowledgement for your event until after your
> cache listener completes. After the cache listener calls completes, geode
> adds informat
Olivier,
Just to be clear, that was logging I added to a local build. The fine-level
logging doesn't have much in the code around adding to the ack map.
Thanks,
Barry Oglesby
On Thu, Jan 25, 2018 at 1:24 AM, Olivier Mallassi <
olivier.malla...@gmail.com> wrote:
> gentlemen, than
,
Barry Oglesby
On Wed, Feb 21, 2018 at 11:41 AM, Gregory Vortman <
gregory.vort...@amdocs.com> wrote:
> That's the point exactly to have a single very thin and generic mechanism
> to cover all threads/threads pool. Nothing is specific in this solution.
> Regards
>
&g
possible to create the VSDCountersManager in the main thread
before the P2P message reader thread attempts to do it (like in a Function
init)?
Thanks,
Barry Oglesby
On Wed, Oct 24, 2018 at 7:40 AM Anthony Baker wrote:
> Sorry I don’t think I understand your question. Did you encounter a
&
t false. That will cause
the function to be executed on the primary bucket.
Thanks,
Barry Oglesby
On Wed, Oct 31, 2018 at 11:53 AM Marcus Dushshantha Chandradasa <
dushshantha.chandarad...@gmail.com> wrote:
> Hi Udo,
>
> This is perfect. This is exactly what I was looking for.
T disk
store is used like:
BACKUPDEFAULT_1.crf
BACKUPDEFAULT_1.drf
BACKUPDEFAULT_1.krf
BACKUPDEFAULT.if
Thanks,
Barry Oglesby
On Wed, Jan 30, 2019 at 3:26 AM aashish choudhary <
aashish.choudha...@gmail.com> wrote:
> Thanks Dan for explanation. So if we replace the files with old one(It
> has an
Do you see values for other MBean attributes?
If you do a thread dump in your server JVM(s), you should see a thread like
this running:
"StatSampler" #39 daemon prio=10 os_prio=31 tid=0x7fdcbf004000
nid=0x7003 in Object.wait() [0x7c50a000]
java.lang.Thread.State: TIMED_WAITING (on
edRegion and once for the BucketRegion.
The misses is incremented for the PartitionedRegion. So, misses is
incremented when it shouldn't be.
For gfsh, I only see CachePerfStats.endGet called one - for the
BucketRegion. This does not increment the misses.
Thanks,
Barry Oglesby
On Fri, May
method with the BucketRegion.
Thanks,
Barry Oglesby
On Tue, May 21, 2019 at 11:57 PM Alberto Gomez
wrote:
> Barry,
>
> Thanks a lot for the hint.
>
> As you figured out, I was getting the hitCount and missCount from the
> members.
>
> I still do not understand why th
, are
they co-located? How do you determine the keys to getAll? Are they passed
into the function? If so, as a filter or as an argument? What does
optimizeForWrite return? How many members are running?
Thanks,
Barry Oglesby
On Mon, Aug 19, 2019 at 1:19 PM aashish choudhary <
aashish.chou
=6; keys=[122, 279, 237, 381, 131, 351]
regionKeysAndValues=6; regionKeysAndValues={122=122, 279=279, 237=237,
381=381, 131=131, 351=351}
Thanks,
Barry Oglesby
On Mon, Aug 19, 2019 at 2:18 PM aashish choudhary <
aashish.choudha...@gmail.com> wrote:
> You have a data-aware function (inv
ys=[77, 264, 342, 125, 433, 405, 193, 196]
regionKeysAndValues=8; regionKeysAndValues={77=77, 264=264, 342=342,
125=125, 433=433, 405=405, 193=193, 196=196}
Thanks,
Barry Oglesby
On Tue, Aug 20, 2019 at 2:55 AM aashish choudhary <
aashish.choudha...@gmail.com> wrote:
> Thanks Barry for thorou
Types are persistent in site2, you won't need to work around
JIRA GEODE-6271
If your senders are persistent, you may need to delete the disk files
before restarting the senders.
Thanks,
Barry Oglesby
On Wed, Oct 23, 2019 at 10:36 PM evaristo.camar...@yahoo.es <
evaristo.camar...@yahoo.es
e an onRegion function to stream the values back to the caller. The
function would iterate the entries and batch them back to the client using
sendResults. A ResultCollector on the client would process each batch in
addResult and do the same thing the CqListener is doing.
Thanks,
Barry Oglesby
On Mon
event will not overwrite a later event.
Thanks,
Barry Oglesby
On Mon, Dec 2, 2019 at 8:57 AM Alberto Gomez wrote:
> Hi,
>
> On the subject of parallel gateway sender receivers, according to the
> Geode documentation:
>
> [1]:
> Although parallel gateway senders
) {
region.create(e.getKey(), e.getValue());
} else if (e.getOperation().isDestroy()) {
region.destroy(e.getKey());
}
}
ctm.commit();
}
}
Thanks,
Barry Oglesby
On Mon, Jan 20, 2020 at 11:52 AM John Blum wrote:
> From within...
>
> c
Geode Users,
I published an article describing how to remove unused PdxTypes from a
Distributed System here:
https://medium.com/@boglesby_2508/remove-unused-pdxtypes-from-an-apache-geode-distributed-system-5a4f0e199e34
Thanks,
Barry Oglesby
he createRegion method is:
private Region createRegion(String poolName) {
return this.cache
.createClientRegionFactory(ClientRegionShortcut.PROXY)
.setPoolName(poolName)
.create(this.regionName);
}
Thanks,
Barry Oglesby
On Tue, May 5, 2020 at 9:37 AM aashish choudhary &l
Yes, you can't have a single region pointing at 2 pools. What I posted is
the way I've done it in the past. I just tried it, and it still works.
Maybe if you post your full code, I can take a look.
Thanks,
Barry Oglesby
On Tue, May 5, 2020 at 10:19 AM aashish choudhary <
aa
n the RemoveUnusedPdxTypesFunction
- removes the PdxTypes from the in-memory maps
- releases the DistributedLock
Thanks,
Barry Oglesby
On Sat, May 2, 2020 at 9:03 AM Jacob Barrett wrote:
> This is awesome! It sounds like a good solid thing to have as a feature to
> me. What’s the smal
the
Region.
Something like this should work:
this.region1 = clientCache.createClientRegionFactory(ClientRegionShortcut.PROXY)
.setPoolName("B")
.create("region1");
Thanks,
Barry Oglesby
On Tue, May 5, 2020 at 11:14 AM aashish choudhary <
aashish.choudha...@gmail.com
x27;ll have to
handle the RegionDestroyedExceptions that occur when the region is closed
out from under them
- I don't know if your clients are REST-enabled, but a REST API to switch
pools would be pretty cool.
Thanks,
Barry Oglesby
On Wed, May 6, 2020 at 9:40 AM aashish choudhary <
aa
Geode Users,
I published an article describing how to convert all Geode statistics to
Micrometer meters here:
https://medium.com/@boglesby_2508/converting-all-apache-geode-statistics-to-micrometer-meters-e5c94fdc1c56
Thanks,
Barry Oglesby
Alberto,
I can only speak to the WAN question in your email. The conserve-sockets
setting was (or is) a limitation on serial WAN, but I just ran a few tests, and
it is not deadlocking. Its been a while since I've tried serial WAN with
conserve-sockets=true, but I'm pretty sure a test with sever
Yes, the ManagementAgent.startHttpService checks for HTTP_SERVICE_PORT !=
0. If it is 0, it doesn't start Jetty.
Also, if none of the geode-web.war, geode-pulse.war or geode-web-api.war
files are available. Jetty won't be started.
Thanks,
Barry Oglesby
On Mon, Jan 23, 2017 at 1:1
r to
crash.
Thanks,
Barry Oglesby
On Thu, Feb 9, 2017 at 2:42 AM, Thacker, Dharam wrote:
> Hi Team,
>
>
>
> I am facing below error while working with continuous query listener. We
> are receiving high number of events matching to various continuous query
> listeners wh
ever to recover its connection to the
server.
The QueueManagerImpl uses a ScheduledThreadPoolExecutor with a maximum pool
size of Integer.MAX_VALUE, so the number of available threads in this area
is limited only by the JVM and OS resources.
Thanks,
Barry Oglesby
On Fri, Feb 10, 2017 at 6:27 AM, Th
Bing,
The gfsh gc command is reporting incorrect results. I filed
https://issues.apache.org/jira/browse/GEODE-2883.
Thanks for finding this.
Thanks,
Barry Oglesby
On Fri, May 5, 2017 at 1:03 AM, Bing Jiang wrote:
>
> hi, All.
>
> We launch a geode locator and 7 geode servers (m
Amit,
What is being serialized? Is there any chance the value being serialized
references itself?
Thanks,
Barry Oglesby
On Tue, Jun 6, 2017 at 12:40 PM, Amit Pandey
wrote:
> Hi ,
>
> Can any one please help with below error. I get it whenever I am trying to
> load a region
>
ution Thread-2: Processing batch 11 member
boglesbymac-2(4145):3184 containing 35 values (total=975)
Function Execution Thread-3: Processing batch 12 member
boglesbymac-2(4131):46709 containing 25 values (total=1000)
Thanks,
Barry Oglesby
On Mon, Aug 14, 2017 at 9:14 AM, Amit Pandey
wrote:
>
eue.
- the network is preventing or slowing transmission between the server and
client. Does the network traffic stop completely or slow to a crawl?
Can you provide these in the JIRA?
- client and server stats
- client and server thread dumps
Thanks,
Barry Oglesby
On Wed, Sep 27, 2017 at 3:53 P
ither. That would be a
modification
to org.apache.geode.management.internal.beans.RegionMBeanCompositeDataFactory.
It looks like you'd have to write your own function to get this data
currently.
Thanks,
Barry Oglesby
On Fri, Nov 3, 2017 at 1:03 PM, Xu, Nan wrote:
> Hi,
>
>
>
>
38 matches
Mail list logo