nizhikov commented on a change in pull request #6907: IGNITE-11723: IgniteSpark
integration should support skipStore option for internal dataStreamer
(IgniteRdd and Ignite DataFrame)
URL: https://github.com/apache/ignite/pull/6907#discussion_r330016533
##########
File path:
modules/spark/src/test/java/org/apache/ignite/spark/JavaEmbeddedIgniteRDDSelfTest.java
##########
@@ -150,6 +169,59 @@ public void testStoreDataToIgnite() throws Exception {
}
}
+ /**
+ * @throws Exception If failed.
+ */
+ @Test
+ public void testStoreDataToIgniteWithEnabledOptionSkipStore() throws
Exception {
+ storeMap = new ConcurrentHashMap<>();
+ store = new TestStore();
+
+ JavaSparkContext sc = createContext();
+
+ JavaIgniteContext<Integer, Integer> ic = null;
+
+ try {
+ ic = new JavaIgniteContext<>(sc, new IgniteConfigProvider(),
false);
+
+ Ignite ignite = ic.ignite();
+
+ IgniteCache<Integer, Integer> cache =
ignite.cache(PARTITIONED_CACHE_NAME);
+
+ // 1000 entries in store; 1000 entries in cache
Review comment:
Nit: The sentence should start with the capital letter and ends with the dot.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
