ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity
spark-instrumented-optimizer/external
History
zsxwing bcb5cdad61 [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'
2014-12-08 23:54:15 -08:00
..
flume SPARK-3962 Marked scope as provided for external projects. 2014-11-19 14:18:10 -08:00
flume-sink [SPARK-3154][STREAMING] Replace ConcurrentHashMap with mutable.HashMap and remove @volatile from 'stopped' 2014-12-08 23:54:15 -08:00
kafka SPARK-3962 Marked scope as provided for external projects. 2014-11-19 14:18:10 -08:00
mqtt [SPARK-4632] version update 2014-11-30 20:51:53 -08:00
twitter SPARK-3962 Marked scope as provided for external projects. 2014-11-19 14:18:10 -08:00
zeromq SPARK-3962 Marked scope as provided for external projects. 2014-11-19 14:18:10 -08:00