|
@@ -103,6 +103,8 @@ public class TestEditLogJournalFailures {
|
|
GenericTestUtils.assertExceptionContains(
|
|
GenericTestUtils.assertExceptionContains(
|
|
"Could not sync enough journals to persistent storage. " +
|
|
"Could not sync enough journals to persistent storage. " +
|
|
"Unsynced transactions: 1", re);
|
|
"Unsynced transactions: 1", re);
|
|
|
|
+ cluster.getNamesystem().getFSImage().getEditLog()
|
|
|
|
+ .abortCurrentLogSegment();
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|