[GitHub] [spark] AngersZhuuuu commented on a diff in pull request #36564: [SPARK-39195][SQL] Spark OutputCommitCoordinator should abort stage when committed file not consistent with task status

AngersZh commented on code in PR #36564: URL: https://github.com/apache/spark/pull/36564#discussion_r899701507 ## core/src/test/scala/org/apache/spark/scheduler/OutputCommitCoordinatorSuite.scala: ## @@ -235,7 +226,6 @@ class OutputCommitCoordinatorSuite extends

[GitHub] [spark] AngersZhuuuu commented on a diff in pull request #36564: [SPARK-39195][SQL] Spark OutputCommitCoordinator should abort stage when committed file not consistent with task status

AngersZh commented on code in PR #36564: URL: https://github.com/apache/spark/pull/36564#discussion_r897810583 ## core/src/test/scala/org/apache/spark/scheduler/OutputCommitCoordinatorSuite.scala: ## @@ -143,13 +144,6 @@ class OutputCommitCoordinatorSuite extends

[GitHub] [spark] AngersZhuuuu commented on a diff in pull request #36564: [SPARK-39195][SQL] Spark OutputCommitCoordinator should abort stage when committed file not consistent with task status

AngersZh commented on code in PR #36564: URL: https://github.com/apache/spark/pull/36564#discussion_r897024156 ## core/src/test/scala/org/apache/spark/scheduler/OutputCommitCoordinatorIntegrationSuite.scala: ## @@ -47,11 +46,12 @@ class

[GitHub] [spark] AngersZhuuuu commented on a diff in pull request #36564: [SPARK-39195][SQL] Spark OutputCommitCoordinator should abort stage when committed file not consistent with task status

AngersZh commented on code in PR #36564: URL: https://github.com/apache/spark/pull/36564#discussion_r896311302 ## core/src/test/scala/org/apache/spark/scheduler/OutputCommitCoordinatorSuite.scala: ## @@ -270,6 +263,16 @@ class OutputCommitCoordinatorSuite extends

[GitHub] [spark] AngersZhuuuu commented on a diff in pull request #36564: [SPARK-39195][SQL] Spark OutputCommitCoordinator should abort stage when committed file not consistent with task status

AngersZh commented on code in PR #36564: URL: https://github.com/apache/spark/pull/36564#discussion_r894985431 ## core/src/test/scala/org/apache/spark/scheduler/OutputCommitCoordinatorSuite.scala: ## @@ -235,7 +226,6 @@ class OutputCommitCoordinatorSuite extends

[GitHub] [spark] AngersZhuuuu commented on a diff in pull request #36564: [SPARK-39195][SQL] Spark OutputCommitCoordinator should abort stage when committed file not consistent with task status

AngersZh commented on code in PR #36564: URL: https://github.com/apache/spark/pull/36564#discussion_r894985147 ## core/src/test/scala/org/apache/spark/scheduler/OutputCommitCoordinatorSuite.scala: ## @@ -289,6 +289,7 @@ private case class OutputCommitFunctions(tempDirPath:

[GitHub] [spark] AngersZhuuuu commented on a diff in pull request #36564: [SPARK-39195][SQL] Spark OutputCommitCoordinator should abort stage when committed file not consistent with task status

AngersZh commented on code in PR #36564: URL: https://github.com/apache/spark/pull/36564#discussion_r894985125 ## core/src/test/scala/org/apache/spark/scheduler/OutputCommitCoordinatorIntegrationSuite.scala: ## @@ -46,21 +45,21 @@ class

[GitHub] [spark] AngersZhuuuu commented on a diff in pull request #36564: [SPARK-39195][SQL] Spark OutputCommitCoordinator should abort stage when committed file not consistent with task status

AngersZh commented on code in PR #36564: URL: https://github.com/apache/spark/pull/36564#discussion_r893074610 ## core/src/test/scala/org/apache/spark/scheduler/OutputCommitCoordinatorSuite.scala: ## @@ -187,12 +181,6 @@ class OutputCommitCoordinatorSuite extends

[GitHub] [spark] AngersZhuuuu commented on a diff in pull request #36564: [SPARK-39195][SQL] Spark OutputCommitCoordinator should abort stage when committed file not consistent with task status

AngersZh commented on code in PR #36564: URL: https://github.com/apache/spark/pull/36564#discussion_r893072393 ## core/src/main/scala/org/apache/spark/SparkContext.scala: ## @@ -461,7 +467,8 @@ class SparkContext(config: SparkConf) extends Logging {

[GitHub] [spark] AngersZhuuuu commented on a diff in pull request #36564: [SPARK-39195][SQL] Spark OutputCommitCoordinator should abort stage when committed file not consistent with task status

AngersZh commented on code in PR #36564: URL: https://github.com/apache/spark/pull/36564#discussion_r893017815 ## core/src/main/scala/org/apache/spark/SparkContext.scala: ## @@ -461,7 +467,8 @@ class SparkContext(config: SparkConf) extends Logging {