You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ip...@apache.org on 2019/12/26 10:52:55 UTC

[ignite] branch ignite-12248 updated: Fix compilation

This is an automated email from the ASF dual-hosted git repository.

ipavlukhin pushed a commit to branch ignite-12248
in repository https://gitbox.apache.org/repos/asf/ignite.git


The following commit(s) were added to refs/heads/ignite-12248 by this push:
     new f86a0e3  Fix compilation
f86a0e3 is described below

commit f86a0e3cbd5158ce9388b025738b08db4a50cd9f
Author: ipavlukhin <vo...@gmail.com>
AuthorDate: Thu Dec 26 13:51:50 2019 +0300

    Fix compilation
---
 .../internal/processors/query/calcite/util/TableScanIterator.java      | 3 ++-
 .../test/java/org/apache/ignite/testsuites/IgniteCalciteTestSuite.java | 3 ++-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/TableScanIterator.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/TableScanIterator.java
index 35ce613..cc76087 100644
--- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/TableScanIterator.java
+++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/TableScanIterator.java
@@ -56,6 +56,7 @@ public class TableScanIterator<T> extends GridCloseableIteratorAdapter<T> {
     /** */
     private T next;
 
+    /** */
     public TableScanIterator(int cacheId, Iterator<GridDhtLocalPartition> parts, Function<CacheDataRow, T> typeWrapper,
         Predicate<CacheDataRow> typeFilter) {
         this.cacheId = cacheId;
@@ -91,7 +92,7 @@ public class TableScanIterator<T> extends GridCloseableIteratorAdapter<T> {
 
                     IgniteCacheOffheapManager.CacheDataStore ds = part.dataStore();
 
-                    cur = cacheId == UNDEFINED_CACHE_ID ? ds.cursor() : ds.cursor(cacheId, false);
+                    cur = cacheId == UNDEFINED_CACHE_ID ? ds.cursor() : ds.cursor(cacheId);
                 } else
                     break;
             }
diff --git a/modules/calcite/src/test/java/org/apache/ignite/testsuites/IgniteCalciteTestSuite.java b/modules/calcite/src/test/java/org/apache/ignite/testsuites/IgniteCalciteTestSuite.java
index 21c2163..652cae3 100644
--- a/modules/calcite/src/test/java/org/apache/ignite/testsuites/IgniteCalciteTestSuite.java
+++ b/modules/calcite/src/test/java/org/apache/ignite/testsuites/IgniteCalciteTestSuite.java
@@ -32,4 +32,5 @@ import org.junit.runners.Suite;
     OutboxTest.class,
     ExecutionTest.class
 })
-public class IgniteCalciteTestSuite { }
+public class IgniteCalciteTestSuite {
+}