[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r461567745 ## File path: core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala ## @@ -0,0 +1,420 @@ +/* + * Licensed to the Apache Software

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r460525105 ## File path: core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala ## @@ -0,0 +1,424 @@ +/* + * Licensed to the Apache Software

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r460525105 ## File path: core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala ## @@ -0,0 +1,424 @@ +/* + * Licensed to the Apache Software

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r460524057 ## File path: core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala ## @@ -0,0 +1,424 @@ +/* + * Licensed to the Apache Software

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r460520697 ## File path: core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala ## @@ -0,0 +1,424 @@ +/* + * Licensed to the Apache Software

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r460520625 ## File path: core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala ## @@ -0,0 +1,424 @@ +/* + * Licensed to the Apache Software

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r460520661 ## File path: core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala ## @@ -0,0 +1,424 @@ +/* + * Licensed to the Apache Software

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r460241664 ## File path: core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala ## @@ -0,0 +1,401 @@ +/* + * Licensed to the Apache Software

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r460241664 ## File path: core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala ## @@ -0,0 +1,401 @@ +/* + * Licensed to the Apache Software

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r460238860 ## File path: core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala ## @@ -0,0 +1,401 @@ +/* + * Licensed to the Apache Software

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r460237743 ## File path: core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala ## @@ -0,0 +1,401 @@ +/* + * Licensed to the Apache Software

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r460231485 ## File path: core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala ## @@ -0,0 +1,401 @@ +/* + * Licensed to the Apache Software

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r460231485 ## File path: core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala ## @@ -0,0 +1,401 @@ +/* + * Licensed to the Apache Software

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r460201258 ## File path: core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala ## @@ -0,0 +1,401 @@ +/* + * Licensed to the Apache Software

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r460168600 ## File path: core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala ## @@ -0,0 +1,401 @@ +/* + * Licensed to the Apache Software

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r460165492 ## File path: core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala ## @@ -0,0 +1,401 @@ +/* + * Licensed to the Apache Software

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r460102245 ## File path: core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala ## @@ -0,0 +1,401 @@ +/* + * Licensed to the Apache Software

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r459995140 ## File path: core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala ## @@ -0,0 +1,401 @@ +/* + * Licensed to the Apache Software

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r459997319 ## File path: core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala ## @@ -0,0 +1,401 @@ +/* + * Licensed to the Apache Software

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r459995140 ## File path: core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala ## @@ -0,0 +1,401 @@ +/* + * Licensed to the Apache Software

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r459987737 ## File path: core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala ## @@ -0,0 +1,401 @@ +/* + * Licensed to the Apache Software

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r459953796 ## File path: core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala ## @@ -0,0 +1,401 @@ +/* + * Licensed to the Apache Software

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r459953031 ## File path: core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala ## @@ -0,0 +1,401 @@ +/* + * Licensed to the Apache Software

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r459946300 ## File path: core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala ## @@ -0,0 +1,401 @@ +/* + * Licensed to the Apache Software

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r459946300 ## File path: core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala ## @@ -0,0 +1,401 @@ +/* + * Licensed to the Apache Software

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r459926684 ## File path: core/src/test/scala/org/apache/spark/scheduler/TaskSchedulerImplSuite.scala ## @@ -1802,6 +1802,46 @@ class TaskSchedulerImplSuite exte

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r459924690 ## File path: core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala ## @@ -939,12 +941,43 @@ private[spark] class TaskSchedulerImpl(

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r459766863 ## File path: core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala ## @@ -914,12 +916,42 @@ private[spark] class TaskSchedulerImpl(

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r458185146 ## File path: core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala ## @@ -0,0 +1,405 @@ +/* + * Licensed to the Apache Software

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r458185146 ## File path: core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala ## @@ -0,0 +1,405 @@ +/* + * Licensed to the Apache Software

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r458119261 ## File path: core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala ## @@ -0,0 +1,405 @@ +/* + * Licensed to the Apache Software

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r458119261 ## File path: core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala ## @@ -0,0 +1,405 @@ +/* + * Licensed to the Apache Software

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r458052603 ## File path: core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala ## @@ -0,0 +1,405 @@ +/* + * Licensed to the Apache Software

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r458145315 ## File path: core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala ## @@ -0,0 +1,405 @@ +/* + * Licensed to the Apache Software

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r458141234 ## File path: core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala ## @@ -0,0 +1,405 @@ +/* + * Licensed to the Apache Software

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r458119261 ## File path: core/src/test/scala/org/apache/spark/deploy/DecommissionWorkerSuite.scala ## @@ -0,0 +1,405 @@ +/* + * Licensed to the Apache Software

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r457402821 ## File path: core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala ## @@ -912,13 +914,39 @@ private[spark] class TaskSchedulerImpl(

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r457513559 ## File path: core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala ## @@ -1007,6 +1035,8 @@ private[spark] class TaskSchedulerImpl(

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r457516905 ## File path: core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala ## @@ -1007,6 +1035,8 @@ private[spark] class TaskSchedulerImpl(

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r457513559 ## File path: core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala ## @@ -1007,6 +1035,8 @@ private[spark] class TaskSchedulerImpl(

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r457511329 ## File path: core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala ## @@ -912,13 +914,39 @@ private[spark] class TaskSchedulerImpl(

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r457402821 ## File path: core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala ## @@ -912,13 +914,39 @@ private[spark] class TaskSchedulerImpl(

[GitHub] [spark] attilapiros commented on a change in pull request #29014: [SPARK-32199][SPARK-32198] Reduce job failures during decommissioning

attilapiros commented on a change in pull request #29014: URL: https://github.com/apache/spark/pull/29014#discussion_r457378657 ## File path: core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala ## @@ -1767,10 +1767,18 @@ private[spark] class DAGScheduler(