Blindly trying to fix the smoke tests

DataDog · Nov 20, 2024 · 0fa642e · 0fa642e
1 parent 17ef73a
commit 0fa642e
Showing 1 changed file with 17 additions and 17 deletions.
diff --git a/internal-api/src/main/java/datadog/trace/util/PidHelper.java b/internal-api/src/main/java/datadog/trace/util/PidHelper.java
@@ -75,30 +75,30 @@ public static Set<String> getJavaPids() {
       // start draining the subcommand's pipes asynchronously to avoid flooding them
       CompletableFuture<Set<String>> collecting =
           CompletableFuture.supplyAsync(
-              (Supplier<Set<String>>)
-                  () -> {
-                    try (BufferedReader br =
-                        new BufferedReader(new InputStreamReader(p.getInputStream()))) {
-                      return br.lines()
-                          .filter(l -> !l.contains("jps"))
-                          .map(
-                              l -> {
-                                int idx = l.indexOf(' ');
-                                return l.substring(0, idx);
-                              })
-                          .collect(java.util.stream.Collectors.toSet());
-                    } catch (IOException e) {
-                      log.debug("Unable to list java processes via 'jps'", e);
-                      return Collections.emptySet();
-                    }
-                  });
+              () -> {
+                try (BufferedReader br =
+                    new BufferedReader(new InputStreamReader(p.getInputStream()))) {
+                  return br.lines()
+                      .filter(l -> !l.contains("jps"))
+                      .map(
+                          l -> {
+                            int idx = l.indexOf(' ');
+                            return l.substring(0, idx);
+                          })
+                      .collect(java.util.stream.Collectors.toSet());
+                } catch (IOException e) {
+                  log.debug("Unable to list java processes via 'jps'", e);
+                  return Collections.emptySet();
+                }
+              });
       if (p.waitFor(500, TimeUnit.MILLISECONDS)) {
         if (p.exitValue() == 0) {
           return collecting.get();
         } else {
           log.debug("Execution of 'jps' failed with exit code {}", p.exitValue());
         }
       } else {
+        p.destroyForcibly();
         log.debug("Execution of 'jps' timed out");
       }
     } catch (Exception e) {