Merge pull request #132 from uber-java/logportunreachableexception

adamjeanlaurent · web-flow · commit ff9ca7259af3 · 2025-12-12T09:00:12.000-05:00
Downgrade PortUnreachableException in UDP flush from an exception to a warn log.
diff --git 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
@@ -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
@@ -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 {
