From a7d10e550f5ac3b8a43e22b2c4a5706fddbe34c3 Mon Sep 17 00:00:00 2001 From: Michael Stack Date: Sat, 12 Jun 2021 07:27:34 -0700 Subject: [PATCH] HBASE-25989 FanOutOneBlockAsyncDFSOutput using shaded protobuf in hdfs 3.3+ (#3368) Signed-off-by: Wei-Chiu Chuang Signed-off-by: Duo Zhang --- .../org/apache/hadoop/hbase/io/asyncfs/ProtobufDecoder.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hbase-asyncfs/src/main/java/org/apache/hadoop/hbase/io/asyncfs/ProtobufDecoder.java b/hbase-asyncfs/src/main/java/org/apache/hadoop/hbase/io/asyncfs/ProtobufDecoder.java index 98b4e6f08e1..d6e68f30542 100644 --- a/hbase-asyncfs/src/main/java/org/apache/hadoop/hbase/io/asyncfs/ProtobufDecoder.java +++ b/hbase-asyncfs/src/main/java/org/apache/hadoop/hbase/io/asyncfs/ProtobufDecoder.java @@ -123,7 +123,7 @@ public class ProtobufDecoder extends MessageToMessageDecoder { try { protobufMessageLiteClass = Class.forName("org.apache.hadoop.thirdparty.protobuf.MessageLite"); protobufMessageLiteBuilderClass = Class.forName( - "org.apache.hadoop.thirdparty.protobuf.MessageLite.Builder"); + "org.apache.hadoop.thirdparty.protobuf.MessageLite$Builder"); LOG.debug("Hadoop 3.3 and above shades protobuf."); } catch (ClassNotFoundException e) { LOG.debug("Hadoop 3.2 and below use unshaded protobuf.", e);