Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/622#discussion_r29140570
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
---
@@ -137,7 +137,7 @@ extends Actor with ActorLogMessages with ActorLogging {
protected val resources =
HardwareDescription.extractFromSystem(memoryManager.getMemorySize)
/** Registry of all tasks currently executed by this TaskManager */
- protected val runningTasks =
scala.collection.mutable.HashMap[ExecutionAttemptID, Task]()
+ protected val runningTasks =
scala.collection.concurrent.TrieMap[ExecutionAttemptID, Task]()
--- End diff --
I have recently read (I think in the Databricks Scala guide) that they
discourage the Scala concurrent package, because of bugs. How about using the
java concurrent HashMap? That one has pretty good performance seems to work
reliably.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
