diff --git a/Utils/hdinsight-node-common/src/com/microsoft/azure/hdinsight/sdk/common/livy/interactive/Session.java b/Utils/hdinsight-node-common/src/com/microsoft/azure/hdinsight/sdk/common/livy/interactive/Session.java index a0a88147b5..0e510d57f6 100644 --- a/Utils/hdinsight-node-common/src/com/microsoft/azure/hdinsight/sdk/common/livy/interactive/Session.java +++ b/Utils/hdinsight-node-common/src/com/microsoft/azure/hdinsight/sdk/common/livy/interactive/Session.java @@ -61,6 +61,7 @@ import static com.microsoft.azure.hdinsight.common.MessageInfoType.Debug; import static com.microsoft.azure.hdinsight.common.MessageInfoType.Info; +import static com.microsoft.azure.hdinsight.common.MessageInfoType.Warning; import static com.microsoft.azure.hdinsight.spark.common.log.SparkLogLine.TOOL; import static java.lang.Thread.sleep; import static rx.exceptions.Exceptions.propagate; @@ -512,6 +513,14 @@ public Observable deploy() { .doOnNext(uri -> ctrlSubject.onNext( new SparkLogLine(TOOL, Info, "Uploaded to " + uri))) .toList() + .onErrorResumeNext(err -> { + ctrlSubject.onNext( + new SparkLogLine(TOOL, Warning, "Failed to upload artifact: " + err)); + ctrlSubject.onNext( + new SparkLogLine(TOOL, Warning, "Try to start interactive session without those artifacts dependency...")); + + return Observable.empty(); + }) .map(uploadedUris -> { this.createParameters.uploadedArtifactsUris.addAll(uploadedUris);