Repository: falcon
Updated Branches:
  refs/heads/0.10 641d57afa -> b4b32daa1


FALCON-1931 : Adding multiCluster tag for Multiple Cluster scenarios

In the regression test suite, there are lot of places multiCluster annotation 
has been defined to denote it uses multiple cluster. It is very useful 
annotation since we require additional cluster and setup to test the test case 
. Some of the major test cases such as feed replication and Hive DR are missing 
this annotation.

Author: Murali Ramasami <[email protected]>
Author: Murali Ramasami <[email protected]>

Reviewers: "Raghav Gautam <[email protected]>"

Closes #123 from muraliramasami/multiClusterTag

(cherry picked from commit 7dab15f0036c56c06a29d36a5df0527823a930f8)
Signed-off-by: Sowmya Ramesh <[email protected]>


Project: http://git-wip-us.apache.org/repos/asf/falcon/repo
Commit: http://git-wip-us.apache.org/repos/asf/falcon/commit/b4b32daa
Tree: http://git-wip-us.apache.org/repos/asf/falcon/tree/b4b32daa
Diff: http://git-wip-us.apache.org/repos/asf/falcon/diff/b4b32daa

Branch: refs/heads/0.10
Commit: b4b32daa181fa4e33b57de52f89f2934c3501545
Parents: 641d57a
Author: Murali Ramasami <murali dot msse at gmail dot com>
Authored: Thu Jun 23 13:48:38 2016 -0700
Committer: Sowmya Ramesh <[email protected]>
Committed: Thu Jun 23 13:48:50 2016 -0700

----------------------------------------------------------------------
 .../java/org/apache/falcon/regression/FeedLateRerunTest.java | 2 +-
 .../org/apache/falcon/regression/FeedReplicationTest.java    | 2 +-
 .../org/apache/falcon/regression/InstanceSummaryTest.java    | 4 ++--
 .../falcon/regression/ProcessInstanceColoMixedTest.java      | 2 +-
 .../falcon/regression/hcat/HCatFeedOperationsTest.java       | 8 ++++----
 .../apache/falcon/regression/hcat/HCatReplicationTest.java   | 2 +-
 .../org/apache/falcon/regression/hive/dr/HdfsRecipeTest.java | 2 +-
 .../org/apache/falcon/regression/hive/dr/HiveDRTest.java     | 2 +-
 .../org/apache/falcon/regression/hive/dr/HiveDbDRTest.java   | 2 +-
 .../apache/falcon/regression/lineage/EntitySummaryTest.java  | 2 +-
 .../falcon/regression/lineage/ListFeedInstancesTest.java     | 2 +-
 .../regression/nativeScheduler/NativeScheduleTest.java       | 2 +-
 .../regression/prism/PrismFeedReplicationUpdateTest.java     | 2 +-
 .../falcon/regression/prism/PrismFeedScheduleTest.java       | 2 +-
 .../apache/falcon/regression/prism/PrismFeedUpdateTest.java  | 2 +-
 .../apache/falcon/regression/prism/PrismProcessSnSTest.java  | 8 ++++----
 .../org/apache/falcon/regression/searchUI/MirrorTest.java    | 2 +-
 17 files changed, 24 insertions(+), 24 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/falcon/blob/b4b32daa/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/FeedLateRerunTest.java
----------------------------------------------------------------------
diff --git 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/FeedLateRerunTest.java
 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/FeedLateRerunTest.java
index ec2b877..6405b30 100644
--- 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/FeedLateRerunTest.java
+++ 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/FeedLateRerunTest.java
@@ -56,7 +56,7 @@ import java.util.List;
  * On adding further late data it checks whether the data has been replicated 
correctly in the given late cut-off time.
  * Assuming that late frequency set in server is 3 minutes. Although value can 
be changed according to requirement.
  */
