CDH Oozie 邮件配置

简介: CDH Oozie 邮件配置

CDH Oozie 邮件配置

  • 准备工作,邮件操作 SMTP 配置
  1. 使用微信企业邮箱进行配置,执行测试任务时报错:Encountered an error while sending the email message over SMTP,错误原因是配置 Oozie 邮箱操作 SMTP 身份验证密码时错误,根据文档多次测试没有成功,改为 163 邮箱,一次性配置成功。
  2. 网易 163 邮箱配置步骤

关键路径:

设置——> POP3/SMTP/IMAP

开启 SMTP 服务(截图中已经是开启状态,所以显示 关闭),按提示一步步操作,最后生成授权码,用于登录第三方邮件客户端的专用密码,在下面的“Oozie 电子邮件操作 SMTP 身份验证密码” 中使用此授权码

到这一步,准备工作完成。

  • 从 Cloudera Manager 进入 Oozie 配置,输入 email

cdh-ooize-email

  • 配置邮件相关字段

cdh-ooize-email-config

  1. Oozie 电子邮件操作 SMTP 主机:即邮件服务器主机名,比如smtp.163.com、smtp.qq.com 等
  2. Oozie 电子邮件操作发件人地址:邮件发件人地址,如 xxx.163.com
  3. 启用身份验证
  4. Oozie 电子邮件操作 SMTP 身份验证用户名:可以使用与2一样的地址 xxx.163.com
  5. Oozie 电子邮件操作 SMTP 身份验证密码,不是邮箱密码
  • Oozie 启用 SLA

cdh-ooize-sla-config

  • 重启 Oozie 使得配置生效

通过 Hue 配置工作流 SLA

  • 点击 Workflows 的 settings 按钮,Enable SLA Configuration后,输入收件人邮件地址

  • 测试邮件效果

遇到的问题

错误信息

在 WorkFlow 中设置邮件告警,执行测试任务时报错:Encountered an error while sending the email message over SMTP,具体的错误信息如下:

2020-10-30 11:34:15,224 WARN org.apache.oozie.command.wf.ActionStartXCommand: SERVER[hadoop01.rxhui.com] USER[admin] GROUP[-] TOKEN[] APP[test_alert] JOB[0000214-201029173514233-oozie-oozi-W] ACTION[0000214-201029173514233-oozie-oozi-W@Kill] Error starting action [Kill]. ErrorType [ERROR], ErrorCode [EM007], Message [EM007: Encountered an error while sending the email message over SMTP.]
org.apache.oozie.action.ActionExecutorException: EM007: Encountered an error while sending the email message over SMTP.
 at org.apache.oozie.action.email.EmailActionExecutor.email(EmailActionExecutor.java:301)
 at org.apache.oozie.action.email.EmailActionExecutor.validateAndMail(EmailActionExecutor.java:172)
 at org.apache.oozie.action.email.EmailActionExecutor.start(EmailActionExecutor.java:111)
 at org.apache.oozie.command.wf.ActionStartXCommand.execute(ActionStartXCommand.java:243)
 at org.apache.oozie.command.wf.ActionStartXCommand.execute(ActionStartXCommand.java:68)
 at org.apache.oozie.command.XCommand.call(XCommand.java:290)
 at org.apache.oozie.command.wf.SignalXCommand.execute(SignalXCommand.java:459)
 at org.apache.oozie.command.wf.SignalXCommand.execute(SignalXCommand.java:82)
 at org.apache.oozie.command.XCommand.call(XCommand.java:290)
 at org.apache.oozie.command.wf.ActionEndXCommand.execute(ActionEndXCommand.java:283)
 at org.apache.oozie.command.wf.ActionEndXCommand.execute(ActionEndXCommand.java:62)
 at org.apache.oozie.command.XCommand.call(XCommand.java:290)
 at org.apache.oozie.command.wf.ActionCheckXCommand.execute(ActionCheckXCommand.java:244)
 at org.apache.oozie.command.wf.ActionCheckXCommand.execute(ActionCheckXCommand.java:56)
 at org.apache.oozie.command.XCommand.call(XCommand.java:290)
 at java.util.concurrent.FutureTask.run(FutureTask.java:266)
 at org.apache.oozie.service.CallableQueueService$CallableWrapper.run(CallableQueueService.java:182)
 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
 at java.lang.Thread.run(Thread.java:748)
