1 files changed, 4 insertions, 0 deletions
diff --git a/spark-common/src/main/java/me/lucko/spark/common/sampler/async/AsyncProfilerJob.java b/spark-common/src/main/java/me/lucko/spark/common/sampler/async/AsyncProfilerJob.java
index 8991e94..1310e97 100644
--- a/spark-common/src/main/java/me/lucko/spark/common/sampler/async/AsyncProfilerJob.java
+++ b/spark-common/src/main/java/me/lucko/spark/common/sampler/async/AsyncProfilerJob.java
@@ -250,6 +250,10 @@ public class AsyncProfilerJob {
             }
 
             String threadName = reader.threads.get(sample.tid);
+            if (threadName == null) {
+                continue;
+            }
+
             if (!threadFilter.test(threadName)) {
                 continue;
             }