diff --git a/spark-common/src/main/java/me/lucko/spark/common/platform/PlatformStatisticsProvider.java b/spark-common/src/main/java/me/lucko/spark/common/platform/PlatformStatisticsProvider.java index d9fbff2ab8..536274f2b1 100644 --- a/spark-common/src/main/java/me/lucko/spark/common/platform/PlatformStatisticsProvider.java +++ b/spark-common/src/main/java/me/lucko/spark/common/platform/PlatformStatisticsProvider.java @@ -279,10 +279,18 @@ static final class VmArgRedactor { private static final Pattern MACOS_USERNAME = Pattern.compile("/Users/\\w+"); private static final Pattern LINUX_USERNAME = Pattern.compile("/home/\\w+"); + // Hide Yourkit broker url and broker token + private static final Pattern BROKER_URL = Pattern.compile("(broker_url=)[^,\\s]+"); + private static final Pattern BROKER_TOKEN = Pattern.compile("(broker_token=)[^,\\s]+"); + static String replace(String input) { input = WINDOWS_USERNAME.matcher(input).replaceAll("C:\\\\Users\\\\"); input = MACOS_USERNAME.matcher(input).replaceAll("/Users/"); input = LINUX_USERNAME.matcher(input).replaceAll("/home/"); + + input = BROKER_URL.matcher(input).replaceAll("$1"); + input = BROKER_TOKEN.matcher(input).replaceAll("$1"); + return input; } }