This is an automated email from the ASF dual-hosted git repository.
mcmellawatt pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/geode.git
The following commit(s) were added to refs/heads/develop by this push:
new 08bd776 GEODE-7015: Fixing redundant copies in test
08bd776 is described below
commit 08bd776f8ceaa127b40523a49a294f3c115d0aa6
Author: Ryan McMahon <[email protected]>
AuthorDate: Tue Aug 6 20:40:45 2019 -0700
GEODE-7015: Fixing redundant copies in test
---
.../internal/cache/control/RebalanceOperationDistributedTest.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/geode-core/src/distributedTest/java/org/apache/geode/internal/cache/control/RebalanceOperationDistributedTest.java
b/geode-core/src/distributedTest/java/org/apache/geode/internal/cache/control/RebalanceOperationDistributedTest.java
index fa02901..656b4a5 100644
---
a/geode-core/src/distributedTest/java/org/apache/geode/internal/cache/control/RebalanceOperationDistributedTest.java
+++
b/geode-core/src/distributedTest/java/org/apache/geode/internal/cache/control/RebalanceOperationDistributedTest.java
@@ -2238,7 +2238,7 @@ public class RebalanceOperationDistributedTest extends
CacheTestCase {
RebalanceResults results = doRebalance(false, manager);
// The rebalance should have done some work since the buckets were
imbalanced
- assertThat(results.getTotalPrimaryTransfersCompleted() > 0).isTrue();
+ assertThat(results.getTotalBucketTransfersCompleted() > 0).isTrue();
});
}
@@ -2314,7 +2314,7 @@ public class RebalanceOperationDistributedTest extends
CacheTestCase {
RebalanceResults results = doRebalance(false,
getCache().getInternalResourceManager());
// The rebalance should have done some work since the buckets were
imbalanced
- assertThat(results.getTotalPrimaryTransfersCompleted() > 0).isTrue();
+ assertThat(results.getTotalBucketTransfersCompleted() > 0).isTrue();
});
}
@@ -2435,7 +2435,7 @@ public class RebalanceOperationDistributedTest extends
CacheTestCase {
diskStoreFactory.setDiskDirs(diskDirs).create(diskStoreName);
PartitionAttributesFactory partitionAttributesFactory = new
PartitionAttributesFactory();
- partitionAttributesFactory.setRedundantCopies(1);
+ partitionAttributesFactory.setRedundantCopies(redundantCopies);
partitionAttributesFactory.setRecoveryDelay(-1);
partitionAttributesFactory.setStartupRecoveryDelay(-1);