Skip to content

Instantly share code, notes, and snippets.

@ivankelly
Created March 7, 2012 11:01
Show Gist options
  • Save ivankelly/1992521 to your computer and use it in GitHub Desktop.
Save ivankelly/1992521 to your computer and use it in GitHub Desktop.
try {
cluster.transitionToActive(1); // This line is TestBookKeeperAsHASharedDir.java:241
fail("Shouldn't have been able to start two primaries"
+ " with single shared storage");
} catch (java.lang.IllegalStateException e) {
LOG.info("IKCheck1", e);
} catch (Throwable t) {
LOG.info("IKCheck", t);
//assertTrue(e.getMessage().contains("Cannot start writing at"));
}
Logs show:
2012-03-07 11:51:43,753 - INFO - [main:TestBookKeeperAsHASharedDir@248] - IKCheck
java.lang.IllegalStateException: java.lang.IllegalStateException: Cannot start writing at txid 4 when there is a stream available for read: org.apache.hadoop.contrib.bkjournal.BookKeeperEditLogInputStream@39019275
at com.google.common.base.Preconditions.checkState(Preconditions.java:172)
at org.apache.hadoop.hdfs.server.namenode.FSEditLog.openForWrite(FSEditLog.java:261)
at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.startActiveServices(FSNamesystem.java:561)
at org.apache.hadoop.hdfs.server.namenode.NameNode$NameNodeHAContext.startActiveServices(NameNode.java:987)
at org.apache.hadoop.hdfs.server.namenode.ha.ActiveState.enterState(ActiveState.java:61)
at org.apache.hadoop.hdfs.server.namenode.ha.HAState.setStateInternal(HAState.java:63)
at org.apache.hadoop.hdfs.server.namenode.ha.StandbyState.setState(StandbyState.java:49)
at org.apache.hadoop.hdfs.server.namenode.NameNode.transitionToActive(NameNode.java:936)
at org.apache.hadoop.hdfs.server.namenode.NameNodeRpcServer.transitionToActive(NameNodeRpcServer.java:976)
at org.apache.hadoop.ha.protocolPB.HAServiceProtocolServerSideTranslatorPB.transitionToActive(HAServiceProtocolServerSideTranslatorPB.java:82)
at org.apache.hadoop.ha.proto.HAServiceProtocolProtos$HAServiceProtocolService$2.callBlockingMethod(HAServiceProtocolProtos.java:3350)
at org.apache.hadoop.ipc.ProtobufRpcEngine$Server$ProtoBufRpcInvoker.call(ProtobufRpcEngine.java:448)
at org.apache.hadoop.ipc.RPC$Server.call(RPC.java:884)
at org.apache.hadoop.ipc.Server$Handler$1.run(Server.java:1660)
at org.apache.hadoop.ipc.Server$Handler$1.run(Server.java:1656)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:396)
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1177)
at org.apache.hadoop.ipc.Server$Handler.run(Server.java:1654)
at org.apache.hadoop.ipc.ProtobufRpcEngine$Invoker.invoke(ProtobufRpcEngine.java:205)
at $Proxy15.transitionToActive(Unknown Source)
at org.apache.hadoop.ha.protocolPB.HAServiceProtocolClientSideTranslatorPB.transitionToActive(HAServiceProtocolClientSideTranslatorPB.java:86)
at org.apache.hadoop.ha.HAServiceProtocolHelper.transitionToActive(HAServiceProtocolHelper.java:45)
at org.apache.hadoop.hdfs.MiniDFSCluster.transitionToActive(MiniDFSCluster.java:1648)
at org.apache.hadoop.contrib.bkjournal.TestBookKeeperAsHASharedDir.testMultiplePrimariesStarted(TestBookKeeperAsHASharedDir.java:241)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment