| commit | f4b36b70789dd7cc89a0f5c21d5b9888efd213cc | [log] [tgz] |
|---|---|---|
| author | madhusudancs@gmail.com <madhusudancs@gmail.com@123451ca-8445-de46-9d55-352943316053> | Sat Apr 06 00:54:24 2013 +0000 |
| committer | madhusudancs@gmail.com <madhusudancs@gmail.com@123451ca-8445-de46-9d55-352943316053> | Sat Apr 06 00:54:24 2013 +0000 |
| tree | 1a42a04b1ba0bff1ffcd3a3c4c7d1f2a5aa2191a | |
| parent | 443f0446e1f8e88a3758c77a7f92f5bef3086459 [diff] |
If there is no result page, nothing should be attempted to be read from the result store. git-svn-id: https://hyracks.googlecode.com/svn/branches/fullstack_rsd_fixes@3333 123451ca-8445-de46-9d55-352943316053
diff --git a/hyracks/hyracks-control/hyracks-control-nc/src/main/java/edu/uci/ics/hyracks/control/nc/dataset/DatasetPartitionReader.java b/hyracks/hyracks-control/hyracks-control-nc/src/main/java/edu/uci/ics/hyracks/control/nc/dataset/DatasetPartitionReader.java index 296c502..74a4c55 100644 --- a/hyracks/hyracks-control/hyracks-control-nc/src/main/java/edu/uci/ics/hyracks/control/nc/dataset/DatasetPartitionReader.java +++ b/hyracks/hyracks-control/hyracks-control-nc/src/main/java/edu/uci/ics/hyracks/control/nc/dataset/DatasetPartitionReader.java
@@ -66,6 +66,9 @@ if (readSize < buffer.capacity()) { long localPageOffset = offset - resultState.getPersistentSize(); + if (localPageOffset <= 0) { + return readSize; + } int localPageIndex = (int) (localPageOffset / datasetMemoryManager.getPageSize()); int pageOffset = (int) (localPageOffset % datasetMemoryManager.getPageSize()); Page page = resultState.getPage(localPageIndex);