Skip to content

Commit 091f17b

Browse files
Sumedh Walesumwale
authored andcommitted
[SNAPPYDATA] MemoryStore changes for snappydata
1 parent 9b47fb4 commit 091f17b

File tree

2 files changed

+4
-0
lines changed

2 files changed

+4
-0
lines changed

core/src/main/scala/org/apache/spark/storage/memory/MemoryStore.scala

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -762,6 +762,9 @@ private[storage] class PartiallyUnrolledIterator[T](
762762
override def next(): T = {
763763
if (unrolled == null || !unrolled.hasNext) {
764764
rest.next()
765+
} else if (!unrolled.hasNext) {
766+
releaseUnrollMemory()
767+
rest.next
765768
} else {
766769
unrolled.next()
767770
}

sql/catalyst/.gitignore

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
src/generated/antlr4

0 commit comments

Comments
 (0)