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 0ea00ea commit 6061372Copy full SHA for 6061372
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/DistributedCacheDfsTest.java
@@ -143,7 +143,7 @@ public void testSubmittingJobViaRestClusterClient() throws Exception {
143
144
final JobResult jobResult = restClusterClient
145
.submitJob(jobGraph)
146
- .thenCompose(restClusterClient::requestJobResult)
+ .thenCompose((submissionRes) -> restClusterClient.requestJobResult(submissionRes.getJobID()))
147
.get();
148
149
final String messageInCaseOfFailure = jobResult.getSerializedThrowable().isPresent() ?
0 commit comments