@@ -709,11 +709,7 @@ public void testCallContextPropagatedInMutationBatcher()
709709 contextInterceptor .contexts .clear ();
710710
711711 // Override the timeout
712- GrpcCallContext clientCtx =
713- GrpcCallContext .createDefault ()
714- .withTimeout (Duration .ofMinutes (10 ))
715- .withRetrySettings (
716- RetrySettings .newBuilder ().setTotalTimeout (Duration .ofMinutes (10 )).build ());
712+ GrpcCallContext clientCtx = GrpcCallContext .createDefault ().withTimeout (Duration .ofMinutes (10 ));
717713
718714 // Send a batch
719715 try (Batcher <RowMutationEntry , Void > batcher =
@@ -742,11 +738,7 @@ public void testCallContextPropagatedInReadBatcher()
742738 contextInterceptor .contexts .clear ();
743739
744740 // Override the timeout
745- GrpcCallContext clientCtx =
746- GrpcCallContext .createDefault ()
747- .withTimeout (Duration .ofMinutes (10 ))
748- .withRetrySettings (
749- RetrySettings .newBuilder ().setTotalTimeout (Duration .ofMinutes (10 )).build ());
741+ GrpcCallContext clientCtx = GrpcCallContext .createDefault ().withTimeout (Duration .ofMinutes (10 ));
750742
751743 // Send a batch
752744 try (Batcher <ByteString , Row > batcher =
@@ -981,7 +973,7 @@ private static class ContextInterceptor implements ServerInterceptor {
981973 final BlockingQueue <MethodContext > contexts = Queues .newLinkedBlockingDeque ();
982974
983975 static class MethodContext {
984- final MethodDescriptor <?, ?> method ;
976+ final MethodDescriptor <?,?> method ;
985977 final Context context ;
986978
987979 MethodContext (MethodDescriptor <?, ?> method , Context context ) {
0 commit comments