File tree Expand file tree Collapse file tree 1 file changed +7
-3
lines changed
resource-managers/yarn/src/test/scala/org/apache/spark/deploy/yarn Expand file tree Collapse file tree 1 file changed +7
-3
lines changed Original file line number Diff line number Diff line change 17
17
18
18
package org .apache .spark .deploy .yarn
19
19
20
- import scala .collection .JavaConverters ._
20
+ import java .io .{PrintWriter , StringWriter }
21
+
21
22
import scala .collection .mutable .{HashMap , HashSet , Set }
22
23
23
24
import org .apache .hadoop .yarn .api .records ._
@@ -46,7 +47,11 @@ class LocalityPlacementStrategySuite extends SparkFunSuite {
46
47
thread.start()
47
48
thread.join()
48
49
49
- assert(error === null )
50
+ if (error != null ) {
51
+ val errors = new StringWriter ()
52
+ error.printStackTrace(new PrintWriter (errors))
53
+ fail(s " StackOverflowError should not be thrown; however, got: \n\n $errors" )
54
+ }
50
55
}
51
56
52
57
private def runTest (): Unit = {
@@ -57,7 +62,6 @@ class LocalityPlacementStrategySuite extends SparkFunSuite {
57
62
// goal is to create enough requests for localized containers (so there should be many
58
63
// tasks on several hosts that have no allocated containers).
59
64
60
- val resource = Resource .newInstance(8 * 1024 , 4 )
61
65
val strategy = new LocalityPreferredContainerPlacementStrategy (new SparkConf (),
62
66
yarnConf, new MockResolver ())
63
67
You can’t perform that action at this time.
0 commit comments