Examples of org.apache.hadoop.hdfs.qjournal.server.Journal.newEpoch()

Package org.apache.hadoop.hdfs.qjournal.server

Class org.apache.hadoop.hdfs.qjournal.server.Journal

Examples of org.apache.hadoop.hdfs.qjournal.server.Journal.newEpoch()

org.apache.hadoop.hdfs.qjournal.server.Journal.newEpoch()
Try to create a new epoch for this journal. @param nsInfo the namespace, which is verified for consistency or used toformat, if the Journal has not yet been written to. @param epoch the epoch to start @return the status information necessary to begin recovery @throws IOException if the node has already made a promise to anotherwriter with a higher epoch number, if the namespace is inconsistent, or if a disk error occurs.

    journal.close();
    
    // Journal should no longer be locked after the close() call.
    // Hence, should be able to create a new Journal in the same dir.
    Journal journal2 = new Journal(conf, TEST_LOG_DIR, JID, mockErrorReporter);
    journal2.newEpoch(FAKE_NSINFO, 2);
    journal2.close();
  }
  
  /**
   * Test finalizing a segment after some batch of edits were missed.

View Full Code Here

    journal.close();
    
    // Journal should no longer be locked after the close() call.
    // Hence, should be able to create a new Journal in the same dir.
    Journal journal2 = new Journal(TEST_LOG_DIR, JID, mockErrorReporter);
    journal2.newEpoch(FAKE_NSINFO, 2);
  }
  
  /**
   * Test finalizing a segment after some batch of edits were missed.
   * This should fail, since we validate the log before finalization.

View Full Code Here


    // Journal should no longer be locked after the close() call.
    // Hence, should be able to create a new Journal in the same dir.
    Journal journal2 = new Journal(TEST_LOG_DIR, TEST_IMG_DIR, JID,
        mockErrorReporter, mockJournalNode);
    journal2.newEpoch(FAKE_NSINFO, 2);
    journal2.close();
  }


  /**
   * Test finalizing a segment after some batch of edits were missed. This

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.