RE: Query for JMX "Async Event Queue properties"

2017-07-09 Thread Dinesh Akhand 
Please suggest on below question.

Thanks,
Dinesh

-Original Message-
From: Dinesh Akhand 
Sent: Friday, July 7, 2017 6:30 PM
To: dev@geode.apache.org; bogle...@pivotal.io
Subject: RE: Query for JMX "Async Event Queue properties"

Hi Team,



I tried to execute select sql  on  Internal region associated the Async Queue 
using command “gfsh>query --query=’select * from 
/AsyncEventQueue_XYZ_PARALLEL_GATEWAY_SENDER_QUEUE’

But in geode 1.1.1



There is a validation check in below method .   we always try to find out the 
Bean associated with it.   But for internal region we don’t have bean . Can 
someone suggest how I can skip this check.



Could  you please  suggest more generic check here , so we can make query on 
internal regions.





Classs:



   management/internal/cli/commands/DataCommands.java



method:

--

public static Set getRegionAssociatedMembers(String region,

  final InternalCache cache, boolean returnAll) {



DistributedMember member;



if (StringUtils.isEmpty(region)) {

  return null;

}



DistributedRegionMXBean bean =


ManagementService.getManagementService(cache).getDistributedRegionMXBean(region);



if (bean == null) {

  // try with slash ahead

  bean = ManagementService.getManagementService(cache)

  .getDistributedRegionMXBean(Region.SEPARATOR + region);

}



if (bean == null) {

  return null;

}



---



Thanks,

Dinesh Akhand































-Original Message-
From: Barry Oglesby [mailto:bogle...@pivotal.io]
Sent: Thursday, June 22, 2017 12:04 AM
To: dev@geode.apache.org
Subject: Re: Query for JMX "Async Event Queue properties"



I don't see that OR clause on Geode develop. What version of Geode are you 
using?



In any event, the JMX MBeans are registered using a ResourceEventsListener 
called ManagementListener. That listener is invoked by handleResourceEvent 
calls in GemFireCacheImpl for a bunch of different events including region 
creation. There isn't any other property that could be set to create the MBean 
for that region.



Rather than test the region name in that OR clause, a slightly better way to 
implement that would be:



if (!region.isInternalRegion()

|| region.isUsedForParallelGatewaySenderQueue()

|| region.isUsedForSerialGatewaySenderQueue()) {





btw - the MBean should be removed if the region is destroyed. The LocalRegion 
recursiveDestroyRegion and basicDestroyRegion methods contain code like this 
that should also be modified like above:



if (!region.isInternalRegion()) {

InternalDistributedSystem system =

region.cache.getInternalDistributedSystem();

system.handleResourceEvent(ResourceEvent.REGION_REMOVE, region); }





Thanks,

Barry Oglesby





On Tue, Jun 20, 2017 at 6:33 AM, Dinesh Akhand 
mailto:dines...@amdocs.com>> wrote:



> Hi Barry,

>

>

>

> Looks like things are already implemented in geode:

>

>

>

> Class : GemFireCacheImpl

>

>

>

> if (!rgn.isInternalRegion() ||

> rgn.getFullPath().contains("GATEWAY_SENDER_QUEUE"))

> {

>

>   system.handleResourceEvent(ResourceEvent.REGION_CREATE, rgn);

>

> }

>

>

>

> Above code solved my problem .  Async Queue Partition region visible

> in JMX.

>

>

>

> But above code looks like hack in existing code.  Is this fix can we

> take and go ahead because in our requirement we need to show all

> internal partition region.

>

>

>

> Or can we define some property in .properties files to enable stats in

> jmx for internal region?.

>

>

>

> Thanks,

>

> Dinesh Akhand

>

>

>

>

>

> -Original Message-

> From: Barry Oglesby [mailto:bogle...@pivotal.io]

> Sent: Saturday, June 17, 2017 2:14 AM

> To: dev@geode.apache.org

> Subject: Re: Query for JMX "Async Event Queue properties"

>

>

>

> The AsynceEventQueueMBean is monitoring the AsyncEventQueueStats not

> the PartitionedRegionStats. And, actually, the only stat being

> monitored by that MBean is the eventQueueSize stat. The parallel

> AsyncEventQueue creates a colocated PartitionedRegion under the

> covers, and the stats for that PR are the PartitionedRegionStats you

> referenced. There isn't currently any JMX support for those 
> PartitionedRegionStats.

>

>

>

> Are you looking to add support for those PartitionedRegionStats to the

> AsynceEventQueueMBean? If so, I guess there are a few ways to do. The

> first would be to find the underlying PartitionedRegion for the

> parallel AsyncEventQueue, add its PartitionedRegionStats to the

> AsyncEventQueueMBeanBridge's monitor and reference the appropriate

> one(s) (in your case dataStoreBytesInUse). Another would be to

> actually create an MBean for that internal PartitionedRegion.

>

>

>

> Both of these would only be applicable for a p

[Spring CI] Spring Data GemFire > Nightly-ApacheGeode > #611 was SUCCESSFUL (with 1908 tests)

2017-07-09 Thread Spring CI 

---
Spring Data GemFire > Nightly-ApacheGeode > #611 was successful.
---
Scheduled
1910 tests in total.

https://build.spring.io/browse/SGF-NAG-611/




--
Code Changes
--
John Blum (0907ecbe441b93f598d5651bce7887dff8439a8a):

>DATAGEODE-17 - Adapt to API changes in mapping subsystem.



--
This message is automatically generated by Atlassian Bamboo

[Spring CI] Spring Data GemFire > Nightly-ApacheGeode > #610 was SUCCESSFUL (with 1908 tests)

2017-07-09 Thread Spring CI 

---
Spring Data GemFire > Nightly-ApacheGeode > #610 was successful (rerun once).
---
This build was rerun by John Blum.
1910 tests in total.

https://build.spring.io/browse/SGF-NAG-610/





--
This message is automatically generated by Atlassian Bamboo

Build failed in Jenkins: Geode-nightly #891

2017-07-09 Thread Apache Jenkins Server 
See 

--
[...truncated 109.43 KB...]
Note: Recompile with -Xlint:unchecked for details.

:geode-cq:processTestResources
:geode-cq:testClasses
:geode-cq:checkMissedTests
:geode-cq:spotlessJavaCheck
:geode-cq:spotlessCheck
:geode-cq:test
:geode-cq:check
:geode-cq:build
:geode-cq:distributedTest
:geode-cq:integrationTest
:geode-json:assemble
:geode-json:compileTestJava UP-TO-DATE
:geode-json:processTestResources
:geode-json:testClasses
:geode-json:checkMissedTests UP-TO-DATE
:geode-json:spotlessJavaCheck
:geode-json:spotlessCheck
:geode-json:test UP-TO-DATE
:geode-json:check
:geode-json:build
:geode-json:distributedTest UP-TO-DATE
:geode-json:integrationTest UP-TO-DATE
:geode-junit:javadoc
:geode-junit:javadocJar
:geode-junit:sourcesJar
:geode-junit:signArchives SKIPPED
:geode-junit:assemble
:geode-junit:compileTestJava
:geode-junit:processTestResources UP-TO-DATE
:geode-junit:testClasses
:geode-junit:checkMissedTests
:geode-junit:spotlessJavaCheck
:geode-junit:spotlessCheck
:geode-junit:test
:geode-junit:check
:geode-junit:build
:geode-junit:distributedTest
:geode-junit:integrationTest
:geode-lucene:assemble
:geode-lucene:compileTestJavaNote: Some input files use or override a 
deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.

:geode-lucene:processTestResources
:geode-lucene:testClasses
:geode-lucene:checkMissedTests
:geode-lucene:spotlessJavaCheck
:geode-lucene:spotlessCheck
:geode-lucene:test
:geode-lucene:check
:geode-lucene:build
:geode-lucene:distributedTest
:geode-lucene:integrationTest
:geode-old-client-support:assemble
:geode-old-client-support:compileTestJavaNote: 

 uses or overrides a deprecated API.
Note: Recompile with -Xlint:deprecation for details.

:geode-old-client-support:processTestResources UP-TO-DATE
:geode-old-client-support:testClasses
:geode-old-client-support:checkMissedTests
:geode-old-client-support:spotlessJavaCheck
:geode-old-client-support:spotlessCheck
:geode-old-client-support:test
:geode-old-client-support:check
:geode-old-client-support:build
:geode-old-client-support:distributedTest
:geode-old-client-support:integrationTest
:geode-old-versions:javadoc UP-TO-DATE
:geode-old-versions:javadocJar
:geode-old-versions:sourcesJar
:geode-old-versions:signArchives SKIPPED
:geode-old-versions:assemble
:geode-old-versions:compileTestJava UP-TO-DATE
:geode-old-versions:processTestResources UP-TO-DATE
:geode-old-versions:testClasses UP-TO-DATE
:geode-old-versions:checkMissedTests UP-TO-DATE
:geode-old-versions:spotlessJavaCheck
:geode-old-versions:spotlessCheck
:geode-old-versions:test UP-TO-DATE
:geode-old-versions:check
:geode-old-versions:build
:geode-old-versions:distributedTest UP-TO-DATE
:geode-old-versions:integrationTest UP-TO-DATE
:geode-protobuf:assemble
:geode-protobuf:extractIncludeTestProto
:geode-protobuf:extractTestProto UP-TO-DATE
:geode-protobuf:generateTestProto UP-TO-DATE
:geode-protobuf:compileTestJavaNote: Some input files use unchecked or unsafe 
operations.
Note: Recompile with -Xlint:unchecked for details.

:geode-protobuf:processTestResources UP-TO-DATE
:geode-protobuf:testClasses
:geode-protobuf:checkMissedTests
:geode-protobuf:spotlessJavaCheck
:geode-protobuf:spotlessCheck
:geode-protobuf:test
:geode-protobuf:check
:geode-protobuf:build
:geode-protobuf:distributedTest
:geode-protobuf:integrationTest
:geode-pulse:assemble
:geode-pulse:compileTestJavaNote: Some input files use or override a deprecated 
API.
Note: Recompile with -Xlint:deprecation for details.
Note: 

 uses unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.

:geode-pulse:processTestResources
:geode-pulse:testClasses
:geode-pulse:checkMissedTests
:geode-pulse:spotlessJavaCheck
:geode-pulse:spotlessCheck
:geode-pulse:test
:geode-pulse:check
:geode-pulse:build
:geode-pulse:distributedTest
:geode-pulse:integrationTest
:geode-rebalancer:assemble
:geode-rebalancer:compileTestJava
:geode-rebalancer:processTestResources UP-TO-DATE
:geode-rebalancer:testClasses
:geode-rebalancer:checkMissedTests
:geode-rebalancer:spotlessJavaCheck
:geode-rebalancer:spotlessCheck
:geode-rebalancer:test
:geode-rebalancer:check
:geode-rebalancer:build
:geode-rebalancer:distributedTest
:geode-rebalancer:integrationTest
:geode-wan:assemble
:geode-wan:compileTestJavaNote: Some input files use or override a deprecated 
API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for d