HBASE-19166 AsyncProtobufLogWriter persists ProtobufLogWriter as class name for backward compatibility
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/bf5f0344 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/bf5f0344 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/bf5f0344 Branch: refs/heads/HBASE-19064 Commit: bf5f034463d357f31e2c7d02c6477c2fcd93d7f4 Parents: 5d994a2 Author: tedyu <yuzhih...@gmail.com> Authored: Wed Feb 21 13:04:59 2018 -0800 Committer: tedyu <yuzhih...@gmail.com> Committed: Wed Feb 21 13:04:59 2018 -0800 ---------------------------------------------------------------------- .../hbase/regionserver/wal/AsyncProtobufLogWriter.java | 9 +++++++++ .../regionserver/wal/SecureAsyncProtobufLogWriter.java | 8 ++++++++ 2 files changed, 17 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/bf5f0344/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/AsyncProtobufLogWriter.java ---------------------------------------------------------------------- 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 67258ec..abdc24e 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 @@ -108,6 +108,15 @@ public class AsyncProtobufLogWriter extends AbstractProtobufLogWriter this.channelClass = channelClass; } + /* + * @return class name which is recognized by hbase-1.x to avoid ProtobufLogReader throwing error: + * IOException: Got unknown writer class: AsyncProtobufLogWriter + */ + @Override + protected String getWriterClassName() { + return "ProtobufLogWriter"; + } + @Override public void append(Entry entry) { int buffered = output.buffered(); http://git-wip-us.apache.org/repos/asf/hbase/blob/bf5f0344/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/SecureAsyncProtobufLogWriter.java ---------------------------------------------------------------------- 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..e2d294a 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 @@ -38,6 +38,14 @@ public class SecureAsyncProtobufLogWriter extends AsyncProtobufLogWriter { super(eventLoopGroup, channelClass); } + /* + * @return class name which is recognized by hbase-1.x to avoid ProtobufLogReader throwing error: + * IOException: Got unknown writer class: SecureAsyncProtobufLogWriter + */ + @Override + protected String getWriterClassName() { + return "SecureProtobufLogWriter"; + } @Override protected WALHeader buildWALHeader(Configuration conf, WALHeader.Builder builder) throws IOException {