You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@falcon.apache.org by ar...@apache.org on 2014/08/28 19:11:28 UTC
git commit: FALCON-641 Tests using LateDataBundles should stop using
root dir. Contributed by Raghav Kumar Gautam
Repository: incubator-falcon
Updated Branches:
refs/heads/FALCON-585 577d47f37 -> 92e46b009
FALCON-641 Tests using LateDataBundles should stop using root dir. Contributed by Raghav Kumar Gautam
Project: http://git-wip-us.apache.org/repos/asf/incubator-falcon/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-falcon/commit/92e46b00
Tree: http://git-wip-us.apache.org/repos/asf/incubator-falcon/tree/92e46b00
Diff: http://git-wip-us.apache.org/repos/asf/incubator-falcon/diff/92e46b00
Branch: refs/heads/FALCON-585
Commit: 92e46b009cc88551cf65ce7b990ee1ca52faf9f3
Parents: 577d47f
Author: arpit <ar...@apache.org>
Authored: Thu Aug 28 10:11:19 2014 -0700
Committer: arpit <ar...@apache.org>
Committed: Thu Aug 28 10:11:19 2014 -0700
----------------------------------------------------------------------
falcon-regression/CHANGES.txt | 7 ++++---
.../org/apache/falcon/regression/core/util/BundleUtil.java | 4 ++--
.../falcon/regression/prism/PrismClusterDeleteTest.java | 3 ++-
.../apache/falcon/regression/prism/PrismFeedResumeTest.java | 3 ++-
.../apache/falcon/regression/prism/PrismFeedScheduleTest.java | 3 ++-
.../falcon/regression/prism/PrismProcessDeleteTest.java | 2 +-
.../falcon/regression/prism/PrismProcessResumeTest.java | 3 ++-
.../falcon/regression/prism/PrismProcessScheduleTest.java | 3 ++-
.../apache/falcon/regression/prism/PrismProcessSnSTest.java | 3 ++-
.../falcon/regression/prism/PrismProcessSuspendTest.java | 3 ++-
10 files changed, 21 insertions(+), 13 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-falcon/blob/92e46b00/falcon-regression/CHANGES.txt
----------------------------------------------------------------------
diff --git a/falcon-regression/CHANGES.txt b/falcon-regression/CHANGES.txt
index ff4ddcc..2e2b447 100644
--- a/falcon-regression/CHANGES.txt
+++ b/falcon-regression/CHANGES.txt
@@ -7,14 +7,15 @@ Trunk (Unreleased)
NEW FEATURES
IMPROVEMENTS
-
- FALCON-633 RetryTests and Retentions tests should stop using root dir
- (Raghav Kumar Gautam via Samarth Gupta)
FALCON-629 Add javadoc for method stitchTwoHdfsPaths (Raghav Kumar Gautam
via Samarth Gupta)
FALCON-585 Remove requirement to have write access to / (Raghav Kumar Gautam)
+ FALCON-641 Tests using LateDataBundles should stop using root dir (Raghav
+ Kumar Gautam via Arpit Gupta)
+ FALCON-633 RetryTests and Retentions tests should stop using root dir
+ (Raghav Kumar Gautam via Samarth Gupta)
FALCON-606 hcat tests should stop using root dir (Raghav Kumar Gautam
via Arpit Gupta)
http://git-wip-us.apache.org/repos/asf/incubator-falcon/blob/92e46b00/falcon-regression/merlin-core/src/main/java/org/apache/falcon/regression/core/util/BundleUtil.java
----------------------------------------------------------------------
diff --git a/falcon-regression/merlin-core/src/main/java/org/apache/falcon/regression/core/util/BundleUtil.java b/falcon-regression/merlin-core/src/main/java/org/apache/falcon/regression/core/util/BundleUtil.java
index ca3a3d3..6463af2 100644
--- a/falcon-regression/merlin-core/src/main/java/org/apache/falcon/regression/core/util/BundleUtil.java
+++ b/falcon-regression/merlin-core/src/main/java/org/apache/falcon/regression/core/util/BundleUtil.java
@@ -44,8 +44,8 @@ public final class BundleUtil {
}
private static final Logger LOGGER = Logger.getLogger(BundleUtil.class);
- public static Bundle readLateDataBundle() throws IOException {
- return readBundleFromFolder("LateDataBundles");
+ public static Bundle readLateDataBundle(String appPath, String testName) throws IOException {
+ return generateBundleFromTemplate("LateDataBundles", appPath, testName);
}
public static Bundle readRetryBundle(String appPath, String testName) throws IOException {
http://git-wip-us.apache.org/repos/asf/incubator-falcon/blob/92e46b00/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismClusterDeleteTest.java
----------------------------------------------------------------------
diff --git a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismClusterDeleteTest.java b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismClusterDeleteTest.java
index 24af96e..24f0068 100644
--- a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismClusterDeleteTest.java
+++ b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismClusterDeleteTest.java
@@ -55,7 +55,8 @@ public class PrismClusterDeleteTest extends BaseTestClass {
public void setUp(Method method) throws Exception {
logger.info("test name: " + method.getName());
restartRequired = false;
- Bundle bundle = BundleUtil.readLateDataBundle();
+ Bundle bundle = BundleUtil.readLateDataBundle(baseAppHDFSDir,
+ this.getClass().getSimpleName());
bundles[0] = new Bundle(bundle, cluster1);
bundles[0].generateUniqueBundle();
bundles[0].setProcessWorkflow(aggregateWorkflowDir);
http://git-wip-us.apache.org/repos/asf/incubator-falcon/blob/92e46b00/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismFeedResumeTest.java
----------------------------------------------------------------------
diff --git a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismFeedResumeTest.java b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismFeedResumeTest.java
index 4c82baf..f137204 100644
--- a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismFeedResumeTest.java
+++ b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismFeedResumeTest.java
@@ -56,7 +56,8 @@ public class PrismFeedResumeTest extends BaseTestClass {
@BeforeMethod(alwaysRun = true)
public void testName(Method method) throws Exception {
logger.info("test name: " + method.getName());
- Bundle bundle = BundleUtil.readLateDataBundle();
+ Bundle bundle = BundleUtil.readLateDataBundle(baseAppHDFSDir,
+ this.getClass().getSimpleName());
for (int i = 0; i < 2; i++) {
bundles[i] = new Bundle(bundle, servers.get(i));
http://git-wip-us.apache.org/repos/asf/incubator-falcon/blob/92e46b00/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 dc82c39..d7181ff 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
@@ -53,7 +53,8 @@ public class PrismFeedScheduleTest extends BaseTestClass {
@BeforeMethod(alwaysRun = true)
public void setUp(Method method) throws IOException {
logger.info("test name: " + method.getName());
- Bundle bundle = BundleUtil.readLateDataBundle();
+ Bundle bundle = BundleUtil.readLateDataBundle(baseAppHDFSDir,
+ this.getClass().getSimpleName());
for (int i = 0; i < 2; i++) {
bundles[i] = new Bundle(bundle, servers.get(i));
http://git-wip-us.apache.org/repos/asf/incubator-falcon/blob/92e46b00/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismProcessDeleteTest.java
----------------------------------------------------------------------
diff --git a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismProcessDeleteTest.java b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismProcessDeleteTest.java
index 1fe768a..1adcf8d 100644
--- a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismProcessDeleteTest.java
+++ b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismProcessDeleteTest.java
@@ -59,7 +59,7 @@ public class PrismProcessDeleteTest extends BaseTestClass {
@BeforeMethod(alwaysRun = true)
public void setUp(Method method) throws Exception {
logger.info("test name: " + method.getName());
- bundle = BundleUtil.readLateDataBundle();
+ bundle = BundleUtil.readLateDataBundle(baseAppHDFSDir, this.getClass().getSimpleName());
for (int i = 0; i < 2; i++) {
bundles[i] = new Bundle(bundle, servers.get(i));
bundles[i].generateUniqueBundle();
http://git-wip-us.apache.org/repos/asf/incubator-falcon/blob/92e46b00/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismProcessResumeTest.java
----------------------------------------------------------------------
diff --git a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismProcessResumeTest.java b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismProcessResumeTest.java
index 2e0fbaf..5bc9dcf 100644
--- a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismProcessResumeTest.java
+++ b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismProcessResumeTest.java
@@ -55,7 +55,8 @@ public class PrismProcessResumeTest extends BaseTestClass {
@BeforeMethod(alwaysRun = true)
public void setUp(Method method) throws Exception {
logger.info("test name: " + method.getName());
- Bundle bundle = BundleUtil.readLateDataBundle();
+ Bundle bundle = BundleUtil.readLateDataBundle(baseAppHDFSDir,
+ this.getClass().getSimpleName());
for (int i = 0; i < 2; i++) {
bundles[i] = new Bundle(bundle, servers.get(i));
bundles[i].generateUniqueBundle();
http://git-wip-us.apache.org/repos/asf/incubator-falcon/blob/92e46b00/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismProcessScheduleTest.java
----------------------------------------------------------------------
diff --git a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismProcessScheduleTest.java b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismProcessScheduleTest.java
index 319363c..571c657 100644
--- a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismProcessScheduleTest.java
+++ b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismProcessScheduleTest.java
@@ -61,7 +61,8 @@ public class PrismProcessScheduleTest extends BaseTestClass {
@BeforeMethod(alwaysRun = true)
public void setUp(Method method) throws Exception {
logger.info("test name: " + method.getName());
- Bundle bundle = BundleUtil.readLateDataBundle();
+ Bundle bundle = BundleUtil.readLateDataBundle(baseAppHDFSDir,
+ this.getClass().getSimpleName());
for (int i = 0; i < 2; i++) {
bundles[i] = new Bundle(bundle, servers.get(i));
bundles[i].generateUniqueBundle();
http://git-wip-us.apache.org/repos/asf/incubator-falcon/blob/92e46b00/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 efa5b8f..5edce4b 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
@@ -57,7 +57,8 @@ public class PrismProcessSnSTest extends BaseTestClass {
@BeforeMethod(alwaysRun = true)
public void setUp(Method method) throws Exception {
logger.info("test name: " + method.getName());
- Bundle bundle = BundleUtil.readLateDataBundle();
+ Bundle bundle = BundleUtil.readLateDataBundle(baseAppHDFSDir,
+ this.getClass().getSimpleName());
for (int i = 0; i < 2; i++) {
bundles[i] = new Bundle(bundle, servers.get(i));
bundles[i].generateUniqueBundle();
http://git-wip-us.apache.org/repos/asf/incubator-falcon/blob/92e46b00/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismProcessSuspendTest.java
----------------------------------------------------------------------
diff --git a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismProcessSuspendTest.java b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismProcessSuspendTest.java
index e77ae13..66861ec 100644
--- a/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismProcessSuspendTest.java
+++ b/falcon-regression/merlin/src/test/java/org/apache/falcon/regression/prism/PrismProcessSuspendTest.java
@@ -57,7 +57,8 @@ public class PrismProcessSuspendTest extends BaseTestClass {
public void setUp(Method method) throws Exception {
logger.info("test name: " + method.getName());
restartRequired = false;
- Bundle bundle = BundleUtil.readLateDataBundle();
+ Bundle bundle = BundleUtil.readLateDataBundle(baseAppHDFSDir,
+ this.getClass().getSimpleName());
for (int i = 0; i < 2; i++) {
bundles[i] = new Bundle(bundle, servers.get(i));
bundles[i].generateUniqueBundle();