Skip to content

Commit 9df7587

Browse files
committed
[MINOR][CORE] Fix line too long in TransportClientFactory
## What changes were proposed in this pull request? See https://github.com/apache/spark/pull/24702/files#r296765487 -- this just fixes a Java style error. I'm not clear why the PR build didn't catch it. ## How was this patch tested? N/A Closes apache#24951 from srowen/SPARK-27989.2. Authored-by: Sean Owen <[email protected]> Signed-off-by: Sean Owen <[email protected]>
1 parent 6064368 commit 9df7587

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

common/network-common/src/main/java/org/apache/spark/network/client/TransportClientFactory.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -174,9 +174,11 @@ public TransportClient createClient(String remoteHost, int remotePort)
174174
final long hostResolveTimeMs = (System.nanoTime() - preResolveHost) / 1000000;
175175
final String resolvMsg = resolvedAddress.isUnresolved() ? "failed" : "succeed";
176176
if (hostResolveTimeMs > 2000) {
177-
logger.warn("DNS resolution {} for {} took {} ms", resolvMsg, resolvedAddress, hostResolveTimeMs);
177+
logger.warn("DNS resolution {} for {} took {} ms",
178+
resolvMsg, resolvedAddress, hostResolveTimeMs);
178179
} else {
179-
logger.trace("DNS resolution {} for {} took {} ms", resolvMsg, resolvedAddress, hostResolveTimeMs);
180+
logger.trace("DNS resolution {} for {} took {} ms",
181+
resolvMsg, resolvedAddress, hostResolveTimeMs);
180182
}
181183

182184
synchronized (clientPool.locks[clientIndex]) {

0 commit comments

Comments
 (0)