MINOR: Fix null exception in coordinator log
Reviewers: A. Sophie Blee-Goldman Chia-Ping Tsai
@@ -256,8 +256,8 @@ public abstract class AbstractCoordinator implements Closeable {
log.debug("Coordinator discovery failed, refreshing metadata", future.exception());
client.awaitMetadataUpdate(timer);
} else {
- log.info("FindCoordinator request hit fatal exception", fatalException);
fatalException = future.exception();
+ log.info("FindCoordinator request hit fatal exception", fatalException);
}
} else if (coordinator != null && client.isUnavailable(coordinator)) {
// we found the coordinator, but the connection has failed, so mark
