ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [19/24] incubator-ignite git commit: # ignite-26
Date Fri, 30 Jan 2015 16:52:25 GMT
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/main/java/org/apache/ignite/lang/IgniteFuture.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/lang/IgniteFuture.java
index d2229ef,0000000..bc74203
mode 100644,000000..100644
--- a/modules/core/src/main/java/org/apache/ignite/lang/IgniteFuture.java
+++ b/modules/core/src/main/java/org/apache/ignite/lang/IgniteFuture.java
@@@ -1,152 -1,0 +1,154 @@@
 +/*
 + * Licensed to the Apache Software Foundation (ASF) under one or more
 + * contributor license agreements.  See the NOTICE file distributed with
 + * this work for additional information regarding copyright ownership.
 + * The ASF licenses this file to You under the Apache License, Version 2.0
 + * (the "License"); you may not use this file except in compliance with
 + * the License.  You may obtain a copy of the License at
 + *
 + *      http://www.apache.org/licenses/LICENSE-2.0
 + *
 + * Unless required by applicable law or agreed to in writing, software
 + * distributed under the License is distributed on an "AS IS" BASIS,
 + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 + * See the License for the specific language governing permissions and
 + * limitations under the License.
 + */
 +
 +package org.apache.ignite.lang;
 +
 +import org.apache.ignite.*;
 +import org.jetbrains.annotations.*;
 +
 +import java.util.concurrent.*;
 +
 +/**
 + * Extension for standard {@link Future} interface. It adds simplified exception handling,
 + * functional programming support and ability to listen for future completion via functional
 + * callback.
 + * @param <V> Type of the result for the future.
 + */
 +public interface IgniteFuture<V> extends Future<V> {
 +    /**
 +     * @throws IgniteException
 +     * @throws IgniteInterruptedException
 +     */
 +    @Override public V get() throws IgniteException, IgniteInterruptedException;
 +
++    public V get(long timeout);
++
 +    /**
 +     * @param timeout
 +     * @param unit
 +     * @return
 +     * @throws IgniteException
 +     * @throws IgniteInterruptedException
 +     */
 +    @Override public V get(long timeout, TimeUnit unit) throws IgniteException, IgniteInterruptedException, IgniteFutureTimeoutException;
 +
 +    /**
 +     * Cancels this future.
 +     *
 +     * @return {@code True} if future was canceled (i.e. was not finished prior to this call).
 +     * @throws IgniteException If cancellation failed.
 +     */
 +    public boolean cancel() throws IgniteException;
 +
 +    /**
 +     * Gets start time for this future.
 +     *
 +     * @return Start time for this future.
 +     */
 +    public long startTime();
 +
 +    /**
 +     * Gets duration in milliseconds between start of the future and current time if future
 +     * is not finished, or between start and finish of this future.
 +     *
 +     * @return Time in milliseconds this future has taken to execute.
 +     */
 +    public long duration();
 +
 +    /**
 +     * Flag to turn on or off synchronous listener notification. If this flag is {@code true}, then
 +     * upon future completion the notification may happen in the same thread that created
 +     * the future. This becomes especially important when adding listener to a future that
 +     * is already {@code done} - if this flag is {@code true}, then listener will be
 +     * immediately notified within the same thread.
 +     * <p>
 +     * Default value is {@code false}. To change the default, set
 +     * {@link IgniteSystemProperties#GG_FUT_SYNC_NOTIFICATION} system property to {@code true}.
 +     *
 +     * @param syncNotify Flag to turn on or off synchronous listener notification.
 +     */
 +    public void syncNotify(boolean syncNotify);
 +
 +    /**
 +     * Gets value of synchronous listener notification flag. If this flag is {@code true}, then
 +     * upon future completion the notification may happen in the same thread that created
 +     * the future. This becomes especially important when adding listener to a future that
 +     * is already {@code done} - if this flag is {@code true}, then listener will be
 +     * immediately notified within the same thread.
 +     * <p>
 +     * Default value is {@code false}. To change the default, set
 +     * {@link IgniteSystemProperties#GG_FUT_SYNC_NOTIFICATION} system property to {@code true}.
 +     *
 +     * @return Synchronous listener notification flag.
 +     */
 +    public boolean syncNotify();
 +
 +    /**
 +     * Flag to turn on or off concurrent listener notification. This flag comes into play only
 +     * when a future has more than one listener subscribed to it. If this flag is {@code true},
 +     * then all listeners will be notified concurrently by different threads; otherwise,
 +     * listeners will be notified one after another within one thread (depending on
 +     * {@link #syncNotify()} flag, these notifications may happen either in the same thread which
 +     * started the future, or in a different thread).
 +     * <p>
 +     * Default value is {@code false}. To change the default, set
 +     * {@link IgniteSystemProperties#GG_FUT_CONCURRENT_NOTIFICATION} system property to {@code true}.
 +     *
 +     * @param concurNotify Flag to turn on or off concurrent listener notification.
 +     */
 +    public void concurrentNotify(boolean concurNotify);
 +
 +    /**
 +     * Gets value concurrent listener notification flag. This flag comes into play only
 +     * when a future has more than one listener subscribed to it. If this flag is {@code true},
 +     * then all listeners will be notified concurrently by different threads; otherwise,
 +     * listeners will be notified one after another within one thread (depending on
 +     * {@link #syncNotify()} flag, these notifications may happen either in the same thread which
 +     * started the future, or in a different thread).
 +     * <p>
 +     * Default value is {@code false}. To change the default, set
 +     * {@link IgniteSystemProperties#GG_FUT_CONCURRENT_NOTIFICATION} system property to {@code true}.
 +     *
 +     * @return Concurrent listener notification flag
 +     */
 +    public boolean concurrentNotify();
 +
 +    /**
 +     * Registers listener closure to be asynchronously notified whenever future completes.
 +     *
 +     * @param lsnr Listener closure to register. If not provided - this method is no-op.
 +     */
 +    public void listenAsync(@Nullable IgniteInClosure<? super IgniteFuture<V>> lsnr);
 +
 +    /**
 +     * Removes given listeners from the future. If no listener is passed in, then all listeners
 +     * will be removed.
 +     *
 +     * @param lsnr Listeners to remove.
 +     */
 +    public void stopListenAsync(@Nullable IgniteInClosure<? super IgniteFuture<V>>... lsnr);
 +
 +    /**
 +     * Make a chained future to convert result of this future (when complete) into a new format.
 +     * It is guaranteed that done callback will be called only ONCE.
 +     *
 +     * @param doneCb Done callback that is applied to this future when it finishes to produce chained future result.
 +     * @return Chained future that finishes after this future completes and done callback is called.
 +     */
 +    public <T> IgniteFuture<T> chain(IgniteClosure<? super IgniteFuture<V>, T> doneCb);
 +
 +}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/main/java/org/apache/ignite/plugin/security/GridSecurity.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/plugin/security/GridSecurity.java
index 142af74,142af74..9527fc7
--- a/modules/core/src/main/java/org/apache/ignite/plugin/security/GridSecurity.java
+++ b/modules/core/src/main/java/org/apache/ignite/plugin/security/GridSecurity.java
@@@ -85,7 -85,7 +85,7 @@@ public interface GridSecurity 
       *
       * @return Collection of authenticated subjects.
       */
--    public Collection<GridSecuritySubject> authenticatedSubjects() throws IgniteCheckedException;
++    public Collection<GridSecuritySubject> authenticatedSubjects() throws IgniteException;
  
      /**
       * Gets security subject based on subject ID.
@@@ -93,5 -93,5 +93,5 @@@
       * @param subjId Subject ID.
       * @return Authorized security subject.
       */
--    public GridSecuritySubject authenticatedSubject(UUID subjId) throws IgniteCheckedException;
++    public GridSecuritySubject authenticatedSubject(UUID subjId) throws IgniteException;
  }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiAdapter.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiAdapter.java
index aef2490,aef2490..7f35d2d
--- a/modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiAdapter.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiAdapter.java
@@@ -579,22 -579,22 +579,22 @@@ public abstract class IgniteSpiAdapter 
          }
  
          /** {@inheritDoc} */
