Skip to content
This repository has been archived by the owner on Oct 30, 2020. It is now read-only.

EmailClient Fixes #214

Merged
merged 2 commits into from
Apr 23, 2015
Merged

EmailClient Fixes #214

merged 2 commits into from
Apr 23, 2015

Conversation

sumitchawla
Copy link
Contributor

No description provided.

@sumitchawla sumitchawla changed the title Updated the class for the decoder EmailClient Fixes Apr 23, 2015
@sumitchawla
Copy link
Contributor Author

If emaillist is not configured then it produces following warning:

javax.mail.internet.AddressException: Illegal address in string ``''
    at javax.mail.internet.InternetAddress.<init>(InternetAddress.java:110)
    at javax.mail.internet.InternetAddress.<init>(InternetAddress.java:135)
    at com.linkedin.camus.etl.kafka.common.EmailClient.sendEmail(EmailClient.java:75)
    at com.linkedin.camus.etl.kafka.mapred.EtlInputFormat.getSplits(EtlInputFormat.java:442)
    at org.apache.hadoop.mapreduce.JobSubmitter.writeNewSplits(JobSubmitter.java:597)
    at org.apache.hadoop.mapreduce.JobSubmitter.writeSplits(JobSubmitter.java:614)
    at org.apache.hadoop.mapreduce.JobSubmitter.submitJobInternal(JobSubmitter.java:492)
    at org.apache.hadoop.mapreduce.Job$10.run(Job.java:1296)
    at org.apache.hadoop.mapreduce.Job$10.run(Job.java:1293)
    at java.security.AccessController.doPrivileged(Native Method)
    at javax.security.auth.Subject.doAs(Subject.java:415)
    at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1628)
    at org.apache.hadoop.mapreduce.Job.submit(Job.java:1293)
    at com.linkedin.camus.etl.kafka.CamusJob.run(CamusJob.java:354)
    at com.linkedin.camus.etl.kafka.CamusJob.run(CamusJob.java:235)
    at com.linkedin.camus.etl.kafka.CamusJob.run(CamusJob.java:690)
    at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:70)
    at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:84)
    at com.linkedin.camus.etl.kafka.CamusJob.main(CamusJob.java:645)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:606)
    at org.apache.hadoop.util.RunJar.run(RunJar.java:221)
    at org.apache.hadoop.util.RunJar.main(RunJar.java:136)

@zliu41
Copy link
Contributor

zliu41 commented Apr 23, 2015

LGTM. Thanks.

zliu41 added a commit that referenced this pull request Apr 23, 2015
@zliu41 zliu41 merged commit 623e3b2 into LinkedInAttic:master Apr 23, 2015
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants