(ignite) branch master updated: IGNITE-24091 Remove CONT_QRY_WITH_TRANSFORMER_SINCE (#11802)

[nizhikov]

This is an automated email from the ASF dual-hosted git repository.

nizhikov 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 acf8b160857 IGNITE-24091 Remove CONT_QRY_WITH_TRANSFORMER_SINCE 
(#11802)
acf8b160857 is described below

commit acf8b1608574d3d7259bde743cbc40b23ad35f7d
Author: Maksim Davydov <70368398+maksa...@users.noreply.github.com>
AuthorDate: Fri Jan 17 22:21:56 2025 +0300

    IGNITE-24091 Remove CONT_QRY_WITH_TRANSFORMER_SINCE (#11802)
---
 .../internal/processors/cache/IgniteCacheProxyImpl.java | 17 -----------------
 1 file changed, 17 deletions(-)

diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxyImpl.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxyImpl.java
index ba681758614..5a1ffc7b970 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxyImpl.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxyImpl.java
@@ -73,7 +73,6 @@ import org.apache.ignite.cache.query.SqlFieldsQuery;
 import org.apache.ignite.cache.query.SqlQuery;
 import org.apache.ignite.cache.query.TextQuery;
 import org.apache.ignite.cluster.ClusterGroup;
-import org.apache.ignite.cluster.ClusterNode;
 import org.apache.ignite.configuration.CacheConfiguration;
 import org.apache.ignite.internal.AsyncSupportAdapter;
 import org.apache.ignite.internal.IgniteEx;
@@ -106,7 +105,6 @@ import org.apache.ignite.internal.util.typedef.internal.U;
 import org.apache.ignite.lang.IgniteBiPredicate;
 import org.apache.ignite.lang.IgniteClosure;
 import org.apache.ignite.lang.IgniteFuture;
-import org.apache.ignite.lang.IgniteProductVersion;
 import org.apache.ignite.plugin.security.SecurityPermission;
 import org.jetbrains.annotations.NotNull;
 import org.jetbrains.annotations.Nullable;
@@ -120,12 +118,6 @@ public class IgniteCacheProxyImpl<K, V> extends 
AsyncSupportAdapter<IgniteCache<
     /** */
     private static final long serialVersionUID = 0L;
 
-    /**
-     * Ignite version that introduce {@link ContinuousQueryWithTransformer} 
feature.
-     */
-    private static final IgniteProductVersion CONT_QRY_WITH_TRANSFORMER_SINCE =
-        IgniteProductVersion.fromString("2.5.0");
-
     /** Cache name. */
     private String cacheName;
 
@@ -695,15 +687,6 @@ public class IgniteCacheProxyImpl<K, V> extends 
AsyncSupportAdapter<IgniteCache<
             if (qry0.getRemoteTransformerFactory() == null)
                 throw new IgniteException("Mandatory RemoteTransformerFactory 
is not set for the query: " + qry);
 
-            Collection<ClusterNode> nodes = context().grid().cluster().nodes();
-
-            for (ClusterNode node : nodes) {
-                if (node.version().compareTo(CONT_QRY_WITH_TRANSFORMER_SINCE) 
< 0) {
-                    throw new IgniteException("Can't start 
ContinuousQueryWithTransformer, " +
-                        "because some nodes in cluster doesn't support this 
feature: " + node);
-                }
-            }
-
             locTransLsnr = qry0.getLocalListener();
 
             rmtTransFactory = qry0.getRemoteTransformerFactory();