Skip to content

Use Minicluster for WAL tests. #17

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
tdas merged 5 commits into from
Oct 22, 2014
Merged

Use Minicluster for WAL tests. #17

Changes from 1 commit
Commits
Show all changes
5 commits
Select commit Hold shift + click to select a range
5c70d1f
Remove underlying stream from the WALWriter.
harishreedharan Oct 22, 2014
edcbee1
Tests reading and writing data using writers now use Minicluster.
harishreedharan Oct 9, 2014
b4be0c1
Remove unused method
harishreedharan Oct 22, 2014
587b876
Fix broken test. Call getFileSystem only from synchronized method.
harishreedharan Oct 22, 2014
7e40e56
Restore old build directory after tests
harishreedharan Oct 22, 2014
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Restore old build directory after tests
  • Loading branch information
@harishreedharan
harishreedharan committed Oct 22, 2014
commit 7e40e56a506f48268c529a0352ec29d7bae805b4
1 change: 1 addition & 0 deletions streaming/src/test/scala/org/apache/spark/streaming/util/WriteAheadLogSuite.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -59,6 +59,7 @@ class WriteAheadLogSuite extends FunSuite with BeforeAndAfter with BeforeAndAfte
override def afterAll() {
cluster.shutdown()
FileUtils.deleteDirectory(dfsDir)
System.setProperty(TEST_BUILD_DATA_KEY, oldTestBuildDataProp)
}

test("WriteAheadLogWriter - writing data") {
Expand Down