Skip to content

Commit c72e10a

Browse files
committed
Fix the function partial rename issue.
Signed-off-by: Wei Zhang <[email protected]>
1 parent 2578717 commit c72e10a

File tree

1 file changed

+2
-2
lines changed
  • Utils/hdinsight-node-common/src/com/microsoft/azure/hdinsight/spark/common

1 file changed

+2
-2
lines changed

Utils/hdinsight-node-common/src/com/microsoft/azure/hdinsight/spark/common/SparkBatchJob.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -480,8 +480,8 @@ public Observable<SimpleImmutableEntry<String, String>> getSparkJobYarnContainer
480480
.retry(getRetriesMax())
481481
.delay(3, TimeUnit.SECONDS) // Workaround to waiting for the page loading finished
482482
.repeatWhen(ob -> ob.delay(getDelaySeconds(), TimeUnit.SECONDS))
483-
.takeUntil(this::isSparkJobYarnAppAttemptNotInLaunched)
484-
.filter(this::isSparkJobYarnAppAttemptNotInLaunched)
483+
.takeUntil(this::isSparkJobYarnAppAttemptNotJustLaunched)
484+
.filter(this::isSparkJobYarnAppAttemptNotJustLaunched)
485485
.flatMap(htmlPage -> {
486486
// Get the container table by XPath
487487
HtmlTableBody containerBody = htmlPage.getFirstByXPath("//*[@id=\"containers\"]/tbody");

0 commit comments

Comments
 (0)