Caused by: javax.mail.MessagingException: Exception reading response;
  nested exception is:
 java.net.SocketTimeoutException: Read timed out
 at com.sun.mail.smtp.SMTPTransport.readServerResponse(SMTPTransport.java:2202)
 at com.sun.mail.smtp.SMTPTransport.openServer(SMTPTransport.java:1939)
 at com.sun.mail.smtp.SMTPTransport.protocolConnect(SMTPTransport.java:654)
 at javax.mail.Service.connect(Service.java:317)
 at javax.mail.Service.connect(Service.java:176)
 at javax.mail.Service.connect(Service.java:125)
 at javax.mail.Transport.send0(Transport.java:194)
 at javax.mail.Transport.send(Transport.java:124)
 at org.apache.oozie.action.email.EmailActionExecutor.email(EmailActionExecutor.java:296)
 ... 19 more
Caused by: java.net.SocketTimeoutException: Read timed out
 at java.net.SocketInputStream.socketRead0(Native Method)
 at java.net.SocketInputStream.socketRead(SocketInputStream.java:116)
 at java.net.SocketInputStream.read(SocketInputStream.java:171)
 at java.net.SocketInputStream.read(SocketInputStream.java:141)
 at com.sun.mail.util.TraceInputStream.read(TraceInputStream.java:124)
 at java.io.BufferedInputStream.fill(BufferedInputStream.java:246)
 at java.io.BufferedInputStream.read(BufferedInputStream.java:265)
 at com.sun.mail.util.LineInputStream.readLine(LineInputStream.java:89)
 at com.sun.mail.smtp.SMTPTransport.readServerResponse(SMTPTransport.java:2182)
 ... 27 more

错误原因

配置 Oozie 邮箱操作 SMTP 身份验证密码时错误,这个密码是启动 SMTP 服务时在邮箱设置的授权码,并不是邮箱密码。

解决方案

CDH Oozie 邮件配置由微信企业邮箱改为 163 邮箱。

如果觉得还有帮助的话,你的关注和转发是对我最大的支持,O(∩_∩)O:

相关文章
|
IDE Java 程序员
IDEA上运行Flink任务
将最简单的flink任务在IDEA上开发和运行,为后面的深入学习和实践打好基础
957 0
IDEA上运行Flink任务
|
消息中间件 Kafka 流计算
Flink读取Kafka报Error sending fetch request
实时计算Flink读取消息队列Kafka,flink日志中出现Error sending fetch request (sessionId=1510763375, epoch=12890978) to node 103: {}. org.apache.flink.kafka.shaded.org.apache.kafka.common.errors.DisconnectException: null
12765 3
Flink读取Kafka报Error sending fetch request
|
7月前
|
Ubuntu Linux 应用服务中间件
Linux使用cpulimit对CPU使用率进行限制
cpulimit是一款简单易用的CPU使用率限制工具,支持对特定程序或整个CPU使用率进行限制。可通过源安装(如`yum`或`apt-get`)或编译安装获取。使用时,可针对程序名、进程号或绝对路径设置CPU占用上限(如`cpulimit -e xmrig -l 60 -b`)。ROOT用户可限制所有进程,普通用户仅限于权限范围内进程。注意,CPU百分比基于实际核心数(单核100%,双核200%,依此类推)。
518 7
|
流计算
Flink CDC在运行过程中遇到"Could not upload job files"的问题
Flink CDC在运行过程中遇到"Could not upload job files"的问题
418 1
|
关系型数据库 MySQL Java
实时计算 Flink版操作报错之遇到java.lang.IllegalStateException: The elasticsearch emitter must be serializable.的错误,如何处理
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
|
存储 PyTorch 算法框架/工具
Transformers 4.37 中文文档(七十五)(1)
Transformers 4.37 中文文档(七十五)
145 0
|
分布式计算 监控 大数据
大数据-148 Apache Kudu 从 Flink 下沉数据到 Kudu
大数据-148 Apache Kudu 从 Flink 下沉数据到 Kudu
236 1
|
Windows
Windows操作系统部署安装Kerberos客户端
详细介绍了在Windows操作系统上部署安装Kerberos客户端的完整过程,包括下载安装包、安装步骤、自定义安装路径、修改环境变量、配置hosts文件和Kerberos配置文件,以及安装后的验证步骤。
1301 3
Windows操作系统部署安装Kerberos客户端
|
消息中间件 SQL Kafka
实时计算 Flink版操作报错合集之遇到报错:javax.management.InstanceAlreadyExistsException,该如何处理
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
|
存储 分布式计算 Hadoop
Hadoop 集群小文件归档 HAR、小文件优化 Uber 模式
该文介绍了Hadoop中两种小文件管理策略。首先,通过Hadoop Archive (HAR)将小文件归档成大文件以减少存储和管理开销。操作包括使用`hadoop archive`命令进行归档和解档。其次,文章讨论了小文件优化的Uber模式,这种模式在同一JVM中运行所有MapReduce任务以提高效率和局部性,但可能引发单点故障和资源限制问题。启用Uber模式需在`mapred-site.xml`配置文件中设置相关参数。文中还提供了使用WordCount例子验证Uber模式配置的步骤。
484 0