Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-2488 Master should warn more loudly about unexpected events 

git-svn-id: https://svn.apache.org/repos/asf/hadoop/hbase/trunk@938258 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Michael Stack 2010-04-26 22:13:18 +00:00
parent e37f4ecef9
commit 5dccb9751c
3 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
CHANGES.txt
View File

@ -531,6 +531,8 @@ Release 0.21.0 - Unreleased
HBASE-2452 Fix our Maven dependencies (Lars Francke via Stack) HBASE-2452 Fix our Maven dependencies (Lars Francke via Stack)
HBASE-2490 Improve the javadoc of the client API for HTable HBASE-2490 Improve the javadoc of the client API for HTable
(Benoit Sigoure via Stack) (Benoit Sigoure via Stack)
HBASE-2488 Master should warn more loudly about unexpected events
(Todd Lipcon via Stack)
NEW FEATURES NEW FEATURES
HBASE-1961 HBase EC2 scripts HBASE-1961 HBase EC2 scripts

9
core/src/main/java/org/apache/hadoop/hbase/master/ServerManager.java
View File

@ -254,6 +254,8 @@ public class ServerManager implements HConstants {
throws IOException { throws IOException {
HServerInfo info = new HServerInfo(serverInfo); HServerInfo info = new HServerInfo(serverInfo);
if (isDead(info.getServerName())) { if (isDead(info.getServerName())) {
LOG.info("Received report from region server " + info.getServerName() +
" previously marked dead. Rejecting report.");
throw new Leases.LeaseStillHeldException(info.getServerName()); throw new Leases.LeaseStillHeldException(info.getServerName());
} }
if (msgs.length > 0) { if (msgs.length > 0) {
@ -573,11 +575,8 @@ public class ServerManager implements HConstants {
} }
if (duplicateAssignment) { if (duplicateAssignment) {
if (LOG.isDebugEnabled()) { LOG.warn("region server " + serverInfo.getServerAddress().toString() +
LOG.debug("region server " + serverInfo.getServerAddress().toString() + " should not have opened region " + Bytes.toString(region.getRegionName()));
" should not have opened region " +
Bytes.toString(region.getRegionName()));
}
// This Region should not have been opened. // This Region should not have been opened.
// Ask the server to shut it down, but don't report it as closed. // Ask the server to shut it down, but don't report it as closed.

4
core/src/test/java/org/apache/hadoop/hbase/client/TestScannerTimeout.java
View File

@ -2,7 +2,7 @@ package org.apache.hadoop.hbase.client;
import org.apache.commons.logging.Log; import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory; import org.apache.commons.logging.LogFactory;
import org.apache.hadoop.hbase.HBaseConfiguration; import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseTestingUtility; import org.apache.hadoop.hbase.HBaseTestingUtility;
import org.apache.hadoop.hbase.util.Bytes; import org.apache.hadoop.hbase.util.Bytes;
import org.junit.After; import org.junit.After;
@ -30,7 +30,7 @@ public class TestScannerTimeout {
*/ */
@BeforeClass @BeforeClass
public static void setUpBeforeClass() throws Exception { public static void setUpBeforeClass() throws Exception {
HBaseConfiguration c = TEST_UTIL.getConfiguration(); Configuration c = TEST_UTIL.getConfiguration();
c.setInt("hbase.regionserver.lease.period", 1000); c.setInt("hbase.regionserver.lease.period", 1000);
TEST_UTIL.startMiniCluster(1); TEST_UTIL.startMiniCluster(1);
} }