Fix the error handling on hourly to ignore certain kafka error codes, fixed the bug on reprocessing on sweeper

Not sure why these lines (231, 251, 289) changed, maybe it's from 'git merge'?  Can you take a look at the latest diff where I reverted those lines back to where it were before.

________________________________
From: kengoodhope [notifications@github.com]
Sent: Monday, September 08, 2014 2:24 PM
To: linkedin/camus
Cc: Henry Cai
Subject: Re: [camus] Fix the error handling on hourly to ignore certain kafka error codes, fixed the bug on reprocessing on sweeper (#112)


In camus-etl-kafka/src/main/java/com/linkedin/camus/etl/kafka/CamusJob.java:

> @@ -231,7 +231,7 @@ public void run() throws Exception {
>                               .getFloat(ETL_EXECUTION_HISTORY_MAX_OF_QUOTA, (float) .5));
>               limit = limit == 0 ? 50000 : limit;
>
> -             if (props.containsKey(ETL_BASEDIR_QUOTA_OVERIDE)){


Isn't containsKey correct? contains checks the value and ETL_BASEDIR_QUOTA_OVERIDE is the key, if I remember correctly.

—
Reply to this email directly or view it on GitHub<https://github.com/linkedin/camus/pull/112/files#r17268041>.