Author: rvs
Date: Tue Oct 4 17:32:09 2011
New Revision: 1178870
URL: http://svn.apache.org/viewvc?rev=1178870&view=rev
Log:
Fixing hadoop streaming test
Modified:
incubator/bigtop/branches/hadoop-0.22/bigtop-tests/test-artifacts/hadoop/src/main/groovy/org/apache/bigtop/itest/hadoopexamples/TestHadoopExamples.groovy
incubator/bigtop/branches/hadoop-0.22/bigtop-tests/test-artifacts/hadoop/src/main/groovy/org/apache/bigtop/itest/hadoopsmoke/TestHadoopSmoke.groovy
Modified:
incubator/bigtop/branches/hadoop-0.22/bigtop-tests/test-artifacts/hadoop/src/main/groovy/org/apache/bigtop/itest/hadoopexamples/TestHadoopExamples.groovy
URL:
http://svn.apache.org/viewvc/incubator/bigtop/branches/hadoop-0.22/bigtop-tests/test-artifacts/hadoop/src/main/groovy/org/apache/bigtop/itest/hadoopexamples/TestHadoopExamples.groovy?rev=1178870&r1=1178869&r2=1178870&view=diff
==============================================================================
---
incubator/bigtop/branches/hadoop-0.22/bigtop-tests/test-artifacts/hadoop/src/main/groovy/org/apache/bigtop/itest/hadoopexamples/TestHadoopExamples.groovy
(original)
+++
incubator/bigtop/branches/hadoop-0.22/bigtop-tests/test-artifacts/hadoop/src/main/groovy/org/apache/bigtop/itest/hadoopexamples/TestHadoopExamples.groovy
Tue Oct 4 17:32:09 2011
@@ -63,7 +63,7 @@ class TestHadoopExamples {
private static String HADOOP_OPTIONS;
@BeforeClass
- void setUp() {
+ static void setUp() {
conf = new Configuration();
conf.addResource('mapred-site.xml');
HADOOP_OPTIONS =
Modified:
incubator/bigtop/branches/hadoop-0.22/bigtop-tests/test-artifacts/hadoop/src/main/groovy/org/apache/bigtop/itest/hadoopsmoke/TestHadoopSmoke.groovy
URL:
http://svn.apache.org/viewvc/incubator/bigtop/branches/hadoop-0.22/bigtop-tests/test-artifacts/hadoop/src/main/groovy/org/apache/bigtop/itest/hadoopsmoke/TestHadoopSmoke.groovy?rev=1178870&r1=1178869&r2=1178870&view=diff
==============================================================================
---
incubator/bigtop/branches/hadoop-0.22/bigtop-tests/test-artifacts/hadoop/src/main/groovy/org/apache/bigtop/itest/hadoopsmoke/TestHadoopSmoke.groovy
(original)
+++
incubator/bigtop/branches/hadoop-0.22/bigtop-tests/test-artifacts/hadoop/src/main/groovy/org/apache/bigtop/itest/hadoopsmoke/TestHadoopSmoke.groovy
Tue Oct 4 17:32:09 2011
@@ -39,7 +39,7 @@ class TestHadoopSmoke {
static String testDir = "test.hadoopsmoke." + (new Date().getTime())
static String nn = (new
Configuration()).get(DFSConfigKeys.FS_DEFAULT_NAME_KEY)
- String cmd = "hadoop jar
${hadoopHome}/contrib/streaming/hadoop-streaming*.jar" +
+ String cmd = "hadoop jar
${hadoopHome}/contrib/streaming/hadoop*streaming*.jar" +
" -D mapred.map.tasks=1 -D mapred.reduce.tasks=1 -D
mapred.job.name=Experiment "
String cmd2 =" -input ${testDir}/cachefile/input.txt -mapper map.sh -file
map.sh -reducer cat" +
" -output ${testDir}/cachefile/out -verbose "
