Repository: incubator-geode Updated Branches: refs/heads/feature/GEODE-1571 b43d0266d -> b37f43932
Removing flaky test label from tests with fixed bugs. Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/49d144bb Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/49d144bb Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/49d144bb Branch: refs/heads/feature/GEODE-1571 Commit: 49d144bb2cf731d4c62fc86715fd8c9e0a680d45 Parents: 7ad9cc9 Author: Dan Smith <upthewatersp...@apache.org> Authored: Tue Jun 21 18:22:51 2016 -0700 Committer: Dan Smith <upthewatersp...@apache.org> Committed: Mon Jun 27 11:58:04 2016 -0700 ---------------------------------------------------------------------- .../java/com/gemstone/gemfire/cache/ConnectionPoolDUnitTest.java | 2 -- .../cache/client/internal/pooling/ConnectionManagerJUnitTest.java | 2 -- .../gemfire/cache/query/dunit/QueryUsingPoolDUnitTest.java | 2 -- .../com/gemstone/gemfire/cache30/ClientMembershipDUnitTest.java | 2 -- .../java/com/gemstone/gemfire/distributed/LocatorDUnitTest.java | 2 -- .../distributed/internal/LocatorLoadSnapshotIntegrationTest.java | 2 -- .../ScheduledThreadPoolExecutorWithKeepAliveJUnitTest.java | 1 - .../gemstone/gemfire/internal/cache/SingleHopStatsDUnitTest.java | 2 -- .../management/UniversalMembershipListenerAdapterDUnitTest.java | 2 -- .../gemfire/cache/query/cq/dunit/CqPerfUsingPoolDUnitTest.java | 2 -- .../management/internal/cli/commands/ClientCommandsDUnitTest.java | 1 - .../gemstone/gemfire/security/ClientAuthzObjectModDUnitTest.java | 2 -- .../com/gemstone/gemfire/cache/CacheXml70GatewayDUnitTest.java | 2 -- .../gemfire/internal/cache/wan/CacheClientNotifierDUnitTest.java | 1 - .../ParallelWANPersistenceEnabledGatewaySenderDUnitTest.java | 2 -- 15 files changed, 27 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/49d144bb/geode-core/src/test/java/com/gemstone/gemfire/cache/ConnectionPoolDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-core/src/test/java/com/gemstone/gemfire/cache/ConnectionPoolDUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/cache/ConnectionPoolDUnitTest.java index 3ae6cf6..fef2171 100755 --- a/geode-core/src/test/java/com/gemstone/gemfire/cache/ConnectionPoolDUnitTest.java +++ b/geode-core/src/test/java/com/gemstone/gemfire/cache/ConnectionPoolDUnitTest.java @@ -72,7 +72,6 @@ import com.gemstone.gemfire.test.dunit.Wait; import com.gemstone.gemfire.test.dunit.WaitCriterion; import com.gemstone.gemfire.test.dunit.cache.internal.JUnit4CacheTestCase; import com.gemstone.gemfire.test.junit.categories.DistributedTest; -import com.gemstone.gemfire.test.junit.categories.FlakyTest; /** * This class tests the client connection pool in GemFire. @@ -1180,7 +1179,6 @@ public class ConnectionPoolDUnitTest extends JUnit4CacheTestCase { * Make sure cnx lifetime expiration working on thread local cnxs. * @author darrel */ - @Category(FlakyTest.class) // GEODE-1197: random ports, BindException, FixMethodOrder, expiration, time sensitive, waitForCriterion, async actions @Test public void test009LifetimeExpireOnTL() throws CacheException { basicTestLifetimeExpire(true); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/49d144bb/geode-core/src/test/java/com/gemstone/gemfire/cache/client/internal/pooling/ConnectionManagerJUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-core/src/test/java/com/gemstone/gemfire/cache/client/internal/pooling/ConnectionManagerJUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/cache/client/internal/pooling/ConnectionManagerJUnitTest.java index 28a5342..861569e 100644 --- a/geode-core/src/test/java/com/gemstone/gemfire/cache/client/internal/pooling/ConnectionManagerJUnitTest.java +++ b/geode-core/src/test/java/com/gemstone/gemfire/cache/client/internal/pooling/ConnectionManagerJUnitTest.java @@ -31,7 +31,6 @@ import com.gemstone.gemfire.internal.logging.LocalLogWriter; import com.gemstone.gemfire.test.dunit.ThreadUtils; import com.gemstone.gemfire.test.dunit.Wait; import com.gemstone.gemfire.test.dunit.WaitCriterion; -import com.gemstone.gemfire.test.junit.categories.FlakyTest; import com.gemstone.gemfire.test.junit.categories.IntegrationTest; import org.junit.After; import org.junit.Assert; @@ -219,7 +218,6 @@ public class ConnectionManagerJUnitTest { // // } - @Category(FlakyTest.class) // GEODE-923: time sensitive, expiration, thread sleeps, wait loop @Test public void testIdleExpiration() throws InterruptedException, AllConnectionsInUseException, NoAvailableServersException { final long nanoToMillis = 1000000; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/49d144bb/geode-core/src/test/java/com/gemstone/gemfire/cache/query/dunit/QueryUsingPoolDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-core/src/test/java/com/gemstone/gemfire/cache/query/dunit/QueryUsingPoolDUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/cache/query/dunit/QueryUsingPoolDUnitTest.java index 4672a94..0d844db 100644 --- a/geode-core/src/test/java/com/gemstone/gemfire/cache/query/dunit/QueryUsingPoolDUnitTest.java +++ b/geode-core/src/test/java/com/gemstone/gemfire/cache/query/dunit/QueryUsingPoolDUnitTest.java @@ -66,7 +66,6 @@ import com.gemstone.gemfire.test.dunit.VM; import com.gemstone.gemfire.test.dunit.Wait; import com.gemstone.gemfire.test.dunit.cache.internal.JUnit4CacheTestCase; import com.gemstone.gemfire.test.junit.categories.DistributedTest; -import com.gemstone.gemfire.test.junit.categories.FlakyTest; import static com.gemstone.gemfire.distributed.ConfigurationProperties.LOCATORS; @@ -1025,7 +1024,6 @@ public class QueryUsingPoolDUnitTest extends JUnit4CacheTestCase { /** * Tests client-server query using parameters (compiled queries). */ - @Category(FlakyTest.class) // GEODE-1146: time senstiive, thread sleeps, uses zero port for servers (good!), async actions, AsyncInvocation orphans @Test public void testBindParamsWithMulitipleClients() throws CacheException { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/49d144bb/geode-core/src/test/java/com/gemstone/gemfire/cache30/ClientMembershipDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-core/src/test/java/com/gemstone/gemfire/cache30/ClientMembershipDUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/cache30/ClientMembershipDUnitTest.java index dc6af7a..39ae008 100755 --- a/geode-core/src/test/java/com/gemstone/gemfire/cache30/ClientMembershipDUnitTest.java +++ b/geode-core/src/test/java/com/gemstone/gemfire/cache30/ClientMembershipDUnitTest.java @@ -67,7 +67,6 @@ import com.gemstone.gemfire.test.dunit.SerializableRunnable; import com.gemstone.gemfire.test.dunit.VM; import com.gemstone.gemfire.test.dunit.Wait; import com.gemstone.gemfire.test.junit.categories.DistributedTest; -import com.gemstone.gemfire.test.junit.categories.FlakyTest; import static com.gemstone.gemfire.distributed.ConfigurationProperties.LOCATORS; import static com.gemstone.gemfire.distributed.ConfigurationProperties.MCAST_PORT; @@ -743,7 +742,6 @@ public class ClientMembershipDUnitTest extends ClientServerTestCase { * server joins when the client connects to the server. If the server * crashes or departs gracefully, the client will detect this as a crash. */ - @Category(FlakyTest.class) // GEODE-1240: eats exceptions, random ports, time sensitive waits @Test public void testClientMembershipEventsInClient() throws Exception { getSystem(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/49d144bb/geode-core/src/test/java/com/gemstone/gemfire/distributed/LocatorDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-core/src/test/java/com/gemstone/gemfire/distributed/LocatorDUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/distributed/LocatorDUnitTest.java index 197a665..5e68b9e 100755 --- a/geode-core/src/test/java/com/gemstone/gemfire/distributed/LocatorDUnitTest.java +++ b/geode-core/src/test/java/com/gemstone/gemfire/distributed/LocatorDUnitTest.java @@ -47,7 +47,6 @@ import com.gemstone.gemfire.internal.logging.InternalLogWriter; import com.gemstone.gemfire.internal.logging.LocalLogWriter; import com.gemstone.gemfire.internal.tcp.Connection; import com.gemstone.gemfire.test.dunit.*; -import com.gemstone.gemfire.test.junit.categories.FlakyTest; import java.io.File; import java.io.IOException; @@ -1438,7 +1437,6 @@ public class LocatorDUnitTest extends JUnit4DistributedTestCase { * end up only have 1 master. * GEODE-870 */ - @Category(FlakyTest.class) // GEODE-1150: random ports, disk pollution, waitForCriterion, time sensitive, eats exceptions (fixed several) @Test public void testMultipleLocatorsRestartingAtSameTime() throws Exception { disconnectAllFromDS(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/49d144bb/geode-core/src/test/java/com/gemstone/gemfire/distributed/internal/LocatorLoadSnapshotIntegrationTest.java ---------------------------------------------------------------------- diff --git a/geode-core/src/test/java/com/gemstone/gemfire/distributed/internal/LocatorLoadSnapshotIntegrationTest.java b/geode-core/src/test/java/com/gemstone/gemfire/distributed/internal/LocatorLoadSnapshotIntegrationTest.java index 08648d9..8b9f5f6 100644 --- a/geode-core/src/test/java/com/gemstone/gemfire/distributed/internal/LocatorLoadSnapshotIntegrationTest.java +++ b/geode-core/src/test/java/com/gemstone/gemfire/distributed/internal/LocatorLoadSnapshotIntegrationTest.java @@ -28,7 +28,6 @@ import org.junit.Test; import org.junit.experimental.categories.Category; import com.gemstone.gemfire.cache.server.ServerLoad; -import com.gemstone.gemfire.test.junit.categories.FlakyTest; import com.gemstone.gemfire.test.junit.categories.IntegrationTest; /** @@ -43,7 +42,6 @@ public class LocatorLoadSnapshotIntegrationTest { * three servers. * @throws InterruptedException */ - @Category(FlakyTest.class) // GEODE-613: lots of threads, async action, IntegrationTest-not-UnitTest, thread joins, time sensitive @Test public void testConcurrentBalancing() throws InterruptedException { int NUM_THREADS = 50; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/49d144bb/geode-core/src/test/java/com/gemstone/gemfire/internal/ScheduledThreadPoolExecutorWithKeepAliveJUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-core/src/test/java/com/gemstone/gemfire/internal/ScheduledThreadPoolExecutorWithKeepAliveJUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/internal/ScheduledThreadPoolExecutorWithKeepAliveJUnitTest.java index 5aaa124..5e645fa 100644 --- a/geode-core/src/test/java/com/gemstone/gemfire/internal/ScheduledThreadPoolExecutorWithKeepAliveJUnitTest.java +++ b/geode-core/src/test/java/com/gemstone/gemfire/internal/ScheduledThreadPoolExecutorWithKeepAliveJUnitTest.java @@ -178,7 +178,6 @@ public class ScheduledThreadPoolExecutorWithKeepAliveJUnitTest { TimeUnit.SECONDS.toNanos(10) <= end - start + SLOP); } - @Category(FlakyTest.class) // GEODE-710: time sensitive, async actions, 5 second thread sleeps @Test public void testRepeatedExecution() throws InterruptedException { ex = new ScheduledThreadPoolExecutorWithKeepAlive( http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/49d144bb/geode-core/src/test/java/com/gemstone/gemfire/internal/cache/SingleHopStatsDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-core/src/test/java/com/gemstone/gemfire/internal/cache/SingleHopStatsDUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/internal/cache/SingleHopStatsDUnitTest.java index ffcca1c..e611086 100644 --- a/geode-core/src/test/java/com/gemstone/gemfire/internal/cache/SingleHopStatsDUnitTest.java +++ b/geode-core/src/test/java/com/gemstone/gemfire/internal/cache/SingleHopStatsDUnitTest.java @@ -54,7 +54,6 @@ import com.gemstone.gemfire.test.dunit.LogWriterUtils; import com.gemstone.gemfire.test.dunit.VM; import com.gemstone.gemfire.test.dunit.cache.internal.JUnit4CacheTestCase; import com.gemstone.gemfire.test.junit.categories.DistributedTest; -import com.gemstone.gemfire.test.junit.categories.FlakyTest; @Category(DistributedTest.class) public class SingleHopStatsDUnitTest extends JUnit4CacheTestCase { @@ -119,7 +118,6 @@ public class SingleHopStatsDUnitTest extends JUnit4CacheTestCase { } } - @Category(FlakyTest.class) // GEODE-364: random ports, time sensitive, waitForCriterions, magic numbers (113, 226) @Test public void testClientStatsPR() { Integer port0 = (Integer) member0.invoke(() -> createServerForStats(0, 113, "No_Colocation")); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/49d144bb/geode-core/src/test/java/com/gemstone/gemfire/management/UniversalMembershipListenerAdapterDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-core/src/test/java/com/gemstone/gemfire/management/UniversalMembershipListenerAdapterDUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/management/UniversalMembershipListenerAdapterDUnitTest.java index 5457ed3..91a6188 100644 --- a/geode-core/src/test/java/com/gemstone/gemfire/management/UniversalMembershipListenerAdapterDUnitTest.java +++ b/geode-core/src/test/java/com/gemstone/gemfire/management/UniversalMembershipListenerAdapterDUnitTest.java @@ -61,7 +61,6 @@ import com.gemstone.gemfire.test.dunit.SerializableRunnable; import com.gemstone.gemfire.test.dunit.VM; import com.gemstone.gemfire.test.dunit.Wait; import com.gemstone.gemfire.test.junit.categories.DistributedTest; -import com.gemstone.gemfire.test.junit.categories.FlakyTest; /** * Tests the UniversalMembershipListenerAdapter. @@ -714,7 +713,6 @@ public class UniversalMembershipListenerAdapterDUnitTest extends ClientServerTes /** * Tests notification of events for loner bridge clients in server process. */ - @Category(FlakyTest.class) // GEODE-1174: random port, async behavior, condition await loops @Test public void testSystemClientEventsInServer() throws Exception { try { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/49d144bb/geode-cq/src/test/java/com/gemstone/gemfire/cache/query/cq/dunit/CqPerfUsingPoolDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-cq/src/test/java/com/gemstone/gemfire/cache/query/cq/dunit/CqPerfUsingPoolDUnitTest.java b/geode-cq/src/test/java/com/gemstone/gemfire/cache/query/cq/dunit/CqPerfUsingPoolDUnitTest.java index 0168419..413230c 100644 --- a/geode-cq/src/test/java/com/gemstone/gemfire/cache/query/cq/dunit/CqPerfUsingPoolDUnitTest.java +++ b/geode-cq/src/test/java/com/gemstone/gemfire/cache/query/cq/dunit/CqPerfUsingPoolDUnitTest.java @@ -54,7 +54,6 @@ import com.gemstone.gemfire.test.dunit.NetworkUtils; import com.gemstone.gemfire.test.dunit.SerializableRunnable; import com.gemstone.gemfire.test.dunit.VM; import com.gemstone.gemfire.test.dunit.Wait; -import com.gemstone.gemfire.test.junit.categories.FlakyTest; /** * This class tests the ContiunousQuery mechanism in GemFire. @@ -412,7 +411,6 @@ public class CqPerfUsingPoolDUnitTest extends JUnit4CacheTestCase { * To test the changes relating to, executing CQ only once for all similar CQs. * @throws Exception */ - @Category(FlakyTest.class) // GEODE-988: random ports, time sensitive, waitForCriterion, 20 second timeouts @Test public void testMatchingCqs() throws Exception { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/49d144bb/geode-cq/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ClientCommandsDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-cq/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ClientCommandsDUnitTest.java b/geode-cq/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ClientCommandsDUnitTest.java index 5947883..4ff4a16 100644 --- a/geode-cq/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ClientCommandsDUnitTest.java +++ b/geode-cq/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ClientCommandsDUnitTest.java @@ -925,7 +925,6 @@ public class ClientCommandsDUnitTest extends CliCommandTestBase { } - @Category(FlakyTest.class) // GEODE-1227: HeadlessGFSH, random ports, BindException @Test public void testDescribeMixClientWithServers() throws Exception { String[] clientIds = setupSystemWithSubAndNonSubClient(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/49d144bb/geode-cq/src/test/java/com/gemstone/gemfire/security/ClientAuthzObjectModDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-cq/src/test/java/com/gemstone/gemfire/security/ClientAuthzObjectModDUnitTest.java b/geode-cq/src/test/java/com/gemstone/gemfire/security/ClientAuthzObjectModDUnitTest.java index 12fdea8..bdba7d7 100644 --- a/geode-cq/src/test/java/com/gemstone/gemfire/security/ClientAuthzObjectModDUnitTest.java +++ b/geode-cq/src/test/java/com/gemstone/gemfire/security/ClientAuthzObjectModDUnitTest.java @@ -29,7 +29,6 @@ import com.gemstone.gemfire.security.generator.DummyAuthzCredentialGenerator; import com.gemstone.gemfire.security.generator.DummyCredentialGenerator; import com.gemstone.gemfire.security.templates.UserPasswordAuthInit; import com.gemstone.gemfire.test.junit.categories.DistributedTest; -import com.gemstone.gemfire.test.junit.categories.FlakyTest; import com.gemstone.gemfire.test.junit.categories.SecurityTest; import org.junit.Test; import org.junit.experimental.categories.Category; @@ -74,7 +73,6 @@ public class ClientAuthzObjectModDUnitTest extends ClientAuthorizationTestCase { server2.invoke("registerInstantiator", () -> Instantiator.register(new MyInstantiator(), false)); } - @Category(FlakyTest.class) // GEODE-1228: random ports, BindException, uses Random @Test public void testAllOpsObjectModWithFailover() throws Exception { OperationWithAction[] allOps = allOps(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/49d144bb/geode-wan/src/test/java/com/gemstone/gemfire/cache/CacheXml70GatewayDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/cache/CacheXml70GatewayDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/cache/CacheXml70GatewayDUnitTest.java index b827ae6..3dfbfe9 100644 --- a/geode-wan/src/test/java/com/gemstone/gemfire/cache/CacheXml70GatewayDUnitTest.java +++ b/geode-wan/src/test/java/com/gemstone/gemfire/cache/CacheXml70GatewayDUnitTest.java @@ -50,7 +50,6 @@ import com.gemstone.gemfire.internal.cache.xmlcache.CacheXml; import com.gemstone.gemfire.internal.cache.xmlcache.ParallelGatewaySenderCreation; import com.gemstone.gemfire.internal.cache.xmlcache.RegionAttributesCreation; import com.gemstone.gemfire.internal.cache.xmlcache.SerialGatewaySenderCreation; -import com.gemstone.gemfire.test.junit.categories.FlakyTest; @Category(DistributedTest.class) public class CacheXml70GatewayDUnitTest extends CacheXmlTestCase { @@ -101,7 +100,6 @@ public class CacheXml70GatewayDUnitTest extends CacheXmlTestCase { } } - @Category(FlakyTest.class) // GEODE-978: hardcoded port range, BindException @Test public void testGatewayReceiver() throws Exception{ getSystem(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/49d144bb/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/CacheClientNotifierDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/CacheClientNotifierDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/CacheClientNotifierDUnitTest.java index 64b1906..24b3a40 100755 --- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/CacheClientNotifierDUnitTest.java +++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/CacheClientNotifierDUnitTest.java @@ -165,7 +165,6 @@ public class CacheClientNotifierDUnitTest extends WANTestBase { * The test will start several cache servers, including gateway receivers. * Shutdown them and verify the CacheClientNotifier for each server is correct */ - @Category(FlakyTest.class) // GEODE-1183: random ports, failure to start threads, eats exceptions, time sensitive @Test public void testNormalClient2MultipleCacheServer() throws Exception { doMultipleCacheServer(false); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/49d144bb/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPersistenceEnabledGatewaySenderDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPersistenceEnabledGatewaySenderDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPersistenceEnabledGatewaySenderDUnitTest.java index 443d592..855856e 100644 --- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPersistenceEnabledGatewaySenderDUnitTest.java +++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPersistenceEnabledGatewaySenderDUnitTest.java @@ -40,7 +40,6 @@ import com.gemstone.gemfire.test.dunit.AsyncInvocation; import com.gemstone.gemfire.test.dunit.IgnoredException; import com.gemstone.gemfire.test.dunit.LogWriterUtils; import com.gemstone.gemfire.test.dunit.SerializableRunnableIF; -import com.gemstone.gemfire.test.junit.categories.FlakyTest; @Category(DistributedTest.class) public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends WANTestBase { @@ -463,7 +462,6 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends WANTest * Dispatcher should not start dispatching events recovered from persistent sender. * Check if the remote site receives all the events. */ - @Category(FlakyTest.class) // GEODE-1124: random ports, time sensitive, waitForCriterion, async behavior @Test public void testPersistentPRWithGatewaySenderPersistenceEnabled_Restart2() { //create locator on local site