Repository: incubator-geode Updated Branches: refs/heads/develop e04519dc3 -> 8929e93bd
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8929e93b/geode-cq/src/test/java/org/apache/geode/management/internal/cli/commands/DurableClientCommandsDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-cq/src/test/java/org/apache/geode/management/internal/cli/commands/DurableClientCommandsDUnitTest.java b/geode-cq/src/test/java/org/apache/geode/management/internal/cli/commands/DurableClientCommandsDUnitTest.java index ef29961..ded6a60 100644 --- a/geode-cq/src/test/java/org/apache/geode/management/internal/cli/commands/DurableClientCommandsDUnitTest.java +++ b/geode-cq/src/test/java/org/apache/geode/management/internal/cli/commands/DurableClientCommandsDUnitTest.java @@ -35,6 +35,7 @@ import org.apache.geode.test.dunit.Host; import org.apache.geode.test.dunit.SerializableCallable; import org.apache.geode.test.dunit.VM; import org.apache.geode.test.junit.categories.DistributedTest; +import org.apache.geode.test.junit.categories.FlakyTest; import org.junit.Test; import org.junit.experimental.categories.Category; @@ -120,6 +121,7 @@ public class DurableClientCommandsDUnitTest extends CliCommandTestBase { assertTrue(resultAsString.contains(errorMessage)); } + @Category(FlakyTest.class) // GEODE-1705 @Test public void testCloseDurableCQ() throws Exception{ setupSystem(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8929e93b/geode-lucene/src/test/java/org/apache/geode/cache/lucene/LuceneQueriesPeerPRRedundancyDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-lucene/src/test/java/org/apache/geode/cache/lucene/LuceneQueriesPeerPRRedundancyDUnitTest.java b/geode-lucene/src/test/java/org/apache/geode/cache/lucene/LuceneQueriesPeerPRRedundancyDUnitTest.java index 6366298..af7dffa 100644 --- a/geode-lucene/src/test/java/org/apache/geode/cache/lucene/LuceneQueriesPeerPRRedundancyDUnitTest.java +++ b/geode-lucene/src/test/java/org/apache/geode/cache/lucene/LuceneQueriesPeerPRRedundancyDUnitTest.java @@ -36,6 +36,8 @@ import org.apache.geode.internal.cache.partitioned.BecomePrimaryBucketMessage.Be import org.apache.geode.test.dunit.SerializableRunnableIF; import org.apache.geode.test.dunit.VM; import org.apache.geode.test.junit.categories.DistributedTest; +import org.apache.geode.test.junit.categories.FlakyTest; + import com.jayway.awaitility.Awaitility; import org.junit.Test; @@ -66,6 +68,7 @@ public class LuceneQueriesPeerPRRedundancyDUnitTest extends LuceneQueriesPRBase putEntriesAndValidateResultsWithRedundancy(); } + @Category(FlakyTest.class) // GEODE-1956 @Test public void returnCorrectResultsWhenCloseCacheHappensOnIndexUpdate() throws InterruptedException { dataStore1.invoke(() -> { @@ -80,6 +83,7 @@ public class LuceneQueriesPeerPRRedundancyDUnitTest extends LuceneQueriesPRBase dataStore1.invoke(() -> Awaitility.await().atMost(60, TimeUnit.SECONDS).until(basicGetCache()::isClosed)); } + @Category(FlakyTest.class) // GEODE-1824 @Test public void returnCorrectResultsWhenCloseCacheHappensOnPartialIndexWrite() throws InterruptedException { final DistributedMember member2 = dataStore2.invoke(() -> getCache().getDistributedSystem().getDistributedMember()); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8929e93b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/concurrent/ConcurrentParallelGatewaySenderDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/concurrent/ConcurrentParallelGatewaySenderDUnitTest.java b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/concurrent/ConcurrentParallelGatewaySenderDUnitTest.java index 0ecf810..8adc68c 100644 --- a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/concurrent/ConcurrentParallelGatewaySenderDUnitTest.java +++ b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/concurrent/ConcurrentParallelGatewaySenderDUnitTest.java @@ -25,7 +25,7 @@ import static org.junit.Assert.*; import org.apache.geode.test.dunit.cache.internal.JUnit4CacheTestCase; import org.apache.geode.test.dunit.internal.JUnit4DistributedTestCase; import org.apache.geode.test.junit.categories.DistributedTest; - +import org.apache.geode.test.junit.categories.FlakyTest; import org.apache.geode.cache.EntryExistsException; import org.apache.geode.cache.client.ServerOperationException; import org.apache.geode.cache.wan.GatewaySender.OrderPolicy; @@ -586,6 +586,7 @@ public class ConcurrentParallelGatewaySenderDUnitTest extends WANTestBase { getTestMethodName(), 1000 )); } + @Category(FlakyTest.class) // GEODE-1731 @Test public void testPartitionedParallelPropagationHA() throws Exception { IgnoredException.addIgnoredException(SocketException.class.getName()); // for Connection reset http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8929e93b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/concurrent/ConcurrentParallelGatewaySenderOperation_1_DUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/concurrent/ConcurrentParallelGatewaySenderOperation_1_DUnitTest.java b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/concurrent/ConcurrentParallelGatewaySenderOperation_1_DUnitTest.java index 6b1d6ae..1b02772 100644 --- a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/concurrent/ConcurrentParallelGatewaySenderOperation_1_DUnitTest.java +++ b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/concurrent/ConcurrentParallelGatewaySenderOperation_1_DUnitTest.java @@ -290,6 +290,7 @@ public class ConcurrentParallelGatewaySenderOperation_1_DUnitTest extends WANTes * * @throws Exception */ + @Category(FlakyTest.class) // GEODE-1772 @Test public void testParallelPropagationSenderResumeNegativeScenario() throws Exception { Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8929e93b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/misc/PDXNewWanDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/misc/PDXNewWanDUnitTest.java b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/misc/PDXNewWanDUnitTest.java index df06c49..17ee8d3 100644 --- a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/misc/PDXNewWanDUnitTest.java +++ b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/misc/PDXNewWanDUnitTest.java @@ -25,7 +25,7 @@ import static org.junit.Assert.*; import org.apache.geode.test.dunit.cache.internal.JUnit4CacheTestCase; import org.apache.geode.test.dunit.internal.JUnit4DistributedTestCase; import org.apache.geode.test.junit.categories.DistributedTest; - +import org.apache.geode.test.junit.categories.FlakyTest; import org.apache.geode.internal.cache.wan.WANTestBase; import org.apache.geode.test.dunit.IgnoredException; import org.apache.geode.test.dunit.Wait; @@ -639,6 +639,7 @@ public class PDXNewWanDUnitTest extends WANTestBase{ } + @Category(FlakyTest.class) // GEODE-1319 @Test public void testWANPDX_RR_SerialSenderWithFilter() { Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8929e93b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/misc/WanAutoDiscoveryDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/misc/WanAutoDiscoveryDUnitTest.java b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/misc/WanAutoDiscoveryDUnitTest.java index ed22ee9..8956d51 100644 --- a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/misc/WanAutoDiscoveryDUnitTest.java +++ b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/misc/WanAutoDiscoveryDUnitTest.java @@ -25,6 +25,7 @@ import static org.junit.Assert.*; import org.apache.geode.test.dunit.cache.internal.JUnit4CacheTestCase; import org.apache.geode.test.dunit.internal.JUnit4DistributedTestCase; import org.apache.geode.test.junit.categories.DistributedTest; +import org.apache.geode.test.junit.categories.FlakyTest; import java.net.InetSocketAddress; import java.util.ArrayList; @@ -227,6 +228,7 @@ public class WanAutoDiscoveryDUnitTest extends WANTestBase { vm2.invoke(() -> WANTestBase.checkAllSiteMetaData( dsVsPort )); } + @Category(FlakyTest.class) // GEODE-1920 @Test public void test_NY_Recognises_TK_AND_HK_Simultaneously() { Map<Integer, Set<InetSocketAddress>> dsVsPort = new HashMap<>(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8929e93b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANPersistenceEnabledGatewaySenderDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANPersistenceEnabledGatewaySenderDUnitTest.java b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANPersistenceEnabledGatewaySenderDUnitTest.java index 11465c4..45de562 100644 --- a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANPersistenceEnabledGatewaySenderDUnitTest.java +++ b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANPersistenceEnabledGatewaySenderDUnitTest.java @@ -25,6 +25,7 @@ import static org.junit.Assert.*; import org.apache.geode.test.dunit.cache.internal.JUnit4CacheTestCase; import org.apache.geode.test.dunit.internal.JUnit4DistributedTestCase; import org.apache.geode.test.junit.categories.DistributedTest; +import org.apache.geode.test.junit.categories.FlakyTest; import java.io.IOException; @@ -140,6 +141,7 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends WANTest /** * Enable persistence for the GatewaySender but not the region */ + @Category(FlakyTest.class) // GEODE-1670 @Test public void testPartitionedRegionWithPersistentGatewaySender() { Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8929e93b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANPropagationDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANPropagationDUnitTest.java b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANPropagationDUnitTest.java index af35fc0..3836098 100644 --- a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANPropagationDUnitTest.java +++ b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANPropagationDUnitTest.java @@ -498,7 +498,7 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase { getTestMethodName()+"_child2", 0 )); } - + @Category(FlakyTest.class) // GEODE-1312 @Test public void testParallelPropagationWithOverflow() throws Exception { Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8929e93b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANStatsDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANStatsDUnitTest.java b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANStatsDUnitTest.java index 69ff931..4a68608 100644 --- a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANStatsDUnitTest.java +++ b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANStatsDUnitTest.java @@ -224,6 +224,7 @@ public class ParallelWANStatsDUnitTest extends WANTestBase{ vm3.invoke(() -> WANTestBase.checkGatewayReceiverStats(10, NUM_PUTS, NUM_PUTS )); } + @Category(FlakyTest.class) // GEODE-1384 @Test public void testParallelPropagationHA() throws Exception { Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8929e93b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/serial/SerialWANPropagationDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/serial/SerialWANPropagationDUnitTest.java b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/serial/SerialWANPropagationDUnitTest.java index 2a683cf..52cd25f 100644 --- a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/serial/SerialWANPropagationDUnitTest.java +++ b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/serial/SerialWANPropagationDUnitTest.java @@ -527,6 +527,7 @@ public class SerialWANPropagationDUnitTest extends WANTestBase { getTestMethodName() + "_RR_1", 1000 )); } + @Category(FlakyTest.class) // GEODE-1804 @Test public void testReplicatedSerialPropagationWithRemoteRegionDestroy3() throws Exception { @@ -624,6 +625,7 @@ public class SerialWANPropagationDUnitTest extends WANTestBase { * receiver configured on remote site. Puts to the local region are in progress. * Receiver on remote site is stopped in the middle by closing remote site cache. */ + @Category(FlakyTest.class) // GEODE-1552 @Test public void testReplicatedSerialPropagationWithRemoteReceiverStopped() throws Exception { Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); @@ -962,7 +964,8 @@ public class SerialWANPropagationDUnitTest extends WANTestBase { vm3.invoke(() -> WANTestBase.checkMinimumGatewayReceiverStats( 1, 1 )); vm3.invoke(() -> WANTestBase.validateRegionSize(getTestMethodName() + "_RR_1", 8000)); } - + + @Category(FlakyTest.class) // GEODE-1364, 1478 @Test public void testReplicatedSerialPropagationToTwoWanSites() throws Exception { Integer lnPort = createFirstLocatorWithDSId(1); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8929e93b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/serial/SerialWANPropagationLoopBackDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/serial/SerialWANPropagationLoopBackDUnitTest.java b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/serial/SerialWANPropagationLoopBackDUnitTest.java index c140f41..42062af 100644 --- a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/serial/SerialWANPropagationLoopBackDUnitTest.java +++ b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/serial/SerialWANPropagationLoopBackDUnitTest.java @@ -134,6 +134,7 @@ public class SerialWANPropagationLoopBackDUnitTest extends WANTestBase { assertEquals(1, createList2.size()); } + @Category(FlakyTest.class) // GEODE-1148 @Test public void testReplicatedSerialPropagationLoopBack3SitesLoop() throws Exception { Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8929e93b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/serial/SerialWANPropagation_PartitionedRegionDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/serial/SerialWANPropagation_PartitionedRegionDUnitTest.java b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/serial/SerialWANPropagation_PartitionedRegionDUnitTest.java index 0b361fa..db2dcfe 100644 --- a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/serial/SerialWANPropagation_PartitionedRegionDUnitTest.java +++ b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/serial/SerialWANPropagation_PartitionedRegionDUnitTest.java @@ -368,6 +368,7 @@ public class SerialWANPropagation_PartitionedRegionDUnitTest extends WANTestBase getTestMethodName() + "_PR", 1000 )); } + @Category(FlakyTest.class) // GEODE-1147 @Test public void testPartitionedSerialPropagationWithParallelThreads() throws Exception { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8929e93b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/serial/SerialWANStatsDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/serial/SerialWANStatsDUnitTest.java b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/serial/SerialWANStatsDUnitTest.java index 8872341..4db4890 100644 --- a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/serial/SerialWANStatsDUnitTest.java +++ b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/serial/SerialWANStatsDUnitTest.java @@ -22,6 +22,7 @@ import org.junit.Test; import static org.junit.Assert.*; import org.apache.geode.test.junit.categories.DistributedTest; +import org.apache.geode.test.junit.categories.FlakyTest; import static org.apache.geode.test.dunit.Wait.*; import static org.apache.geode.test.dunit.IgnoredException.*; @@ -381,6 +382,7 @@ public class SerialWANStatsDUnitTest extends WANTestBase { * * @throws Exception */ + @Category(FlakyTest.class) // GEODE-1353 @Test public void testReplicatedSerialPropagationWithRemoteRegionDestroy() throws Exception { int numEntries = 20000; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8929e93b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/wancommand/WanCommandCreateGatewayReceiverDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/wancommand/WanCommandCreateGatewayReceiverDUnitTest.java b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/wancommand/WanCommandCreateGatewayReceiverDUnitTest.java index e280863..30184f5 100644 --- a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/wancommand/WanCommandCreateGatewayReceiverDUnitTest.java +++ b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/wancommand/WanCommandCreateGatewayReceiverDUnitTest.java @@ -25,6 +25,7 @@ import org.apache.geode.management.internal.cli.result.TabularResultData; import org.apache.geode.test.dunit.Host; import org.apache.geode.test.dunit.VM; import org.apache.geode.test.junit.categories.DistributedTest; +import org.apache.geode.test.junit.categories.FlakyTest; import org.junit.Test; import org.junit.experimental.categories.Category; @@ -398,6 +399,7 @@ public class WanCommandCreateGatewayReceiverDUnitTest extends WANCommandTestBase /** * GatewayReceiver with given attributes on multiple members. */ + @Category(FlakyTest.class) // GEODE-1355 @Test public void testCreateGatewayReceiver_onMultipleMembers() { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8929e93b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/wancommand/WanCommandGatewayReceiverStartDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/wancommand/WanCommandGatewayReceiverStartDUnitTest.java b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/wancommand/WanCommandGatewayReceiverStartDUnitTest.java index 3c875d9..0e330c6 100644 --- a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/wancommand/WanCommandGatewayReceiverStartDUnitTest.java +++ b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/wancommand/WanCommandGatewayReceiverStartDUnitTest.java @@ -24,6 +24,7 @@ import org.apache.geode.management.internal.cli.result.TabularResultData; import org.apache.geode.test.dunit.Host; import org.apache.geode.test.dunit.VM; import org.apache.geode.test.junit.categories.DistributedTest; +import org.apache.geode.test.junit.categories.FlakyTest; import org.junit.Test; import org.junit.experimental.categories.Category; @@ -78,6 +79,7 @@ public class WanCommandGatewayReceiverStartDUnitTest extends WANCommandTestBase } } + @Category(FlakyTest.class) // GEODE-1448 @Test public void testStartGatewayReceiver() { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8929e93b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/wancommand/WanCommandGatewayReceiverStopDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/wancommand/WanCommandGatewayReceiverStopDUnitTest.java b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/wancommand/WanCommandGatewayReceiverStopDUnitTest.java index 5bb3b59..8441bcc 100644 --- a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/wancommand/WanCommandGatewayReceiverStopDUnitTest.java +++ b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/wancommand/WanCommandGatewayReceiverStopDUnitTest.java @@ -24,6 +24,7 @@ import org.apache.geode.management.internal.cli.result.TabularResultData; import org.apache.geode.test.dunit.Host; import org.apache.geode.test.dunit.VM; import org.apache.geode.test.junit.categories.DistributedTest; +import org.apache.geode.test.junit.categories.FlakyTest; import org.junit.Test; import org.junit.experimental.categories.Category; @@ -79,6 +80,7 @@ public class WanCommandGatewayReceiverStopDUnitTest extends WANCommandTestBase { } } + @Category(FlakyTest.class) // GEODE-1418 @Test public void testStopGatewayReceiver() { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8929e93b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/wancommand/WanCommandStatusDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/wancommand/WanCommandStatusDUnitTest.java b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/wancommand/WanCommandStatusDUnitTest.java index deae963..55beb71 100644 --- a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/wancommand/WanCommandStatusDUnitTest.java +++ b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/wancommand/WanCommandStatusDUnitTest.java @@ -23,6 +23,7 @@ import org.apache.geode.management.internal.cli.result.CommandResult; import org.apache.geode.management.internal.cli.result.CompositeResultData; import org.apache.geode.management.internal.cli.result.TabularResultData; import org.apache.geode.test.junit.categories.DistributedTest; +import org.apache.geode.test.junit.categories.FlakyTest; import org.junit.Test; import org.junit.experimental.categories.Category; @@ -402,6 +403,7 @@ public class WanCommandStatusDUnitTest extends WANCommandTestBase{ } } + @Category(FlakyTest.class) // GEODE-1395 @Test public void testGatewayReceiverStatus_OnMember(){ http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8929e93b/geode-wan/src/test/java/org/apache/geode/management/WANManagementDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/org/apache/geode/management/WANManagementDUnitTest.java b/geode-wan/src/test/java/org/apache/geode/management/WANManagementDUnitTest.java index a2fb68a..76c1abb 100644 --- a/geode-wan/src/test/java/org/apache/geode/management/WANManagementDUnitTest.java +++ b/geode-wan/src/test/java/org/apache/geode/management/WANManagementDUnitTest.java @@ -24,6 +24,7 @@ import static org.junit.Assert.*; import org.apache.geode.test.dunit.cache.internal.JUnit4CacheTestCase; import org.apache.geode.test.dunit.internal.JUnit4DistributedTestCase; import org.apache.geode.test.junit.categories.DistributedTest; +import org.apache.geode.test.junit.categories.FlakyTest; import java.util.Map; @@ -118,6 +119,7 @@ public class WANManagementDUnitTest extends ManagementTestBase { } + @Category(FlakyTest.class) // GEODE-1603 @Test public void testReceiverMBean() throws Exception { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8929e93b/geode-wan/src/test/java/org/apache/geode/management/internal/configuration/ClusterConfigurationDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/org/apache/geode/management/internal/configuration/ClusterConfigurationDUnitTest.java b/geode-wan/src/test/java/org/apache/geode/management/internal/configuration/ClusterConfigurationDUnitTest.java index 432525f..7740f0b 100644 --- a/geode-wan/src/test/java/org/apache/geode/management/internal/configuration/ClusterConfigurationDUnitTest.java +++ b/geode-wan/src/test/java/org/apache/geode/management/internal/configuration/ClusterConfigurationDUnitTest.java @@ -51,6 +51,7 @@ import org.apache.geode.test.dunit.SerializableCallable; import org.apache.geode.test.dunit.VM; import org.apache.geode.test.dunit.WaitCriterion; import org.apache.geode.test.junit.categories.DistributedTest; +import org.apache.geode.test.junit.categories.FlakyTest; import org.junit.Ignore; import org.junit.Test; import org.junit.experimental.categories.Category; @@ -113,6 +114,7 @@ public class ClusterConfigurationDUnitTest extends CliCommandTestBase { jarFileNames.clear(); } + @Category(FlakyTest.class) // GEODE-1335 @Test public void testConfigDistribution() throws Exception { addIgnoredException("could not get remote locator"); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8929e93b/geode-wan/src/test/java/org/apache/geode/management/internal/pulse/TestRemoteClusterDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/org/apache/geode/management/internal/pulse/TestRemoteClusterDUnitTest.java b/geode-wan/src/test/java/org/apache/geode/management/internal/pulse/TestRemoteClusterDUnitTest.java index ff12811..723d7f8 100644 --- a/geode-wan/src/test/java/org/apache/geode/management/internal/pulse/TestRemoteClusterDUnitTest.java +++ b/geode-wan/src/test/java/org/apache/geode/management/internal/pulse/TestRemoteClusterDUnitTest.java @@ -24,6 +24,7 @@ import static org.junit.Assert.*; import org.apache.geode.test.dunit.cache.internal.JUnit4CacheTestCase; import org.apache.geode.test.dunit.internal.JUnit4DistributedTestCase; import org.apache.geode.test.junit.categories.DistributedTest; +import org.apache.geode.test.junit.categories.FlakyTest; import java.util.Map; @@ -68,6 +69,7 @@ public class TestRemoteClusterDUnitTest extends ManagementTestBase { super(); } + @Category(FlakyTest.class) // GEODE-1629 @Test public void testMBeanCallback() throws Exception {
