From 05378cbf69957b76e8559185ea20235242a8b2e6 Mon Sep 17 00:00:00 2001 From: zhangduo Date: Mon, 9 May 2016 20:45:04 +0800 Subject: [PATCH] HBASE-15609 Addendum fix compilation error --- .../java/org/apache/hadoop/hbase/master/ClusterStatusPublisher.java | 3 ++- .../src/test/java/org/apache/hadoop/hbase/client/TestResult.java | 6 ------ 2 files changed, 2 insertions(+), 7 deletions(-) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/ClusterStatusPublisher.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/ClusterStatusPublisher.java index e90aae6..194e023 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/ClusterStatusPublisher.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/ClusterStatusPublisher.java @@ -59,6 +59,7 @@ import org.apache.hadoop.hbase.HConstants; import org.apache.hadoop.hbase.ScheduledChore; import org.apache.hadoop.hbase.ServerName; import org.apache.hadoop.hbase.classification.InterfaceAudience; +import org.apache.hadoop.hbase.protobuf.ProtobufUtil; import org.apache.hadoop.hbase.protobuf.generated.ClusterStatusProtos; import org.apache.hadoop.hbase.util.Addressing; import org.apache.hadoop.hbase.util.EnvironmentEdgeManager; @@ -332,7 +333,7 @@ public class ClusterStatusPublisher extends ScheduledChore { @Override protected void encode(ChannelHandlerContext channelHandlerContext, ClusterStatus clusterStatus, List objects) { - ClusterStatusProtos.ClusterStatus csp = clusterStatus.convert(); + ClusterStatusProtos.ClusterStatus csp = ProtobufUtil.convert(clusterStatus); objects.add(new DatagramPacket(Unpooled.wrappedBuffer(csp.toByteArray()), isa)); } } diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestResult.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestResult.java index 6baf9e0..0e93ee0 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestResult.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestResult.java @@ -244,12 +244,6 @@ public class TestResult extends TestCase { LOG.debug("As expected: " + ex.getMessage()); } try { - emptyResult.addResults(new RegionLoadStats(0, 0, 0)); - fail("UnsupportedOperationException should have been thrown!"); - } catch (UnsupportedOperationException ex) { - LOG.debug("As expected: " + ex.getMessage()); - } - try { emptyResult.setExists(true); fail("UnsupportedOperationException should have been thrown!"); } catch (UnsupportedOperationException ex) { -- 1.9.1