Github user chenqin commented on a diff in the pull request:
https://github.com/apache/spark/pull/23073#discussion_r234453776
--- Diff:
core/src/main/scala/org/apache/spark/scheduler/cluster/ExecutorData.scala ---
@@ -27,12 +27,14 @@ import org.apache.spark.rpc.{RpcAddress
GitHub user chenqin opened a pull request:
https://github.com/apache/spark/pull/23073
[SPARK-26104] expose pci info to task scheduler
## What changes were proposed in this pull request?
(Please fill in changes proposed in this fix)
## How was this patch tested
Github user chenqin commented on a diff in the pull request:
https://github.com/apache/spark/pull/21494#discussion_r207070253
--- Diff:
core/src/main/scala/org/apache/spark/barrier/BarrierCoordinator.scala ---
@@ -0,0 +1,78 @@
+/*
+ * Licensed to the Apache Software
Github user chenqin commented on a diff in the pull request:
https://github.com/apache/spark/pull/21494#discussion_r207071402
--- Diff:
core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala ---
@@ -359,17 +368,42 @@ private[spark] class TaskSchedulerImpl