[hotfix] Fix error from cherry-picking 0ea00ea

apache · Jan 22, 2020 · 6061372 · 6061372
1 parent 0ea00ea
commit 6061372
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flink-fs-tests/src/test/java/org/apache/flink/hdfstests/DistributedCacheDfsTest.java b/flink-fs-tests/src/test/java/org/apache/flink/hdfstests/DistributedCacheDfsTest.java
@@ -143,7 +143,7 @@ public void testSubmittingJobViaRestClusterClient() throws Exception {
 
 		final JobResult jobResult = restClusterClient
 			.submitJob(jobGraph)
-			.thenCompose(restClusterClient::requestJobResult)
+			.thenCompose((submissionRes) -> restClusterClient.requestJobResult(submissionRes.getJobID()))
 			.get();
 
 		final String messageInCaseOfFailure = jobResult.getSerializedThrowable().isPresent() ?