Github user tison1 commented on the pull request:

    
https://github.com/apache/flink/commit/8231b62ff42aae53ca3a7b552980838ccab824ab#commitcomment-29765803
  
    In 
flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/scheduler/CoLocationGroup.java:
    In 
flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/scheduler/CoLocationGroup.java
 on line 81:
    here is a question from 4 years later.
    
    why this method call `ensureCapacity` twice. it seems to solve some issue 
about concurrency but as the change made in #6353 , this method throws a out of 
index exception. so i try to add a synchronized block to make sure it is 
thread-safe #6370 . definitely i think my code is not that perfect. so i come 
to here, wonder the original purpose of this code and ask advice about the two 
PRs mentioned above
    
    @StephanEwen looking forward to your advice. thanks in advance!


---

Reply via email to