-
Notifications
You must be signed in to change notification settings - Fork 24
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
HPCC4J-577 Added Read Retry to HPCCRemoteFileReader #706
Conversation
Jira Issue: https://hpccsystems.atlassian.net/browse/HPCC4J-577 Jirabot Action Result: |
// if (tasks.length > numThreads) | ||
// { | ||
// numThreads = tasks.length; | ||
// } | ||
|
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.
can be removed
dfsclient/src/main/java/org/hpccsystems/dfs/client/HpccRemoteFileReader.java
Show resolved
Hide resolved
dfsclient/src/main/java/org/hpccsystems/dfs/client/HpccRemoteFileReader.java
Show resolved
Hide resolved
@drealeed Thanks for the code review! Implemented code review changes. @rpastrana please review |
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.
@jpmcmu a few comments
@@ -425,6 +426,7 @@ private static Options getReadTestOptions() | |||
options.addOption("user", true, "Specifies the username used to connect. Defaults to null."); | |||
options.addOption("pass", true, "Specifies the password used to connect. Defaults to null."); | |||
options.addOption("num_threads", true, "Specifies the number of parallel to use to perform operations."); | |||
options.addOption("expiry_seconds", true, "Access token expiration seconds."); |
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.
access_expiry_secs ?
this.recordBuilder = recBuilder; | ||
if (this.originalRecordDef == null) | ||
{ | ||
throw new Exception("HpccRemoteFileReader: Original record definition is null."); |
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.
is there any guidance we can provide to the user in the err message?
@@ -246,6 +257,51 @@ public HpccRemoteFileReader(DataPartition dp, FieldDef originalRD, IRecordBuilde | |||
openTimeMs = System.currentTimeMillis(); | |||
} | |||
|
|||
private boolean retryRead() | |||
{ | |||
if (retryCount < 3) |
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.
shouldn't the max retry count be configurable?
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.
@rpastrana Implemented code review changes, will squash if it looks good
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.
@jpmcmu looks good.
@rpastrana squashed |
- Added Read Retry to HPCCRemoteFileReader - Minor improvements to FileUtility to improve testing Signed-off-by: James McMullan [email protected]
Signed-off-by: James McMullan [email protected]
Type of change:
Checklist:
Testing: