|
117 | 117 | import org.apache.ignite.lang.IgniteBiTuple; |
118 | 118 | import org.apache.ignite.lang.IgniteCallable; |
119 | 119 | import org.apache.ignite.lang.IgniteClosure; |
120 | | -import org.apache.ignite.lang.IgniteProductVersion; |
121 | 120 | import org.apache.ignite.lang.IgniteReducer; |
122 | 121 | import org.apache.ignite.lang.IgniteUuid; |
123 | 122 | import org.apache.ignite.plugin.security.SecurityPermission; |
@@ -153,9 +152,6 @@ public abstract class GridCacheQueryManager<K, V> extends GridCacheManagerAdapte |
153 | 152 | /** Maximum number of query detail metrics to evict at once. */ |
154 | 153 | private static final int QRY_DETAIL_METRICS_EVICTION_LIMIT = 10_000; |
155 | 154 |
|
156 | | - /** Support 'not null' field constraint since v 2.3.0. */ |
157 | | - private static final IgniteProductVersion NOT_NULLS_SUPPORT_VER = IgniteProductVersion.fromString("2.3.0"); |
158 | | - |
159 | 155 | /** Comparator for priority queue with query detail metrics with priority to new metrics. */ |
160 | 156 | private static final Comparator<GridCacheQueryDetailMetricsAdapter> QRY_DETAIL_METRICS_PRIORITY_NEW_CMP = |
161 | 157 | new Comparator<GridCacheQueryDetailMetricsAdapter>() { |
@@ -1971,16 +1967,6 @@ public Collection<GridCacheSqlMetadata> sqlMetadataV2() throws IgniteCheckedExce |
1971 | 1967 |
|
1972 | 1968 | // Get metadata from remote nodes. |
1973 | 1969 | if (!nodes.isEmpty()) { |
1974 | | - boolean allNodesNew = true; |
1975 | | - |
1976 | | - for (ClusterNode n : nodes) { |
1977 | | - if (n.version().compareTo(NOT_NULLS_SUPPORT_VER) < 0) |
1978 | | - allNodesNew = false; |
1979 | | - } |
1980 | | - |
1981 | | - if (!allNodesNew) |
1982 | | - return sqlMetadata(); |
1983 | | - |
1984 | 1970 | rmtFut = cctx.closures().callAsync( |
1985 | 1971 | BROADCAST, |
1986 | 1972 | Collections.singleton(job), |
|
0 commit comments