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 06:59:19 UTC
[30/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/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 <yu...@gmail.com>
Authored: Wed Feb 21 13:04:59 2018 -0800
Committer: tedyu <yu...@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 {