ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [01/14] incubator-ignite git commit: ignite-291 null output replaced with <default>
Date Wed, 01 Apr 2015 10:26:10 GMT
Repository: incubator-ignite
Updated Branches:
  refs/heads/ignite-sprint-3 091369c75 -> b05b06f91


ignite-291 null output replaced with <default>


Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/f1ab7bce
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/f1ab7bce
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/f1ab7bce

Branch: refs/heads/ignite-sprint-3
Commit: f1ab7bce69eec1332fcf2e2284c05ff691e587a7
Parents: 98c9ac1
Author: avinogradov <avinogradov@gridgain.com>
Authored: Thu Mar 26 16:24:56 2015 +0300
Committer: avinogradov <avinogradov@gridgain.com>
Committed: Thu Mar 26 16:24:56 2015 +0300

----------------------------------------------------------------------
 .../store/jdbc/CacheAbstractJdbcStore.java      |  2 +-
 .../apache/ignite/internal/IgniteKernal.java    |  5 +-
 .../cache/DynamicCacheDescriptor.java           |  2 +-
 .../processors/cache/GridCacheAdapter.java      |  4 +-
 .../processors/cache/GridCacheProcessor.java    | 66 ++++++++++----------
 .../processors/igfs/IgfsHelperImpl.java         |  3 +-
 .../ignite/startup/BasicWarmupClosure.java      |  2 +-
 .../processors/query/h2/IgniteH2Indexing.java   |  4 +-
 8 files changed, 43 insertions(+), 45 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f1ab7bce/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheAbstractJdbcStore.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheAbstractJdbcStore.java
b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheAbstractJdbcStore.java
index b6485f0..75e2080 100644
--- a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheAbstractJdbcStore.java
+++ b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheAbstractJdbcStore.java
@@ -605,7 +605,7 @@ public abstract class CacheAbstractJdbcStore<K, V> implements CacheStore<K,
V>,
 
         if (em == null)
             throw new CacheException("Failed to find mapping description [key=" + key +
-                ", cache=" + (cacheName != null ? cacheName : "<default>") + "]");
+                ", cache=" + U.maskName(cacheName) + "]");
 
         return em;
     }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f1ab7bce/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 c9c3b8d..1a27732 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
