You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nutch.apache.org by cu...@apache.org on 2005/07/08 22:27:33 UTC
svn commit: r209879 -
/lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/TaskRunner.java
Author: cutting
Date: Fri Jul 8 13:27:32 2005
New Revision: 209879
URL: http://svn.apache.org/viewcvs?rev=209879&view=rev
Log:
Copy child output in a separate thread.
Modified:
lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/TaskRunner.java
Modified: lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/TaskRunner.java
URL: http://svn.apache.org/viewcvs/lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/TaskRunner.java?rev=209879&r1=209878&r2=209879&view=diff
==============================================================================
--- lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/TaskRunner.java (original)
+++ lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/TaskRunner.java Fri Jul 8 13:27:32 2005
@@ -108,7 +108,12 @@
this.process = Runtime.getRuntime().exec(args, null, dir);
try {
StringBuffer errorBuf = new StringBuffer();
- logStream(process.getErrorStream()); // copy log output
+ new Thread() {
+ public void run() {
+ logStream(process.getErrorStream()); // copy log output
+ }
+ }.start();
+
logStream(process.getInputStream()); // normally empty
if (this.process.waitFor() != 0) {