Skip to content

Commit

Permalink
logging changes.
Browse files Browse the repository at this point in the history
  • Loading branch information
bbansal committed Jan 22, 2010
1 parent 405e23a commit b047812
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 7 deletions.
7 changes: 3 additions & 4 deletions src/java/voldemort/client/rebalance/RebalanceController.java
Expand Up @@ -89,8 +89,8 @@ public void rebalance(final Cluster targetCluster) {
* @param targetCluster: target Cluster configuration
*/
public void rebalance(Cluster currentCluster, final Cluster targetCluster) {
logger.info("Current Cluster configuration:" + currentCluster);
logger.info("Target Cluster configuration:" + targetCluster);
logger.debug("Current Cluster configuration:" + currentCluster);
logger.debug("Target Cluster configuration:" + targetCluster);

adminClient.setAdminClientCluster(currentCluster);

Expand Down Expand Up @@ -137,8 +137,7 @@ public void run() {
int index = (int) (random.nextDouble() * rebalanceSubTaskList.size());
RebalancePartitionsInfo rebalanceSubTask = rebalanceSubTaskList.remove(index);
logger.info("Starting rebalancing for stealerNode:" + stealerNodeId
+ " with rebalanceInfo:" + rebalanceSubTask + " index:"
+ index);
+ " with rebalanceInfo:" + rebalanceSubTask);

try {
int rebalanceAsyncId = startNodeRebalancing(rebalanceSubTask);
Expand Down
8 changes: 5 additions & 3 deletions src/java/voldemort/store/metadata/MetadataStore.java
Expand Up @@ -74,7 +74,7 @@ public class MetadataStore implements StorageEngine<ByteArray, byte[]> {
public static final String CLUSTER_STATE_KEY = "cluster.state";
public static final String SERVER_STATE_KEY = "server.state";
public static final String NODE_ID_KEY = "node.id";
public static final String REBALANCING_STEAL_INFO = "rebalancing.steal.info";
public static final String REBALANCING_STEAL_INFO = "rebalancing.steal.info.key";

public static final Set<String> GOSSIP_KEYS = ImmutableSet.of(CLUSTER_KEY,
STORES_KEY,
Expand Down Expand Up @@ -231,8 +231,10 @@ public List<Versioned<byte[]>> get(ByteArray keyBytes) throws VoldemortException
throw new VoldemortException("Unhandled Key:" + key + " for MetadataStore get()");
}
} catch(Exception e) {
throw new VoldemortException("Failed to get() for key:"
+ ByteUtils.getString(keyBytes.get(), "UTF-8"), e);
throw new VoldemortException("Failed to read metadata key:"
+ ByteUtils.getString(keyBytes.get(), "UTF-8")
+ " delete config/.temp config/.version directories and restart.",
e);
}

}
Expand Down

0 comments on commit b047812

Please sign in to comment.