@@ -2033,10 +2033,7 @@ public class IgniteKernal implements IgniteEx, IgniteMXBean, Externalizable
{
             SB sb = new SB();
 
             for (CacheConfiguration c : cacheCfgs) {
-                String name = c.getName();
-
-                if (name == null)
-                    name = "<default>";
+                String name = U.maskName(c.getName());
 
                 sb.a("'").a(name).a("', ");
             }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f1ab7bce/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/DynamicCacheDescriptor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/DynamicCacheDescriptor.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/DynamicCacheDescriptor.java
index 38c5b77..8c9ed16 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/DynamicCacheDescriptor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/DynamicCacheDescriptor.java
@@ -166,6 +166,6 @@ public class DynamicCacheDescriptor {
 
     /** {@inheritDoc} */
     @Override public String toString() {
-        return S.toString(DynamicCacheDescriptor.class, this, "cacheName", cacheCfg.getName());
+        return S.toString(DynamicCacheDescriptor.class, this, "cacheName", U.maskName(cacheCfg.getName()));
     }
 }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f1ab7bce/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
index 9a5b2a0..7fe866f 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
@@ -567,7 +567,7 @@ public abstract class GridCacheAdapter<K, V> implements GridCache<K,
V>,
      * @return Startup info.
      */
     protected final String startInfo() {
-        return "Cache started: " + ctx.config().getName();
+        return "Cache started: " + U.maskName(ctx.config().getName());
     }
 
     /**
@@ -586,7 +586,7 @@ public abstract class GridCacheAdapter<K, V> implements GridCache<K,
V>,
      * @return Stop info.
      */
     protected final String stopInfo() {
-        return "Cache stopped: " + ctx.config().getName();
+        return "Cache stopped: " + U.maskName(ctx.config().getName());
     }
 
     /**

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f1ab7bce/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java
index c918ed4..6bd73c0 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java
@@ -210,7 +210,7 @@ public class GridCacheProcessor extends GridProcessorAdapter {
 
                 U.warn(log, "Automatically set write order mode to PRIMARY for better performance
" +
                     "[writeSynchronizationMode=" + cfg.getWriteSynchronizationMode() + ",
" +
-                    "cacheName=" + cfg.getName() + ']');
+                    "cacheName=" + U.maskName(cfg.getName()) + ']');
             }
         }
 
@@ -224,11 +224,11 @@ public class GridCacheProcessor extends GridProcessorAdapter {
         else {
             if (cfg.getCacheLoaderFactory() != null)
                 throw new IgniteCheckedException("Cannot set both cache loaded factory and
cache store factory " +
-                    "for cache: " + cfg.getName());
+                    "for cache: " + U.maskName(cfg.getName()));
 
             if (cfg.getCacheWriterFactory() != null)
                 throw new IgniteCheckedException("Cannot set both cache writer factory and
cache store factory " +
-                    "for cache: " + cfg.getName());
+                    "for cache: " + U.maskName(cfg.getName()));
         }
     }
 
@@ -284,20 +284,20 @@ public class GridCacheProcessor extends GridProcessorAdapter {
         if (cc.getCacheMode() == REPLICATED) {
             if (cc.getAffinity() instanceof FairAffinityFunction)
                 throw new IgniteCheckedException("REPLICATED cache can not be started with
FairAffinityFunction" +
-                    " [cacheName=" + cc.getName() + ']');
+                    " [cacheName=" + U.maskName(cc.getName()) + ']');
 
             if (cc.getAffinity() instanceof RendezvousAffinityFunction) {
                 RendezvousAffinityFunction aff = (RendezvousAffinityFunction)cc.getAffinity();
 
                 if (aff.isExcludeNeighbors())
                     throw new IgniteCheckedException("For REPLICATED cache flag 'excludeNeighbors'
in " +
-                        "RendezvousAffinityFunction cannot be set [cacheName=" + cc.getName()
+ ']');
+                        "RendezvousAffinityFunction cannot be set [cacheName=" + U.maskName(cc.getName())
+ ']');
             }
 
             if (cc.getNearConfiguration() != null &&
                 ctx.discovery().cacheAffinityNode(ctx.discovery().localNode(), cc.getName()))
{
                 U.warn(log, "Near cache cannot be used with REPLICATED cache, " +
-                    "will be ignored [cacheName=" + cc.getName() + ']');
+                    "will be ignored [cacheName=" + U.maskName(cc.getName()) + ']');
 
                 cc.setNearConfiguration(null);
             }
@@ -305,7 +305,7 @@ public class GridCacheProcessor extends GridProcessorAdapter {
 
         if (cc.getCacheMode() == LOCAL && !cc.getAffinity().getClass().equals(LocalAffinityFunction.class))
             U.warn(log, "AffinityFunction configuration parameter will be ignored for local
cache [cacheName=" +
-                cc.getName() + ']');
+                U.maskName(cc.getName()) + ']');
 
         if (cc.getRebalanceMode() != CacheRebalanceMode.NONE) {
             assertParameter(cc.getRebalanceThreadPoolSize() > 0, "rebalanceThreadPoolSize
> 0");
@@ -316,7 +316,7 @@ public class GridCacheProcessor extends GridProcessorAdapter {
             if (cc.getAtomicityMode() == ATOMIC && cc.getWriteSynchronizationMode()
== FULL_ASYNC)
                 U.warn(log, "Cache write synchronization mode is set to FULL_ASYNC. All single-key
'put' and " +
                     "'remove' operations will return 'null', all 'putx' and 'removex' operations
will return" +
-                    " 'true' [cacheName=" + cc.getName() + ']');
+                    " 'true' [cacheName=" + U.maskName(cc.getName()) + ']');
         }
 
         DeploymentMode depMode = c.getDeploymentMode();
@@ -331,14 +331,14 @@ public class GridCacheProcessor extends GridProcessorAdapter {
             U.warn(log,
                 "Serializable transactions are disabled while default transaction isolation
is SERIALIZABLE " +
                     "(most likely misconfiguration - either update 'isTxSerializableEnabled'
or " +
-                    "'defaultTxIsolationLevel' properties) for cache: " + cc.getName(),
-                "Serializable transactions are disabled while default transaction isolation
is SERIALIZABLE " +
-                    "for cache: " + cc.getName());
+                    "'defaultTxIsolationLevel' properties) for cache: " + U.maskName(cc.getName()),
+                    "Serializable transactions are disabled while default transaction isolation
is SERIALIZABLE " +
+                        "for cache: " + U.maskName(cc.getName()));
 
         if (cc.isWriteBehindEnabled()) {
             if (cfgStore == null)
                 throw new IgniteCheckedException("Cannot enable write-behind (writer or store
is not provided) " +
-                    "for cache: " + cc.getName());
+                    "for cache: " + U.maskName(cc.getName()));
 
             assertParameter(cc.getWriteBehindBatchSize() > 0, "writeBehindBatchSize >
0");
             assertParameter(cc.getWriteBehindFlushSize() >= 0, "writeBehindFlushSize >=
0");
@@ -347,34 +347,34 @@ public class GridCacheProcessor extends GridProcessorAdapter {
 
             if (cc.getWriteBehindFlushSize() == 0 && cc.getWriteBehindFlushFrequency()
== 0)
                 throw new IgniteCheckedException("Cannot set both 'writeBehindFlushFrequency'
and " +
-                    "'writeBehindFlushSize' parameters to 0 for cache: " + cc.getName());
+                    "'writeBehindFlushSize' parameters to 0 for cache: " + U.maskName(cc.getName()));
         }
 
         if (cc.isReadThrough() && cfgStore == null)
             throw new IgniteCheckedException("Cannot enable read-through (loader or store
is not provided) " +
-                "for cache: " + cc.getName());
+                "for cache: " + U.maskName(cc.getName()));
 
         if (cc.isWriteThrough() && cfgStore == null)
             throw new IgniteCheckedException("Cannot enable write-through (writer or store
is not provided) " +
-                "for cache: " + cc.getName());
+                "for cache: " + U.maskName(cc.getName()));
 
         long delay = cc.getRebalanceDelay();
 
         if (delay != 0) {
             if (cc.getCacheMode() != PARTITIONED)
-                U.warn(log, "Rebalance delay is supported only for partitioned caches (will
ignore): " + cc.getName(),
-                    "Will ignore rebalance delay for cache: " + cc.getName());
+                U.warn(log, "Rebalance delay is supported only for partitioned caches (will
ignore): " + (cc.getName()),
+                    "Will ignore rebalance delay for cache: " + U.maskName(cc.getName()));
             else if (cc.getRebalanceMode() == SYNC) {
                 if (delay < 0) {
                     U.warn(log, "Ignoring SYNC rebalance mode with manual rebalance start
(node will not wait for " +
-                        "rebalancing to be finished): " + cc.getName(),
-                        "Node will not wait for rebalance in SYNC mode: " + cc.getName());
+                        "rebalancing to be finished): " + U.maskName(cc.getName()),
+                        "Node will not wait for rebalance in SYNC mode: " + U.maskName(cc.getName()));
                 }
                 else {
                     U.warn(log,
                         "Using SYNC rebalance mode with rebalance delay (node will wait until
rebalancing is " +
-                            "initiated for " + delay + "ms) for cache: " + cc.getName(),
-                        "Node will wait until rebalancing is initiated for " + delay + "ms
for cache: " + cc.getName());
+                            "initiated for " + delay + "ms) for cache: " + U.maskName(cc.getName()),
+                            "Node will wait until rebalancing is initiated for " + delay
+ "ms for cache: " + U.maskName(cc.getName()));
                 }
             }
         }
@@ -399,7 +399,7 @@ public class GridCacheProcessor extends GridProcessorAdapter {
             case ONHEAP_TIERED:
                 if (!systemCache(cc.getName()) && cc.getEvictionPolicy() == null
&& cc.getOffHeapMaxMemory() >= 0)
                     U.quietAndWarn(log, "Eviction policy not enabled with ONHEAP_TIERED mode
for cache " +
-                        "(entries will not be moved to off-heap store): " + cc.getName());
+                        "(entries will not be moved to off-heap store): " + U.maskName(cc.getName()));
 
                 break;
 
@@ -411,7 +411,7 @@ public class GridCacheProcessor extends GridProcessorAdapter {
             if (GridQueryProcessor.isEnabled(cc))
                 throw new IgniteCheckedException("Cannot have query indexing enabled while
values are stored off-heap. " +
                     "You must either disable query indexing or disable off-heap values only
flag for cache: " +
-                    cc.getName());
+                    U.maskName(cc.getName()));
         }
 
         if (cc.getAtomicityMode() == ATOMIC)
@@ -582,7 +582,7 @@ public class GridCacheProcessor extends GridProcessorAdapter {
 
                 if (cacheName != null)
                     throw new IgniteCheckedException("Duplicate cache name found (check configuration
and " +
-                        "assign unique name to each cache): " + cacheName);
+                        "assign unique name to each cache): " + U.maskName(cacheName));
                 else
                     throw new IgniteCheckedException("Default cache has already been configured
(check configuration and " +
                         "assign unique name to each cache).");
@@ -836,7 +836,7 @@ public class GridCacheProcessor extends GridProcessorAdapter {
         cacheCtx.onStarted();
 
         if (log.isInfoEnabled())
-            log.info("Started cache [name=" + cfg.getName() + ", mode=" + cfg.getCacheMode()
+ ']');
+            log.info("Started cache [name=" + U.maskName(cfg.getName()) + ", mode=" + cfg.getCacheMode()
+ ']');
     }
 
     /**
@@ -1761,7 +1761,7 @@ public class GridCacheProcessor extends GridProcessorAdapter {
                         // If local node initiated start, fail the start future.
                         if (startFut != null && startFut.deploymentId().equals(req.deploymentId()))
{
                             startFut.onDone(new CacheExistsException("Failed to start cache
" +
-                                "(a cache with the same name is already started): " + ccfg.getName()));
+                                "(a cache with the same name is already started): " + U.maskName(ccfg.getName())));
                         }
 
                         return;
@@ -1773,7 +1773,7 @@ public class GridCacheProcessor extends GridProcessorAdapter {
                     if (req.clientStartOnly()) {
                         if (startFut != null && startFut.deploymentId().equals(req.deploymentId()))
{
                             startFut.onDone(new IgniteCheckedException("Failed to start client
cache " +
-                                "(a cache with the given name is not started): " + ccfg.getName()));
+                                "(a cache with the given name is not started): " + U.maskName(ccfg.getName())));
                         }
 
                         return;
@@ -1833,18 +1833,18 @@ public class GridCacheProcessor extends GridProcessorAdapter {
             if (rebalanceOrder > 0) {
                 if (cfg.getCacheMode() == LOCAL)
                     throw new IgniteCheckedException("Rebalance order set for local cache
(fix configuration and restart the " +
-                        "node): " + cfg.getName());
+                        "node): " + U.maskName(cfg.getName()));
 
                 if (cfg.getRebalanceMode() == CacheRebalanceMode.NONE)
                     throw new IgniteCheckedException("Only caches with SYNC or ASYNC rebalance
mode can be set as rebalance " +
-                        "dependency for other caches [cacheName=" + cfg.getName() +
+                        "dependency for other caches [cacheName=" + U.maskName(cfg.getName())
+
                         ", rebalanceMode=" + cfg.getRebalanceMode() + ", rebalanceOrder="
+ cfg.getRebalanceOrder() + ']');
 
                 maxOrder = Math.max(maxOrder, rebalanceOrder);
             }
             else if (rebalanceOrder < 0)
                 throw new IgniteCheckedException("Rebalance order cannot be negative for
cache (fix configuration and restart " +
-                    "the node) [cacheName=" + cfg.getName() + ", rebalanceOrder=" + rebalanceOrder
+ ']');
+                    "the node) [cacheName=" + U.maskName(cfg.getName()) + ", rebalanceOrder="
+ rebalanceOrder + ']');
         }
 
         return maxOrder;
@@ -1877,12 +1877,12 @@ public class GridCacheProcessor extends GridProcessorAdapter {
 
                     if (nodeHashObj.hashCode() == topNodeHashObj.hashCode()) {
                         String errMsg = "Failed to add node to topology because it has the
same hash code for " +
-                            "partitioned affinity as one of existing nodes [cacheName=" +
cfg.getName() +
+                            "partitioned affinity as one of existing nodes [cacheName=" +
U.maskName(cfg.getName()) +
                             ", hashIdResolverClass=" + hashIdRslvr.getClass().getName() +
                             ", existingNodeId=" + topNode.id() + ']';
 
                         String sndMsg = "Failed to add node to topology because it has the
same hash code for " +
-                            "partitioned affinity as one of existing nodes [cacheName=" +
cfg.getName() +
+                            "partitioned affinity as one of existing nodes [cacheName=" +
U.maskName(cfg.getName()) +
                             ", hashIdResolverClass=" + hashIdRslvr.getClass().getName() +
", existingNodeId=" +
                             topNode.id() + ']';
 
@@ -2505,7 +2505,7 @@ public class GridCacheProcessor extends GridProcessorAdapter {
         }
         catch (IgniteCheckedException e) {
             throw new IgniteCheckedException("Failed to validate cache configuration " +
-                "(make sure all objects in cache configuration are serializable): " + val.getName(),
e);
+                "(make sure all objects in cache configuration are serializable): " + U.maskName(val.getName()),
e);
         }
     }
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f1ab7bce/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsHelperImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsHelperImpl.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsHelperImpl.java
index 1607e4a..cf8aa5f 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsHelperImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsHelperImpl.java
@@ -21,6 +21,7 @@ import org.apache.ignite.*;
 import org.apache.ignite.cache.eviction.*;
 import org.apache.ignite.cache.eviction.igfs.*;
 import org.apache.ignite.configuration.*;
+import org.apache.ignite.internal.util.typedef.internal.*;
 
 /**
  * IGFS utils processor.
@@ -43,7 +44,7 @@ public class IgfsHelperImpl implements IgfsHelper {
 
             if (evictFilter != null && !(evictFilter instanceof IgfsEvictionFilter))
                 throw new IgniteCheckedException("Eviction filter cannot be set explicitly
when using " +
-                    "IgfsPerBlockLruEvictionPolicy:" + cfg.getName());
+                    "IgfsPerBlockLruEvictionPolicy:" + U.maskName(cfg.getName()));
         }
     }
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f1ab7bce/modules/core/src/main/java/org/apache/ignite/startup/BasicWarmupClosure.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/startup/BasicWarmupClosure.java
b/modules/core/src/main/java/org/apache/ignite/startup/BasicWarmupClosure.java
index 1f0b73a..08ec420 100644
--- a/modules/core/src/main/java/org/apache/ignite/startup/BasicWarmupClosure.java
+++ b/modules/core/src/main/java/org/apache/ignite/startup/BasicWarmupClosure.java
@@ -303,7 +303,7 @@ public class BasicWarmupClosure implements IgniteInClosure<IgniteConfiguration>
                         futs.add(svc.submit(call));
                     }
 
-                    out("Running warmup [cacheName=" + cc.getName() + ", method=" + warmupMethod
+ ']');
+                    out("Running warmup [cacheName=" + U.maskName(cc.getName()) + ", method="
+ warmupMethod + ']');
 
                     for (Future fut : futs)
                         fut.get();

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f1ab7bce/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/IgniteH2Indexing.java
----------------------------------------------------------------------
diff --git a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/IgniteH2Indexing.java
b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/IgniteH2Indexing.java
index a484a10..a47ad5b 100644
--- a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/IgniteH2Indexing.java
+++ b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/IgniteH2Indexing.java
@@ -1240,7 +1240,7 @@ public class IgniteH2Indexing implements GridQueryIndexing {
         if (schemas.putIfAbsent(schema, new Schema(ccfg.getName(),
             ccfg.getOffHeapMaxMemory() >= 0 || ccfg.getMemoryMode() == CacheMemoryMode.OFFHEAP_TIERED
?
             new GridUnsafeMemory(0) : null, ccfg)) != null)
-            throw new IgniteCheckedException("Cache already registered: " + ccfg.getName());
+            throw new IgniteCheckedException("Cache already registered: " + U.maskName(ccfg.getName()));
 
         createSchema(schema);
         createSqlFunctions(schema, ccfg.getSqlFunctionClasses());
@@ -1256,7 +1256,7 @@ public class IgniteH2Indexing implements GridQueryIndexing {
                 dropSchema(schema);
             }
             catch (IgniteCheckedException e) {
-                U.error(log, "Failed to drop schema on cache stop (will ignore): " + ccfg.getName(),
e);
+                U.error(log, "Failed to drop schema on cache stop (will ignore): " + U.maskName(ccfg.getName()),
e);
             }
         }
     }


Mime
View raw message