|
@@ -17,15 +17,18 @@
|
|
|
*/
|
|
|
package org.apache.hadoop.mapred;
|
|
|
|
|
|
+import java.io.BufferedReader;
|
|
|
+import java.io.InputStream;
|
|
|
+import java.io.InputStreamReader;
|
|
|
+import java.io.OutputStream;
|
|
|
+import java.io.OutputStreamWriter;
|
|
|
+import java.io.Writer;
|
|
|
+import java.util.Properties;
|
|
|
+
|
|
|
import org.apache.hadoop.fs.FileUtil;
|
|
|
import org.apache.hadoop.fs.Path;
|
|
|
import org.apache.hadoop.io.LongWritable;
|
|
|
import org.apache.hadoop.io.Text;
|
|
|
-import org.junit.Ignore;
|
|
|
-
|
|
|
-import java.io.*;
|
|
|
-import java.util.Properties;
|
|
|
-@Ignore
|
|
|
public class TestClusterMapReduceTestCase extends ClusterMapReduceTestCase {
|
|
|
public void _testMapReduce(boolean restart) throws Exception {
|
|
|
OutputStream os = getFileSystem().create(new Path(getInputDir(), "text.txt"));
|