diff --git a/presto-main/src/main/java/io/prestosql/execution/SqlStageExecution.java b/presto-main/src/main/java/io/prestosql/execution/SqlStageExecution.java index eaed6bfc1..1537035e7 100644 --- a/presto-main/src/main/java/io/prestosql/execution/SqlStageExecution.java +++ b/presto-main/src/main/java/io/prestosql/execution/SqlStageExecution.java @@ -335,7 +335,7 @@ public synchronized void cancelToResume() public void OnSnapshotXCompleted(boolean capture, long snapshotId) { - log.debug("OnSnapshotXCompleted() is called!, capture: %b, snapshotId: %d", capture, snapshotId); + LOG.debug("OnSnapshotXCompleted() is called!, capture: %b, snapshotId: %d", capture, snapshotId); if (!capture) { restoreInProgress = false; captureSnapshotId = 0; diff --git a/presto-main/src/main/java/io/prestosql/operator/HttpPageBufferClient.java b/presto-main/src/main/java/io/prestosql/operator/HttpPageBufferClient.java index 538684143..8e032cea4 100644 --- a/presto-main/src/main/java/io/prestosql/operator/HttpPageBufferClient.java +++ b/presto-main/src/main/java/io/prestosql/operator/HttpPageBufferClient.java @@ -440,7 +440,7 @@ public void onFailure(Throwable t) * if node is otherwise (e.g.active), keep retrying till timeout of maxErrorDuration */ FailureDetector.State state = failureDetector.getState(fromUri(uri)); - log.debug("failure detector state is " + state.toString()); + LOG.debug("failure detector state is " + state.toString()); hasFailed = (backoff.maxTried() && !FailureDetector.State.ALIVE.equals(state) || backoff.timeout());