chore: include the cause in retries exhausted exception (#4463)

Thank you for opening a Pull Request! Before submitting your PR, there are a few things you can do to make sure it goes smoothly: - [ ] Make sure to open an issue as a [bug/issue](https://togithub.com/googleapis/java-bigtable-hbase/issues/new/choose) before writing your code! That way we can discuss the change, evaluate designs, and agree on the general idea - [ ] Ensure the tests and linter pass - [ ] Code coverage does not decrease (if any source code was changed) - [ ] Appropriate docs were updated (if necessary) Fixes #<issue_number_goes_here> ☕️ If you write sample code, please follow the [samples format]( https://togithub.com/GoogleCloudPlatform/java-docs-samples/blob/main/SAMPLE_FORMAT.md).

Author: mutianf

bigtable-client-core-parent/bigtable-hbase/src/main/java/com/google/cloud/bigtable/hbase/AbstractBigtableTable.java

@@ -276,8 +276,10 @@ public Result[] get(List<Get> gets) throws IOException {
 
  private RetriesExhaustedWithDetailsException createRetriesExhaustedWithDetailsException(
  Throwable e, Row action) {
- return new RetriesExhaustedWithDetailsException(
- Arrays.asList(e), Arrays.asList(action), Arrays.asList(settings.getDataHost()));
+ return (RetriesExhaustedWithDetailsException)
+ new RetriesExhaustedWithDetailsException(
+ Arrays.asList(e), Arrays.asList(action), Arrays.asList(settings.getDataHost()))
+ .initCause(e);
  }
 
  /** {@inheritDoc} */

bigtable-client-core-parent/bigtable-hbase/src/test/java/com/google/cloud/bigtable/hbase/TestBigtableTable.java

@@ -21,6 +21,7 @@
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertFalse;
 import static org.junit.Assert.assertNull;
+import static org.junit.Assert.assertThrows;
 import static org.junit.Assert.assertTrue;
 import static org.mockito.ArgumentMatchers.isA;
 import static org.mockito.Mockito.doAnswer;
@@ -41,6 +42,8 @@
 import com.google.cloud.bigtable.hbase.wrappers.DataClientWrapper;
 import com.google.common.collect.ImmutableList;
 import com.google.protobuf.ByteString;
+import io.grpc.Status;
+import io.grpc.StatusRuntimeException;
 import java.io.IOException;
 import java.util.Collections;
 import java.util.List;
@@ -55,6 +58,7 @@
 import org.apache.hadoop.hbase.client.Put;
 import org.apache.hadoop.hbase.client.Result;
 import org.apache.hadoop.hbase.client.ResultScanner;
+import org.apache.hadoop.hbase.client.RetriesExhaustedWithDetailsException;
 import org.apache.hadoop.hbase.client.RowMutations;
 import org.apache.hadoop.hbase.client.Scan;
 import org.apache.hadoop.hbase.client.coprocessor.Batch.Call;
@@ -416,4 +420,27 @@ public void testToString() {
  assertThat(abstractTableToStr, containsString("table=" + TEST_TABLE));
  assertThat(abstractTableToStr, containsString("host=" + "localhost"));
  }
+
+ @Test
+ public void testExceptions() {
+ Exception exception =
+ new StatusRuntimeException(Status.DEADLINE_EXCEEDED.withCause(new Throwable("test cause")));
+ when(mockBigtableDataClient.readRowAsync(
+ isA(String.class), isA(ByteString.class), isA(Filters.Filter.class)))
+ .thenThrow(exception);
+
+ RetriesExhaustedWithDetailsException exhaustedWithDetailsException =
+ assertThrows(
+ RetriesExhaustedWithDetailsException.class,
+ () ->
+ table.get(
+ new Get(Bytes.toBytes("rowKey1"))
+ .addColumn(Bytes.toBytes("family"), Bytes.toBytes("qualifier"))));
+
+ assertThat(
+ exhaustedWithDetailsException.getCause().getMessage(), containsString("DEADLINE_EXCEEDED"));
+ assertThat(
+ exhaustedWithDetailsException.getCause().getCause().getMessage(),
+ containsString("test cause"));
+ }
 }