You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by we...@apache.org on 2022/03/31 13:46:22 UTC

[spark] branch master updated (13cfc5b -> f486029)

This is an automated email from the ASF dual-hosted git repository.

wenchen pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git.


    from 13cfc5b  [SPARK-37831][CORE] add task partition id in TaskInfo and Task Metrics
     add f486029  [SPARK-38679][CORE] Expose the number partitions in a stage to TaskContext

No new revisions were added by this update.

Summary of changes:
 .../kafka010/consumer/KafkaDataConsumerSuite.scala | 11 +++----
 .../kafka010/KafkaDataConsumerSuite.scala          |  6 ++--
 .../org/apache/spark/BarrierTaskContext.scala      |  8 ++---
 .../main/scala/org/apache/spark/TaskContext.scala  |  7 ++++-
 .../scala/org/apache/spark/TaskContextImpl.scala   |  1 +
 .../org/apache/spark/scheduler/DAGScheduler.scala  |  6 ++--
 .../org/apache/spark/scheduler/ResultTask.scala    |  6 ++--
 .../apache/spark/scheduler/ShuffleMapTask.scala    |  6 ++--
 .../scala/org/apache/spark/scheduler/Task.scala    |  3 ++
 .../test/scala/org/apache/spark/ShuffleSuite.scala |  6 ++--
 .../org/apache/spark/executor/ExecutorSuite.scala  |  1 +
 .../apache/spark/memory/MemoryTestingUtils.scala   |  1 +
 .../org/apache/spark/scheduler/FakeTask.scala      |  4 +--
 .../spark/scheduler/NotSerializableFakeTask.scala  |  2 +-
 .../apache/spark/scheduler/TaskContextSuite.scala  | 34 ++++++++++++++++++----
 .../spark/scheduler/TaskSchedulerImplSuite.scala   |  4 +--
 .../spark/scheduler/TaskSetManagerSuite.scala      |  4 +--
 .../spark/storage/BlockInfoManagerSuite.scala      |  2 +-
 project/MimaExcludes.scala                         |  3 ++
 .../execution/AggregatingAccumulatorSuite.scala    |  2 +-
 .../UnsafeFixedWidthAggregationMapSuite.scala      |  1 +
 .../execution/UnsafeKVExternalSorterSuite.scala    |  7 +++--
 .../sql/execution/UnsafeRowSerializerSuite.scala   |  2 +-
 .../aggregate/SortBasedAggregationStoreSuite.scala |  2 +-
 .../streaming/UpdatingSessionsIteratorSuite.scala  |  2 +-
 25 files changed, 86 insertions(+), 45 deletions(-)

---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org