You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by zh...@apache.org on 2018/02/22 07:45:45 UTC
[05/50] [abbrv] hbase git commit: HBASE-19166 AsyncProtobufLogWriter
persists ProtobufLogWriter as class name for backward compatibility
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/5c988c99
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/5c988c99
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/5c988c99
Branch: refs/heads/HBASE-19397-branch-2
Commit: 5c988c99606080599534a751f061750f241c0945
Parents: d8ec10e
Author: tedyu <yu...@gmail.com>
Authored: Wed Feb 21 13:05:54 2018 -0800
Committer: tedyu <yu...@gmail.com>
Committed: Wed Feb 21 13:05:54 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/5c988c99/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/5c988c99/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 {