We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9d0e2b8 commit 5d799feCopy full SHA for 5d799fe
core/src/test/scala/org/apache/spark/rdd/RDDSuite.scala
@@ -638,6 +638,12 @@ class RDDSuite extends FunSuite with SharedSparkContext {
638
assert(ancestors9.count(_.isInstanceOf[MappedValuesRDD[_, _, _]]) === 1)
639
}
640
641
+ /**
642
+ * This tests for the pathological condition in which the RDD dependency graph is cyclical.
643
+ *
644
+ * Since RDD is part of the public API, applications may actually implement RDDs that allow
645
+ * such graphs to be constructed. In such cases, getNarrowAncestor should not simply hang.
646
+ */
647
test("getNarrowAncestors with cycles") {
648
val rdd1 = new CyclicalDependencyRDD[Int]
649
val rdd2 = new CyclicalDependencyRDD[Int]
0 commit comments