diff options
author | zsxwing <zsxwing@gmail.com> | 2014-12-08 23:54:15 -0800 |
---|---|---|
committer | Aaron Davidson <aaron@databricks.com> | 2014-12-08 23:54:15 -0800 |
commit | bcb5cdad614d4fce43725dfec3ce88172d2f8c11 (patch) | |
tree | 532261ff55313cd5cada3284b60ae5380378f4c2 /dev | |
parent | 51b1fe1426ffecac6c4644523633ea1562ff9a4e (diff) | |
download | spark-bcb5cdad614d4fce43725dfec3ce88172d2f8c11.tar.gz spark-bcb5cdad614d4fce43725dfec3ce88172d2f8c11.tar.bz2 spark-bcb5cdad614d4fce43725dfec3ce88172d2f8c11.zip |
[SPARK-3154][STREAMING] Replace ConcurrentHashMap with mutable.HashMap and remove @volatile from 'stopped'
Since `sequenceNumberToProcessor` and `stopped` are both protected by the lock `sequenceNumberToProcessor`, `ConcurrentHashMap` and `volatile` is unnecessary. So this PR updated them accordingly.
Author: zsxwing <zsxwing@gmail.com>
Closes #3634 from zsxwing/SPARK-3154 and squashes the following commits:
0d087ac [zsxwing] Replace ConcurrentHashMap with mutable.HashMap and remove @volatile from 'stopped'
Diffstat (limited to 'dev')
0 files changed, 0 insertions, 0 deletions