accumulo-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From David Medinets <david.medin...@gmail.com>
Subject Should MapResourceExample Work Without Calling Run?
Date Sat, 09 Feb 2013 03:09:14 GMT
I am poking around and randomly commented out the run() call as shown below.

  public static void main(String[] args) throws Exception {
    File tmpDir = new File(FileUtils.getTempDirectory(), "macc-" +
UUID.randomUUID().toString());

    try {
      MiniAccumuloCluster la = new MiniAccumuloCluster(tmpDir, "pass1234");
      la.start();

      System.out.println("\n   ---- Running Mapred Against Accumulo\n");

      //run(la.getInstanceName(), la.getZooKeepers(), "pass1234", args);

      System.out.println("\n   ---- Ran Mapred Against Accumulo\n");

      la.stop();
    } finally {
      FileUtils.deleteQuietly(tmpDir);
    }
  }

With this change, I get the following exception which I did not
expect. Shouldn't the above code run cleanly?

java.io.IOException: Stream closed
	at java.io.BufferedInputStream.getBufIfOpen(BufferedInputStream.java:162)
	at java.io.BufferedInputStream.read(BufferedInputStream.java:325)
	at sun.nio.cs.StreamDecoder.readBytes(StreamDecoder.java:282)
	at sun.nio.cs.StreamDecoder.implRead(StreamDecoder.java:324)
	at sun.nio.cs.StreamDecoder.read(StreamDecoder.java:176)
	at java.io.InputStreamReader.read(InputStreamReader.java:184)
	at java.io.BufferedReader.fill(BufferedReader.java:153)
	at java.io.BufferedReader.readLine(BufferedReader.java:316)
	at java.io.BufferedReader.readLine(BufferedReader.java:379)
	at org.apache.accumulo.test.MiniAccumuloCluster$LogWriter.run(MiniAccumuloCluster.java:88)

Mime
View raw message