This is an automated email from the ASF dual-hosted git repository.
ilyak pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new 071726f IGNITE-13686 Data structures smoke test with page compression
- Fixes #8437.
071726f is described below
commit 071726f82e683d8f2cc402dda6cb3d9797697673
Author: zstan <stanilov...@gmail.com>
AuthorDate: Tue Nov 10 17:35:18 2020 +0300
IGNITE-13686 Data structures smoke test with page compression - Fixes #8437.
Signed-off-by: Ilya Kasnacheev <ilya.kasnach...@gmail.com>
---
.../ignite/internal/processors/cache/CacheCompressionManager.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheCompressionManager.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheCompressionManager.java
index a3900c3..3bf2b8b 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheCompressionManager.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheCompressionManager.java
@@ -25,6 +25,7 @@ import
org.apache.ignite.configuration.DataStorageConfiguration;
import org.apache.ignite.configuration.DiskPageCompression;
import org.apache.ignite.internal.pagemem.store.PageStore;
import org.apache.ignite.internal.processors.compress.CompressionProcessor;
+import org.apache.ignite.internal.util.typedef.internal.CU;
import org.apache.ignite.internal.util.typedef.internal.U;
import static
org.apache.ignite.internal.processors.compress.CompressionProcessor.checkCompressionLevelBounds;
@@ -45,7 +46,9 @@ public class CacheCompressionManager extends
GridCacheManagerAdapter {
/** {@inheritDoc} */
@Override protected void start0() throws IgniteCheckedException {
- if (cctx.kernalContext().clientNode()) {
+ CacheConfiguration cfg = cctx.config();
+
+ if (cctx.kernalContext().clientNode() || !CU.isPersistentCache(cfg,
cctx.gridConfig().getDataStorageConfiguration())) {
diskPageCompression = DiskPageCompression.DISABLED;
return;
@@ -53,8 +56,6 @@ public class CacheCompressionManager extends
GridCacheManagerAdapter {
compressProc = cctx.kernalContext().compress();
- CacheConfiguration cfg = cctx.config();
-
diskPageCompression = cctx.kernalContext().config().isClientMode() ?
null : cfg.getDiskPageCompression();
if (diskPageCompression != DiskPageCompression.DISABLED) {
