diff --git a/build.gradle b/build.gradle index 19b6690..4cfbacb 100644 --- a/build.gradle +++ b/build.gradle @@ -45,7 +45,7 @@ configurations.archives.artifacts.clear() allprojects { group = 'com.uber.m3' - version = '0.14.2' + version = '0.14.3' apply plugin: 'java' apply plugin: 'maven' diff --git a/core/src/main/java/com/uber/m3/tally/ScopeImpl.java b/core/src/main/java/com/uber/m3/tally/ScopeImpl.java index d40904d..67d1577 100644 --- a/core/src/main/java/com/uber/m3/tally/ScopeImpl.java +++ b/core/src/main/java/com/uber/m3/tally/ScopeImpl.java @@ -25,7 +25,6 @@ import javax.annotation.Nullable; import java.util.Collection; import java.util.Map; -import java.util.Optional; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.CopyOnWriteArrayList; import java.util.concurrent.ScheduledExecutorService; diff --git a/m3/src/main/java/com/uber/m3/tally/m3/thrift/TUdpClient.java b/m3/src/main/java/com/uber/m3/tally/m3/thrift/TUdpClient.java index bf2275b..4cd727f 100644 --- a/m3/src/main/java/com/uber/m3/tally/m3/thrift/TUdpClient.java +++ b/m3/src/main/java/com/uber/m3/tally/m3/thrift/TUdpClient.java @@ -25,6 +25,7 @@ import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; +import java.net.PortUnreachableException; import java.net.SocketAddress; import java.net.SocketException; @@ -68,6 +69,8 @@ public void flush() throws TTransportException { // directly new DatagramPacket(writeBuffer.array(), writeBuffer.position()) ); + } catch (PortUnreachableException e) { + logger.warn("UDP port unreachable during flush"); } catch (IOException e) { throw new TTransportException(e); } finally {