Skip to content

Commit 8011a96

Browse files
committed
fix a brought-in mistake in StorageLevel
1 parent 70ca182 commit 8011a96

File tree

2 files changed

+6
-6
lines changed

2 files changed

+6
-6
lines changed

core/src/main/scala/org/apache/spark/storage/StorageLevel.scala

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -70,10 +70,10 @@ class StorageLevel private(
7070
def toInt: Int = {
7171
var ret = 0
7272
if (useDisk_) {
73-
ret |= 4
73+
ret |= 8
7474
}
7575
if (useMemory_) {
76-
ret |= 2
76+
ret |= 4
7777
}
7878
if (useTachyon_) {
7979
ret |= 2
@@ -91,8 +91,8 @@ class StorageLevel private(
9191

9292
override def readExternal(in: ObjectInput) {
9393
val flags = in.readByte()
94-
useDisk_ = (flags & 4) != 0
95-
useMemory_ = (flags & 2) != 0
94+
useDisk_ = (flags & 8) != 0
95+
useMemory_ = (flags & 4) != 0
9696
useTachyon_ = (flags & 2) != 0
9797
deserialized_ = (flags & 1) != 0
9898
replication_ = in.readByte()

core/src/test/scala/org/apache/spark/storage/BlockManagerSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -156,12 +156,12 @@ class BlockManagerSuite extends FunSuite with BeforeAndAfter with PrivateMethodT
156156
assert(master.getLocations("a1").size === 0, "master did not remove a1")
157157
assert(master.getLocations("a2").size === 0, "master did not remove a2")
158158
}
159-
159+
160160
test("master + 2 managers interaction") {
161161
store = new BlockManager("exec1", actorSystem, master, serializer, 2000, conf, securityMgr)
162162
store2 = new BlockManager("exec2", actorSystem, master, new KryoSerializer(conf), 2000, conf,
163163
securityMgr)
164-
164+
165165
val peers = master.getPeers(store.blockManagerId, 1)
166166
assert(peers.size === 1, "master did not return the other manager as a peer")
167167
assert(peers.head === store2.blockManagerId, "peer returned by master is not the other manager")

0 commit comments

Comments
 (0)