Skip to content

Commit a5dcecf

Browse files
committed
Still need the workaround to wait for attempts page loading
Signed-off-by: Wei Zhang <[email protected]>
1 parent eed50fa commit a5dcecf

File tree

1 file changed

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

1 file changed

+1
-0
lines changed

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -462,6 +462,7 @@ public Observable<SimpleImmutableEntry<String, String>> getSparkJobYarnContainer
462462
.toString())
463463
.flatMap(this::loadPageByBrowserObservable)
464464
.retry(getRetriesMax())
465+
.delay(3, TimeUnit.SECONDS) // Workaround to waiting for the page loading finished
465466
.repeatWhen(ob -> ob.delay(getDelaySeconds(), TimeUnit.SECONDS))
466467
.takeUntil(this::isSparkJobYarnAppAttemptNotJustLaunched)
467468
.filter(this::isSparkJobYarnAppAttemptNotJustLaunched)

0 commit comments

Comments
 (0)