--        @Override public <K, V> V get(String cacheName, K key) throws IgniteCheckedException {
++        @Override public <K, V> V get(String cacheName, K key) {
              return null;
          }
  
          /** {@inheritDoc} */
--        @Override public <K, V> V put(String cacheName, K key, V val, long ttl) throws IgniteCheckedException {
++        @Override public <K, V> V put(String cacheName, K key, V val, long ttl) {
              return null;
          }
  
          /** {@inheritDoc} */
--        @Override public <K, V> V putIfAbsent(String cacheName, K key, V val, long ttl) throws IgniteCheckedException {
++        @Override public <K, V> V putIfAbsent(String cacheName, K key, V val, long ttl) {
              return null;
          }
  
          /** {@inheritDoc} */
--        @Override public <K, V> V remove(String cacheName, K key) throws IgniteCheckedException {
++        @Override public <K, V> V remove(String cacheName, K key) {
              return null;
          }
  
@@@ -605,32 -605,32 +605,30 @@@
  
          /** {@inheritDoc} */
          @Override public void writeToSwap(String spaceName, Object key, @Nullable Object val,
--            @Nullable ClassLoader ldr) throws IgniteCheckedException {
++            @Nullable ClassLoader ldr) {
              /* No-op. */
          }
  
          /** {@inheritDoc} */
--        @Override public <T> T readFromSwap(String spaceName, SwapKey key, @Nullable ClassLoader ldr)
--            throws IgniteCheckedException {
++        @Override public <T> T readFromSwap(String spaceName, SwapKey key, @Nullable ClassLoader ldr) {
              return null;
          }
  
          /** {@inheritDoc} */
          @Nullable @Override public <T> T readFromOffheap(String spaceName, int part, Object key, byte[] keyBytes,
--            @Nullable ClassLoader ldr) throws IgniteCheckedException {
++            @Nullable ClassLoader ldr) {
              return null;
          }
  
          /** {@inheritDoc} */
          @Override public boolean removeFromOffheap(@Nullable String spaceName, int part, Object key,
--            @Nullable byte[] keyBytes) throws IgniteCheckedException {
++            @Nullable byte[] keyBytes) {
              return false;
          }
  
          /** {@inheritDoc} */
          @Override public void writeToOffheap(@Nullable String spaceName, int part, Object key,
--            @Nullable byte[] keyBytes, Object val, @Nullable byte[] valBytes, @Nullable ClassLoader ldr)
--            throws IgniteCheckedException {
++            @Nullable byte[] keyBytes, Object val, @Nullable byte[] valBytes, @Nullable ClassLoader ldr) {
              // No-op.
          }
  
@@@ -640,8 -640,8 +638,7 @@@
          }
  
          /** {@inheritDoc} */
--        @Override public void removeFromSwap(String spaceName, Object key, @Nullable ClassLoader ldr)
--            throws IgniteCheckedException {
++        @Override public void removeFromSwap(String spaceName, Object key, @Nullable ClassLoader ldr) {
              // No-op.
          }
  
@@@ -712,18 -712,18 +709,18 @@@
          }
  
          /** {@inheritDoc} */
--        @Override public Collection<GridSecuritySubject> authenticatedSubjects() throws IgniteCheckedException {
++        @Override public Collection<GridSecuritySubject> authenticatedSubjects() {
              return Collections.emptyList();
          }
  
          /** {@inheritDoc} */
--        @Override public GridSecuritySubject authenticatedSubject(UUID subjId) throws IgniteCheckedException {
++        @Override public GridSecuritySubject authenticatedSubject(UUID subjId) {
              return null;
          }
  
          /** {@inheritDoc} */
          @Nullable @Override public <T> T readValueFromOffheapAndSwap(@Nullable String spaceName, Object key,
--            @Nullable ClassLoader ldr) throws IgniteCheckedException {
++            @Nullable ClassLoader ldr) {
              return null;
          }
  

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiContext.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiContext.java
index da2152f,da2152f..9dbc9d0
--- a/modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiContext.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiContext.java
@@@ -27,6 -27,6 +27,7 @@@ import org.apache.ignite.internal.manag
  import org.apache.ignite.internal.util.direct.*;
  import org.jetbrains.annotations.*;
  
++import javax.cache.*;
  import java.io.*;
  import java.nio.*;
  import java.util.*;
@@@ -197,9 -197,9 +198,9 @@@ public interface IgniteSpiContext 
       * @param cacheName Cache name.
       * @param key Object key.
       * @return Cached object.
--     * @throws IgniteCheckedException Thrown if any exception occurs.
++     * @throws CacheException Thrown if any exception occurs.
       */
--    @Nullable public <K, V> V get(String cacheName, K key) throws IgniteCheckedException;
++    @Nullable public <K, V> V get(String cacheName, K key) throws CacheException;
  
      /**
       * Puts object in cache.
@@@ -211,9 -211,9 +212,9 @@@
       * @param <K> Key type.
       * @param <V> Value type.
       * @return Previous value associated with specified key, possibly {@code null}.
--     * @throws IgniteCheckedException Thrown if any exception occurs.
++     * @throws CacheException Thrown if any exception occurs.
       */
--    @Nullable public <K, V> V put(String cacheName, K key, V val, long ttl) throws IgniteCheckedException;
++    @Nullable public <K, V> V put(String cacheName, K key, V val, long ttl) throws CacheException;
  
      /**
       * Puts object into cache if there was no previous object associated with
@@@ -226,9 -226,9 +227,9 @@@
       * @param <K> Cache key type.
       * @param <V> Cache value type.
       * @return Either existing value or {@code null} if there was no value for given key.
--     * @throws IgniteCheckedException If put failed.
++     * @throws CacheException If put failed.
       */
--    @Nullable public <K, V> V putIfAbsent(String cacheName, K key, V val, long ttl) throws IgniteCheckedException;
++    @Nullable public <K, V> V putIfAbsent(String cacheName, K key, V val, long ttl) throws CacheException;
  
      /**
       * Removes object from cache.
@@@ -238,9 -238,9 +239,9 @@@
       * @param <K> Key type.
       * @param <V> Value type.
       * @return Previous value associated with specified key, possibly {@code null}.
--     * @throws IgniteCheckedException Thrown if any exception occurs.
++     * @throws CacheException Thrown if any exception occurs.
       */
--    @Nullable public <K, V> V remove(String cacheName, K key) throws IgniteCheckedException;
++    @Nullable public <K, V> V remove(String cacheName, K key) throws CacheException;
  
      /**
       * Returns {@code true} if this cache contains a mapping for the specified key.
@@@ -259,10 -259,10 +260,10 @@@
       * @param key Key.
       * @param val Value.
       * @param ldr Class loader (optional).
--     * @throws IgniteCheckedException If any exception occurs.
++     * @throws IgniteException If any exception occurs.
       */
      public void writeToSwap(String spaceName, Object key, @Nullable Object val, @Nullable ClassLoader ldr)
--        throws IgniteCheckedException;
++        throws IgniteException;
  
      /**
       * Reads object from swap.
@@@ -271,10 -271,10 +272,10 @@@
       * @param key Key.
       * @param ldr Class loader (optional).
       * @return Swapped value.
--     * @throws IgniteCheckedException If any exception occurs.
++     * @throws IgniteException If any exception occurs.
       */
      @Nullable public <T> T readFromSwap(String spaceName, SwapKey key, @Nullable ClassLoader ldr)
--        throws IgniteCheckedException;
++        throws IgniteException;
  
  
      /**
@@@ -286,10 -286,10 +287,10 @@@
       * @param keyBytes Key bytes.
       * @param ldr Class loader for unmarshalling.
       * @return Value.
--     * @throws IgniteCheckedException If failed.
++     * @throws IgniteException If failed.
       */
      @Nullable public <T> T readFromOffheap(@Nullable String spaceName, int part, Object key, @Nullable byte[] keyBytes,
--        @Nullable ClassLoader ldr) throws IgniteCheckedException;
++        @Nullable ClassLoader ldr) throws IgniteException;
  
      /**
       * Writes data to off-heap memory.
@@@ -301,10 -301,10 +302,10 @@@
       * @param val Value.
       * @param valBytes Optional value bytes.
       * @param ldr Class loader.
--     * @throws IgniteCheckedException If failed.
++     * @throws IgniteException If failed.
       */
      public void writeToOffheap(@Nullable String spaceName, int part, Object key, @Nullable byte[] keyBytes, Object val,
--        @Nullable byte[] valBytes, @Nullable ClassLoader ldr) throws IgniteCheckedException;
++        @Nullable byte[] valBytes, @Nullable ClassLoader ldr) throws IgniteException;
  
      /**
       * Removes data from off-heap memory.
@@@ -314,10 -314,10 +315,10 @@@
       * @param key Key.
       * @param keyBytes Optional key bytes.
       * @return {@code true} If succeeded.
--     * @throws IgniteCheckedException If failed.
++     * @throws IgniteException If failed.
       */
      public boolean removeFromOffheap(@Nullable String spaceName, int part, Object key, @Nullable byte[] keyBytes)
--        throws IgniteCheckedException;
++        throws IgniteException;
  
      /**
       * Calculates partition number for given key.
@@@ -334,9 -334,9 +335,9 @@@
       * @param spaceName Swap space name.
       * @param key Key.
       * @param ldr Class loader (optional).
--     * @throws IgniteCheckedException If any exception occurs.
++     * @throws IgniteException If any exception occurs.
       */
--    public void removeFromSwap(String spaceName, Object key, @Nullable ClassLoader ldr) throws IgniteCheckedException;
++    public void removeFromSwap(String spaceName, Object key, @Nullable ClassLoader ldr) throws IgniteException;
  
      /**
       * Validates that new node can join grid topology, this method is called on coordinator
@@@ -371,18 -371,18 +372,18 @@@
       * Gets collection of authenticated subjects together with their permissions.
       *
       * @return Collection of authenticated subjects.
--     * @throws IgniteCheckedException If any exception occurs.
++     * @throws IgniteException If any exception occurs.
       */
--    public Collection<GridSecuritySubject> authenticatedSubjects() throws IgniteCheckedException;
++    public Collection<GridSecuritySubject> authenticatedSubjects() throws IgniteException;
  
      /**
       * Gets security subject based on subject ID.
       *
       * @param subjId Subject ID.
       * @return Authorized security subject.
--     * @throws IgniteCheckedException If any exception occurs.
++     * @throws IgniteException If any exception occurs.
       */
--    public GridSecuritySubject authenticatedSubject(UUID subjId) throws IgniteCheckedException;
++    public GridSecuritySubject authenticatedSubject(UUID subjId) throws IgniteException;
  
      /**
       * Reads swapped cache value from off-heap and swap.
@@@ -391,10 -391,10 +392,10 @@@
       * @param key Key.
       * @param ldr Class loader for unmarshalling.
       * @return Value.
--     * @throws IgniteCheckedException If any exception occurs.
++     * @throws IgniteException If any exception occurs.
       */
      @Nullable public <T> T readValueFromOffheapAndSwap(@Nullable String spaceName, Object key,
--        @Nullable ClassLoader ldr) throws IgniteCheckedException;
++        @Nullable ClassLoader ldr) throws IgniteException;
  
      /**
       * @return Message factory.

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiException.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiException.java
index ed00338,ed00338..91d691e
--- a/modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiException.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiException.java
@@@ -22,7 -22,7 +22,7 @@@ import org.apache.ignite.*
  /**
   * Exception thrown by SPI implementations.
   */
--public class IgniteSpiException extends IgniteCheckedException {
++public class IgniteSpiException extends IgniteException {
      /** */
      private static final long serialVersionUID = 0L;
  

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/main/java/org/apache/ignite/spi/authentication/AuthenticationAclProvider.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/spi/authentication/AuthenticationAclProvider.java
index 93cec53,93cec53..78845f6
--- a/modules/core/src/main/java/org/apache/ignite/spi/authentication/AuthenticationAclProvider.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/authentication/AuthenticationAclProvider.java
@@@ -35,7 -35,7 +35,7 @@@ public interface AuthenticationAclProvi
       * Gets per-user access control map.
       *
       * @return Per-user access control map.
--     * @throws IgniteCheckedException If failed.
++     * @throws IgniteException If failed.
       */
--    public Map<GridSecurityCredentials, GridSecurityPermissionSet> acl() throws IgniteCheckedException;
++    public Map<GridSecurityCredentials, GridSecurityPermissionSet> acl() throws IgniteException;
  }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/main/java/org/apache/ignite/spi/checkpoint/cache/CacheCheckpointSpi.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/spi/checkpoint/cache/CacheCheckpointSpi.java
index 39b3565,39b3565..e37a8dc
--- a/modules/core/src/main/java/org/apache/ignite/spi/checkpoint/cache/CacheCheckpointSpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/checkpoint/cache/CacheCheckpointSpi.java
@@@ -27,6 -27,6 +27,8 @@@ import org.apache.ignite.internal.util.
  import org.apache.ignite.internal.util.typedef.internal.*;
  import org.jetbrains.annotations.*;
  
++import javax.cache.*;
++
  import static org.apache.ignite.events.IgniteEventType.*;
  
  /**
@@@ -192,7 -192,7 +194,7 @@@ public class CacheCheckpointSpi extend
          try {
              return getSpiContext().get(cacheName, key);
          }
--        catch (IgniteCheckedException e) {
++        catch (CacheException e) {
              throw new IgniteSpiException("Failed to load checkpoint data [key=" + key + ']', e);
          }
      }
@@@ -212,7 -212,7 +214,7 @@@
              else
                  return getSpiContext().putIfAbsent(cacheName, key, state, timeout) == null;
          }
--        catch (IgniteCheckedException e) {
++        catch (CacheException e) {
              throw new IgniteSpiException("Failed to save checkpoint data [key=" + key +
                  ", stateSize=" + state.length + ", timeout=" + timeout + ']', e);
          }
@@@ -225,7 -225,7 +227,7 @@@
          try {
              return getSpiContext().remove(cacheName, key) != null;
          }
--        catch (IgniteCheckedException e) {
++        catch (CacheException e) {
              U.error(log, "Failed to remove checkpoint data [key=" + key + ']', e);
  
              return false;

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/main/java/org/apache/ignite/spi/discovery/DiscoverySpiNodeAuthenticator.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/spi/discovery/DiscoverySpiNodeAuthenticator.java
index 9b043b3,9b043b3..3b96d14
--- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/DiscoverySpiNodeAuthenticator.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/DiscoverySpiNodeAuthenticator.java
@@@ -32,10 -32,10 +32,10 @@@ public interface DiscoverySpiNodeAuthen
       * @param node Node to authenticate.
       * @param cred Security credentials.
       * @return Security context if authentication succeeded or {@code null} if authentication failed.
--     * @throws IgniteCheckedException If authentication process failed
++     * @throws IgniteException If authentication process failed
       *      (invalid credentials should not lead to this exception).
       */
--    public GridSecurityContext authenticateNode(ClusterNode node, GridSecurityCredentials cred) throws IgniteCheckedException;
++    public GridSecurityContext authenticateNode(ClusterNode node, GridSecurityCredentials cred) throws IgniteException;
  
      /**
       * Gets global node authentication flag.

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
index 9f4c987,547a332..d1d1448
--- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
@@@ -1284,7 -1284,7 +1284,7 @@@ public class TcpDiscoverySpi extends Tc
  
                      locNode.setAttributes(attrs);
                  }
--                catch (IgniteCheckedException e) {
++                catch (IgniteException | IgniteCheckedException e) {
                      throw new IgniteSpiException("Failed to authenticate local node (will shutdown local node).", e);
                  }
  
@@@ -3155,7 -3155,7 +3155,7 @@@
                          node.setAttributes(attrs);
                      }
                  }
--                catch (IgniteCheckedException e) {
++                catch (IgniteException | IgniteCheckedException e) {
                      LT.error(log, e, "Authentication failed [nodeId=" + node.id() + ", addrs=" +
                          U.addressesAsString(node) + ']');
  
@@@ -3610,7 -3610,7 +3610,7 @@@
                                  authFailed = false;
                          }
                      }
--                    catch (IgniteCheckedException e) {
++                    catch (IgniteException | IgniteCheckedException e) {
                          U.error(log, "Failed to verify node permissions consistency (will drop the node): " + node, e);
                      }
                      finally {

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/main/java/org/apache/ignite/spi/failover/FailoverContext.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/spi/failover/FailoverContext.java
index 3b32cf6,3b32cf6..b0cae92
--- a/modules/core/src/main/java/org/apache/ignite/spi/failover/FailoverContext.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/failover/FailoverContext.java
@@@ -49,7 -49,7 +49,7 @@@ public interface FailoverContext 
       *
       * @param top Topology to pick balanced node from.
       * @return The next balanced node.
--     * @throws IgniteCheckedException If anything failed.
++     * @throws IgniteException If anything failed.
       */
--    public ClusterNode getBalancedNode(List<ClusterNode> top) throws IgniteCheckedException;
++    public ClusterNode getBalancedNode(List<ClusterNode> top) throws IgniteException;
  }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/main/java/org/apache/ignite/spi/failover/always/AlwaysFailoverSpi.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/spi/failover/always/AlwaysFailoverSpi.java
index 0a360be,0a360be..b60e71b
--- a/modules/core/src/main/java/org/apache/ignite/spi/failover/always/AlwaysFailoverSpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/failover/always/AlwaysFailoverSpi.java
@@@ -226,7 -226,7 +226,7 @@@ public class AlwaysFailoverSpi extends 
  
              return node;
          }
--        catch (IgniteCheckedException e) {
++        catch (IgniteException e) {
              U.error(log, "Failed to get next balanced node for failover: " + ctx, e);
  
              return null;

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/main/java/org/apache/ignite/spi/failover/jobstealing/JobStealingFailoverSpi.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/spi/failover/jobstealing/JobStealingFailoverSpi.java
index 4caa960,4caa960..8d79080
--- a/modules/core/src/main/java/org/apache/ignite/spi/failover/jobstealing/JobStealingFailoverSpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/failover/jobstealing/JobStealingFailoverSpi.java
@@@ -331,7 -331,7 +331,7 @@@ public class JobStealingFailoverSpi ext
  
              return thief;
          }
--        catch (IgniteCheckedException e) {
++        catch (IgniteException e) {
              U.error(log, "Failed to get next balanced node for failover: " + ctx, e);
  
              return null;

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/LoadBalancingSpi.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/LoadBalancingSpi.java
index a3fd272,a3fd272..9897ca3
--- a/modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/LoadBalancingSpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/LoadBalancingSpi.java
@@@ -115,8 -115,8 +115,8 @@@ public interface LoadBalancingSpi exten
       * @param ses Grid task session for currently executing task.
       * @param top Topology of task nodes from which to pick the best balanced node for given job.
       * @param job Job for which to pick the best balanced node.
--     * @throws IgniteCheckedException If failed to get next balanced node.
++     * @throws IgniteException If failed to get next balanced node.
       * @return Best balanced node for the given job within given task session.
       */
--    public ClusterNode getBalancedNode(ComputeTaskSession ses, List<ClusterNode> top, ComputeJob job) throws IgniteCheckedException;
++    public ClusterNode getBalancedNode(ComputeTaskSession ses, List<ClusterNode> top, ComputeJob job) throws IgniteException;
  }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/adaptive/AdaptiveLoadBalancingSpi.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/adaptive/AdaptiveLoadBalancingSpi.java
index 82252dc,82252dc..947e845
--- a/modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/adaptive/AdaptiveLoadBalancingSpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/adaptive/AdaptiveLoadBalancingSpi.java
@@@ -413,8 -413,8 +413,7 @@@ public class AdaptiveLoadBalancingSpi e
      }
  
      /** {@inheritDoc} */
--    @Override public ClusterNode getBalancedNode(ComputeTaskSession ses, List<ClusterNode> top, ComputeJob job)
--    throws IgniteCheckedException {
++    @Override public ClusterNode getBalancedNode(ComputeTaskSession ses, List<ClusterNode> top, ComputeJob job) {
          A.notNull(ses, "ses");
          A.notNull(top, "top");
          A.notNull(job, "job");
@@@ -440,10 -440,10 +439,10 @@@
       * @param top List of all nodes.
       * @param node Node to get load for.
       * @return Node load.
--     * @throws IgniteCheckedException If returned load is negative.
++     * @throws IgniteException If returned load is negative.
       */
      @SuppressWarnings({"TooBroadScope"})
--    private double getLoad(Collection<ClusterNode> top, ClusterNode node) throws IgniteCheckedException {
++    private double getLoad(Collection<ClusterNode> top, ClusterNode node) throws IgniteException {
          assert !F.isEmpty(top);
  
          int jobsSentSinceLastUpdate = 0;
@@@ -462,7 -462,7 +461,7 @@@
          double load = probe.getLoad(node, jobsSentSinceLastUpdate);
  
          if (load < 0)
--            throw new IgniteCheckedException("Failed to obtain non-negative load from adaptive load probe: " + load);
++            throw new IgniteException("Failed to obtain non-negative load from adaptive load probe: " + load);
  
          return load;
      }
@@@ -478,7 -478,7 +477,7 @@@
           * @param top Task topology.
           * @throws IgniteCheckedException If any load was negative.
           */
--        WeightedTopology(List<ClusterNode> top) throws IgniteCheckedException {
++        WeightedTopology(List<ClusterNode> top) throws IgniteException {
              assert !F.isEmpty(top);
  
              double totalLoad = 0;

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/roundrobin/RoundRobinGlobalLoadBalancer.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/roundrobin/RoundRobinGlobalLoadBalancer.java
index 2e8b799,2e8b799..d5afbd9
--- a/modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/roundrobin/RoundRobinGlobalLoadBalancer.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/roundrobin/RoundRobinGlobalLoadBalancer.java
@@@ -138,7 -138,7 +138,7 @@@ class RoundRobinGlobalLoadBalancer 
       * @return Best balanced node.
       * @throws IgniteCheckedException Thrown in case of any error.
       */
--    ClusterNode getBalancedNode(Collection<ClusterNode> top) throws IgniteCheckedException {
++    ClusterNode getBalancedNode(Collection<ClusterNode> top) throws IgniteException {
          assert !F.isEmpty(top);
  
          awaitInitializationCompleted();
@@@ -157,7 -157,7 +157,7 @@@
              int cycleSize = nodes.size();
  
              if (cycleSize == 0)
--                throw new IgniteCheckedException("Task topology does not have any alive nodes.");
++                throw new IgniteException("Task topology does not have any alive nodes.");
  
              AtomicInteger idx;
  
@@@ -224,10 -224,10 +224,12 @@@
       * @param top Topology for current request.
       * @param topMap Topology map.
       * @param nodes Current balanced nodes.
--     * @throws IgniteCheckedException If balancer can not return any node.
++     * @throws IgniteException If balancer can not return any node.
       */
--    private static void checkBalancerNodes(Collection<ClusterNode> top, Map<UUID, ClusterNode> topMap, Iterable<UUID> nodes)
--        throws IgniteCheckedException {
++    private static void checkBalancerNodes(Collection<ClusterNode> top,
++        Map<UUID, ClusterNode> topMap,
++        Iterable<UUID> nodes)
++        throws IgniteException {
  
          boolean contains = false;
  
@@@ -240,15 -240,15 +242,15 @@@
          }
  
          if (!contains)
--            throw new IgniteCheckedException("Task topology does not have alive nodes: " + top);
++            throw new IgniteException("Task topology does not have alive nodes: " + top);
      }
  
      /**
       * Awaits initialization of balancing nodes to be completed.
       *
--     * @throws IgniteCheckedException Thrown in case of thread interruption.
++     * @throws IgniteException Thrown in case of thread interruption.
       */
--    private void awaitInitializationCompleted() throws IgniteCheckedException {
++    private void awaitInitializationCompleted() throws IgniteException {
          try {
              if (initLatch.getCount() > 0)
                  initLatch.await();
@@@ -256,7 -256,7 +258,7 @@@
          catch (InterruptedException e) {
              Thread.currentThread().interrupt();
  
--            throw new IgniteCheckedException("Global balancer was interrupted.", e);
++            throw new IgniteException("Global balancer was interrupted.", e);
          }
      }
  

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/roundrobin/RoundRobinLoadBalancingSpi.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/roundrobin/RoundRobinLoadBalancingSpi.java
index 28aaece,28aaece..5a3ed35
--- a/modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/roundrobin/RoundRobinLoadBalancingSpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/roundrobin/RoundRobinLoadBalancingSpi.java
@@@ -276,8 -276,8 +276,7 @@@ public class RoundRobinLoadBalancingSp
      }
  
      /** {@inheritDoc} */
--    @Override public ClusterNode getBalancedNode(ComputeTaskSession ses, List<ClusterNode> top, ComputeJob job)
--        throws IgniteCheckedException {
++    @Override public ClusterNode getBalancedNode(ComputeTaskSession ses, List<ClusterNode> top, ComputeJob job) {
          A.notNull(ses, "ses", top, "top");
  
          if (isPerTask) {

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/main/java/org/apache/ignite/spi/securesession/SecureSessionSpi.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/spi/securesession/SecureSessionSpi.java
index f2574f0,f2574f0..825cd29
--- a/modules/core/src/main/java/org/apache/ignite/spi/securesession/SecureSessionSpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/securesession/SecureSessionSpi.java
@@@ -73,7 -73,7 +73,7 @@@ public interface SecureSessionSpi exten
       * @param tok Token to validate.
       * @param params Additional implementation-specific parameters.
       * @return {@code True} if session token is valid, {@code false} otherwise.
--     * @throws org.apache.ignite.spi.IgniteSpiException If validation resulted in system error. Note that
++     * @throws IgniteSpiException If validation resulted in system error. Note that
       *      bad credentials should not cause this exception.
       */
      public boolean validate(GridSecuritySubjectType subjType, UUID subjId, byte[] tok,

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/main/java/org/apache/ignite/streamer/StreamerContext.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/streamer/StreamerContext.java
index 29e36f7,29e36f7..7ce4cce
--- a/modules/core/src/main/java/org/apache/ignite/streamer/StreamerContext.java
+++ b/modules/core/src/main/java/org/apache/ignite/streamer/StreamerContext.java
@@@ -75,9 -75,9 +75,9 @@@ public interface StreamerContext 
       *
       * @param clo Function to be executed on individual nodes.
       * @return Result received from all streamers.
--     * @throws IgniteCheckedException If query execution failed.
++     * @throws IgniteException If query execution failed.
       */
--    public <R> Collection<R> query(IgniteClosure<StreamerContext, R> clo) throws IgniteCheckedException;
++    public <R> Collection<R> query(IgniteClosure<StreamerContext, R> clo) throws IgniteException;
  
      /**
       * Queries streamer nodes deployed within grid. Given closure will be executed on those of passed nodes
@@@ -88,19 -88,19 +88,19 @@@
       * @param nodes Optional list of nodes to execute query on, if empty, then all nodes on
       *      which this streamer is running will be queried.
       * @return Result received from all streamers.
--     * @throws IgniteCheckedException If query execution failed.
++     * @throws IgniteException If query execution failed.
       */
      public <R> Collection<R> query(IgniteClosure<StreamerContext, R> clo, Collection<ClusterNode> nodes)
--        throws IgniteCheckedException;
++        throws IgniteException;
  
      /**
       * Queries all streamer nodes deployed within grid. Given closure will be executed on each streamer node
       * in the grid. No result is collected.
       *
       * @param clo Function to be executed on individual nodes.
--     * @throws IgniteCheckedException If closure execution failed.
++     * @throws IgniteException If closure execution failed.
       */
--    public void broadcast(IgniteInClosure<StreamerContext> clo) throws IgniteCheckedException;
++    public void broadcast(IgniteInClosure<StreamerContext> clo) throws IgniteException;
  
      /**
       * Queries streamer nodes deployed within grid. Given closure will be executed on those of passed nodes on
@@@ -109,9 -109,9 +109,9 @@@
       * @param clo Function to be executed on individual nodes.
       * @param nodes Optional list of nodes to execute query on, if empty, then all nodes on
       *      which this streamer is running will be queried.
--     * @throws IgniteCheckedException If closure execution failed.
++     * @throws IgniteException If closure execution failed.
       */
--    public void broadcast(IgniteInClosure<StreamerContext> clo, Collection<ClusterNode> nodes) throws IgniteCheckedException;
++    public void broadcast(IgniteInClosure<StreamerContext> clo, Collection<ClusterNode> nodes) throws IgniteException;
  
      /**
       * Queries all streamer nodes deployed within grid. Given closure will be executed on each streamer node in
@@@ -121,9 -121,9 +121,9 @@@
       * @param clo Function to be executed on individual nodes.
       * @param rdc Reducer to reduce results received from remote nodes.
       * @return Reducer result.
--     * @throws IgniteCheckedException If query execution failed.
++     * @throws IgniteException If query execution failed.
       */
--    public <R1, R2> R2 reduce(IgniteClosure<StreamerContext, R1> clo, IgniteReducer<R1, R2> rdc) throws IgniteCheckedException;
++    public <R1, R2> R2 reduce(IgniteClosure<StreamerContext, R1> clo, IgniteReducer<R1, R2> rdc) throws IgniteException;
  
      /**
       * Queries streamer nodes deployed within grid. Given closure will be executed on those of passed nodes on which
@@@ -135,8 -135,8 +135,8 @@@
       * @param nodes Optional list of nodes to execute query on, if empty, then all nodes on
       *      which this streamer is running will be queried.
       * @return Reducer result.
--     * @throws IgniteCheckedException If query execution failed.
++     * @throws IgniteException If query execution failed.
       */
      public <R1, R2> R2 reduce(IgniteClosure<StreamerContext, R1> clo, IgniteReducer<R1, R2> rdc,
--        Collection<ClusterNode> nodes) throws IgniteCheckedException;
++        Collection<ClusterNode> nodes) throws IgniteException;
  }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/main/java/org/apache/ignite/streamer/StreamerStage.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/streamer/StreamerStage.java
index 7efb289,7efb289..4690be3
--- a/modules/core/src/main/java/org/apache/ignite/streamer/StreamerStage.java
+++ b/modules/core/src/main/java/org/apache/ignite/streamer/StreamerStage.java
@@@ -54,8 -54,8 +54,8 @@@ public interface StreamerStage<IN> 
       * @param ctx Streamer context.
       * @param evts Input events.
       * @return Map of stage name to collection of events.
--     * @throws IgniteCheckedException If failed.
++     * @throws IgniteException If failed.
       */
      @Nullable public Map<String, Collection<?>> run(StreamerContext ctx, Collection<IN> evts)
--        throws IgniteCheckedException;
++        throws IgniteException;
  }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/main/java/org/apache/ignite/streamer/StreamerWindow.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/streamer/StreamerWindow.java
index 217ff6d,217ff6d..ae9e778
--- a/modules/core/src/main/java/org/apache/ignite/streamer/StreamerWindow.java
+++ b/modules/core/src/main/java/org/apache/ignite/streamer/StreamerWindow.java
@@@ -103,18 -103,18 +103,18 @@@ public interface StreamerWindow<E> exte
       *
       * @param evt Event to add.
       * @return {@code True} if event was added.
--     * @throws IgniteCheckedException If index update failed.
++     * @throws IgniteException If index update failed.
       */
--    public boolean enqueue(E evt) throws IgniteCheckedException;
++    public boolean enqueue(E evt) throws IgniteException;
  
      /**
       * Adds events to window.
       *
       * @param evts Events to add.
       * @return {@code}
--     * @throws IgniteCheckedException If index update failed.
++     * @throws IgniteException If index update failed.
       */
--    public boolean enqueue(E... evts) throws IgniteCheckedException;
++    public boolean enqueue(E... evts) throws IgniteException;
  
      /**
       * Adds all events to window.
@@@ -122,17 -122,17 +122,17 @@@
       * @param evts Collection of events to add.
       * @return {@code True} if all events were added, {@code false} if at
       *      least 1 event was skipped.
--     * @throws IgniteCheckedException If index update failed.
++     * @throws IgniteException If index update failed.
       */
--    public boolean enqueueAll(Collection<E> evts) throws IgniteCheckedException;
++    public boolean enqueueAll(Collection<E> evts) throws IgniteException;
  
      /**
       * Dequeues last element from windows. Will return {@code null} if window is empty.
       *
       * @return Dequeued element.
--     * @throws IgniteCheckedException If index update failed.
++     * @throws IgniteException If index update failed.
       */
--    @Nullable public E dequeue() throws IgniteCheckedException;
++    @Nullable public E dequeue() throws IgniteException;
  
      /**
       * Dequeues up to {@code cnt} elements from window. If current window size is less than {@code cnt},
@@@ -140,35 -140,35 +140,35 @@@
       *
       * @param cnt Count to dequeue.
       * @return Collection of dequeued elements.
--     * @throws IgniteCheckedException If index update failed.
++     * @throws IgniteException If index update failed.
       */
--    public Collection<E> dequeue(int cnt) throws IgniteCheckedException;
++    public Collection<E> dequeue(int cnt) throws IgniteException;
  
      /**
       * Dequeues all elements from window.
       *
       * @return Collection of dequeued elements.
--     * @throws IgniteCheckedException If index update failed.
++     * @throws IgniteException If index update failed.
       */
--    public Collection<E> dequeueAll() throws IgniteCheckedException;
++    public Collection<E> dequeueAll() throws IgniteException;
  
      /**
       * If window supports eviction, this method will return next evicted element.
       *
       * @return Polls and returns next evicted event or {@code null} if eviction queue is empty or if
       *      window does not support eviction.
--     * @throws IgniteCheckedException If index update failed.
++     * @throws IgniteException If index update failed.
       */
--    @Nullable public E pollEvicted() throws IgniteCheckedException;
++    @Nullable public E pollEvicted() throws IgniteException;
  
      /**
       * If window supports eviction, this method will return up to {@code cnt} evicted elements.
       *
       * @param cnt Number of elements to evict.
       * @return Collection of evicted elements.
--     * @throws IgniteCheckedException If index update failed.
++     * @throws IgniteException If index update failed.
       */
--    public Collection<E> pollEvicted(int cnt) throws IgniteCheckedException;
++    public Collection<E> pollEvicted(int cnt) throws IgniteException;
  
      /**
       * If window supports batch eviction, this method will poll next evicted batch from window.
@@@ -177,24 -177,24 +177,24 @@@
       * If window does not support eviction, will return empty collection.
       *
       * @return Next evicted batch.
--     * @throws IgniteCheckedException If index update failed.
++     * @throws IgniteException If index update failed.
       */
--    public Collection<E> pollEvictedBatch() throws IgniteCheckedException;
++    public Collection<E> pollEvictedBatch() throws IgniteException;
  
      /**
       * If window supports eviction, this method will return all available evicted elements.
       *
       * @return Collection of evicted elements.
--     * @throws IgniteCheckedException If index update failed.
++     * @throws IgniteException If index update failed.
       */
--    public Collection<E> pollEvictedAll() throws IgniteCheckedException;
++    public Collection<E> pollEvictedAll() throws IgniteException;
  
      /**
       * Clears all evicted entries.
       *
--     * @throws IgniteCheckedException If index update failed.
++     * @throws IgniteException If index update failed.
       */
--    public void clearEvicted() throws IgniteCheckedException;
++    public void clearEvicted() throws IgniteException;
  
      /**
       * Create window snapshot. Evicted entries are not included.

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/main/java/org/apache/ignite/streamer/index/StreamerIndexProvider.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/streamer/index/StreamerIndexProvider.java
index 045c9b0,045c9b0..e510985
--- a/modules/core/src/main/java/org/apache/ignite/streamer/index/StreamerIndexProvider.java
+++ b/modules/core/src/main/java/org/apache/ignite/streamer/index/StreamerIndexProvider.java
@@@ -63,18 -63,18 +63,18 @@@ public interface StreamerIndexProvider<
       *
       * @param sync Index update synchronizer.
       * @param evt Event to add to an index.
--     * @throws IgniteCheckedException If failed to add event to an index.
++     * @throws IgniteException If failed to add event to an index.
       */
--    public void add(StreamerIndexUpdateSync sync, E evt) throws IgniteCheckedException;
++    public void add(StreamerIndexUpdateSync sync, E evt) throws IgniteException;
  
      /**
       * Removes an event from index.
       *
       * @param sync Index update synchronizer.
       * @param evt Event to remove from index.
--     * @throws IgniteCheckedException If failed to add event to an index.
++     * @throws IgniteException If failed to add event to an index.
       */
--    public void remove(StreamerIndexUpdateSync sync, E evt) throws IgniteCheckedException;
++    public void remove(StreamerIndexUpdateSync sync, E evt) throws IgniteException;
  
      /**
       * Gets event indexing policy, which defines how events

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/main/java/org/apache/ignite/streamer/index/StreamerIndexProviderAdapter.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/streamer/index/StreamerIndexProviderAdapter.java
index 7e4d2f1,7e4d2f1..da04acf
--- a/modules/core/src/main/java/org/apache/ignite/streamer/index/StreamerIndexProviderAdapter.java
+++ b/modules/core/src/main/java/org/apache/ignite/streamer/index/StreamerIndexProviderAdapter.java
@@@ -154,7 -154,7 +154,7 @@@ public abstract class StreamerIndexProv
       * @param sync Sync.
       * @param evt Event.
       */
--    @Override public void add(StreamerIndexUpdateSync sync, E evt) throws IgniteCheckedException {
++    @Override public void add(StreamerIndexUpdateSync sync, E evt) {
          assert evt != null;
  
          if (threadLocKey.get() != null)
@@@ -182,7 -182,7 +182,7 @@@
       * @param sync Sync.
       * @param evt Event.
       */
--    @Override public void remove(StreamerIndexUpdateSync sync, E evt) throws IgniteCheckedException {
++    @Override public void remove(StreamerIndexUpdateSync sync, E evt) {
          assert evt != null;
  
          if (threadLocKey.get() != null)
@@@ -309,9 -309,9 +309,9 @@@
       * @param evt Event.
       * @param key key.
       * @param sync Sync.
--     * @throws IgniteCheckedException If failed.
++     * @throws IgniteException If failed.
       */
--    protected abstract void add(E evt, K key, StreamerIndexUpdateSync sync) throws IgniteCheckedException;
++    protected abstract void add(E evt, K key, StreamerIndexUpdateSync sync) throws IgniteException;
  
      /**
       * Remove event from the index.
@@@ -319,18 -319,18 +319,18 @@@
       * @param evt Event.
       * @param key Key.
       * @param sync Sync.
--     * @throws IgniteCheckedException If failed.
++     * @throws IgniteException If failed.
       */
--    protected abstract void remove(E evt, K key, StreamerIndexUpdateSync sync) throws IgniteCheckedException;
++    protected abstract void remove(E evt, K key, StreamerIndexUpdateSync sync) throws IgniteException;
  
      /**
       * Lock updates on particular key.
       *
       * @param key Key.
       * @param sync Sync.
--     * @throws IgniteCheckedException If failed.
++     * @throws IgniteException If failed.
       */
--    private void lockKey(K key, StreamerIndexUpdateSync sync) throws IgniteCheckedException {
++    private void lockKey(K key, StreamerIndexUpdateSync sync) throws IgniteException {
          assert key != null;
          assert sync != null;
  
@@@ -342,7 -342,7 +342,7 @@@
                      old.await();
                  }
                  catch (InterruptedException e) {
--                    throw new IgniteCheckedException("Failed to lock on key (thread has been interrupted): " + key, e);
++                    throw new IgniteException("Failed to lock on key (thread has been interrupted): " + key, e);
                  }
  
                  // No point to replace or remove sync here.
@@@ -370,9 -370,9 +370,9 @@@
       *
       * @param key Key.
       * @param sync Sync.
--     * @throws IgniteCheckedException If failed.
++     * @throws IgniteException If failed.
       */
--    protected void lockIndexKey(IndexKey<V> key, StreamerIndexUpdateSync sync) throws IgniteCheckedException {
++    protected void lockIndexKey(IndexKey<V> key, StreamerIndexUpdateSync sync) throws IgniteException {
          assert key != null;
          assert sync != null;
          assert isUnique();
@@@ -385,7 -385,7 +385,7 @@@
                      old.await();
                  }
                  catch (InterruptedException e) {
--                    throw new IgniteCheckedException("Failed to lock on key (thread has been interrupted): " + key, e);
++                    throw new IgniteException("Failed to lock on key (thread has been interrupted): " + key, e);
                  }
  
                  // No point to replace or remove sync here.

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/main/java/org/apache/ignite/streamer/index/StreamerIndexUpdater.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/streamer/index/StreamerIndexUpdater.java
index 4435e2f,4435e2f..ebb3a97
--- a/modules/core/src/main/java/org/apache/ignite/streamer/index/StreamerIndexUpdater.java
+++ b/modules/core/src/main/java/org/apache/ignite/streamer/index/StreamerIndexUpdater.java
@@@ -64,9 -64,9 +64,9 @@@ public interface StreamerIndexUpdater<E
       * @param evt New event.
       * @return New index value for given key, if {@code null}, then current
       *      index entry will be removed the index.
--     * @throws IgniteCheckedException If entry should not be added to index (e.g. if uniqueness is violated).
++     * @throws IgniteException If entry should not be added to index (e.g. if uniqueness is violated).
       */
--    @Nullable public V onAdded(StreamerIndexEntry<E, K, V> entry, E evt) throws IgniteCheckedException;
++    @Nullable public V onAdded(StreamerIndexEntry<E, K, V> entry, E evt) throws IgniteException;
  
      /**
       * Callback invoked whenever an event is being removed from the window and has

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/main/java/org/apache/ignite/streamer/index/hash/StreamerHashIndexProvider.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/streamer/index/hash/StreamerHashIndexProvider.java
index 188de27,188de27..eafa582
--- a/modules/core/src/main/java/org/apache/ignite/streamer/index/hash/StreamerHashIndexProvider.java
+++ b/modules/core/src/main/java/org/apache/ignite/streamer/index/hash/StreamerHashIndexProvider.java
@@@ -65,7 -65,7 +65,7 @@@ public class StreamerHashIndexProvider<
      }
  
      /** {@inheritDoc} */
--    @Override protected void add(E evt, K key, StreamerIndexUpdateSync sync) throws IgniteCheckedException {
++    @Override protected void add(E evt, K key, StreamerIndexUpdateSync sync) {
          State<E, K, V> state0 = state.get();
  
          if (state0 != null)
@@@ -100,7 -100,7 +100,7 @@@
          }
          else {
              if (isUnique())
--                throw new IgniteCheckedException("Index unique key violation [evt=" + evt + ", key=" + key + ']');
++                throw new IgniteException("Index unique key violation [evt=" + evt + ", key=" + key + ']');
  
              V val = updater.onAdded(oldEntry, evt);
  
@@@ -130,7 -130,7 +130,7 @@@
      }
  
      /** {@inheritDoc} */
--    @Override protected void remove(E evt, K key, StreamerIndexUpdateSync sync) throws IgniteCheckedException {
++    @Override protected void remove(E evt, K key, StreamerIndexUpdateSync sync) {
          State<E, K, V> state0 = state.get();
  
          if (state0 != null)

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/main/java/org/apache/ignite/streamer/index/tree/StreamerTreeIndexProvider.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/streamer/index/tree/StreamerTreeIndexProvider.java
index b7a64e0,b7a64e0..70ba5a8
--- a/modules/core/src/main/java/org/apache/ignite/streamer/index/tree/StreamerTreeIndexProvider.java
+++ b/modules/core/src/main/java/org/apache/ignite/streamer/index/tree/StreamerTreeIndexProvider.java
@@@ -101,7 -101,7 +101,7 @@@ public class StreamerTreeIndexProvider<
      }
  
      /** {@inheritDoc} */
--    @Override protected void add(E evt, K key, StreamerIndexUpdateSync sync) throws IgniteCheckedException {
++    @Override protected void add(E evt, K key, StreamerIndexUpdateSync sync) {
          State<E, K, V> state0 = state.get();
  
          if (state0 != null)
@@@ -137,7 -137,7 +137,7 @@@
  
              if (isUnique()) {
                  if (old != null)
--                    throw new IgniteCheckedException("Index unique key violation [evt=" + evt + ", key=" + key +
++                    throw new IgniteException("Index unique key violation [evt=" + evt + ", key=" + key +
                          ", idxKey=" + idxKey + ']');
              }
              else
@@@ -198,7 -198,7 +198,7 @@@
  
                  if (isUnique()) {
                      if (old != null)
--                        throw new IgniteCheckedException("Index unique key violation [evt=" + evt + ", key=" + key +
++                        throw new IgniteException("Index unique key violation [evt=" + evt + ", key=" + key +
                              ", idxKey=" + newIdxKey + ']');
                  }
                  else
@@@ -220,7 -220,7 +220,7 @@@
      }
  
      /** {@inheritDoc} */
--    @Override protected void remove(E evt, K key, StreamerIndexUpdateSync sync) throws IgniteCheckedException {
++    @Override protected void remove(E evt, K key, StreamerIndexUpdateSync sync) {
          State<E, K, V> state0 = state.get();
  
          if (state0 != null)
@@@ -293,7 -293,7 +293,7 @@@
  
                  if (isUnique()) {
                      if (old != null)
--                        throw new IgniteCheckedException("Index unique key violation [evt=" + evt + ", key=" + key +
++                        throw new IgniteException("Index unique key violation [evt=" + evt + ", key=" + key +
                              ", idxKey=" + newIdxKey + ']');
                  }
                  else
@@@ -318,10 -318,10 +318,10 @@@
       * @param key2 Key.
       * @param order Keys comparison result.
       * @param sync Sync.
--     * @throws IgniteCheckedException If interrupted.
++     * @throws IgniteException If interrupted.
       */
      private void lockKeys(IndexKey<V> key1, IndexKey<V> key2, int order, StreamerIndexUpdateSync sync)
--        throws IgniteCheckedException {
++        throws IgniteException {
          assert isUnique();
          assert key1 != null;
          assert key2 != null;

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/main/java/org/apache/ignite/streamer/window/StreamerWindowAdapter.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/streamer/window/StreamerWindowAdapter.java
index 18337e4,18337e4..3448f39
--- a/modules/core/src/main/java/org/apache/ignite/streamer/window/StreamerWindowAdapter.java
+++ b/modules/core/src/main/java/org/apache/ignite/streamer/window/StreamerWindowAdapter.java
@@@ -89,7 -89,7 +89,7 @@@ public abstract class StreamerWindowAda
      protected abstract GridStreamerWindowIterator<E> iterator0();
  
      /** {@inheritDoc} */
--    @Override public boolean enqueue(E evt) throws IgniteCheckedException {
++    @Override public boolean enqueue(E evt) {
          lock.readLock();
  
          try {
@@@ -110,12 -110,12 +110,12 @@@
      }
  
      /** {@inheritDoc} */
--    @Override public boolean enqueue(E... evts) throws IgniteCheckedException {
++    @Override public boolean enqueue(E... evts) {
          return enqueueAll(Arrays.asList(evts));
      }
  
      /** {@inheritDoc} */
--    @Override public boolean enqueueAll(Collection<E> evts) throws IgniteCheckedException {
++    @Override public boolean enqueueAll(Collection<E> evts) {
          lock.readLock();
  
          try {
@@@ -152,17 -152,17 +152,17 @@@
      protected abstract boolean enqueue0(E evt);
  
      /** {@inheritDoc} */
--    @Override public E dequeue() throws IgniteCheckedException {
++    @Override public E dequeue() {
          return F.first(dequeue(1));
      }
  
      /** {@inheritDoc} */
--    @Override public Collection<E> dequeueAll() throws IgniteCheckedException {
++    @Override public Collection<E> dequeueAll() {
          return dequeue(size());
      }
  
      /** {@inheritDoc} */
--    @Override public Collection<E> dequeue(int cnt) throws IgniteCheckedException {
++    @Override public Collection<E> dequeue(int cnt) {
          lock.readLock();
  
          try {
@@@ -190,17 -190,17 +190,17 @@@
      protected abstract Collection<E> dequeue0(int cnt);
  
      /** {@inheritDoc} */
--    @Override public E pollEvicted() throws IgniteCheckedException {
++    @Override public E pollEvicted() {
          return F.first(pollEvicted(1));
      }
  
      /** {@inheritDoc} */
--    @Override public Collection<E> pollEvictedAll() throws IgniteCheckedException {
++    @Override public Collection<E> pollEvictedAll() {
          return pollEvicted(evictionQueueSize());
      }
  
      /** {@inheritDoc} */
--    @Override public Collection<E> pollEvicted(int cnt) throws IgniteCheckedException {
++    @Override public Collection<E> pollEvicted(int cnt) {
          lock.readLock();
  
          try {
@@@ -227,7 -227,7 +227,7 @@@
      protected abstract Collection<E> pollEvicted0(int cnt);
  
      /** {@inheritDoc} */
--    @Override public Collection<E> pollEvictedBatch() throws IgniteCheckedException {
++    @Override public Collection<E> pollEvictedBatch() {
          lock.readLock();
  
          try {
@@@ -434,7 -434,7 +434,7 @@@
      }
  
      /** {@inheritDoc} */
--    @Override public void clearEvicted() throws IgniteCheckedException {
++    @Override public void clearEvicted() {
          pollEvictedAll();
      }
  
@@@ -443,9 -443,9 +443,9 @@@
       *
       * @param evt Event.
       * @param rmv Remove flag.
--     * @throws IgniteCheckedException If index update failed.
++     * @throws IgniteException If index update failed.
       */
--    protected void updateIndexes(E evt, boolean rmv) throws IgniteCheckedException {
++    protected void updateIndexes(E evt, boolean rmv) throws IgniteException {
          if (idxs != null) {
              StreamerIndexUpdateSync sync = new StreamerIndexUpdateSync();
  
@@@ -524,8 -524,8 +524,8 @@@
                      try {
                          updateIndexes(evt, true);
                      }
--                    catch (IgniteCheckedException e) {
--                        throw new IgniteException("Faied to remove event: " + evt, e);
++                    catch (IgniteException e) {
++                        throw new IgniteException("Failed to remove event: " + evt, e);
                       }
                  }
              }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/test/java/org/apache/ignite/GridTestJob.java
----------------------------------------------------------------------
diff --cc modules/core/src/test/java/org/apache/ignite/GridTestJob.java
index 549faa5,549faa5..a5fd4cc
--- a/modules/core/src/test/java/org/apache/ignite/GridTestJob.java
+++ b/modules/core/src/test/java/org/apache/ignite/GridTestJob.java
@@@ -42,7 -42,7 +42,7 @@@ public class GridTestJob extends Comput
      }
  
      /** {@inheritDoc} */
--    @Override public String execute() throws IgniteCheckedException {
++    @Override public String execute() {
          if (log.isDebugEnabled())
              log.debug("Executing job [job=" + this + ", arg=" + argument(0) + ']');
  

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/test/java/org/apache/ignite/GridTestJobResult.java
----------------------------------------------------------------------
diff --cc modules/core/src/test/java/org/apache/ignite/GridTestJobResult.java
index 98929ab,98929ab..74c18e8
--- a/modules/core/src/test/java/org/apache/ignite/GridTestJobResult.java
+++ b/modules/core/src/test/java/org/apache/ignite/GridTestJobResult.java
@@@ -30,7 -30,7 +30,7 @@@ public class GridTestJobResult implemen
      private final Serializable data;
  
      /** */
--    private final IgniteCheckedException e;
++    private final IgniteException e;
  
      /** */
      private final ComputeJob job;
@@@ -57,7 -57,7 +57,11 @@@
       * @param node Grid node.
       * @param jobCtx Job context.
       */
--    public GridTestJobResult(Serializable data, IgniteCheckedException e, ComputeJob job, ClusterNode node, ComputeJobContext jobCtx) {
++    public GridTestJobResult(Serializable data,
++        IgniteException e,
++        ComputeJob job,
++        ClusterNode node,
++        ComputeJobContext jobCtx) {
          this.data = data;
          this.e = e;
          this.job = job;
@@@ -79,7 -79,7 +83,7 @@@
  
      /** {@inheritDoc} */ @Override public Serializable getData() { return data; }
  
--    /** {@inheritDoc} */ @Override public IgniteCheckedException getException() { return e; }
++    /** {@inheritDoc} */ @Override public IgniteException getException() { return e; }
  
      /** {@inheritDoc} */ @Override public boolean isCancelled() { return false; }
  

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/test/java/org/apache/ignite/GridTestTask.java
----------------------------------------------------------------------
diff --cc modules/core/src/test/java/org/apache/ignite/GridTestTask.java
index a7a8cbc,a7a8cbc..6ae2505
--- a/modules/core/src/test/java/org/apache/ignite/GridTestTask.java
+++ b/modules/core/src/test/java/org/apache/ignite/GridTestTask.java
@@@ -44,7 -44,7 +44,7 @@@ public class GridTestTask extends Compu
      }
  
      /** {@inheritDoc} */
--    @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException {
++    @Override public Object reduce(List<ComputeJobResult> results) {
          if (log.isDebugEnabled())
              log.debug("Reducing task [task=" + this + ", results=" + results + ']');
  

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/test/java/org/apache/ignite/GridTestTaskSession.java
----------------------------------------------------------------------
diff --cc modules/core/src/test/java/org/apache/ignite/GridTestTaskSession.java
index b1b0825,b1b0825..5147b3d
--- a/modules/core/src/test/java/org/apache/ignite/GridTestTaskSession.java
+++ b/modules/core/src/test/java/org/apache/ignite/GridTestTaskSession.java
@@@ -172,31 -172,31 +172,30 @@@ public class GridTestTaskSession implem
      }
  
      /** {@inheritDoc} */
--    @Override public void saveCheckpoint(String key, Object state) throws IgniteCheckedException {
++    @Override public void saveCheckpoint(String key, Object state) {
          assert false : "Not implemented";
      }
  
      /** {@inheritDoc} */
--    @Override public void saveCheckpoint(String key, Object state, ComputeTaskSessionScope scope, long timeout)
--        throws IgniteCheckedException {
++    @Override public void saveCheckpoint(String key, Object state, ComputeTaskSessionScope scope, long timeout) {
          assert false : "Not implemented";
      }
  
      /** {@inheritDoc} */
      @Override public void saveCheckpoint(String key, Object state, ComputeTaskSessionScope scope, long timeout,
--        boolean overwrite) throws IgniteCheckedException {
++        boolean overwrite) {
          assert false : "Not implemented";
      }
  
      /** {@inheritDoc} */
--    @Override public <T> T loadCheckpoint(String key) throws IgniteCheckedException {
++    @Override public <T> T loadCheckpoint(String key) {
          assert false : "Not implemented";
  
          return null;
      }
  
      /** {@inheritDoc} */
--    @Override public boolean removeCheckpoint(String key) throws IgniteCheckedException {
++    @Override public boolean removeCheckpoint(String key) {
          assert false : "Not implemented";
  
          return false;

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/test/java/org/apache/ignite/fs/GridGgfsEventsAbstractSelfTest.java
----------------------------------------------------------------------
diff --cc modules/core/src/test/java/org/apache/ignite/fs/GridGgfsEventsAbstractSelfTest.java
index c96ad41,c96ad41..a7821de
--- a/modules/core/src/test/java/org/apache/ignite/fs/GridGgfsEventsAbstractSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/fs/GridGgfsEventsAbstractSelfTest.java
@@@ -516,7 -516,7 +516,7 @@@ public abstract class GridGgfsEventsAbs
          try {
              ggfs.delete(dir.parent(), false); // Will generate no events.
          }
--        catch (IgniteCheckedException ignore) {
++        catch (IgniteException ignore) {
              // No-op.
          }
  

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/test/java/org/apache/ignite/internal/GridAlwaysFailoverSpiFailSelfTest.java
----------------------------------------------------------------------
diff --cc modules/core/src/test/java/org/apache/ignite/internal/GridAlwaysFailoverSpiFailSelfTest.java
index 2c235c1,2c235c1..c7103b7
--- a/modules/core/src/test/java/org/apache/ignite/internal/GridAlwaysFailoverSpiFailSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/GridAlwaysFailoverSpiFailSelfTest.java
@@@ -68,7 -68,7 +68,7 @@@ public class GridAlwaysFailoverSpiFailS
  
              assert false;
          }
--        catch (IgniteCheckedException e) {
++        catch (IgniteException e) {
              //No-op
          }
  
@@@ -88,11 -88,11 +88,11 @@@
  
          try {
              ignite.compute().execute(GridTestFailoverTask.class.getName(),
--                new IgniteCheckedException("Task should NOT be failed over"));
++                new IgniteException("Task should NOT be failed over"));
  
              assert false;
          }
--        catch (IgniteCheckedException e) {
++        catch (IgniteException e) {
              //No-op
          }
  
@@@ -117,19 -117,19 +117,19 @@@
          /** {@inheritDoc} */
          @Override public Collection<? extends ComputeJob> split(int gridSize, Object arg) {
              assert gridSize == 1;
--            assert arg instanceof IgniteCheckedException;
++            assert arg instanceof IgniteException;
  
              Collection<ComputeJob> res = new ArrayList<>(gridSize);
  
              for (int i = 0; i < gridSize; i++)
--                res.add(new GridTestFailoverJob((IgniteCheckedException)arg));
++                res.add(new GridTestFailoverJob((IgniteException)arg));
  
              return res;
          }
  
          /** {@inheritDoc} */
          @Override public ComputeJobResultPolicy result(ComputeJobResult res,
--            List<ComputeJobResult> received) throws IgniteCheckedException {
++            List<ComputeJobResult> received) {
              if (res.getException() != null)
                  return ComputeJobResultPolicy.FAILOVER;
  
@@@ -149,11 -149,11 +149,11 @@@
          /**
           * @param ex Exception to be thrown in {@link #execute}.
           */
--        GridTestFailoverJob(IgniteCheckedException ex) { super(ex); }
++        GridTestFailoverJob(IgniteException ex) { super(ex); }
  
          /** {@inheritDoc} */
--        @Override public IgniteCheckedException execute() throws IgniteCheckedException {
--            throw this.<IgniteCheckedException>argument(0);
++        @Override public IgniteException execute() {
++            throw this.<IgniteException>argument(0);
          }
      }
  }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/test/java/org/apache/ignite/internal/GridCancelOnGridStopSelfTest.java
----------------------------------------------------------------------
diff --cc modules/core/src/test/java/org/apache/ignite/internal/GridCancelOnGridStopSelfTest.java
index 42a15d2,42a15d2..1270080
--- a/modules/core/src/test/java/org/apache/ignite/internal/GridCancelOnGridStopSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/GridCancelOnGridStopSelfTest.java
@@@ -71,8 -71,8 +71,7 @@@ public class GridCancelOnGridStopSelfTe
          private Ignite ignite;
  
          /** {@inheritDoc} */
--        @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, @Nullable String arg)
--            throws IgniteCheckedException {
++        @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, @Nullable String arg) {
              for (ClusterNode node : subgrid) {
                  if (node.id().equals(ignite.configuration().getNodeId())) {
                      return Collections.singletonMap(new ComputeJob() {
@@@ -80,14 -80,14 +79,14 @@@
                              cancelCall = true;
                          }
  
--                        @Override public Serializable execute() throws IgniteCheckedException {
++                        @Override public Serializable execute() {
                              cnt.countDown();
  
                              try {
                                  Thread.sleep(Long.MAX_VALUE);
                              }
                              catch (InterruptedException e) {
--                                throw new IgniteCheckedException(e);
++                                throw new IgniteException(e);
                              }
  
                              return null;
@@@ -96,11 -96,11 +95,11 @@@
                  }
              }
  
--            throw new IgniteCheckedException("Local node not found");
++            throw new IgniteException("Local node not found");
          }
  
          /** {@inheritDoc} */
--        @Nullable @Override public Void reduce(List<ComputeJobResult> results) throws IgniteCheckedException {
++        @Nullable @Override public Void reduce(List<ComputeJobResult> results) {
              return null;
          }
      }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/test/java/org/apache/ignite/internal/GridCancelUnusedJobSelfTest.java
----------------------------------------------------------------------
diff --cc modules/core/src/test/java/org/apache/ignite/internal/GridCancelUnusedJobSelfTest.java
index a751b11,a751b11..99fe967
--- a/modules/core/src/test/java/org/apache/ignite/internal/GridCancelUnusedJobSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/GridCancelUnusedJobSelfTest.java
@@@ -124,7 -124,7 +124,7 @@@ public class GridCancelUnusedJobSelfTes
          private IgniteLogger log;
  
          /** {@inheritDoc} */
--        @Override protected Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteCheckedException {
++        @Override protected Collection<? extends ComputeJob> split(int gridSize, Object arg) {
              if (log.isInfoEnabled())
                  log.info("Splitting job [job=" + this + ", gridSize=" + gridSize + ", arg=" + arg + ']');
  
@@@ -142,7 -142,7 +142,7 @@@
          }
  
          /** {@inheritDoc} */
--        @Override public Serializable reduce(List<ComputeJobResult> results) throws IgniteCheckedException {
++        @Override public Serializable reduce(List<ComputeJobResult> results) {
              if (log.isInfoEnabled())
                  log.info("Reducing job [job=" + this + ", results=" + results + ']');
  

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/test/java/org/apache/ignite/internal/GridCancelledJobsMetricsSelfTest.java
----------------------------------------------------------------------
diff --cc modules/core/src/test/java/org/apache/ignite/internal/GridCancelledJobsMetricsSelfTest.java
index e04b9e0,e04b9e0..5a8baef
--- a/modules/core/src/test/java/org/apache/ignite/internal/GridCancelledJobsMetricsSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/GridCancelledJobsMetricsSelfTest.java
@@@ -93,7 -93,7 +93,7 @@@ public class GridCancelledJobsMetricsSe
  
                  assert false : "Job was not interrupted.";
              }
--            catch (IgniteCheckedException e) {
++            catch (IgniteException e) {
                  if (e.hasCause(InterruptedException.class))
                      throw new IgniteCheckedException("Test run has been interrupted.", e);
  
@@@ -129,7 -129,7 +129,7 @@@
       */
      private static final class GridCancelledJob extends ComputeJobAdapter {
          /** {@inheritDoc} */
--        @Override public String execute() throws IgniteCheckedException {
++        @Override public String execute() {
              X.println("Executing job.");
  
              try {
@@@ -140,10 -140,10 +140,10 @@@
                      Thread.sleep(1000);
                  }
                  catch (InterruptedException e1) {
--                    throw new IgniteCheckedException("Unexpected exception: ", e1);
++                    throw new IgniteException("Unexpected exception: ", e1);
                  }
  
--                throw new IgniteCheckedException("Job got interrupted while waiting for cancellation.");
++                throw new IgniteException("Job got interrupted while waiting for cancellation.");
              }
              finally {
                  X.println("Finished job.");

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/test/java/org/apache/ignite/internal/GridContinuousJobAnnotationSelfTest.java
----------------------------------------------------------------------
diff --cc modules/core/src/test/java/org/apache/ignite/internal/GridContinuousJobAnnotationSelfTest.java
index 4b33496,4b33496..5857b60
--- a/modules/core/src/test/java/org/apache/ignite/internal/GridContinuousJobAnnotationSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/GridContinuousJobAnnotationSelfTest.java
@@@ -104,12 -104,12 +104,12 @@@ public class GridContinuousJobAnnotatio
          private ComputeTaskContinuousMapper mapper;
  
          /** {@inheritDoc} */
--        @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, Object arg) throws IgniteCheckedException {
++        @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, Object arg) {
              try {
                  mapper.send(((Class<ComputeJob>)arg).newInstance());
              }
              catch (Exception e) {
--                throw new IgniteCheckedException("Job instantination failed.", e);
++                throw new IgniteException("Job instantination failed.", e);
              }
  
              return null;
@@@ -117,10 -117,10 +117,10 @@@
  
          /** {@inheritDoc} */
          @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> received)
--            throws IgniteCheckedException {
++            throws IgniteException {
              if (res.getException() != null) {
                  if (res.getException() instanceof ComputeUserUndeclaredException)
--                    throw new IgniteCheckedException("Job threw unexpected exception.", res.getException());
++                    throw new IgniteException("Job threw unexpected exception.", res.getException());
  
                  return ComputeJobResultPolicy.FAILOVER;
              }
@@@ -129,7 -129,7 +129,7 @@@
          }
  
          /** {@inheritDoc} */
--        @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException {
++        @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException {
              assert results.size() == 1 : "Unexpected result count: " + results.size();
  
              return null;
@@@ -178,7 -178,7 +178,7 @@@
          }
  
          /** {@inheritDoc} */
--        @Override public Serializable execute() throws IgniteCheckedException {
++        @Override public Serializable execute() throws IgniteException {
              X.println("Execute TestJob [this=" + this + ", identity=" + System.identityHashCode(this) +
                  ", flag=" + flag + "]");
  
@@@ -194,7 -194,7 +194,7 @@@
              if (fail.get()) {
                  fail.set(false);
  
--                throw new IgniteCheckedException("Expected test exception.");
++                throw new IgniteException("Expected test exception.");
              }
  
              return null;

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/core/src/test/java/org/apache/ignite/internal/GridContinuousJobSiblingsSelfTest.java
----------------------------------------------------------------------
diff --cc modules/core/src/test/java/org/apache/ignite/internal/GridContinuousJobSiblingsSelfTest.java
index 6cb511e,6cb511e..adbe08d
--- a/modules/core/src/test/java/org/apache/ignite/internal/GridContinuousJobSiblingsSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/GridContinuousJobSiblingsSelfTest.java
@@@ -76,15 -76,15 +76,14 @@@ public class GridContinuousJobSiblingsS
          private volatile int jobCnt;
  
          /** {@inheritDoc} */
--        @Override protected Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteCheckedException {
++        @Override protected Collection<? extends ComputeJob> split(int gridSize, Object arg) {
              return Collections.singleton(new TestJob(++jobCnt));
          }
  
          /** {@inheritDoc} */
--        @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> received)
--            throws IgniteCheckedException {
++        @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> received) {
              if (res.getException() != null)
--                throw new IgniteCheckedException("Job resulted in error: " + res, res.getException());
++                throw new IgniteException("Job resulted in error: " + res, res.getException());
  
              assert ses.getJobSiblings().size() == jobCnt;
  
@@@ -98,7 -98,7 +97,7 @@@
          }
  
          /** {@inheritDoc} */
--        @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException {
++        @Override public Object reduce(List<ComputeJobResult> results) {
              assertEquals(JOB_COUNT, results.size());
  
              return null;
@@@ -123,7 -123,7 +122,7 @@@
          }
  
          /** {@inheritDoc} */
--        @Override public Serializable execute() throws IgniteCheckedException {
++        @Override public Serializable execute() {
              assert ses != null;
              assert argument(0) != null;
  


Mime
View raw message