Repository: storm Updated Branches: refs/heads/0.9.x-branch 12b4459b0 -> 67cc2201a
Fix incorrect WARN log Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/9221dba1 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/9221dba1 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/9221dba1 Branch: refs/heads/0.9.x-branch Commit: 9221dba1eee59686ec6a1bcfd93d4ce542b071e9 Parents: ff42a3d Author: Xin Wang <best.wang...@163.com> Authored: Thu Jul 16 10:06:28 2015 +0800 Committer: Xin Wang <best.wang...@163.com> Committed: Thu Jul 16 10:06:28 2015 +0800 ---------------------------------------------------------------------- external/storm-kafka/src/jvm/storm/kafka/KafkaUtils.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/9221dba1/external/storm-kafka/src/jvm/storm/kafka/KafkaUtils.java ---------------------------------------------------------------------- diff --git a/external/storm-kafka/src/jvm/storm/kafka/KafkaUtils.java b/external/storm-kafka/src/jvm/storm/kafka/KafkaUtils.java index 918da74..df33c4b 100644 --- a/external/storm-kafka/src/jvm/storm/kafka/KafkaUtils.java +++ b/external/storm-kafka/src/jvm/storm/kafka/KafkaUtils.java @@ -180,9 +180,7 @@ public class KafkaUtils { if (fetchResponse.hasError()) { KafkaError error = KafkaError.getError(fetchResponse.errorCode(topic, partitionId)); if (error.equals(KafkaError.OFFSET_OUT_OF_RANGE) && config.useStartOffsetTimeIfOffsetOutOfRange) { - LOG.warn("Got fetch request with offset out of range: [" + offset + "]; " + - "retrying with default start offset time from configuration. " + - "configured start offset time: [" + config.startOffsetTime + "]"); + LOG.warn("Got fetch request with offset out of range: [" + offset + "]"); throw new UpdateOffsetException(); } else { String message = "Error fetching data from [" + partition + "] for topic [" + topic + "]: [" + error + "]";
