Skip to content
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

Add support for un compressed files, unit test added. #381

Open
wants to merge 2 commits into
base: master
Choose a base branch
from

Conversation

achyuthsamudrala
Copy link

Currently in the pathAndCodecforEventLog function in the second case block there is no support for un compressed files, this makes Dr. Elephant look for files with lz4 compression default. This patch adds support for the same.

Achyuth Samudrala added 2 commits May 16, 2018 17:47
Currently in the pathAndCodecforEventLog function in the second case block there is no support for un compressed files, this makes Dr. Elephant look for files with lz4 compression default. This patch adds support for the same.
@achyuthsamudrala achyuthsamudrala changed the title Add support for non compression files Add support for un compressed files, unit test added. May 17, 2018
@@ -274,6 +282,9 @@ trait SparkUtils {
// if codec is not available, but we found a file match with appId, use the actual file Path from the first match
case nocodec if nocodec._1 != None & nocodec._3 == None => (attemptsList(0).getPath(), DEFAULT_COMPRESSION_CODEC)

case nocompression if nocompression._1 == None & nocompression._2 == None & nocompression._3 == None
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Please write the coment for this case condition , as have written in another case conditions

@@ -182,6 +187,7 @@ trait SparkUtils {
private val IN_PROGRESS = ".inprogress"
private val DEFAULT_COMPRESSION_CODEC = "lz4"


Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Nit : Remove unnecessary lines (apply elsewhere)

" withlogPath: " + eventLogPath +
" with codec:" + eventLogCodec)
" with codec:" + eventLogCodec)
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Nit : Extra space

Copy link
Contributor

@pralabhkumar pralabhkumar Dec 19, 2018

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Please log also in case eventLogCodec empty (as with no-compression case)

@pralabhkumar
Copy link
Contributor

@achyuthsamudrala Please add more description in pull request . It will help other reviewers to understand the context better

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants