1. [SPARK-26732][CORE][TEST] Wait for listener bus to process events in (commit: f6391e165b8e4dde8a9636fc220042b38eabd056) (details)
  2. [SPARK-26718][SS][BRANCH-2.3] Fixed integer overflow in SS kafka (commit: ad18faa65251aa35437adee49a1767d9b4977d48) (details)
Commit f6391e165b8e4dde8a9636fc220042b38eabd056 by yamamuro
[SPARK-26732][CORE][TEST] Wait for listener bus to process events in
Otherwise the RDD data may be out of date by the time the test tries to
check it.
Tested with an artificial delay inserted in AppStatusListener.
Closes #23654 from vanzin/SPARK-26732.
Authored-by: Marcelo Vanzin <> Signed-off-by: Takeshi
Yamamuro <>
(cherry picked from commit 6a2f3dcc2bd601fd1fe7610854bc0f5bf90300f4)
Signed-off-by: Takeshi Yamamuro <>
(commit: f6391e165b8e4dde8a9636fc220042b38eabd056)
The file was modifiedcore/src/test/scala/org/apache/spark/SparkContextInfoSuite.scala (diff)
Commit ad18faa65251aa35437adee49a1767d9b4977d48 by dongjoon
[SPARK-26718][SS][BRANCH-2.3] Fixed integer overflow in SS kafka
rateLimit calculation
## What changes were proposed in this pull request?
Fix the integer overflow issue in rateLimit.
## How was this patch tested?
Pass the Jenkins with newly added UT for the possible case where integer
could be overflowed.
Closes #23703 from linehrr/fix/2.3-integeroverflow.
Authored-by: ryne.yang <> Signed-off-by: Dongjoon
Hyun <>
(commit: ad18faa65251aa35437adee49a1767d9b4977d48)
The file was modifiedexternal/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaSourceSuite.scala (diff)
The file was modifiedexternal/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSource.scala (diff)