Skip to content

Commit 3c11d1b

Browse files
committed
fixed broken test
1 parent f400ade commit 3c11d1b

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

core/src/test/java/org/apache/spark/JavaAPISuite.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -157,11 +157,11 @@ public void sample() {
157157
public void randomSplit() {
158158
List<Integer> ints = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);
159159
JavaRDD<Integer> rdd = sc.parallelize(ints);
160-
JavaRDD<Integer>[] splits = rdd.randomSplit(new double[] { 0.4, 0.6, 1.0 }, 11);
160+
JavaRDD<Integer>[] splits = rdd.randomSplit(new double[] { 0.4, 0.6, 1.0 }, 31);
161161
Assert.assertEquals(3, splits.length);
162-
Assert.assertEquals(2, splits[0].count());
163-
Assert.assertEquals(3, splits[1].count());
164-
Assert.assertEquals(5, splits[2].count());
162+
Assert.assertEquals(1, splits[0].count());
163+
Assert.assertEquals(2, splits[1].count());
164+
Assert.assertEquals(7, splits[2].count());
165165
}
166166

167167
@Test

0 commit comments

Comments
 (0)