This is an automated email from the ASF dual-hosted git repository. eshu11 pushed a change to branch feature/GEODE-5624 in repository https://gitbox.apache.org/repos/asf/geode.git.
from 13b6cfe more refactoring. new bc42e83 restore catch InternalGemFireError. add 9f13a5b GEODE-5610: CI Failure: DiskRegionJUnitTest testAssertionErrorIfMissingOplog (#2357) add c7ca13d GEODE-5460: Fixing a race condition in TestFunctionsDUNitTest add 6ee86d6 GEODE-5597 verify geode-dependency jar ClassPath (#2369) add 879b2cd GEODE-5597: Fixes formatting. add a1f747c GEODE-5440: when we need re-evaluate a entry in a index, we need to pass in the outer value key in the equiJoin. (#2338) add abb2702 GEODE-5630: fix use of Awaitility in BucketCreationCrashCompletesRegressionTest add 9be422c GEODE-5617: FIxing a race in AutoBalancerJUnitTest add cfa7ca5 GEODE-5627: ConcurrencyRule passes when not used. (#2370) add 39b2236 GEODE-5597 let AssemblyContentsIntegrationTest pass on windows add 583d141 GEODE-5562 Reading the values of LocalRegion.memoryThresholdReached and DistributedRegion.memoryThresholdReachedMembers must be atomic (#2320) add 9de289d GEODE-5632: import Assertions instead of AssertionsForClassTypes add b951146 GEODE-5142 new Thread Monitoring Mechanism add 123b8c4 GEODE-5614: rename DistributedTestRule as DistributedRule add 16d0f69 GEODE-5614: rename distributedTestRule field to distributedRule add f91c2df GEODE-5614: update RegionManagementDUnitTest usage of DistributedRule add e719331 GEODE-5629: Changing GMSEncryptJUnitTest to use ConcurrencyRule add a383053 GEODE-5623: Use Awaitility in StopLcoatorCommandDUnitTest (#2379) add 85953f0 GEODE-5631: failedBatchRemovalMessageKeys not used after GII (#2375) add 45138b4 GEODE-5630: fixup usage of Awaitility add 0cbf8e5 GEODE-5620: Adds project property to control test forking add 76af1dd GEODE-5597 Publish geode artifacts to maven repo on GCS (#2347) new 5ebd326 Merge remote-tracking branch 'origin/develop' into feature/GEODE-5624 The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: build.gradle | 2 +- ci/pipelines/geode-build/deploy_pipeline.sh | 2 + ci/pipelines/geode-build/jinja.template.yml | 39 ++- ci/scripts/publish.sh | 96 ++++++ geode-assembly/build.gradle | 47 +-- .../cli/commands/StopLocatorCommandDUnitTest.java | 29 +- .../geode/AssemblyContentsIntegrationTest.java | 4 +- ...java => GeodeDependencyJarIntegrationTest.java} | 69 +++-- .../resources/dependency_classpath.txt | 67 +++++ .../test/junit/rules/MySqlConnectionRule.java | 5 +- .../junit/rules/SqlDatabaseConnectionRule.java | 4 +- .../geode/connectors/jdbc/JdbcAsyncWriterTest.java | 4 +- .../geode/connectors/jdbc/JdbcWriterTest.java | 2 +- geode-core/build.gradle | 14 +- .../CreateAndLocalDestroyInTXRegressionTest.java | 7 +- .../PRCreationTotalNumBucketsDistributedTest.java | 8 +- .../cache/RegionClearStatsDistributedTest.java | 8 +- .../cache/RegionExpirationDistributedTest.java | 8 +- .../ReplicateCacheListenerDistributedTest.java | 18 +- .../internal/AutoConnectionSourceDUnitTest.java | 3 +- .../management/MemoryThresholdsDUnitTest.java | 2 +- .../MemoryThresholdsOffHeapDUnitTest.java | 18 +- .../dunit/QueryDataInconsistencyDUnitTest.java | 34 +-- .../query/dunit/QueryIndexUsingXMLDUnitTest.java | 3 +- .../partitioned/PRColocatedEquiJoinDUnitTest.java | 47 --- .../query/partitioned/PRQueryDUnitHelper.java | 86 +----- .../geode/cache30/DiskRegionDistributedTest.java | 11 +- ...okenSerializationConsistencyRegressionTest.java | 8 +- .../cache/BucketCreationCrashRegressionTest.java | 11 +- ...ntServerTransactionFailoverDistributedTest.java | 35 +-- ...overWithMixedVersionServersDistributedTest.java | 44 +-- .../EntriesDoNotExpireDuringGiiRegressionTest.java | 14 +- ...zedDiskRegionWithIoExceptionRegressionTest.java | 18 +- .../cache/PRCustomPartitioningDistributedTest.java | 10 +- .../PREntryIdleExpirationDistributedTest.java | 31 +- .../internal/cache/PRQueryDistributedTest.java | 8 +- .../PRQueryWithIndexAndPdxDistributedTest.java | 9 +- .../cache/PRQueryWithIndexDistributedTest.java | 9 +- .../cache/PRQueryWithOrderByDistributedTest.java | 9 +- ...RQueryWithPdxDuringRebalanceRegressionTest.java | 9 +- .../PRWithIndexAfterRebalanceRegressionTest.java | 9 +- .../PartitionedRegionCloseDistributedTest.java | 19 +- .../cache/PersistentRegionRecoveryDUnitTest.java | 19 +- .../cache/RegionListenerDistributedTest.java | 17 +- ...eplicateEntryIdleExpirationDistributedTest.java | 36 ++- .../cache/backup/BackupDistributedTest.java | 12 +- .../backup/IncrementalBackupDistributedTest.java | 12 +- .../PrepareAndFinishBackupDistributedTest.java | 6 +- .../ClientFunctionTimeoutRegressionTest.java | 26 +- ...ctionExecutionWithExceptionDistributedTest.java | 9 +- ...ctionOnBehalfOfClientMemberDistributedTest.java | 14 +- .../cache/ha/HARegionQueueSizeRegressionTest.java | 9 +- .../HARegionQueueThreadIdExpiryRegressionTest.java | 11 +- ...BucketCreationCrashCompletesRegressionTest.java | 55 ++-- .../BucketRebalanceStatRegressionTest.java | 4 +- ...RDiskConflictWithColocationDistributedTest.java | 5 +- ...PersistentPartitionedRegionDistributedTest.java | 21 +- .../PersistentPartitionedRegionRegressionTest.java | 7 +- ...eueRemovalMessageProcessingDistributedTest.java | 87 +++--- .../RegisterInterestKeysValuesDistributedTest.java | 50 ++-- .../DeltaPropagationFailureRegressionTest.java | 33 +-- .../AcceptorImplClientQueueDistributedTest.java | 42 +-- ...entDestroyRegionNotificationRegressionTest.java | 31 +- ...troyRegionUnregisterInterestRegressionTest.java | 31 +- .../ClientProxyWithDeltaDistributedTest.java | 34 +-- .../ClientWithInterestFailoverDistributedTest.java | 32 +- .../GetConnectedServerCountRegressionTest.java | 8 +- .../HARegionQueueStatsCloseRegressionTest.java | 24 +- .../MessageTrackingTimeoutRegressionTest.java | 18 +- ...nterestOnServerWithoutRegionRegressionTest.java | 15 +- ...isterInterestServerMetaDataDistributedTest.java | 44 ++- ...RootRegionsExcludesHARegionsRegressionTest.java | 24 +- .../AsyncEventListenerDistributedTest.java | 4 +- ...ventListenerWithCacheLoaderDistributedTest.java | 6 +- ...syncEventListenerWithFilterDistributedTest.java | 6 +- ...oncurrentAsyncEventListenerDistributedTest.java | 4 +- .../ParallelAsyncEventListenerDistributedTest.java | 6 +- .../SerialEventListenerDistributedTest.java | 4 +- .../ClientServerJTAFailoverDistributedTest.java | 48 +-- .../apache/geode/management/JMXMBeanDUnitTest.java | 59 ++-- .../management/JMXMBeanReconnectDUnitTest.java | 10 +- .../management/RegionManagementDUnitTest.java | 11 +- .../internal/pulse/TestClientIdsDUnitTest.java | 8 +- .../internal/pulse/TestFunctionsDUnitTest.java | 96 +++--- .../tests/GetCurrentVmNumDistributedTest.java | 5 +- .../GetPidAndIdAfterBounceDistributedTest.java | 11 +- .../dunit/tests/GetPidAndIdDistributedTest.java | 9 +- .../query/internal/IndexManagerJUnitTest.java | 12 +- .../query/partitioned/PRColocatedEquiJoinTest.java | 110 +++++++ .../gms/messenger/GMSEncryptJUnitTest.java | 122 +++----- .../geode/internal/cache/DiskRegionJUnitTest.java | 94 +++--- .../CacheClientNotifierIntegrationTest.java | 24 +- .../cache/query/internal/DefaultQueryService.java | 17 +- .../query/internal/IndexTrackingQueryObserver.java | 1 + .../geode/cache/query/internal/QueryUtils.java | 10 +- .../cache/query/internal/index/IndexManager.java | 30 +- .../cache/query/internal/index/RangeIndex.java | 7 +- .../internal/cache/AbstractBucketRegionQueue.java | 12 + .../geode/internal/cache/BucketRegionQueue.java | 1 + .../internal/cache/CacheDistributionAdvisor.java | 2 +- .../geode/internal/cache/DistributedRegion.java | 41 +-- .../geode/internal/cache/InternalRegion.java | 2 + .../apache/geode/internal/cache/LocalRegion.java | 63 ++-- .../geode/internal/cache/MemoryThresholdInfo.java | 53 ++++ .../geode/internal/cache/PartitionedRegion.java | 29 +- .../org/apache/geode/internal/cache/TXState.java | 54 ++-- .../internal/cache/control/HeapMemoryMonitor.java | 70 ++++- .../internal/cache/control/ResourceAdvisor.java | 2 +- .../execute/DistributedRegionFunctionExecutor.java | 16 +- .../cache/execute/MemberFunctionExecutor.java | 19 +- .../cache/execute/MultiRegionFunctionExecutor.java | 32 +- .../execute/PartitionedRegionFunctionExecutor.java | 17 +- .../partitioned/PartitionedRegionRebalanceOp.java | 2 +- .../internal/cache/partitioned/RegionAdvisor.java | 4 +- .../tier/sockets/command/ExecuteFunction.java | 19 +- .../tier/sockets/command/ExecuteFunction65.java | 20 +- .../tier/sockets/command/ExecuteFunction66.java | 20 +- .../wan/parallel/ParallelQueueRemovalMessage.java | 10 +- .../monitoring/ThreadsMonitoringProcess.java | 8 +- .../monitoring/executor/AbstractExecutor.java | 24 +- .../internal/QueueConnectionImplJUnitTest.java | 6 +- ...pClientExecutorSubmitTaskWithExceptionTest.java | 9 +- .../cache/query/internal/QueryMonitorTest.java | 5 +- .../internal/cache/DistributedRegionJUnitTest.java | 32 ++ ...onMapTest.java => MemoryThresholdInfoTest.java} | 26 +- .../cache/control/HeapMemoryMonitorTest.java | 325 +++++++++++++++++++++ .../sockets/command/ExecuteFunction66Test.java | 4 + .../ParallelQueueRemovalMessageJUnitTest.java | 24 ++ .../GemFireBasicDataSourceJUnitTest.java | 17 +- ...ientStatisticsPublicationSecurityDUnitTest.java | 14 +- .../tier/sockets/ClientServerMiscBCDUnitTest.java | 15 +- .../examples/AsyncInvokeCallableExampleTest.java | 26 +- .../examples/AsyncInvokeRunnableExampleTest.java | 12 +- .../CatchingUnexpectedExceptionExampleTest.java | 13 +- ... => DistributedRuleAsClassRuleExampleTest.java} | 32 +- .../dunit/examples/InvokeRunnableExampleTest.java | 13 +- .../examples/LocatorPortClusterExampleTest.java | 7 +- .../examples/ReplaceTryFinallyExampleTest.java | 14 +- .../tests/CacheRuleBuilderDistributedTest.java | 9 +- .../rules/tests/CacheRuleDistributedTest.java | 4 +- .../tests/ClientCacheRuleDistributedTest.java | 114 ++++++++ ...utedRestoreSystemPropertiesDistributedTest.java | 14 +- ...st.java => DistributedRuleDistributedTest.java} | 11 +- .../tests/SharedCountersRuleDistributedTest.java | 69 +++-- .../tests/SharedErrorCollectorDistributedTest.java | 45 ++- .../internal/cache/functions/TestFunction.java | 286 ++++++++---------- .../dunit/internal/JUnit4DistributedTestCase.java | 4 +- ...dTestRule.java => AbstractDistributedRule.java} | 8 +- .../apache/geode/test/dunit/rules/CacheRule.java | 39 ++- .../test/dunit/rules/CleanupDUnitVMsRule.java | 2 +- .../geode/test/dunit/rules/ClientCacheRule.java | 52 +++- .../geode/test/dunit/rules/ClusterStartupRule.java | 8 + .../rules/DistributedRestoreSystemProperties.java | 2 +- ...stributedTestRule.java => DistributedRule.java} | 95 ++++-- .../geode/test/dunit/rules/SharedCountersRule.java | 57 +++- .../test/dunit/rules/SharedErrorCollector.java | 22 +- .../geode/test/junit/rules/ServerStarterRule.java | 21 ++ .../DoNotHandleUnexpectedExceptionExampleTest.java | 2 - geode-junit/build.gradle | 2 +- .../geode/test/junit/rules/ConcurrencyRule.java | 8 +- .../test/junit/rules/ConcurrencyRuleTest.java | 7 + geode-lucene/build.gradle | 2 +- .../geode/cache/lucene/ExpirationDUnitTest.java | 9 +- ...eneIndexCreationPersistenceIntegrationTest.java | 13 +- .../LuceneSearchWithRollingUpgradeDUnit.java | 15 +- geode-pulse/build.gradle | 10 +- .../geode/cache/util/AutoBalancerJUnitTest.java | 6 +- .../GatewayLegacyAuthenticationRegressionTest.java | 22 +- geode-web-api/build.gradle | 2 +- geode-web/build.gradle | 10 +- gradle/publish.gradle | 117 +++++++- gradle/test.gradle | 10 +- gradle/utilities.gradle | 3 + 173 files changed, 2685 insertions(+), 1859 deletions(-) create mode 100755 ci/scripts/publish.sh copy geode-assembly/src/integrationTest/java/org/apache/geode/{AssemblyContentsIntegrationTest.java => GeodeDependencyJarIntegrationTest.java} (50%) create mode 100644 geode-assembly/src/integrationTest/resources/dependency_classpath.txt create mode 100644 geode-core/src/integrationTest/java/org/apache/geode/cache/query/partitioned/PRColocatedEquiJoinTest.java create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/MemoryThresholdInfo.java copy geode-core/src/test/java/org/apache/geode/internal/cache/{VMLRURegionMapTest.java => MemoryThresholdInfoTest.java} (61%) create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/control/HeapMemoryMonitorTest.java rename geode-dunit/src/distributedTest/java/org/apache/geode/test/dunit/examples/{DistributedTestRuleExampleTest.java => DistributedRuleAsClassRuleExampleTest.java} (50%) create mode 100644 geode-dunit/src/distributedTest/java/org/apache/geode/test/dunit/rules/tests/ClientCacheRuleDistributedTest.java rename geode-dunit/src/distributedTest/java/org/apache/geode/test/dunit/rules/tests/{DistributedTestRuleDistributedTest.java => DistributedRuleDistributedTest.java} (76%) rename geode-dunit/src/main/java/org/apache/geode/test/dunit/rules/{AbstractDistributedTestRule.java => AbstractDistributedRule.java} (90%) rename geode-dunit/src/main/java/org/apache/geode/test/dunit/rules/{DistributedTestRule.java => DistributedRule.java} (71%)