diff options
| author | Shixiong Zhu <shixiong@databricks.com> | 2016-04-11 10:42:51 -0700 |
|---|---|---|
| committer | Michael Armbrust <michael@databricks.com> | 2016-04-11 10:42:51 -0700 |
| commit | 2dacc81ec31233e558855a26340ad4662d470387 (patch) | |
| tree | d755aeaae1c3349ac8784c713d9f96cf016b05ad /mllib | |
| parent | 5de26194a3aaeab9b7a8323107f614126c90441f (diff) | |
| download | spark-2dacc81ec31233e558855a26340ad4662d470387.tar.gz spark-2dacc81ec31233e558855a26340ad4662d470387.tar.bz2 spark-2dacc81ec31233e558855a26340ad4662d470387.zip | |
[SPARK-14494][SQL] Fix the race conditions in MemoryStream and MemorySink
## What changes were proposed in this pull request?
Make sure accessing mutable variables in MemoryStream and MemorySink are protected by `synchronized`.
This is probably why MemorySinkSuite failed here: https://amplab.cs.berkeley.edu/jenkins/job/spark-master-test-sbt-hadoop-2.2/650/testReport/junit/org.apache.spark.sql.streaming/MemorySinkSuite/registering_as_a_table/
## How was this patch tested?
Existing unit tests.
Author: Shixiong Zhu <shixiong@databricks.com>
Closes #12261 from zsxwing/memory-race-condition.
Diffstat (limited to 'mllib')
0 files changed, 0 insertions, 0 deletions