You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by la...@apache.org on 2013/11/19 00:02:23 UTC
svn commit: r1543220 - in
/hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase:
regionserver/wal/WALEdit.java replication/regionserver/ReplicationSource.java
Author: larsh
Date: Mon Nov 18 23:02:23 2013
New Revision: 1543220
URL: http://svn.apache.org/r1543220
Log:
HBASE-9993 0.94: HBASE-9865 breaks coprocessor compatibility with WALEdit.
Modified:
hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/regionserver/wal/WALEdit.java
hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java
Modified: hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/regionserver/wal/WALEdit.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/regionserver/wal/WALEdit.java?rev=1543220&r1=1543219&r2=1543220&view=diff
==============================================================================
--- hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/regionserver/wal/WALEdit.java (original)
+++ hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/regionserver/wal/WALEdit.java Mon Nov 18 23:02:23 2013
@@ -132,7 +132,7 @@ public class WALEdit implements Writable
return kvs.size();
}
- public ArrayList<KeyValue> getKeyValues() {
+ public List<KeyValue> getKeyValues() {
return kvs;
}
Modified: hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java?rev=1543220&r1=1543219&r2=1543220&view=diff
==============================================================================
--- hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java (original)
+++ hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java Mon Nov 18 23:02:23 2013
@@ -662,7 +662,8 @@ public class ReplicationSource extends T
* @param edit The KV to check for replication
*/
protected void removeNonReplicableEdits(WALEdit edit) {
- ArrayList<KeyValue> kvs = edit.getKeyValues();
+ // for backward compatibility WALEdit returns a List
+ ArrayList<KeyValue> kvs = (ArrayList<KeyValue>)edit.getKeyValues();
int size = edit.size();
for (int i = size-1; i >= 0; i--) {
KeyValue kv = kvs.get(i);