Apache
/
lucene
mirror of https://github.com/apache/lucene.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

SOLR-1301: make debugging these tests a whole lot easier by sending map reduce job logging to std out 

git-svn-id: https://svn.apache.org/repos/asf/lucene/dev/trunk@1555647 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Mark Robert Miller 2014-01-06 02:03:00 +00:00
parent 2e6b894036
commit 50e277c1ef
2 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
solr/contrib/map-reduce/src/test/org/apache/solr/hadoop/MorphlineBasicMiniMRTest.java
View File

@ -316,6 +316,7 @@ public class MorphlineBasicMiniMRTest extends SolrTestCaseJ4 {
fs.copyFromLocalFile(new Path(DOCUMENTS_DIR, inputAvroFile), dataDir); fs.copyFromLocalFile(new Path(DOCUMENTS_DIR, inputAvroFile), dataDir);
JobConf jobConf = getJobConf(); JobConf jobConf = getJobConf();
jobConf.set("jobclient.output.filter", "ALL");
if (ENABLE_LOCAL_JOB_RUNNER) { // enable Hadoop LocalJobRunner; this enables to run in debugger and set breakpoints if (ENABLE_LOCAL_JOB_RUNNER) { // enable Hadoop LocalJobRunner; this enables to run in debugger and set breakpoints
jobConf.set("mapred.job.tracker", "local"); jobConf.set("mapred.job.tracker", "local");
} }

1
solr/contrib/map-reduce/src/test/org/apache/solr/hadoop/MorphlineGoLiveMiniMRTest.java
View File

@ -362,6 +362,7 @@ public class MorphlineGoLiveMiniMRTest extends AbstractFullDistribZkTestBase {
Path INPATH = upAvroFile(fs, inDir, DATADIR, dataDir, inputAvroFile1); Path INPATH = upAvroFile(fs, inDir, DATADIR, dataDir, inputAvroFile1);
JobConf jobConf = getJobConf(); JobConf jobConf = getJobConf();
jobConf.set("jobclient.output.filter", "ALL");
// enable mapred.job.tracker = local to run in debugger and set breakpoints // enable mapred.job.tracker = local to run in debugger and set breakpoints
// jobConf.set("mapred.job.tracker", "local"); // jobConf.set("mapred.job.tracker", "local");
jobConf.setMaxMapAttempts(1); jobConf.setMaxMapAttempts(1);