Commit 2f312486 authored by Mygod's avatar Mygod

Avoid too many reschedules correctly

parent 88d5c01c
......@@ -46,8 +46,6 @@ object AclSyncJob {
}
class AclSyncJob(route: String) extends Job {
var rescheduled = 0
override def onRunJob(params: Params): Result = {
try {
//noinspection JavaAccessorMethodCalledAsEmptyParen
......@@ -57,11 +55,7 @@ class AclSyncJob(route: String) extends Job {
} catch {
case e: IOException =>
e.printStackTrace()
rescheduled += 1
if (rescheduled < AclSyncJob.MAX_RESCHEDULE)
Result.RESCHEDULE
else
Result.FAILURE
if (params.getFailureCount < AclSyncJob.MAX_RESCHEDULE) Result.RESCHEDULE else Result.FAILURE
case e: Exception => // unknown failures, probably shouldn't retry
e.printStackTrace()
Result.FAILURE
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment