0

我正在使用 oozie 协调器来安排我的 hadoop 作业。我将开始时间定为 12:26,但它在 8-9 小时后开始,并根据我在工作属性文件中给出的频率完成所有剩余的工作。

为什么这个 8 小时的暂停,仍然使用我在 job.properties 中给出的 startTime 完成剩余的工作?

nameNode=hdfs://localhost:8020
jobTracker=localhost:8021
queueName=default

oozie.libpath=${nameNode}/user/oozie/share/lib
oozie.use.system.libpath=true
oozie.wf.rerun.failnodes=true


appPath=${nameNode}/user/user1/mr
oozie.wf.application.path=${appPath}



frequency=60
jobStart=2014-12-31T12:26Z
jobEnd=2015-12-16T23:00Z
timezone=GMT+0530

inputDir=${nameNode}/user/user1/input
outputDir=${nameNode}/user/user1/output

oozie.coord.application.path=${appPath}/coordinator.xml

协调器.xml

<coordinator-app name="LogCoordinator" frequency="${frequency}" start="${jobStart}" end="${jobEnd}" timezone="${timezone}" xmlns="uri:oozie:coordinator:0.1">
<action>
<workflow>
<app-path>${appPath}</app-path>
</workflow>
</action>          
</coordinator-app>

有没有时区问题?

4

2 回答 2

1

您是否交叉检查了 GMT 时间和我们的 IST 时间!!确保您的 jobstart 变量的 IST 时间。

于 2015-01-06T10:36:07.820 回答
0

首先您需要在 oozie-site.xml 中配置“ oozie.processing.timezone ”,默认值为 UTC。通过将 (GMT+0530) 指定为其值并重新启动 oozie,将其更改为所需的时区(此处为 IST)。然后您必须使用 timezone="IST" (或 GMT+0530)配置 coordinator.xml。并在 coordinator.properties 中提供 startTime/endTime 以及实际的 IST时间。UTC 时区的时间戳格式为 (yyyy-MM-dd'T'HH:mm'Z') 指定时间的格式现在将更改为(yyyy-MM-dd'T'HH:mm+0530)即如果您希望您的作业在 05:30(IST) 运行,那么属性文件中 startTime 的值将是(2018-10-07T05:30+0530)。这对我有用。希望这可以帮助。

于 2018-10-07T15:29:02.003 回答