This is an automated email from the ASF dual-hosted git repository.
dongjoon pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/master by this push:
new 4b0ceaddde17 [SPARK-46664][CORE][TESTS][FOLLOWUP] Add a persistent
`DriverInfo`
4b0ceaddde17 is described below
commit 4b0ceaddde17a870289f20269526fba39242bbda
Author: Dongjoon Hyun <dh...@apple.com>
AuthorDate: Thu Jan 11 08:34:03 2024 -0800
[SPARK-46664][CORE][TESTS][FOLLOWUP] Add a persistent `DriverInfo`
### What changes were proposed in this pull request?
This is a follow-up of #44673 to fix the test case by adding a persistent
`DriverInfo`.
### Why are the changes needed?
To make the test case fail without the main patch. Previously, this is
missed. So, the test case succeeds without the main patch.
### Does this PR introduce _any_ user-facing change?
No.
### How was this patch tested?
Pass the CIs.
### Was this patch authored or co-authored using generative AI tooling?
No.
Closes #44693 from dongjoon-hyun/SPARK-46664-2.
Authored-by: Dongjoon Hyun <dh...@apple.com>
Signed-off-by: Dongjoon Hyun <dongj...@apache.org>
---
.../scala/org/apache/spark/deploy/master/MasterSuite.scala | 12 ++++++++++++
1 file changed, 12 insertions(+)
diff --git
a/core/src/test/scala/org/apache/spark/deploy/master/MasterSuite.scala
b/core/src/test/scala/org/apache/spark/deploy/master/MasterSuite.scala
index 6490ee3e8241..e7146747b843 100644
--- a/core/src/test/scala/org/apache/spark/deploy/master/MasterSuite.scala
+++ b/core/src/test/scala/org/apache/spark/deploy/master/MasterSuite.scala
@@ -256,6 +256,18 @@ class MasterSuite extends SparkFunSuite
conf.set(RECOVERY_MODE_FACTORY,
classOf[FakeRecoveryModeFactory].getCanonicalName)
conf.set(MASTER_REST_SERVER_ENABLED, false)
+ val fakeDriverInfo = new DriverInfo(
+ startTime = 0,
+ id = "test_driver",
+ desc = new DriverDescription(
+ jarUrl = "",
+ mem = 1024,
+ cores = 1,
+ supervise = false,
+ command = new Command("", Nil, Map.empty, Nil, Nil, Nil)),
+ submitDate = new Date())
+ FakeRecoveryModeFactory.persistentData.put(s"driver_${fakeDriverInfo.id}",
fakeDriverInfo)
+
var master: Master = null
try {
master = makeMaster(conf)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org
For additional commands, e-mail: commits-h...@spark.apache.org
