Repository: falcon Updated Branches: refs/heads/master 4a9151efc -> d2fd49e5c
http://git-wip-us.apache.org/repos/asf/falcon/blob/d2fd49e5/test-tools/hadoop-webapp/src/versioned-src/v2/java/org/apache/hadoop/mapred/LocalRunnerV2.java ---------------------------------------------------------------------- diff --git a/test-tools/hadoop-webapp/src/versioned-src/v2/java/org/apache/hadoop/mapred/LocalRunnerV2.java b/test-tools/hadoop-webapp/src/versioned-src/v2/java/org/apache/hadoop/mapred/LocalRunnerV2.java new file mode 100644 index 0000000..ccb1bd5 --- /dev/null +++ b/test-tools/hadoop-webapp/src/versioned-src/v2/java/org/apache/hadoop/mapred/LocalRunnerV2.java @@ -0,0 +1,242 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.apache.hadoop.mapred; + +import org.apache.falcon.JobTrackerService; +import org.apache.hadoop.conf.Configuration; +import org.apache.hadoop.io.Text; +import org.apache.hadoop.ipc.ProtocolSignature; +import org.apache.hadoop.ipc.RPC; +import org.apache.hadoop.ipc.Server; +import org.apache.hadoop.mapreduce.Cluster; +import org.apache.hadoop.mapreduce.ClusterMetrics; +import org.apache.hadoop.mapreduce.Counters; +import org.apache.hadoop.mapreduce.JobID; +import org.apache.hadoop.mapreduce.JobStatus; +import org.apache.hadoop.mapreduce.QueueAclsInfo; +import org.apache.hadoop.mapreduce.QueueInfo; +import org.apache.hadoop.mapreduce.TaskAttemptID; +import org.apache.hadoop.mapreduce.TaskCompletionEvent; +import org.apache.hadoop.mapreduce.TaskReport; +import org.apache.hadoop.mapreduce.TaskTrackerInfo; +import org.apache.hadoop.mapreduce.TaskType; +import org.apache.hadoop.mapreduce.protocol.ClientProtocol; +import org.apache.hadoop.mapreduce.security.token.delegation.DelegationTokenIdentifier; +import org.apache.hadoop.mapreduce.v2.LogParams; +import org.apache.hadoop.security.Credentials; +import org.apache.hadoop.security.authorize.AccessControlList; +import org.apache.hadoop.security.token.Token; + +import java.io.IOException; + +/** + * Local Job Runner for Hadoop v2. + * Please note that one of org.apache.hadoop.mapred.LocalRunnerV2 or + * org.apache.hadoop.mapred.LocalRunnerV2 is active in the project depending + * on the profile chosen. + */ +public class LocalRunnerV2 implements ClientProtocol, JobTrackerService { + + private final ClientProtocol localProxy; + private final Configuration conf; + private Server server; + + public LocalRunnerV2() { + try { + conf = new Configuration(); + localProxy = new LocalJobRunner(conf); + } catch (IOException e) { + throw new RuntimeException("Unable to initialize localRunner"); + } + } + + @Override + public void start() throws Exception { + server = new RPC.Builder(conf).setBindAddress("0.0.0.0").setPort(41021).setInstance(this). + setProtocol(ClientProtocol.class).build(); + server.start(); + } + + public void stop() throws Exception { + server.stop(); + } + + @Override + public JobID getNewJobID() throws IOException, InterruptedException { + return localProxy.getNewJobID(); + } + + @Override + public JobStatus submitJob(JobID jobId, String jobSubmitDir, Credentials ts) + throws IOException, InterruptedException { + return localProxy.submitJob(jobId, jobSubmitDir, ts); + } + + @Override + public ClusterMetrics getClusterMetrics() throws IOException, InterruptedException { + return localProxy.getClusterMetrics(); + } + + @Override + public Cluster.JobTrackerStatus getJobTrackerStatus() throws IOException, InterruptedException { + return localProxy.getJobTrackerStatus(); + } + + @Override + public long getTaskTrackerExpiryInterval() throws IOException, InterruptedException { + return localProxy.getTaskTrackerExpiryInterval(); + } + + @Override + public AccessControlList getQueueAdmins(String queueName) throws IOException { + return localProxy.getQueueAdmins(queueName); + } + + @Override + public void killJob(JobID jobid) throws IOException, InterruptedException { + localProxy.killJob(jobid); + } + + @Override + public void setJobPriority(JobID jobid, String priority) throws IOException, InterruptedException { + localProxy.setJobPriority(jobid, priority); + } + + @Override + public boolean killTask(TaskAttemptID taskId, boolean shouldFail) throws IOException, InterruptedException { + return localProxy.killTask(taskId, shouldFail); + } + + @Override + public JobStatus getJobStatus(JobID jobid) throws IOException, InterruptedException { + return localProxy.getJobStatus(jobid); + } + + @Override + public Counters getJobCounters(JobID jobid) throws IOException, InterruptedException { + return localProxy.getJobCounters(jobid); + } + + @Override + public TaskReport[] getTaskReports(JobID jobid, TaskType type) throws IOException, InterruptedException { + return localProxy.getTaskReports(jobid, type); + } + + @Override + public String getFilesystemName() throws IOException, InterruptedException { + return localProxy.getFilesystemName(); + } + + @Override + public JobStatus[] getAllJobs() throws IOException, InterruptedException { + return localProxy.getAllJobs(); + } + + @Override + public TaskCompletionEvent[] getTaskCompletionEvents(JobID jobid, int fromEventId, int maxEvents) + throws IOException, InterruptedException { + return localProxy.getTaskCompletionEvents(jobid, fromEventId, maxEvents); + } + + @Override + public String[] getTaskDiagnostics(TaskAttemptID taskId) throws IOException, InterruptedException { + return localProxy.getTaskDiagnostics(taskId); + } + + @Override + public TaskTrackerInfo[] getActiveTrackers() throws IOException, InterruptedException { + return localProxy.getActiveTrackers(); + } + + @Override + public TaskTrackerInfo[] getBlacklistedTrackers() throws IOException, InterruptedException { + return localProxy.getBlacklistedTrackers(); + } + + @Override + public String getSystemDir() throws IOException, InterruptedException { + return localProxy.getSystemDir(); + } + + @Override + public String getStagingAreaDir() throws IOException, InterruptedException { + return localProxy.getStagingAreaDir(); + } + + @Override + public String getJobHistoryDir() throws IOException, InterruptedException { + return localProxy.getJobHistoryDir(); + } + + @Override + public QueueInfo[] getQueues() throws IOException, InterruptedException { + return localProxy.getQueues(); + } + + @Override + public QueueInfo getQueue(String queueName) throws IOException, InterruptedException { + return localProxy.getQueue(queueName); + } + + @Override + public QueueAclsInfo[] getQueueAclsForCurrentUser() throws IOException, InterruptedException { + return localProxy.getQueueAclsForCurrentUser(); + } + + @Override + public QueueInfo[] getRootQueues() throws IOException, InterruptedException { + return localProxy.getRootQueues(); + } + + @Override + public QueueInfo[] getChildQueues(String queueName) throws IOException, InterruptedException { + return localProxy.getChildQueues(queueName); + } + + @Override + public Token<DelegationTokenIdentifier> getDelegationToken(Text renewer) throws IOException, InterruptedException { + return localProxy.getDelegationToken(renewer); + } + + @Override + public long renewDelegationToken(Token<DelegationTokenIdentifier> token) throws IOException, InterruptedException { + return localProxy.renewDelegationToken(token); + } + + @Override + public void cancelDelegationToken(Token<DelegationTokenIdentifier> token) throws IOException, InterruptedException { + localProxy.cancelDelegationToken(token); + } + + @Override + public LogParams getLogFileParams(JobID jobID, TaskAttemptID taskAttemptID) + throws IOException, InterruptedException { + return localProxy.getLogFileParams(jobID, taskAttemptID); + } + + @Override + public long getProtocolVersion(String protocol, long clientVersion) throws IOException { + return localProxy.getProtocolVersion(protocol, clientVersion); + } + + @Override + public ProtocolSignature getProtocolSignature(String protocol, long clientVersion, int clientMethodsHash) + throws IOException { + return localProxy.getProtocolSignature(protocol, clientVersion, clientMethodsHash); + } +} http://git-wip-us.apache.org/repos/asf/falcon/blob/d2fd49e5/test-tools/hcatalog-sharelib/pom.xml ---------------------------------------------------------------------- diff --git a/test-tools/hcatalog-sharelib/pom.xml b/test-tools/hcatalog-sharelib/pom.xml new file mode 100644 index 0000000..513b32d --- /dev/null +++ b/test-tools/hcatalog-sharelib/pom.xml @@ -0,0 +1,64 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- +Licensed to the Apache Software Foundation (ASF) under one or more +contributor license agreements. See the NOTICE file distributed with +this work for additional information regarding copyright ownership. +The ASF licenses this file to You under the Apache License, Version 2.0 +(the "License"); you may not use this file except in compliance with +the License. You may obtain a copy of the License at + +http://www.apache.org/licenses/LICENSE-2.0 + +Unless required by applicable law or agreed to in writing, software +distributed under the License is distributed on an "AS IS" BASIS, +WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +See the License for the specific language governing permissions and +limitations under the License. +--> +<project xmlns="http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; + xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd";> + + <modelVersion>4.0.0</modelVersion> + <parent> + <groupId>org.apache.falcon</groupId> + <artifactId>falcon-main</artifactId> + <version>0.7-SNAPSHOT</version> + <relativePath>../..</relativePath> + </parent> + <artifactId>falcon-sharelib-hcatalog</artifactId> + <description>Apache Falcon Sharelib Hcatalog - Test Cluster</description> + <name>Apache Falcon Sharelib Hcatalog - Test Cluster</name> + <packaging>jar</packaging> + + <dependencies> + <dependency> + <groupId>org.apache.oozie</groupId> + <artifactId>oozie-sharelib-hcatalog</artifactId> + <version>${oozie.buildversion}</version> + </dependency> + <dependency> + <groupId>org.testng</groupId> + <artifactId>testng</artifactId> + <scope>test</scope> + </dependency> + </dependencies> + <build> + <plugins> + <plugin> + <artifactId>maven-dependency-plugin</artifactId> + <executions> + <execution> + <id>add-jar</id> + <phase>install</phase> + <goals> + <goal>copy-dependencies</goal> + </goals> + <configuration> + <outputDirectory>../../target/share/lib/hcatalog/</outputDirectory> + </configuration> + </execution> + </executions> + </plugin> + </plugins> + </build> +</project> http://git-wip-us.apache.org/repos/asf/falcon/blob/d2fd49e5/test-tools/hive-sharelib/pom.xml ---------------------------------------------------------------------- diff --git a/test-tools/hive-sharelib/pom.xml b/test-tools/hive-sharelib/pom.xml new file mode 100644 index 0000000..be4f03d --- /dev/null +++ b/test-tools/hive-sharelib/pom.xml @@ -0,0 +1,64 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- +Licensed to the Apache Software Foundation (ASF) under one or more +contributor license agreements. See the NOTICE file distributed with +this work for additional information regarding copyright ownership. +The ASF licenses this file to You under the Apache License, Version 2.0 +(the "License"); you may not use this file except in compliance with +the License. You may obtain a copy of the License at + +http://www.apache.org/licenses/LICENSE-2.0 + +Unless required by applicable law or agreed to in writing, software +distributed under the License is distributed on an "AS IS" BASIS, +WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +See the License for the specific language governing permissions and +limitations under the License. +--> +<project xmlns="http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; + xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd";> + + <modelVersion>4.0.0</modelVersion> + <parent> + <groupId>org.apache.falcon</groupId> + <artifactId>falcon-main</artifactId> + <version>0.7-SNAPSHOT</version> + <relativePath>../..</relativePath> + </parent> + <artifactId>falcon-sharelib-hive</artifactId> + <description>Apache Falcon Sharelib Hive - Test Cluster</description> + <name>Apache Falcon Sharelib Hive - Test Cluster</name> + <packaging>jar</packaging> + + <dependencies> + <dependency> + <groupId>org.apache.oozie</groupId> + <artifactId>oozie-sharelib-hive</artifactId> + <version>${oozie.buildversion}</version> + </dependency> + <dependency> + <groupId>org.testng</groupId> + <artifactId>testng</artifactId> + <scope>test</scope> + </dependency> + </dependencies> + <build> + <plugins> + <plugin> + <artifactId>maven-dependency-plugin</artifactId> + <executions> + <execution> + <id>add-jar</id> + <phase>install</phase> + <goals> + <goal>copy-dependencies</goal> + </goals> + <configuration> + <outputDirectory>../../target/share/lib/hive/</outputDirectory> + </configuration> + </execution> + </executions> + </plugin> + </plugins> + </build> +</project> http://git-wip-us.apache.org/repos/asf/falcon/blob/d2fd49e5/test-tools/oozie-sharelib/pom.xml ---------------------------------------------------------------------- diff --git a/test-tools/oozie-sharelib/pom.xml b/test-tools/oozie-sharelib/pom.xml new file mode 100644 index 0000000..f8b25da --- /dev/null +++ b/test-tools/oozie-sharelib/pom.xml @@ -0,0 +1,63 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- +Licensed to the Apache Software Foundation (ASF) under one or more +contributor license agreements. See the NOTICE file distributed with +this work for additional information regarding copyright ownership. +The ASF licenses this file to You under the Apache License, Version 2.0 +(the "License"); you may not use this file except in compliance with +the License. You may obtain a copy of the License at + +http://www.apache.org/licenses/LICENSE-2.0 + +Unless required by applicable law or agreed to in writing, software +distributed under the License is distributed on an "AS IS" BASIS, +WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +See the License for the specific language governing permissions and +limitations under the License. +--> +<project xmlns="http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; + xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd";> + <modelVersion>4.0.0</modelVersion> + <parent> + <groupId>org.apache.falcon</groupId> + <artifactId>falcon-main</artifactId> + <version>0.7-SNAPSHOT</version> + <relativePath>../..</relativePath> + </parent> + <artifactId>falcon-sharelib-oozie</artifactId> + <description>Apache Falcon Sharelib Oozie - Test Cluster</description> + <name>Apache Falcon Sharelib Oozie - Test Cluster</name> + <packaging>jar</packaging> + + <dependencies> + <dependency> + <groupId>org.apache.oozie</groupId> + <artifactId>oozie-sharelib-oozie</artifactId> + <version>${oozie.buildversion}</version> + </dependency> + <dependency> + <groupId>org.testng</groupId> + <artifactId>testng</artifactId> + <scope>compile</scope> + </dependency> + </dependencies> + <build> + <plugins> + <plugin> + <artifactId>maven-dependency-plugin</artifactId> + <executions> + <execution> + <id>add-jar</id> + <phase>install</phase> + <goals> + <goal>copy-dependencies</goal> + </goals> + <configuration> + <outputDirectory>../../target/share/lib/oozie/</outputDirectory> + </configuration> + </execution> + </executions> + </plugin> + </plugins> + </build> +</project> http://git-wip-us.apache.org/repos/asf/falcon/blob/d2fd49e5/test-tools/pig-sharelib/pom.xml ---------------------------------------------------------------------- diff --git a/test-tools/pig-sharelib/pom.xml b/test-tools/pig-sharelib/pom.xml new file mode 100644 index 0000000..1e50510 --- /dev/null +++ b/test-tools/pig-sharelib/pom.xml @@ -0,0 +1,63 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- +Licensed to the Apache Software Foundation (ASF) under one or more +contributor license agreements. See the NOTICE file distributed with +this work for additional information regarding copyright ownership. +The ASF licenses this file to You under the Apache License, Version 2.0 +(the "License"); you may not use this file except in compliance with +the License. You may obtain a copy of the License at + +http://www.apache.org/licenses/LICENSE-2.0 + +Unless required by applicable law or agreed to in writing, software +distributed under the License is distributed on an "AS IS" BASIS, +WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +See the License for the specific language governing permissions and +limitations under the License. +--> +<project xmlns="http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; + xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd";> + <modelVersion>4.0.0</modelVersion> + <parent> + <groupId>org.apache.falcon</groupId> + <artifactId>falcon-main</artifactId> + <version>0.7-SNAPSHOT</version> + <relativePath>../..</relativePath> + </parent> + <artifactId>falcon-sharelib-pig</artifactId> + <description>Apache Falcon Sharelib Pig - Test Cluster</description> + <name>Apache Falcon Sharelib Pig - Test Cluster</name> + <packaging>jar</packaging> + + <dependencies> + <dependency> + <groupId>org.apache.oozie</groupId> + <artifactId>oozie-sharelib-pig</artifactId> + <version>${oozie.buildversion}</version> + </dependency> + <dependency> + <groupId>org.testng</groupId> + <artifactId>testng</artifactId> + <scope>test</scope> + </dependency> + </dependencies> + <build> + <plugins> + <plugin> + <artifactId>maven-dependency-plugin</artifactId> + <executions> + <execution> + <id>add-jar</id> + <phase>install</phase> + <goals> + <goal>copy-dependencies</goal> + </goals> + <configuration> + <outputDirectory>../../target/share/lib/pig/</outputDirectory> + </configuration> + </execution> + </executions> + </plugin> + </plugins> + </build> +</project> http://git-wip-us.apache.org/repos/asf/falcon/blob/d2fd49e5/test-tools/pom.xml ---------------------------------------------------------------------- diff --git a/test-tools/pom.xml b/test-tools/pom.xml new file mode 100644 index 0000000..b9a31bc --- /dev/null +++ b/test-tools/pom.xml @@ -0,0 +1,42 @@ +<?xml version="1.0" encoding="UTF-8"?> + +<!-- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + --> + +<project xmlns="http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; + xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd";> + + <modelVersion>4.0.0</modelVersion> + <parent> + <groupId>org.apache.falcon</groupId> + <artifactId>falcon-main</artifactId> + <version>0.7-SNAPSHOT</version> + </parent> + <artifactId>falcon-test-tools</artifactId> + <description>Apache Falcon Test Tools - Test Cluster</description> + <name>Apache Falcon Test Tools - Test Cluster</name> + <packaging>pom</packaging> + + <modules> + <module>hadoop-webapp</module> + <module>hive-sharelib</module> + <module>pig-sharelib</module> + <module>hcatalog-sharelib</module> + <module>oozie-sharelib</module> + </modules> + +</project> http://git-wip-us.apache.org/repos/asf/falcon/blob/d2fd49e5/webapp/pom.xml ---------------------------------------------------------------------- diff --git a/webapp/pom.xml b/webapp/pom.xml index 86fcc2a..7e89125 100644 --- a/webapp/pom.xml +++ b/webapp/pom.xml @@ -345,7 +345,7 @@ <target> <delete dir="../target/store" /> <delete dir="target/webapps/oozie/data" /> - <copy file="../hadoop-webapp/target/oozie.war" toDir="target/webapps" /> + <copy file="../test-tools/hadoop-webapp/target/oozie.war" toDir="target/webapps" /> <delete dir="../target/store" /> </target> </configuration> @@ -405,13 +405,13 @@ <useTestClasspath>true</useTestClasspath> <contextHandlers> <contextHandler implementation="org.mortbay.jetty.webapp.WebAppContext"> - <war>${project.build.directory}/webapps/oozie.war</war> - <contextPath>/oozie</contextPath> - </contextHandler> - <contextHandler implementation="org.mortbay.jetty.webapp.WebAppContext"> <war>${project.build.directory}/webapps/hadoop.war</war> <contextPath>/hadoop</contextPath> </contextHandler> + <contextHandler implementation="org.mortbay.jetty.webapp.WebAppContext"> + <war>${project.build.directory}/webapps/oozie.war</war> + <contextPath>/oozie</contextPath> + </contextHandler> </contextHandlers> <systemProperties> <systemProperty> http://git-wip-us.apache.org/repos/asf/falcon/blob/d2fd49e5/webapp/src/conf/oozie/conf/hadoop-conf/core-site.xml ---------------------------------------------------------------------- diff --git a/webapp/src/conf/oozie/conf/hadoop-conf/core-site.xml b/webapp/src/conf/oozie/conf/hadoop-conf/core-site.xml index bc8fa99..a0f1e07 100644 --- a/webapp/src/conf/oozie/conf/hadoop-conf/core-site.xml +++ b/webapp/src/conf/oozie/conf/hadoop-conf/core-site.xml @@ -39,4 +39,9 @@ <value>unittests</value> </property> + <property> + <name>fs.defaultFS</name> + <value>jail://global:00</value> + </property> + </configuration> http://git-wip-us.apache.org/repos/asf/falcon/blob/d2fd49e5/webapp/src/conf/oozie/conf/hadoop-conf/mapred-site.xml ---------------------------------------------------------------------- diff --git a/webapp/src/conf/oozie/conf/hadoop-conf/mapred-site.xml b/webapp/src/conf/oozie/conf/hadoop-conf/mapred-site.xml new file mode 100644 index 0000000..96574b7 --- /dev/null +++ b/webapp/src/conf/oozie/conf/hadoop-conf/mapred-site.xml @@ -0,0 +1,28 @@ +<?xml version="1.0"?> +<?xml-stylesheet type="text/xsl" href="configuration.xsl"?> +<!-- + Licensed to the Apache Software Foundation (ASF) under one + or more contributor license agreements. See the NOTICE file + distributed with this work for additional information + regarding copyright ownership. The ASF licenses this file + to you under the Apache License, Version 2.0 (the + "License"); you may not use this file except in compliance + with the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. +--> + +<!-- Put site-specific property overrides in this file. --> + +<configuration> + <property> + <name>mapreduce.framework.name</name> + <value>yarn</value> + </property> +</configuration> http://git-wip-us.apache.org/repos/asf/falcon/blob/d2fd49e5/webapp/src/conf/oozie/conf/oozie-site.xml ---------------------------------------------------------------------- diff --git a/webapp/src/conf/oozie/conf/oozie-site.xml b/webapp/src/conf/oozie/conf/oozie-site.xml index 0f25383..ded4873 100644 --- a/webapp/src/conf/oozie/conf/oozie-site.xml +++ b/webapp/src/conf/oozie/conf/oozie-site.xml @@ -242,7 +242,7 @@ <property> <name>oozie.service.WorkflowAppService.system.libpath</name> - <value>/user/${user.name}/share/lib</value> + <value>jail://global:00/user/${user.name}/share/lib</value> <description> System library path to use for workflow applications. This path is added to workflow application if their job properties sets @@ -527,7 +527,7 @@ <property> <name>oozie.service.HadoopAccessorService.supported.filesystems</name> - <value>hdfs,hftp,webhdfs,jail</value> + <value>*</value> <description> Enlist the different filesystems supported for federation. If wildcard "*" is specified, then ALL file schemes will be allowed.
