Skip to content

Commit

Permalink
Fix typo in PinotException#isRetriable method name
Browse files Browse the repository at this point in the history
  • Loading branch information
findepi committed Jul 16, 2021
1 parent af1b45f commit 183f78f
Show file tree
Hide file tree
Showing 3 changed files with 9 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -23,33 +23,33 @@ public class PinotException
extends TrinoException
{
private final Optional<String> query;
private final boolean retriable;
private final boolean retryable;

public PinotException(PinotErrorCode errorCode, Optional<String> query, String message)
{
this(errorCode, query, message, false, null);
}

public PinotException(PinotErrorCode errorCode, Optional<String> query, String message, boolean retriable)
public PinotException(PinotErrorCode errorCode, Optional<String> query, String message, boolean retryable)
{
this(errorCode, query, message, retriable, null);
this(errorCode, query, message, retryable, null);
}

public PinotException(PinotErrorCode errorCode, Optional<String> query, String message, Throwable throwable)
{
this(errorCode, query, message, false, throwable);
}

public PinotException(PinotErrorCode errorCode, Optional<String> query, String message, boolean retriable, Throwable throwable)
public PinotException(PinotErrorCode errorCode, Optional<String> query, String message, boolean retryable, Throwable throwable)
{
super(requireNonNull(errorCode, "errorCode is null"), requireNonNull(message, "message is null"), throwable);
this.retriable = retriable;
this.retryable = retryable;
this.query = requireNonNull(query, "query is null");
}

public boolean isRetriable()
public boolean isRetryable()
{
return retriable;
return retryable;
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -494,7 +494,7 @@ public static <T> T doWithRetries(int retries, Function<Integer, T> caller)
if (firstError == null) {
firstError = e;
}
if (!e.isRetriable()) {
if (!e.isRetryable()) {
throw e;
}
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -132,7 +132,7 @@ private <T> T doWithRetries(int retries, Function<Long, T> caller)
if (firstError == null) {
firstError = e;
}
if (!e.isRetriable()) {
if (!e.isRetryable()) {
throw e;
}
}
Expand Down

0 comments on commit 183f78f

Please sign in to comment.