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 e8e2867 commit c0153a5Copy full SHA for c0153a5
core/src/test/java/org/apache/spark/JavaAPISuite.java
@@ -1384,7 +1384,7 @@ public void testAsyncActionErrorWrapping() throws Exception {
1384
JavaRDD<Integer> rdd = sc.parallelize(data, 1);
1385
JavaFutureAction<Long> future = rdd.map(new BuggyMapFunction<Integer>()).countAsync();
1386
try {
1387
- long count = future.get(2, TimeUnit.SECONDS);
+ future.get(2, TimeUnit.SECONDS);
1388
Assert.fail("Expected future.get() for failed job to throw ExcecutionException");
1389
} catch (ExecutionException ee) {
1390
Assert.assertTrue(Throwables.getStackTraceAsString(ee).contains("Custom exception!"));
0 commit comments