Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/5135#discussion_r155627163
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
---
@@ -585,7 +585,7 @@ class TaskManager(
config.getMaxRegistrationPause().toMilliseconds,
TimeUnit.MILLISECONDS))
- // schedule (with our timeout s delay) a check triggers a new
registration
+ // schedule (with our timeout's delay) a check triggers a new
registration
--- End diff --
"triggers" -> "to trigger"? Or rewrite like "schedule a check to trigger a
new registration attempt if not registered by the timeout"?
---
