Skip to content

Commit e4a0acd

Browse files
author
Daniel Roudnitsky
committed
spotless + docstring
1 parent 6c9d5c1 commit e4a0acd

File tree

8 files changed

+8
-10
lines changed

8 files changed

+8
-10
lines changed

hbase-client/src/main/java/org/apache/hadoop/hbase/filter/CompareFilter.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,6 @@
2222
import java.util.Objects;
2323
import org.apache.hadoop.hbase.Cell;
2424
import org.apache.hadoop.hbase.CompareOperator;
25-
import org.apache.hadoop.hbase.DoNotRetryIOException;
2625
import org.apache.hadoop.hbase.HBaseIOException;
2726
import org.apache.hadoop.hbase.PrivateCellUtil;
2827
import org.apache.hadoop.hbase.util.Bytes;
@@ -86,7 +85,8 @@ public boolean filterRowKey(Cell cell) throws IOException {
8685
* RuntimeException when applying a comparator indicates a code bug or misconfigured
8786
* filter/comparator, we wrap it in `HBaseIOException` to provide a clear exception message/stack
8887
* trace and prevent propagating a runtime exception up the call stack (which would lead to
89-
* unexpected throwable at RpcServer layer and a complicated unclear remote exception on the client)
88+
* unexpected throwable at RpcServer layer and a complicated unclear remote exception on the
89+
* client)
9090
*/
9191
public static HBaseIOException wrapInHBaseIOException(RuntimeException e,
9292
ByteArrayComparable comparator) {

hbase-client/src/main/java/org/apache/hadoop/hbase/filter/DependentColumnFilter.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,6 @@
2626
import org.apache.hadoop.hbase.Cell;
2727
import org.apache.hadoop.hbase.CellUtil;
2828
import org.apache.hadoop.hbase.CompareOperator;
29-
import org.apache.hadoop.hbase.DoNotRetryIOException;
3029
import org.apache.hadoop.hbase.exceptions.DeserializationException;
3130
import org.apache.hadoop.hbase.util.Bytes;
3231
import org.apache.yetus.audience.InterfaceAudience;

hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FamilyFilter.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@
2121
import java.util.ArrayList;
2222
import org.apache.hadoop.hbase.Cell;
2323
import org.apache.hadoop.hbase.CompareOperator;
24-
import org.apache.hadoop.hbase.DoNotRetryIOException;
2524
import org.apache.hadoop.hbase.exceptions.DeserializationException;
2625
import org.apache.yetus.audience.InterfaceAudience;
2726

hbase-client/src/main/java/org/apache/hadoop/hbase/filter/QualifierFilter.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@
2121
import java.util.ArrayList;
2222
import org.apache.hadoop.hbase.Cell;
2323
import org.apache.hadoop.hbase.CompareOperator;
24-
import org.apache.hadoop.hbase.DoNotRetryIOException;
2524
import org.apache.hadoop.hbase.exceptions.DeserializationException;
2625
import org.apache.yetus.audience.InterfaceAudience;
2726

hbase-client/src/main/java/org/apache/hadoop/hbase/filter/RowFilter.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@
2121
import java.util.ArrayList;
2222
import org.apache.hadoop.hbase.Cell;
2323
import org.apache.hadoop.hbase.CompareOperator;
24-
import org.apache.hadoop.hbase.DoNotRetryIOException;
2524
import org.apache.hadoop.hbase.exceptions.DeserializationException;
2625
import org.apache.yetus.audience.InterfaceAudience;
2726

hbase-client/src/main/java/org/apache/hadoop/hbase/filter/SingleColumnValueFilter.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,6 @@
2323
import org.apache.hadoop.hbase.Cell;
2424
import org.apache.hadoop.hbase.CellUtil;
2525
import org.apache.hadoop.hbase.CompareOperator;
26-
import org.apache.hadoop.hbase.DoNotRetryIOException;
2726
import org.apache.hadoop.hbase.PrivateCellUtil;
2827
import org.apache.hadoop.hbase.exceptions.DeserializationException;
2928
import org.apache.hadoop.hbase.util.Bytes;

hbase-client/src/main/java/org/apache/hadoop/hbase/filter/ValueFilter.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@
2121
import java.util.ArrayList;
2222
import org.apache.hadoop.hbase.Cell;
2323
import org.apache.hadoop.hbase.CompareOperator;
24-
import org.apache.hadoop.hbase.DoNotRetryIOException;
2524
import org.apache.hadoop.hbase.exceptions.DeserializationException;
2625
import org.apache.yetus.audience.InterfaceAudience;
2726

hbase-client/src/test/java/org/apache/hadoop/hbase/filter/TestFiltersWithComparatorException.java

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,6 @@
2525
import java.util.List;
2626
import org.apache.hadoop.hbase.Cell;
2727
import org.apache.hadoop.hbase.CompareOperator;
28-
import org.apache.hadoop.hbase.DoNotRetryIOException;
2928
import org.apache.hadoop.hbase.HBaseIOException;
3029
import org.apache.hadoop.hbase.KeyValue;
3130
import org.apache.hadoop.hbase.testclassification.SmallTests;
@@ -37,6 +36,11 @@
3736
@Category(SmallTests.class)
3837
public class TestFiltersWithComparatorException {
3938

39+
/**
40+
* Tests that filters which take a ByteArrayComparable comparator handle runtime exceptions in the
41+
* comparator layer, see HBASE-29672
42+
*/
43+
4044
byte[] cf = Bytes.toBytes("cf");
4145
byte[] row = Bytes.toBytes("row1");
4246
byte[] cq = Bytes.toBytes("q");
@@ -122,8 +126,8 @@ private void testFilter(Filter filter, BadComparator badComparator) {
122126
filterFunction.run(filter);
123127
} catch (HBaseIOException e) {
124128
ioExceptionThrown = true;
129+
} catch (IOException ignored) {
125130
}
126-
catch (IOException ignored) {}
127131
if (invocationsBefore != badComparator.compareToInvokations) {
128132
Assert.assertTrue("IOException should have been thrown", ioExceptionThrown);
129133
}

0 commit comments

Comments
 (0)