Reworked example for snapshots
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/ab7d7955 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/ab7d7955 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/ab7d7955 Branch: refs/heads/ignite-5267-1 Commit: ab7d7955b5f6ffe170ca5588c6c45d390c84df08 Parents: 44f2d4c Author: Denis Magda <[email protected]> Authored: Thu Jun 15 13:40:39 2017 -0700 Committer: Denis Magda <[email protected]> Committed: Thu Jun 15 13:40:39 2017 -0700 ---------------------------------------------------------------------- examples/config/persistentstore/example-persistent-store.xml | 6 ++++++ .../examples/persistentstore/PersistentStoreExample.java | 4 ++++ .../persistentstore/PersistentStoreExampleNodeStartup.java | 4 ++++ .../src/main/java/org/apache/ignite/internal/IgniteKernal.java | 4 +++- 4 files changed, 17 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/ab7d7955/examples/config/persistentstore/example-persistent-store.xml ---------------------------------------------------------------------- diff --git a/examples/config/persistentstore/example-persistent-store.xml b/examples/config/persistentstore/example-persistent-store.xml index 955ef8c..8714b09 100644 --- a/examples/config/persistentstore/example-persistent-store.xml +++ b/examples/config/persistentstore/example-persistent-store.xml @@ -50,6 +50,12 @@ </list> </property> + <property name="binaryConfiguration"> + <bean class="org.apache.ignite.configuration.BinaryConfiguration"> + <property name="compactFooter" value="false"/> + </bean> + </property> + <!-- Explicitly configure TCP discovery SPI to provide a list of initial nodes. --> <property name="discoverySpi"> <bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi"> http://git-wip-us.apache.org/repos/asf/ignite/blob/ab7d7955/examples/src/main/java/org/apache/ignite/examples/persistentstore/PersistentStoreExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/persistentstore/PersistentStoreExample.java b/examples/src/main/java/org/apache/ignite/examples/persistentstore/PersistentStoreExample.java index 2e066ef..5cd2f08 100644 --- a/examples/src/main/java/org/apache/ignite/examples/persistentstore/PersistentStoreExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/persistentstore/PersistentStoreExample.java @@ -55,6 +55,10 @@ public class PersistentStoreExample { try (Ignite ig = Ignition.start("examples/config/persistentstore/example-persistent-store.xml")) { + // Activate the cluster. Required to do if the persistent store is enabled because you might need + // to wait while all the nodes, that store a subset of data on disk, join the cluster. + ig.active(true); + IgniteCache<Long, Organization> cache = ig.cache("organization"); if (UPDATE) { http://git-wip-us.apache.org/repos/asf/ignite/blob/ab7d7955/examples/src/main/java/org/apache/ignite/examples/persistentstore/PersistentStoreExampleNodeStartup.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/persistentstore/PersistentStoreExampleNodeStartup.java b/examples/src/main/java/org/apache/ignite/examples/persistentstore/PersistentStoreExampleNodeStartup.java index ecada47..9b50acd 100644 --- a/examples/src/main/java/org/apache/ignite/examples/persistentstore/PersistentStoreExampleNodeStartup.java +++ b/examples/src/main/java/org/apache/ignite/examples/persistentstore/PersistentStoreExampleNodeStartup.java @@ -23,6 +23,10 @@ import org.apache.ignite.Ignition; * @see PersistentStoreExampleNodeStartup */ public class PersistentStoreExampleNodeStartup { + /** + * @param args Program arguments, ignored. + * @throws Exception If failed. + */ public static void main(String[] args) throws Exception { Ignition.start("examples/config/persistentstore/example-persistent-store.xml"); } http://git-wip-us.apache.org/repos/asf/ignite/blob/ab7d7955/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java b/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java index 7d8d0fa..f2b0762 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java @@ -3663,7 +3663,9 @@ public class IgniteKernal implements IgniteEx, IgniteMXBean, Externalizable { */ private void checkClusterState() throws IgniteException { if (!ctx.state().active()) - throw new IgniteException("can not perform operation, because cluster inactive"); + throw new IgniteException("Can not perform the operation because the cluster is inactive. Note, that " + + "the cluster is considered inactive by default if Ignite Persistent Store is used to let all the nodes " + + "join the cluster. To activate the cluster call Ignite.activate(true)."); } /**