-@Test(groups = { "distributed", "embedded", "sanity" })
+@Test(groups = { "distributed", "embedded", "sanity", "multiCluster" })
 public class FeedLateRerunTest extends BaseTestClass {
 
     private ColoHelper cluster1 = servers.get(0);

http://git-wip-us.apache.org/repos/asf/falcon/blob/b4b32daa/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/FeedReplicationTest.java
----------------------------------------------------------------------
diff --git 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/FeedReplicationTest.java
 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/FeedReplicationTest.java
index dad0dc2..3367817 100644
--- 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/FeedReplicationTest.java
+++ 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/FeedReplicationTest.java
@@ -60,7 +60,7 @@ import java.util.Map;
  * feed replication test.
  * Replicates empty directories as well as directories containing data.
  */
-@Test(groups = { "distributed", "embedded", "sanity" })
+@Test(groups = { "distributed", "embedded", "sanity", "multiCluster" })
 public class FeedReplicationTest extends BaseTestClass {
 
     private ColoHelper cluster1 = servers.get(0);

http://git-wip-us.apache.org/repos/asf/falcon/blob/b4b32daa/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/InstanceSummaryTest.java
----------------------------------------------------------------------
diff --git 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/InstanceSummaryTest.java
 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/InstanceSummaryTest.java
index df1716f..dbb93eb 100644
--- 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/InstanceSummaryTest.java
+++ 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/InstanceSummaryTest.java
@@ -173,7 +173,7 @@ public class InstanceSummaryTest extends BaseTestClass {
     /**
      * Adjust multi-cluster process. Submit and schedule it. Get its instances 
summary.
      */
-    @Test(enabled = true, timeOut = 1200000)
+    @Test(enabled = true, timeOut = 1200000, groups = "multiCluster")
     public void testSummaryMultiClusterProcess() throws JAXBException,
             ParseException, IOException, URISyntaxException, 
AuthenticationException,
             InterruptedException {
@@ -208,7 +208,7 @@ public class InstanceSummaryTest extends BaseTestClass {
     /**
      *  Adjust multi-cluster feed. Submit and schedule it. Get its instances 
summary.
      */
-    @Test(enabled = true, timeOut = 1200000)
+    @Test(enabled = true, timeOut = 1200000, groups = "multiCluster")
     public void testSummaryMultiClusterFeed() throws JAXBException, 
ParseException, IOException,
             URISyntaxException, OozieClientException, AuthenticationException,
             InterruptedException {

http://git-wip-us.apache.org/repos/asf/falcon/blob/b4b32daa/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/ProcessInstanceColoMixedTest.java
----------------------------------------------------------------------
diff --git 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/ProcessInstanceColoMixedTest.java
 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/ProcessInstanceColoMixedTest.java
index 20f8f46..ce4c903 100644
--- 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/ProcessInstanceColoMixedTest.java
+++ 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/ProcessInstanceColoMixedTest.java
@@ -48,7 +48,7 @@ import java.util.List;
 /**
  * Process instance mixed colo tests.
  */
-@Test(groups = { "distributed", "embedded" })
+@Test(groups = { "distributed", "embedded", "multiCluster" })
 public class ProcessInstanceColoMixedTest extends BaseTestClass {
 
     private final String baseTestHDFSDir = cleanAndGetTestDir();

http://git-wip-us.apache.org/repos/asf/falcon/blob/b4b32daa/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/hcat/HCatFeedOperationsTest.java
----------------------------------------------------------------------
diff --git 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/hcat/HCatFeedOperationsTest.java
 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/hcat/HCatFeedOperationsTest.java
index eb20d7c..db020ec 100644
--- 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/hcat/HCatFeedOperationsTest.java
+++ 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/hcat/HCatFeedOperationsTest.java
@@ -119,7 +119,7 @@ public class HCatFeedOperationsTest extends BaseTestClass {
      *
      * @throws Exception
      */
-    @Test(groups = {"singleCluster"})
+    @Test(groups = {"multiCluster"})
     public void submitFeedWhenTableDoesNotExist() throws Exception {
         Bundle.submitCluster(bundles[1]);
         feed = bundles[1].getInputFeedFromBundle();
@@ -159,7 +159,7 @@ public class HCatFeedOperationsTest extends BaseTestClass {
      *
      * @throws Exception
      */
-    @Test
+    @Test(groups = {"multiCluster"})
     public void 
submitAndScheduleReplicationFeedWhenTableExistsOnSourceAndTarget() throws 
Exception {
         Bundle.submitCluster(bundles[0], bundles[1]);
         final String startDate = "2010-01-01T20:00Z";
@@ -192,7 +192,7 @@ public class HCatFeedOperationsTest extends BaseTestClass {
      *
      * @throws Exception
      */
-    @Test
+    @Test(groups = {"multiCluster"})
     public void suspendAndResumeReplicationFeed() throws Exception {
 
         submitAndScheduleReplicationFeedWhenTableExistsOnSourceAndTarget();
@@ -215,7 +215,7 @@ public class HCatFeedOperationsTest extends BaseTestClass {
      *
      * @throws Exception
      */
-    @Test
+    @Test(groups = {"multiCluster"})
     public void deleteReplicationFeed() throws Exception {
         submitAndScheduleReplicationFeedWhenTableExistsOnSourceAndTarget();
 

http://git-wip-us.apache.org/repos/asf/falcon/blob/b4b32daa/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/hcat/HCatReplicationTest.java
----------------------------------------------------------------------
diff --git 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/hcat/HCatReplicationTest.java
 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/hcat/HCatReplicationTest.java
index a96b17e..6643ce5 100644
--- 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/hcat/HCatReplicationTest.java
+++ 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/hcat/HCatReplicationTest.java
@@ -64,7 +64,7 @@ import java.util.Map;
 /**
  * Tests for replication with hcat.
  */
-@Test(groups = "embedded")
+@Test(groups = {"embedded", "multiCluster"})
 public class HCatReplicationTest extends BaseTestClass {
 
     private static final Logger LOGGER = 
Logger.getLogger(HCatReplicationTest.class);

http://git-wip-us.apache.org/repos/asf/falcon/blob/b4b32daa/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/hive/dr/HdfsRecipeTest.java
----------------------------------------------------------------------
diff --git 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/hive/dr/HdfsRecipeTest.java
 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/hive/dr/HdfsRecipeTest.java
index 4a2d913..07996d5 100644
--- 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/hive/dr/HdfsRecipeTest.java
+++ 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/hive/dr/HdfsRecipeTest.java
@@ -50,7 +50,7 @@ import java.util.List;
 /**
  * Hdfs recipe test.
  */
-@Test(groups = "embedded")
+@Test(groups = {"embedded", "multiCluster"})
 public class HdfsRecipeTest extends BaseTestClass {
     private static final Logger LOGGER = 
Logger.getLogger(HdfsRecipeTest.class);
     private final ColoHelper cluster = servers.get(0);

http://git-wip-us.apache.org/repos/asf/falcon/blob/b4b32daa/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/hive/dr/HiveDRTest.java
----------------------------------------------------------------------
diff --git 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/hive/dr/HiveDRTest.java
 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/hive/dr/HiveDRTest.java
index 4dab0db..7cd71e1 100644
--- 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/hive/dr/HiveDRTest.java
+++ 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/hive/dr/HiveDRTest.java
@@ -65,7 +65,7 @@ import static 
org.apache.falcon.regression.hive.dr.HiveObjectCreator.createVanil
 /**
  * Hive DR Testing.
  */
-@Test(groups = "embedded")
+@Test(groups = {"embedded", "multiCluster"})
 public class HiveDRTest extends BaseTestClass {
     private static final Logger LOGGER = Logger.getLogger(HiveDRTest.class);
     private static final String DB_NAME = "hdr_sdb1";

http://git-wip-us.apache.org/repos/asf/falcon/blob/b4b32daa/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/hive/dr/HiveDbDRTest.java
----------------------------------------------------------------------
diff --git 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/hive/dr/HiveDbDRTest.java
 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/hive/dr/HiveDbDRTest.java
index 5efd69f..e281bee 100644
--- 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/hive/dr/HiveDbDRTest.java
+++ 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/hive/dr/HiveDbDRTest.java
@@ -59,7 +59,7 @@ import static 
org.apache.falcon.regression.hive.dr.HiveObjectCreator.createVanil
 /**
  * Hive DR Testing for Hive database replication.
  */
-@Test(groups = "embedded")
+@Test(groups = {"embedded", "multiCluster"})
 public class HiveDbDRTest extends BaseTestClass {
     private static final Logger LOGGER = Logger.getLogger(HiveDbDRTest.class);
     private final ColoHelper cluster = servers.get(0);

http://git-wip-us.apache.org/repos/asf/falcon/blob/b4b32daa/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/lineage/EntitySummaryTest.java
----------------------------------------------------------------------
diff --git 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/lineage/EntitySummaryTest.java
 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/lineage/EntitySummaryTest.java
index 849f67a..ac91d59 100644
--- 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/lineage/EntitySummaryTest.java
+++ 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/lineage/EntitySummaryTest.java
@@ -128,7 +128,7 @@ public class EntitySummaryTest extends BaseTestClass {
      * Get status of 7 feeds and 7 instances of each feed the call should give 
correct information,
      * instance info must be recent.
      */
-    @Test
+    @Test(groups = "multiCluster")
     public void getFeedSummary() throws Exception {
         //prepare feed template.
         bundles[0].setInputFeedPeriodicity(5, Frequency.TimeUnit.minutes);

http://git-wip-us.apache.org/repos/asf/falcon/blob/b4b32daa/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/lineage/ListFeedInstancesTest.java
----------------------------------------------------------------------
diff --git 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/lineage/ListFeedInstancesTest.java
 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/lineage/ListFeedInstancesTest.java
index 4f86594..93efbac 100644
--- 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/lineage/ListFeedInstancesTest.java
+++ 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/lineage/ListFeedInstancesTest.java
@@ -59,7 +59,7 @@ import java.util.List;
  * expected instance statuses which are being compared with actual result of 
-list request
  * with different parameters in different order, variation, etc.
  */
-@Test(groups = { "distributed", "embedded", "sanity" })
+@Test(groups = { "distributed", "embedded", "sanity", "multiCluster"})
 public class ListFeedInstancesTest extends BaseTestClass {
     private static final Logger LOGGER = 
Logger.getLogger(ListFeedInstancesTest.class);
     private OozieClient cluster2OC = serverOC.get(1);

http://git-wip-us.apache.org/repos/asf/falcon/blob/b4b32daa/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/nativeScheduler/NativeScheduleTest.java
----------------------------------------------------------------------
diff --git 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/nativeScheduler/NativeScheduleTest.java
 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/nativeScheduler/NativeScheduleTest.java
index 54e7805..81e0a7e 100644
--- 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/nativeScheduler/NativeScheduleTest.java
+++ 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/nativeScheduler/NativeScheduleTest.java
@@ -184,7 +184,7 @@ public class NativeScheduleTest extends BaseTestClass {
      * Successfully schedule process via native scheduler through prism and 
server on multiple cluster.
      * Schedule the same process on oozie. It should fail.
      */
-    @Test(groups = {"prism", "0.2"})
+    @Test(groups = {"prism", "0.2", "multiCluster"})
     public void scheduleProcessWithNativeOnTwoClusters() throws Exception {
 
         ProcessMerlin processMerlinNative = bundles[0].getProcessObject();

http://git-wip-us.apache.org/repos/asf/falcon/blob/b4b32daa/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismFeedReplicationUpdateTest.java
----------------------------------------------------------------------
diff --git 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismFeedReplicationUpdateTest.java
 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismFeedReplicationUpdateTest.java
index 405725d..0a5e9ce 100644
--- 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismFeedReplicationUpdateTest.java
+++ 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismFeedReplicationUpdateTest.java
@@ -49,7 +49,7 @@ import java.io.IOException;
 /**
  * Update replication feed tests.
  */
-@Test(groups = { "distributed", "embedded" })
+@Test(groups = { "distributed", "embedded", "multiCluster" })
 public class PrismFeedReplicationUpdateTest extends BaseTestClass {
 
     private ColoHelper cluster1 = servers.get(0);

http://git-wip-us.apache.org/repos/asf/falcon/blob/b4b32daa/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismFeedScheduleTest.java
----------------------------------------------------------------------
diff --git 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismFeedScheduleTest.java
 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismFeedScheduleTest.java
index 137ef6f..1a1dc98 100644
--- 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismFeedScheduleTest.java
+++ 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismFeedScheduleTest.java
@@ -38,7 +38,7 @@ import java.io.IOException;
 /**
  * Schedule feed via prism tests.
  */
-@Test(groups = { "distributed", "embedded" })
+@Test(groups = { "distributed", "embedded", "multiCluster"})
 public class PrismFeedScheduleTest extends BaseTestClass {
 
     private OozieClient cluster1OC = serverOC.get(0);

http://git-wip-us.apache.org/repos/asf/falcon/blob/b4b32daa/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismFeedUpdateTest.java
----------------------------------------------------------------------
diff --git 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismFeedUpdateTest.java
 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismFeedUpdateTest.java
index a5220e3..6caac9f 100644
--- 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismFeedUpdateTest.java
+++ 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismFeedUpdateTest.java
@@ -96,7 +96,7 @@ public class PrismFeedUpdateTest extends BaseTestClass {
      * Set 2 processes with common output feed. Second one is zero-input 
process. Update feed
      * queue. TODO : complete test case
      */
-    @Test(enabled = true, timeOut = 1200000)
+    @Test(enabled = true, timeOut = 1200000 , groups = "multiCluster")
     public void updateFeedQueueDependentMultipleProcessOneProcessZeroInput() 
throws Exception {
         //cluster1colo and cluster2colo are source. feed01 on cluster1colo 
target cluster2colo,
         // feed02 on cluster2colo target cluster1colo

http://git-wip-us.apache.org/repos/asf/falcon/blob/b4b32daa/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismProcessSnSTest.java
----------------------------------------------------------------------
diff --git 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismProcessSnSTest.java
 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismProcessSnSTest.java
index 4aa7189..63f793f 100644
--- 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismProcessSnSTest.java
+++ 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismProcessSnSTest.java
@@ -80,7 +80,7 @@ public class PrismProcessSnSTest extends BaseTestClass {
      * Submit and schedule process2 on cluster2. Check that process2 is 
running and process1 is
      * not running on cluster2.
      */
-    @Test(groups = {"prism", "0.2", "embedded"})
+    @Test(groups = {"prism", "0.2", "embedded", "multiCluster"})
     public void testProcessSnSOnBothColos() throws Exception {
         //schedule both bundles
         bundles[0].submitAndScheduleProcess();
@@ -100,7 +100,7 @@ public class PrismProcessSnSTest extends BaseTestClass {
      * on cluster2. Submit process2 but schedule process1 once more. Check 
that process1 is running
      * on cluster1 but not on cluster2.
      */
-    @Test(groups = {"prism", "0.2", "embedded"})
+    @Test(groups = {"prism", "0.2", "embedded", "multiCluster"})
     public void testProcessSnSForSubmittedProcessOnBothColos() throws 
Exception {
         //schedule both bundles
         bundles[0].submitProcess(true);
@@ -122,7 +122,7 @@ public class PrismProcessSnSTest extends BaseTestClass {
      * once more and check that it is still running on cluster1 but process2 
isn't running on
      * cluster2.
      */
-    @Test(groups = {"prism", "0.2", "embedded"})
+    @Test(groups = {"prism", "0.2", "embedded", "multiCluster"})
     public void testProcessSnSForSubmittedProcessOnBothColosUsingColoHelper()
         throws Exception {
         bundles[0].submitProcess(true);
@@ -228,7 +228,7 @@ public class PrismProcessSnSTest extends BaseTestClass {
      * running. Delete both of them. Submit and schedule them once more. Check 
that they are
      * running again.
      */
-    @Test(groups = {"prism", "0.2", "embedded"})
+    @Test(groups = {"prism", "0.2", "embedded", "multiCluster"})
     public void testSnSDeletedProcessOnBothColos() throws Exception {
         //schedule both bundles
         final String cluster1Running = 
cluster1.getClusterHelper().getColoName() + "/RUNNING";

http://git-wip-us.apache.org/repos/asf/falcon/blob/b4b32daa/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/searchUI/MirrorTest.java
----------------------------------------------------------------------
diff --git 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/searchUI/MirrorTest.java
 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/searchUI/MirrorTest.java
index e99202b..a7887da 100644
--- 
a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/searchUI/MirrorTest.java
+++ 
b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/searchUI/MirrorTest.java
@@ -56,7 +56,7 @@ import java.sql.Connection;
 import java.util.Arrays;
 
 /** UI tests for Mirror Setup Wizard. */
-@Test(groups = "search-ui")
+@Test(groups = {"search-ui", "multiCluster"})
 public class MirrorTest extends BaseUITestClass {
     private static final Logger LOGGER = Logger.getLogger(MirrorTest.class);
     private final String baseTestDir = cleanAndGetTestDir();

Reply via email to