You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ju...@apache.org on 2015/04/09 04:06:33 UTC
kafka git commit: kafka-2090;
Remove duplicate check to metadataFetchInProgress; patched by Tim Brook;
reviewed by Ewen Cheslack-PostavaJun Rao
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 <tb...@gmail.com>
Authored: Wed Apr 8 19:06:05 2015 -0700
Committer: Jun Rao <ju...@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 {