diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.java index 9688bbd..fe015c2 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.java @@ -109,6 +109,11 @@ public class AsyncProtobufLogWriter extends AbstractProtobufLogWriter } @Override + protected String getWriterClassName() { + return "ProtobufLogWriter"; + } + + @Override public void append(Entry entry) { int buffered = output.buffered(); entry.setCompressionContext(compressionContext); diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/SecureAsyncProtobufLogWriter.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/SecureAsyncProtobufLogWriter.java index 7741b5e..cee4047 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/SecureAsyncProtobufLogWriter.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/SecureAsyncProtobufLogWriter.java @@ -39,6 +39,10 @@ public class SecureAsyncProtobufLogWriter extends AsyncProtobufLogWriter { } @Override + protected String getWriterClassName() { + return "SecureProtobufLogWriter"; + } + @Override protected WALHeader buildWALHeader(Configuration conf, WALHeader.Builder builder) throws IOException { return super.buildSecureWALHeader(conf, builder);