You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@falcon.apache.org by ve...@apache.org on 2014/09/12 22:29:31 UTC
[3/5] FALCON-661 Add list types to Lineage API. Contributed by Balu
Vellanki
http://git-wip-us.apache.org/repos/asf/incubator-falcon/blob/7f98570b/webapp/src/test/java/org/apache/falcon/resource/TestContext.java
----------------------------------------------------------------------
diff --git a/webapp/src/test/java/org/apache/falcon/resource/TestContext.java b/webapp/src/test/java/org/apache/falcon/resource/TestContext.java
index d1b320f..e9545d1 100644
--- a/webapp/src/test/java/org/apache/falcon/resource/TestContext.java
+++ b/webapp/src/test/java/org/apache/falcon/resource/TestContext.java
@@ -387,7 +387,7 @@ public class TestContext {
}
public static void prepare() throws Exception {
- prepare(TestContext.CLUSTER_TEMPLATE);
+ prepare(TestContext.CLUSTER_TEMPLATE, true);
}
private static void mkdir(FileSystem fs, Path path) throws Exception {
@@ -402,14 +402,16 @@ public class TestContext {
}
}
- public static void prepare(String clusterTemplate) throws Exception {
+ public static void prepare(String clusterTemplate, boolean disableLineage) throws Exception {
// setup a logged in user
CurrentUser.authenticate(REMOTE_USER);
- // disable recording lineage metadata if enabled
- String services = StartupProperties.get().getProperty("application.services");
- StartupProperties.get().setProperty("application.services",
- services.replace("org.apache.falcon.metadata.MetadataMappingService", ""));
+ if (disableLineage) {
+ // disable recording lineage metadata
+ String services = StartupProperties.get().getProperty("application.services");
+ StartupProperties.get().setProperty("application.services",
+ services.replace("org.apache.falcon.metadata.MetadataMappingService", ""));
+ }
Map<String, String> overlay = new HashMap<String, String>();
overlay.put("cluster", RandomStringUtils.randomAlphabetic(5));