reswqa commented on code in PR #3179:
URL: https://github.com/apache/celeborn/pull/3179#discussion_r2020362251
##########
tests/flink-it/src/test/scala/org/apache/celeborn/tests/flink/HybridShuffleWordCountTest.scala:
##########
@@ -144,10 +137,9 @@ class HybridShuffleWordCountTest extends AnyFunSuite with
Logging with MiniClust
configuration.setString("rest.bind-port", "8081-8099")
val env = getEnvironment(configuration);
env.getConfig.setParallelism(parallelism)
- env.setRestartStrategy(RestartStrategies.fixedDelayRestart(1, 0L))
env.disableOperatorChaining()
// make parameters available in the web interface
- WordCountHelper.execute(env, parallelism)
+ WordCountHelper.execute(env, 1)
Review Comment:
Add comment for this line of change. If we bump flink to 2.1, this can be
reverted IMO.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
