kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject kafka git commit: kafka-2090; Remove duplicate check to metadataFetchInProgress; patched by Tim Brook; reviewed by Ewen Cheslack-PostavaJun Rao
Date Thu, 09 Apr 2015 02:06:33 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 194d1fc03 -> 2490b1c49


kafka-2090; Remove duplicate check to metadataFetchInProgress; patched by Tim Brook; reviewed
by Ewen Cheslack-PostavaJun Rao


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/2490b1c4
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/2490b1c4
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/2490b1c4

Branch: refs/heads/trunk
Commit: 2490b1c4994295ba6c291b1109c5d67ebb4c244d
Parents: 194d1fc
Author: Tim Brooks <tbrooks8@gmail.com>
Authored: Wed Apr 8 19:06:05 2015 -0700
Committer: Jun Rao <junrao@gmail.com>
Committed: Wed Apr 8 19:06:05 2015 -0700

----------------------------------------------------------------------
 clients/src/main/java/org/apache/kafka/clients/NetworkClient.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/2490b1c4/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
----------------------------------------------------------------------
diff --git a/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java b/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
index f429502..b7ae595 100644
--- a/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
+++ b/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
@@ -214,7 +214,7 @@ public class NetworkClient implements KafkaClient {
         // if there is no node available to connect, back off refreshing metadata
         long metadataTimeout = Math.max(Math.max(timeToNextMetadataUpdate, timeToNextReconnectAttempt),
                                         waitForMetadataFetch);
-        if (!this.metadataFetchInProgress && metadataTimeout == 0)
+        if (metadataTimeout == 0)
             maybeUpdateMetadata(now);
         // do the I/O
         try {


Mime
View raw message