Skip to content

Commit 3f969ad

Browse files
dcoliversunHyukjinKwon
authored andcommitted
[SPARK-39676][CORE][TESTS] Add task partition id for TaskInfo assertEquals method in JsonProtocolSuite
### What changes were proposed in this pull request? In #35185 , task partition id was added in taskInfo. And, JsonProtocolSuite#assertEquals about TaskInfo doesn't have partitionId. ### Why are the changes needed? Should assert partitionId equals or not. ### Does this PR introduce _any_ user-facing change? No. ### How was this patch tested? No need to add unit test. Closes #37081 from dcoliversun/SPARK-39676. Authored-by: Qian.Sun <qian.sun2020@gmail.com> Signed-off-by: Hyukjin Kwon <gurwls223@apache.org>
1 parent 3e28f33 commit 3f969ad

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

core/src/test/scala/org/apache/spark/util/JsonProtocolSuite.scala

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -790,6 +790,8 @@ private[spark] object JsonProtocolSuite extends Assertions {
790790
assert(info1.taskId === info2.taskId)
791791
assert(info1.index === info2.index)
792792
assert(info1.attemptNumber === info2.attemptNumber)
793+
// The "Partition ID" field was added in Spark 3.3.0
794+
assert(info1.partitionId === info2.partitionId)
793795
assert(info1.launchTime === info2.launchTime)
794796
assert(info1.executorId === info2.executorId)
795797
assert(info1.host === info2.host)

0 commit comments

Comments
 (0)