Skip to content

Commit

Permalink
delete log
Browse files Browse the repository at this point in the history
  • Loading branch information
zaynt4606 committed Dec 17, 2024
1 parent af931b4 commit ae259da
Showing 1 changed file with 0 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -122,7 +122,6 @@ class RetryReviveTest extends AnyFunSuite
.flatMap(_ => (1 to 15000).iterator.map(num => num)).repartition(100).count()
val taskTime = System.currentTimeMillis() - startTime
val writeTime = taskTime * 0.35
logInfo(s"[test] taskTime: $taskTime, writeTime: $writeTime")
workerKiller(writeTime.toInt)
val result1 = ss.sparkContext.parallelize(1 to 1000, 100)
.flatMap(_ => (1 to 15000).iterator.map(num => num)).repartition(100).count()
Expand Down

0 comments on commit ae259da

Please sign in to comment.