You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2017/05/23 12:09:55 UTC
[7/8] ignite git commit: Merge remote-tracking branch
'remotes/origin/master' into ignite-5075
Merge remote-tracking branch 'remotes/origin/master' into ignite-5075
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/7fc01683
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/7fc01683
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/7fc01683
Branch: refs/heads/ignite-5075-pds
Commit: 7fc01683a7e0995d41ad8d900767d6e48443d8b2
Parents: 19ed098 ca94cf3
Author: sboikov <sb...@gridgain.com>
Authored: Tue May 23 15:05:52 2017 +0300
Committer: sboikov <sb...@gridgain.com>
Committed: Tue May 23 15:05:52 2017 +0300
----------------------------------------------------------------------
.../store/cassandra/CassandraCacheStore.java | 15 +-
.../ignite/tests/IgnitePersistentStoreTest.java | 62 ++++-
.../persistence/loadall_blob/ignite-config.xml | 90 +++++++
.../loadall_blob/persistence-settings.xml | 29 +++
.../store/jdbc/CacheAbstractJdbcStore.java | 6 +-
.../managers/communication/GridIoManager.java | 30 ++-
.../communication/GridIoMessageFactory.java | 2 +
.../platform/cache/PlatformCache.java | 28 ++-
.../cache/query/GridCacheTwoStepQuery.java | 84 ++-----
.../processors/cache/query/QueryTable.java | 164 +++++++++++++
.../processors/query/h2/IgniteH2Indexing.java | 84 +++----
.../query/h2/opt/GridH2IndexBase.java | 2 +-
.../processors/query/h2/opt/GridH2Table.java | 28 ++-
.../query/h2/sql/GridSqlQuerySplitter.java | 21 +-
.../query/h2/twostep/GridMapQueryExecutor.java | 15 +-
.../h2/twostep/GridReduceQueryExecutor.java | 233 +++++++++----------
.../h2/twostep/msg/GridH2QueryRequest.java | 13 +-
.../twostep/msg/GridH2ValueMessageFactory.java | 4 +
.../core/include/ignite/cache/query/query_sql.h | 2 +
.../ignite/cache/query/query_sql_fields.h | 3 +
.../Cache/Query/CacheLinqTest.cs | 36 ++-
.../Cache/Query/CacheQueriesTest.cs | 60 ++++-
.../Cache/Query/SqlFieldsQuery.cs | 29 ++-
.../Apache.Ignite.Core/Cache/Query/SqlQuery.cs | 31 +++
.../Apache.Ignite.Core/Impl/Cache/CacheImpl.cs | 3 +
.../Apache.Ignite.Linq/CacheExtensions.cs | 10 +
.../Impl/CacheFieldsQueryExecutor.cs | 42 ++--
.../Apache.Ignite.Linq/Impl/CacheQueryable.cs | 3 +-
.../dotnet/Apache.Ignite.Linq/QueryOptions.cs | 23 ++
.../spring/SpringTransactionManager.java | 13 ++
.../GridSpringTransactionManagerSelfTest.java | 45 ++++
31 files changed, 892 insertions(+), 318 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/7fc01683/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/7fc01683/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/GridReduceQueryExecutor.java
----------------------------------------------------------------------
diff --cc modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/GridReduceQueryExecutor.java
index 8286b45,75914ef..bba5fca
--- a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/GridReduceQueryExecutor.java
+++ b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/GridReduceQueryExecutor.java
@@@ -1163,10 -1143,11 +1143,11 @@@ public class GridReduceQueryExecutor
continue; // Skip unmapped partitions.
if (F.isEmpty(owners)) {
- if (!F.isEmpty(dataNodes(extraCctx.name(), NONE)))
+ if (!F.isEmpty(dataNodes(extraCctx.groupId(), NONE)))
return null; // Retry.
- throw new CacheException("Failed to find data nodes [cache=" + extraCctx.name() + ", part=" + p + "]");
+ throw new CacheException("Failed to find data nodes [cache=" + extraCctx.name() +
+ ", part=" + p + "]");
}
if (partLocs[p] == null)