-
Notifications
You must be signed in to change notification settings - Fork 8.9k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
HDDS-1224. Restructure code to validate the response from server in the Read path. #793
Conversation
…ents discussed offline.
💔 -1 overall
This message was automatically generated. |
@Override | ||
public void connect() throws Exception { | ||
*/ | ||
@Override public void connect() throws Exception { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
What's the purpose of modifying it?
boolean isEmpty() { | ||
return streamEntries.isEmpty(); | ||
} | ||
} |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
} | |
} | |
Should better add a new line at the end of file.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
These are changes from a different patch altogether and not related to the issue.
*/ | ||
public class BlockOutputStreamEntryPool { | ||
|
||
public static final Logger LOG = |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
public static final Logger LOG = | |
private static final Logger LOG = |
@@ -83,15 +85,15 @@ | |||
* data nodes. | |||
* | |||
* @param pipeline - Pipeline that defines the machines. | |||
* @param config -- Ozone Config | |||
* @param config -- Ozone Config |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
* @param config -- Ozone Config | |
* @param config - Ozone Config |
@@ -69,7 +71,8 @@ | |||
* The underlying RPC mechanism can be chosen via the constructor. | |||
*/ | |||
public final class XceiverClientRatis extends XceiverClientSpi { | |||
static final Logger LOG = LoggerFactory.getLogger(XceiverClientRatis.class); | |||
public static final Logger LOG = |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
public static final Logger LOG = | |
private static final Logger LOG = |
@@ -121,12 +121,12 @@ | |||
TimeDuration.valueOf(3000, TimeUnit.MILLISECONDS); | |||
public static final String DFS_RATIS_CLIENT_REQUEST_MAX_RETRIES_KEY = | |||
"dfs.ratis.client.request.max.retries"; | |||
public static final int DFS_RATIS_CLIENT_REQUEST_MAX_RETRIES_DEFAULT = 20; | |||
public static final int DFS_RATIS_CLIENT_REQUEST_MAX_RETRIES_DEFAULT = 180; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
What's the purpose of modifying it?
Closing this pull request, will create a new one to address the issue. |
Author: Jagadish <jvenkatraman@linkedin.com> Reviewers: Jagadish<jagadish@apache.org> Closes apache#793 from vjagadish1989/website-reorg30
No description provided.