ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity
spark-instrumented-optimizer/core/src/main/scala/spark
History
Kay Ousterhout 88049a214d Fixed 3 bugs that caused UI to crash (including SPARK-810). 
One bug caused the UI to crash if you try to look at a job's status
before any of the tasks have finished.

The second bug was a concurrency issue where two different threads
(the scheduling thread and a UI thread) could be reading/updating
the data structures in JobProgressListener concurrently.

The third bug mis-used an Option, also causing the UI to crash
under certain conditions.
2013-08-07 23:09:25 -07:00
..
api Eliminated code duplication, refactored to pattern-matching style Partitioner and PythonPartitioner 2013-07-31 13:19:42 +03:00
broadcast Changed other LZF uses to use the compression codec interface. 2013-07-31 10:32:13 -07:00
deploy Moved handling of timed out workers within the Master actor 2013-08-05 13:13:56 -07:00
executor Moved all StandaloneClusterMessage's into StandaloneClusterMessages object. 2013-07-29 17:53:01 -07:00
io Renamed compressionOutputStream and compressionInputStream to compressedOutputStream and compressedInputStream. 2013-07-30 18:28:46 -07:00
metrics Small style fix 2013-08-01 15:25:52 -07:00
network Add Apache license headers and LICENSE and NOTICE files 2013-07-16 17:21:33 -07:00
partial Add Apache license headers and LICENSE and NOTICE files 2013-07-16 17:21:33 -07:00
rdd Merge pull request #724 from dlyubimov/SPARK-826 2013-08-06 22:31:02 -07:00
scheduler Merge pull request #724 from dlyubimov/SPARK-826 2013-08-06 22:31:02 -07:00
serializer Add Apache license headers and LICENSE and NOTICE files 2013-07-16 17:21:33 -07:00
storage Renamed compressionOutputStream and compressionInputStream to compressedOutputStream and compressedInputStream. 2013-07-30 18:28:46 -07:00
ui Fixed 3 bugs that caused UI to crash (including SPARK-810). 2013-08-07 23:09:25 -07:00
util More elegant rewrite of the same. 2013-07-31 21:41:00 -07:00
Accumulators.scala Add Apache license headers and LICENSE and NOTICE files 2013-07-16 17:21:33 -07:00
Aggregator.scala Add Apache license headers and LICENSE and NOTICE files 2013-07-16 17:21:33 -07:00
BlockStoreShuffleFetcher.scala Add Apache license headers and LICENSE and NOTICE files 2013-07-16 17:21:33 -07:00
CacheManager.scala Add Apache license headers and LICENSE and NOTICE files 2013-07-16 17:21:33 -07:00
ClosureCleaner.scala Add Apache license headers and LICENSE and NOTICE files 2013-07-16 17:21:33 -07:00
Dependency.scala Add Apache license headers and LICENSE and NOTICE files 2013-07-16 17:21:33 -07:00
DoubleRDDFunctions.scala Fix bug: DoubleRDDFunctions.sampleStdev() computed non-sample stdev(). 2013-07-22 13:21:48 -07:00
FetchFailedException.scala Add Apache license headers and LICENSE and NOTICE files 2013-07-16 17:21:33 -07:00
HadoopWriter.scala Add Apache license headers and LICENSE and NOTICE files 2013-07-16 17:21:33 -07:00
HttpFileServer.scala Add Apache license headers and LICENSE and NOTICE files 2013-07-16 17:21:33 -07:00
HttpServer.scala Add Apache license headers and LICENSE and NOTICE files 2013-07-16 17:21:33 -07:00
JavaSerializer.scala Add Apache license headers and LICENSE and NOTICE files 2013-07-16 17:21:33 -07:00
KryoSerializer.scala fix wrapping 2013-07-24 22:08:09 -07:00
Logging.scala Add Apache license headers and LICENSE and NOTICE files 2013-07-16 17:21:33 -07:00
MapOutputTracker.scala Add Apache license headers and LICENSE and NOTICE files 2013-07-16 17:21:33 -07:00
package.scala Add Apache license headers and LICENSE and NOTICE files 2013-07-16 17:21:33 -07:00
PairRDDFunctions.scala Add Apache license headers and LICENSE and NOTICE files 2013-07-16 17:21:33 -07:00
Partition.scala Add Apache license headers and LICENSE and NOTICE files 2013-07-16 17:21:33 -07:00
Partitioner.scala Eliminated code duplication, refactored to pattern-matching style Partitioner and PythonPartitioner 2013-07-31 13:19:42 +03:00
RDD.scala More elegant rewrite of the same. 2013-07-31 21:41:00 -07:00
RDDCheckpointData.scala Add Apache license headers and LICENSE and NOTICE files 2013-07-16 17:21:33 -07:00
SequenceFileRDDFunctions.scala Add Apache license headers and LICENSE and NOTICE files 2013-07-16 17:21:33 -07:00
SerializableWritable.scala Add Apache license headers and LICENSE and NOTICE files 2013-07-16 17:21:33 -07:00
ShuffleFetcher.scala Add Apache license headers and LICENSE and NOTICE files 2013-07-16 17:21:33 -07:00
SizeEstimator.scala Add Apache license headers and LICENSE and NOTICE files 2013-07-16 17:21:33 -07:00
SparkContext.scala Merge pull request #774 from pwendell/job-description 2013-08-05 19:14:52 -07:00
SparkEnv.scala [HOTFIX] Mark lastSetSparkEnv @volatile in case it gets HotSpot-cached 2013-08-05 17:22:27 -07:00
SparkException.scala Add Apache license headers and LICENSE and NOTICE files 2013-07-16 17:21:33 -07:00
SparkFiles.java Add Apache license headers and LICENSE and NOTICE files 2013-07-16 17:21:33 -07:00
TaskContext.scala Add Apache license headers and LICENSE and NOTICE files 2013-07-16 17:21:33 -07:00
TaskEndReason.scala Add Apache license headers and LICENSE and NOTICE files 2013-07-16 17:21:33 -07:00
TaskState.scala Add Apache license headers and LICENSE and NOTICE files 2013-07-16 17:21:33 -07:00
Utils.scala Merge remote-tracking branch 'mesos/master' into SPARK-826 2013-07-31 22:09:22 -07:00