storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kabh...@apache.org
Subject [1/4] storm git commit: Fix incorrect WARN log
Date Sat, 18 Jul 2015 01:11:07 GMT
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.wangxin@163.com>
Authored: Thu Jul 16 10:06:28 2015 +0800
Committer: Xin Wang <best.wangxin@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 + "]";


Mime
View raw message