ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [24/24] incubator-ignite git commit: # ignite-26
Date Fri, 30 Jan 2015 16:52:30 GMT
# ignite-26


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

Branch: refs/heads/ignite-26
Commit: cb2b9eaa5d7ced6d9556a727774e4e3bc851fd66
Parents: f4ca658 9550905
Author: sboikov <sboikov@gridgain.com>
Authored: Fri Jan 30 09:19:15 2015 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Fri Jan 30 17:43:12 2015 +0300

----------------------------------------------------------------------
 assembly/release-hadoop.xml                     |   6 +-
 .../compute/ComputeContinuousMapperExample.java |  14 +-
 .../ComputeFibonacciContinuationExample.java    | 135 +++++----
 .../compute/ComputeRunnableExample.java         |   4 +-
 .../compute/ComputeScheduleExample.java         |  19 +-
 .../failover/ComputeFailoverExample.java        |  51 ++--
 .../examples/ggfs/GgfsMapReduceExample.java     |   6 +-
 .../misc/deployment/DeploymentExample.java      |   4 +-
 .../streaming/StreamingCheckInExample.java      |  18 +-
 .../StreamingPopularNumbersExample.java         |   5 +-
 .../streaming/StreamingPriceBarsExample.java    |   8 +-
 .../StreamingRunningAverageExample.java         |   7 +-
 .../examples/ScalarContinuationExample.scala    |   8 +-
 .../apache/ignite/gridify/BasicAopSelfTest.java |   4 +-
 .../apache/ignite/gridify/TestGridifyJob.java   |   2 +-
 .../apache/ignite/gridify/TestGridifyTask.java  |   4 +-
 .../singlesplit/SingleSplitTestJobTarget.java   |   3 +-
 .../direct/singlesplit/SingleSplitTestTask.java |   6 +-
 .../singlesplit/SingleSplitsLoadTest.java       |   2 +-
 .../loadtests/gridify/GridifyLoadTestTask.java  |   6 +-
 .../org/test/gridify/ExternalGridifyTask.java   |   4 +-
 .../ClientAbstractMultiThreadedSelfTest.java    |   5 +-
 .../ignite/client/ClientGetAffinityTask.java    |   4 +-
 .../apache/ignite/client/ClientHttpTask.java    |   6 +-
 .../client/ClientPortableArgumentTask.java      |   2 +-
 .../ignite/client/ClientPutPortableTask.java    |   4 +-
 .../ignite/client/ClientStartNodeTask.java      |   4 +-
 .../ignite/client/ClientStopNodeTask.java       |   6 +-
 .../ignite/client/ClientStringLengthTask.java   |   6 +-
 .../org/apache/ignite/client/ClientTcpTask.java |   6 +-
 .../ClientTestPortableAffinityKeyTask.java      |  16 +-
 .../org/apache/ignite/client/SleepTestTask.java |   6 +-
 .../client/TaskSingleJobSplitAdapter.java       |  15 +-
 .../ClientAbstractMultiNodeSelfTest.java        |   4 +-
 .../integration/ClientAbstractSelfTest.java     |  16 +-
 .../integration/ClientPreferDirectSelfTest.java |   4 +-
 .../client/router/ClientFailedInitSelfTest.java |   4 +-
 .../internal/TaskEventSubjectIdSelfTest.java    |  14 +-
 .../rest/RestBinaryProtocolSelfTest.java        |   4 +-
 .../rest/TaskCommandHandlerSelfTest.java        |   4 +-
 .../internal/processors/rest/TestTask1.java     |   7 +-
 .../internal/processors/rest/TestTask2.java     |   8 +-
 .../main/java/org/apache/ignite/IgniteFs.java   |  98 +++----
 .../java/org/apache/ignite/IgniteStreamer.java  |  20 +-
 .../ComputeExecutionRejectedException.java      |   2 +-
 .../org/apache/ignite/compute/ComputeJob.java   |   4 +-
 .../ignite/compute/ComputeJobAdapter.java       |   2 +-
 .../compute/ComputeJobFailoverException.java    |   5 +-
 .../compute/ComputeJobMasterLeaveAware.java     |   4 +-
 .../apache/ignite/compute/ComputeJobResult.java |   6 +-
 .../ignite/compute/ComputeJobSibling.java       |   4 +-
 .../ignite/compute/ComputeLoadBalancer.java     |   4 +-
 .../org/apache/ignite/compute/ComputeTask.java  |  12 +-
 .../ignite/compute/ComputeTaskAdapter.java      |  11 +-
 .../compute/ComputeTaskCancelledException.java  |   2 +-
 .../compute/ComputeTaskContinuousMapper.java    |  16 +-
 .../ignite/compute/ComputeTaskFuture.java       |   4 +-
 .../ignite/compute/ComputeTaskSession.java      |  40 +--
 .../ignite/compute/ComputeTaskSplitAdapter.java |  11 +-
 .../compute/ComputeUserUndeclaredException.java |   4 +-
 .../gridify/aop/GridifyDefaultRangeTask.java    |   9 +-
 .../compute/gridify/aop/GridifyDefaultTask.java |   4 +-
 .../org/apache/ignite/fs/IgniteFsException.java |   2 +-
 .../apache/ignite/fs/IgniteFsFileSystem.java    |  56 ++--
 .../IgniteFsInputStreamJobAdapter.java          |   6 +-
 .../apache/ignite/fs/mapreduce/IgniteFsJob.java |   4 +-
 .../fs/mapreduce/IgniteFsRecordResolver.java    |   4 +-
 .../ignite/fs/mapreduce/IgniteFsTask.java       |  10 +-
 .../IgniteFsByteDelimiterRecordResolver.java    |   2 +-
 .../IgniteFsFixedLengthRecordResolver.java      |   2 +-
 .../ignite/internal/ClusterGroupAdapter.java    |  22 +-
 .../ignite/internal/GridJobExecuteResponse.java |  24 +-
 .../ignite/internal/GridJobResultImpl.java      |  10 +-
 .../ignite/internal/GridJobSessionImpl.java     |  54 ++--
 .../ignite/internal/GridJobSiblingImpl.java     |  12 +-
 .../apache/ignite/internal/GridKillTask.java    |   7 +-
 .../ignite/internal/GridTaskSessionImpl.java    |  63 ++--
 .../ignite/internal/IgniteComputeImpl.java      |  42 +++
 .../apache/ignite/internal/IgniteKernal.java    |   8 +-
 .../ComputeTaskCancelledCheckedException.java   |  58 ++++
 .../internal/executor/GridExecutorService.java  |  24 +-
 .../internal/managers/GridManagerAdapter.java   | 103 ++++---
 .../discovery/GridDiscoveryManager.java         |  10 +-
 .../failover/GridFailoverContextImpl.java       |   2 +-
 .../loadbalancer/GridLoadBalancerManager.java   |  35 ++-
 .../managers/security/GridSecurityImpl.java     |  19 +-
 .../processors/cache/GridCacheAdapter.java      |  16 +-
 .../processors/cache/GridCacheStoreManager.java |  25 +-
 .../processors/cache/IgniteCacheProxy.java      |   2 +-
 .../jdbc/GridCacheQueryJdbcMetadataTask.java    |  13 +-
 .../query/jdbc/GridCacheQueryJdbcTask.java      | 251 ++++++++--------
 .../jdbc/GridCacheQueryJdbcValidationTask.java  |   4 +-
 .../cache/transactions/IgniteTxAdapter.java     |   4 +-
 .../transactions/IgniteTxLocalAdapter.java      |  42 ++-
 .../cache/transactions/IgniteTxProxyImpl.java   |  11 +-
 .../closure/GridClosureProcessor.java           | 218 +++++++-------
 .../processors/fs/GridGgfsAsyncImpl.java        | 100 ++++---
 .../processors/fs/GridGgfsDataManager.java      |  22 +-
 .../internal/processors/fs/GridGgfsEx.java      |   8 +-
 .../internal/processors/fs/GridGgfsImpl.java    | 260 +++++++++++------
 .../internal/processors/fs/GridGgfsJobImpl.java |   4 +-
 .../processors/job/GridJobProcessor.java        |  16 +-
 .../internal/processors/job/GridJobWorker.java  |  21 +-
 .../handlers/cache/GridCacheCommandHandler.java |  18 +-
 .../cache/GridCacheQueryCommandHandler.java     |  57 ++--
 .../handlers/task/GridTaskCommandHandler.java   |  31 +-
 .../streamer/GridStreamerContextDelegate.java   |  15 +-
 .../streamer/GridStreamerContextImpl.java       |  15 +-
 .../processors/streamer/IgniteStreamerImpl.java |  11 +-
 .../streamer/StreamerStageWrapper.java          |   3 +-
 .../task/GridStreamerBroadcastTask.java         |   9 +-
 .../streamer/task/GridStreamerQueryTask.java    |   9 +-
 .../streamer/task/GridStreamerReduceTask.java   |   9 +-
 .../processors/task/GridTaskProcessor.java      |  11 +-
 .../processors/task/GridTaskWorker.java         | 100 +++----
 .../ignite/internal/util/IgniteUtils.java       |   2 +
 .../util/future/IgniteFinishedFutureImplEx.java |  30 ++
 .../internal/util/future/IgniteFutureImpl.java  |  10 +
 .../util/gridify/GridifyArgumentBuilder.java    |   6 +-
 .../util/gridify/GridifyJobAdapter.java         |  15 +-
 .../util/lang/GridComputeJobWrapper.java        |   5 +-
 .../ignite/internal/util/lang/GridFunc.java     |  16 --
 .../apache/ignite/internal/util/typedef/X.java  |   6 +-
 .../apache/ignite/internal/visor/VisorJob.java  |   5 +-
 .../internal/visor/VisorMultiNodeTask.java      |  15 +-
 .../ignite/internal/visor/VisorOneNodeTask.java |   2 +-
 .../visor/cache/VisorCacheClearTask.java        |   2 +-
 .../visor/cache/VisorCacheCompactTask.java      |  33 ++-
 .../visor/cache/VisorCacheLoadTask.java         |  37 +--
 .../visor/cache/VisorCacheMetadataTask.java     |  19 +-
 .../cache/VisorCacheMetricsCollectorTask.java   |   5 +-
 .../visor/cache/VisorCachePreloadTask.java      |  23 +-
 .../visor/cache/VisorCacheResetMetricsTask.java |   2 +-
 .../visor/cache/VisorCacheSwapBackupsTask.java  |   2 +-
 .../compute/VisorComputeCancelSessionsTask.java |   4 +-
 .../compute/VisorComputeResetMetricsTask.java   |   2 +-
 .../VisorComputeToggleMonitoringTask.java       |   4 +-
 .../visor/debug/VisorThreadDumpTask.java        |   2 +-
 .../internal/visor/file/VisorFileBlockTask.java |   2 +-
 .../visor/file/VisorLatestTextFilesTask.java    |   2 +-
 .../visor/ggfs/VisorGgfsFormatTask.java         |   4 +-
 .../visor/ggfs/VisorGgfsProfilerClearTask.java  |   9 +-
 .../visor/ggfs/VisorGgfsProfilerTask.java       |   7 +-
 .../visor/ggfs/VisorGgfsResetMetricsTask.java   |   4 +-
 .../visor/ggfs/VisorGgfsSamplingStateTask.java  |   9 +-
 .../internal/visor/log/VisorLogSearchTask.java  |   9 +-
 .../internal/visor/misc/VisorAckTask.java       |   4 +-
 .../visor/misc/VisorLatestVersionTask.java      |   2 +-
 .../internal/visor/misc/VisorNopTask.java       |   8 +-
 .../visor/misc/VisorResolveHostNameTask.java    |   4 +-
 .../visor/node/VisorNodeDataCollectorJob.java   |   4 +-
 .../visor/node/VisorNodeDataCollectorTask.java  |  13 +-
 .../node/VisorNodeEventsCollectorTask.java      |   6 +-
 .../internal/visor/node/VisorNodeGcTask.java    |   5 +-
 .../internal/visor/node/VisorNodePingTask.java  |   7 +-
 .../visor/node/VisorNodeRestartTask.java        |   4 +-
 .../internal/visor/node/VisorNodeStopTask.java  |   4 +-
 .../VisorPortableMetadataCollectorTask.java     |   2 +-
 .../visor/query/VisorQueryCleanupTask.java      |   6 +-
 .../visor/query/VisorQueryNextPageTask.java     |   9 +-
 .../internal/visor/query/VisorQueryTask.java    |   3 +-
 .../streamer/VisorStreamerMetricsResetTask.java |   4 +-
 .../visor/streamer/VisorStreamerResetTask.java  |   4 +-
 .../org/apache/ignite/lang/IgniteFuture.java    |   2 +
 .../ignite/plugin/security/GridSecurity.java    |   4 +-
 .../org/apache/ignite/spi/IgniteSpiAdapter.java |  29 +-
 .../org/apache/ignite/spi/IgniteSpiContext.java |  53 ++--
 .../apache/ignite/spi/IgniteSpiException.java   |   2 +-
 .../AuthenticationAclProvider.java              |   4 +-
 .../checkpoint/cache/CacheCheckpointSpi.java    |   8 +-
 .../DiscoverySpiNodeAuthenticator.java          |   4 +-
 .../spi/discovery/tcp/TcpDiscoverySpi.java      |   6 +-
 .../ignite/spi/failover/FailoverContext.java    |   4 +-
 .../spi/failover/always/AlwaysFailoverSpi.java  |   2 +-
 .../jobstealing/JobStealingFailoverSpi.java     |   2 +-
 .../spi/loadbalancing/LoadBalancingSpi.java     |   4 +-
 .../adaptive/AdaptiveLoadBalancingSpi.java      |  11 +-
 .../RoundRobinGlobalLoadBalancer.java           |  20 +-
 .../roundrobin/RoundRobinLoadBalancingSpi.java  |   3 +-
 .../spi/securesession/SecureSessionSpi.java     |   2 +-
 .../apache/ignite/streamer/StreamerContext.java |  24 +-
 .../apache/ignite/streamer/StreamerStage.java   |   4 +-
 .../apache/ignite/streamer/StreamerWindow.java  |  44 +--
 .../streamer/index/StreamerIndexProvider.java   |   8 +-
 .../index/StreamerIndexProviderAdapter.java     |  24 +-
 .../streamer/index/StreamerIndexUpdater.java    |   4 +-
 .../index/hash/StreamerHashIndexProvider.java   |   6 +-
 .../index/tree/StreamerTreeIndexProvider.java   |  14 +-
 .../streamer/window/StreamerWindowAdapter.java  |  30 +-
 .../java/org/apache/ignite/GridTestJob.java     |   2 +-
 .../org/apache/ignite/GridTestJobResult.java    |  10 +-
 .../java/org/apache/ignite/GridTestTask.java    |   2 +-
 .../org/apache/ignite/GridTestTaskSession.java  |  11 +-
 .../fs/GridGgfsEventsAbstractSelfTest.java      |   2 +-
 .../GridAlwaysFailoverSpiFailSelfTest.java      |  18 +-
 .../internal/GridCancelOnGridStopSelfTest.java  |  11 +-
 .../internal/GridCancelUnusedJobSelfTest.java   |   4 +-
 .../GridCancelledJobsMetricsSelfTest.java       |   8 +-
 .../GridContinuousJobAnnotationSelfTest.java    |  14 +-
 .../GridContinuousJobSiblingsSelfTest.java      |  11 +-
 .../internal/GridContinuousTaskSelfTest.java    |  24 +-
 .../GridDeploymentMultiThreadedSelfTest.java    |   6 +-
 .../ignite/internal/GridDeploymentSelfTest.java |  15 +-
 .../GridEventStorageCheckAllEventsSelfTest.java |  12 +-
 .../internal/GridEventStorageSelfTest.java      |   6 +-
 .../GridFailoverCustomTopologySelfTest.java     |   8 +-
 .../ignite/internal/GridFailoverSelfTest.java   |  12 +-
 .../GridFailoverTaskWithPredicateSelfTest.java  |  17 +-
 .../internal/GridFailoverTopologySelfTest.java  |  12 +-
 .../GridJobCheckpointCleanupSelfTest.java       |   7 +-
 .../GridJobCollisionCancelSelfTest.java         |   2 +-
 .../ignite/internal/GridJobContextSelfTest.java |   4 +-
 .../GridJobMasterLeaveAwareSelfTest.java        |  72 ++---
 .../internal/GridJobStealingSelfTest.java       |  11 +-
 .../GridJobStealingZeroActiveJobsSelfTest.java  |   8 +-
 .../internal/GridJobSubjectIdSelfTest.java      |   6 +-
 .../internal/GridMultipleJobsSelfTest.java      |   7 +-
 .../internal/GridMultipleSpisSelfTest.java      |  12 +-
 .../GridMultipleVersionsDeploymentSelfTest.java |   8 +-
 .../GridMultithreadedJobStealingSelfTest.java   |  11 +-
 .../internal/GridNonHistoryMetricsSelfTest.java |   2 +-
 .../internal/GridProjectionAbstractTest.java    |  24 +-
 .../ignite/internal/GridReduceSelfTest.java     |   9 +-
 .../internal/GridRuntimeExceptionSelfTest.java  |  15 +-
 .../internal/GridSpiExceptionSelfTest.java      |   2 +-
 .../internal/GridStopWithCancelSelfTest.java    |   8 +-
 .../internal/GridStopWithWaitSelfTest.java      |  16 +-
 .../GridTaskCancelSingleNodeSelfTest.java       |   4 +-
 .../GridTaskContinuousMapperSelfTest.java       |  28 +-
 .../GridTaskExecutionContextSelfTest.java       |   6 +-
 .../internal/GridTaskFailoverSelfTest.java      |   7 +-
 .../GridTaskFutureImplStopGridSelfTest.java     |   9 +-
 .../GridTaskInstanceExecutionSelfTest.java      |   4 +-
 .../internal/GridTaskInstantiationSelfTest.java |   4 +-
 .../internal/GridTaskJobRejectSelfTest.java     |   2 +-
 .../internal/GridTaskListenerSelfTest.java      |   6 +-
 .../internal/GridTaskMapAsyncSelfTest.java      |   8 +-
 .../GridTaskNameAnnotationSelfTest.java         |   7 +-
 .../internal/GridTaskResultCacheSelfTest.java   |  11 +-
 .../internal/GridTaskTimeoutSelfTest.java       |   8 +-
 ...gniteExplicitImplicitDeploymentSelfTest.java |   8 +-
 .../GridCheckpointManagerAbstractSelfTest.java  |  62 ++--
 .../checkpoint/GridCheckpointTaskSelfTest.java  |  12 +-
 ...idCommunicationManagerListenersSelfTest.java |   6 +-
 .../events/GridEventStorageManagerSelfTest.java |   8 +-
 .../cache/GridCacheAbstractFullApiSelfTest.java |  12 +-
 .../GridCacheAbstractProjectionSelfTest.java    |  50 ++++
 .../cache/GridCacheAffinityRoutingSelfTest.java |   4 +-
 .../GridCacheConcurrentTxMultiNodeTest.java     |  10 +-
 .../GridCacheGroupLockFailoverSelfTest.java     |   6 +-
 .../cache/GridCacheGroupLockPutTask.java        |  43 +--
 .../cache/GridCachePutAllFailoverSelfTest.java  |  18 +-
 .../processors/cache/GridCachePutAllTask.java   |  10 +-
 .../cache/IgniteCacheInvokeAbstractTest.java    |   5 +-
 .../GridCacheCountDownLatchSelfTest.java        |   2 +-
 ...ridCacheQueueJoinedNodeSelfAbstractTest.java |   6 +-
 ...CacheQueueRotativeMultiNodeAbstractTest.java |   2 +-
 .../GridCacheAbstractJobExecutionTest.java      |   5 +-
 .../GridCacheNodeFailureAbstractTest.java       |   5 +-
 .../IgniteCrossCacheTxStoreSelfTest.java        | 288 +++++++++++++++++++
 ...cOriginatingNodeFailureAbstractSelfTest.java |   3 +-
 ...GridCacheDhtEvictionNearReadersSelfTest.java |   6 +-
 .../dht/GridCacheDhtEvictionSelfTest.java       |   8 +-
 .../dht/GridCacheDhtPreloadSelfTest.java        |  10 +-
 .../GridCachePartitionedEntryLockSelfTest.java  |   3 +-
 ...titionedExplicitLockNodeFailureSelfTest.java |   5 +-
 ...achePartitionedMultiNodeFullApiSelfTest.java |   3 +-
 .../GridCacheReplicatedEvictionSelfTest.java    |   4 +-
 .../IgniteCacheTxStoreSessionTest.java          |  11 +-
 .../continuous/GridEventConsumeSelfTest.java    |   6 +-
 ...heGgfsPerBlockLruEvictionPolicySelfTest.java |  11 +-
 .../processors/fs/GridGgfsAbstractSelfTest.java |  36 +--
 .../fs/GridGgfsDualAbstractSelfTest.java        |  12 +-
 .../processors/fs/GridGgfsTaskSelfTest.java     |  15 +-
 .../GridServiceProcessorAbstractSelfTest.java   |  21 +-
 .../GridServiceProcessorMultiNodeSelfTest.java  |   8 +-
 .../processors/streamer/GridTestStage.java      |   3 +-
 .../loadtest/GridSingleExecutionTest.java       |  14 +-
 ...idFileSwapSpaceSpiMultithreadedLoadTest.java |   2 +-
 .../loadtests/GridCacheLoadPopulationTask.java  |   8 +-
 .../direct/multisplit/GridLoadTestJob.java      |   2 +-
 .../direct/multisplit/GridLoadTestTask.java     |   4 +-
 .../multisplit/GridMultiSplitsLoadTest.java     |   2 +-
 .../GridMultiSplitsRedeployLoadTest.java        |   2 +-
 .../GridSingleSplitNewNodesTestJobTarget.java   |   5 +-
 .../GridSingleSplitNewNodesTestTask.java        |   6 +-
 .../GridSingleSplitsRedeployLoadTest.java       |   2 +-
 .../direct/session/GridSessionLoadTestJob.java  |   2 +-
 .../direct/session/GridSessionLoadTestTask.java |   6 +-
 .../stealing/GridStealingLoadTestJob.java       |   2 +-
 .../stealing/GridStealingLoadTestTask.java      |   4 +-
 .../loadtests/dsi/GridDsiRequestTask.java       |   4 +-
 .../loadtests/dsi/GridDsiResponseTask.java      |   4 +-
 .../job/GridJobExecutionLoadTestClient.java     |   6 +-
 .../job/GridJobExecutionLoadTestJob.java        |   2 +-
 .../job/GridJobExecutionLoadTestTask.java       |   7 +-
 .../job/GridJobExecutionSingleNodeLoadTest.java |  12 +-
 ...JobExecutionSingleNodeSemaphoreLoadTest.java |   9 +-
 .../loadtests/job/GridJobLoadTestJob.java       |   4 +-
 .../loadtests/job/GridJobLoadTestTask.java      |   7 +-
 .../mapper/GridContinuousMapperTask1.java       |  17 +-
 .../mapper/GridContinuousMapperTask2.java       |   7 +-
 .../mergesort/GridMergeSortLoadTask.java        |   7 +-
 .../ignite/loadtests/streamer/EventClosure.java |   2 +-
 .../loadtests/streamer/average/TestStage.java   |   3 +-
 .../optimized/GridOptimizedMarshallerTest.java  |   2 +-
 .../ignite/messaging/GridMessagingSelfTest.java |  12 +-
 .../p2p/GridP2PJobClassLoaderSelfTest.java      |   6 +-
 .../p2p/GridP2PLocalDeploymentSelfTest.java     |   9 +-
 .../GridP2PMissedResourceCacheSizeSelfTest.java |   2 +-
 .../p2p/GridP2PRecursionTaskSelfTest.java       |   9 +-
 .../p2p/GridP2PRemoteClassLoadersSelfTest.java  |   7 +-
 .../org/apache/ignite/p2p/GridP2PTestJob.java   |   2 +-
 .../org/apache/ignite/p2p/GridP2PTestTask.java  |   4 +-
 .../ignite/p2p/GridP2PTimeoutSelfTest.java      |   2 +-
 ...SessionCancelSiblingsFromFutureSelfTest.java |   6 +-
 ...ridSessionCancelSiblingsFromJobSelfTest.java |   9 +-
 ...idSessionCancelSiblingsFromTaskSelfTest.java |   7 +-
 .../GridSessionCheckpointAbstractSelfTest.java  |  10 +-
 .../GridSessionCollisionSpiSelfTest.java        |   6 +-
 ...idSessionFutureWaitJobAttributeSelfTest.java |   9 +-
 ...dSessionFutureWaitTaskAttributeSelfTest.java |   7 +-
 .../session/GridSessionJobFailoverSelfTest.java |  15 +-
 ...GridSessionJobWaitTaskAttributeSelfTest.java |  11 +-
 .../ignite/session/GridSessionLoadSelfTest.java |  18 +-
 .../GridSessionSetFutureAttributeSelfTest.java  |  11 +-
 ...nSetFutureAttributeWaitListenerSelfTest.java |  11 +-
 .../GridSessionSetJobAttribute2SelfTest.java    |   8 +-
 ...GridSessionSetJobAttributeOrderSelfTest.java |  10 +-
 .../GridSessionSetJobAttributeSelfTest.java     |  15 +-
 ...sionSetJobAttributeWaitListenerSelfTest.java |  10 +-
 .../GridSessionSetTaskAttributeSelfTest.java    |  17 +-
 ...GridSessionTaskWaitJobAttributeSelfTest.java |  15 +-
 .../GridSessionWaitAttributeSelfTest.java       |  13 +-
 ...heckpointSpiMultipleDirectoriesSelfTest.java |   2 +-
 .../collision/GridTestCollisionTaskSession.java |  15 +-
 .../tcp/GridTcpCommunicationSpiLanTest.java     |   2 +-
 ...cpCommunicationSpiMultithreadedSelfTest.java |   6 +-
 .../local/GridLocalDeploymentSpiSelfTest.java   |   8 +-
 .../spi/failover/GridFailoverTestContext.java   |   2 +-
 ...RobinLoadBalancingSpiNotPerTaskSelfTest.java |   2 +-
 .../index/GridStreamerIndexSelfTest.java        |  11 +-
 .../testframework/GridSpiTestContext.java       |  29 +-
 .../cache/GridAbstractCacheStoreSelfTest.java   |   2 +-
 .../junits/common/GridCommonAbstractTest.java   |   4 +-
 .../ignite/testsuites/IgniteCacheTestSuite.java |   1 +
 .../tests/p2p/CacheDeploymentTestTask1.java     |  10 +-
 .../tests/p2p/CacheDeploymentTestTask2.java     |   4 +-
 .../tests/p2p/CacheDeploymentTestTask3.java     |   8 +-
 .../p2p/GridP2PContinuousDeploymentTask1.java   |   8 +-
 .../p2p/GridP2PContinuousDeploymentTask2.java   |   4 +-
 .../ignite/tests/p2p/JobStealingTask.java       |   8 +-
 .../tests/p2p/P2PTestTaskExternalPath1.java     |   8 +-
 .../tests/p2p/P2PTestTaskExternalPath2.java     |   8 +-
 .../ignite/tests/p2p/SingleSplitTestTask.java   |   4 +-
 .../GridUriDeploymentAbstractTestTask.java      |   4 +-
 .../tasks/GridUriDeploymentInnerTestTask.java   |   4 +-
 .../GridUriDeploymentNonePublicTestTask.java    |   4 +-
 .../uri/tasks/GridUriDeploymentTestTask0.java   |   4 +-
 .../uri/tasks/GridUriDeploymentTestTask1.java   |   4 +-
 .../uri/tasks/GridUriDeploymentTestTask2.java   |   4 +-
 .../uri/tasks/GridUriDeploymentTestTask3.java   |   4 +-
 .../uri/tasks/GridUriDeploymentTestTask4.java   |   4 +-
 .../uri/tasks/GridUriDeploymentTestTask5.java   |   4 +-
 .../uri/tasks/GridUriDeploymentTestTask6.java   |   4 +-
 .../GridUriDeploymentTestWithNameTask0.java     |   4 +-
 .../GridUriDeploymentTestWithNameTask3.java     |   4 +-
 .../GridUriDeploymentTestWithNameTask4.java     |   4 +-
 .../GridUriDeploymentTestWithNameTask5.java     |   4 +-
 .../GridUriDeploymentTestWithNameTask6.java     |   4 +-
 .../GridUriDeploymentTestWithNameTask7.java     |   4 +-
 .../fs/hadoop/GridGgfsHadoopFSProperties.java   |   6 +-
 .../hadoop/GridGgfsHadoopFileSystemWrapper.java |  30 +-
 .../internal/fs/hadoop/GridGgfsHadoopUtils.java |   8 +-
 .../proto/GridHadoopProtocolNextTaskIdTask.java |   3 +-
 .../proto/GridHadoopProtocolTaskAdapter.java    |  19 +-
 ...idHadoopDefaultMapReducePlannerSelfTest.java |  70 +++--
 .../hadoop/GridHadoopMapReduceTest.java         |   7 +-
 .../GridHibernateAccessStrategyAdapter.java     |   2 +-
 .../tcp/GridOrderedMessageCancelSelfTest.java   |  32 ++-
 .../scalar/pimps/ScalarProjectionPimp.scala     |  49 ++--
 .../processors/schedule/ScheduleFutureImpl.java |  11 +
 .../apache/ignite/cache/spring/SpringCache.java |   9 +-
 .../ignite/internal/GridFactorySelfTest.java    |   6 +-
 .../resource/GridResourceProcessorSelfTest.java |   4 +-
 .../resource/GridServiceInjectionSelfTest.java  |   4 +-
 .../ignite/p2p/GridP2PDisabledSelfTest.java     |   2 +-
 ...riDeploymentClassloaderRegisterSelfTest.java |   5 +-
 .../uri/GridUriDeploymentSimpleSelfTest.java    |   8 +-
 .../commands/alert/VisorAlertCommand.scala      |   2 +-
 .../visor/commands/gc/VisorGcCommand.scala      |  13 +-
 .../visor/commands/gc/VisorGcCommandSpec.scala  |  25 +-
 392 files changed, 3117 insertions(+), 2390 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/examples/src/main/java/org/apache/ignite/examples/compute/ComputeContinuousMapperExample.java
----------------------------------------------------------------------
diff --cc examples/src/main/java/org/apache/ignite/examples/compute/ComputeContinuousMapperExample.java
index cea5ee0,cea5ee0..99a2b8f
--- a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeContinuousMapperExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeContinuousMapperExample.java
@@@ -87,10 -87,10 +87,9 @@@ public class ComputeContinuousMapperExa
          private final AtomicInteger totalChrCnt = new AtomicInteger(0);
  
          /** {@inheritDoc} */
--        @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> grid, String phrase)
--            throws IgniteCheckedException {
++        @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> grid, String phrase) {
              if (phrase == null || phrase.isEmpty())
--                throw new IgniteCheckedException("Phrase is empty.");
++                throw new IgniteException("Phrase is empty.");
  
              // Populate word queue.
              Collections.addAll(words, phrase.split(" "));
@@@ -104,8 -104,8 +103,7 @@@
          }
  
          /** {@inheritDoc} */
--        @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd)
--            throws IgniteCheckedException {
++        @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) {
              // If there is an error, fail-over to another node.
              if (res.getException() != null)
                  return super.result(res, rcvd);
@@@ -120,16 -120,16 +118,14 @@@
          }
  
          /** {@inheritDoc} */
--        @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException {
++        @Override public Integer reduce(List<ComputeJobResult> results) {
              return totalChrCnt.get();
          }
  
          /**
           * Sends next queued word to the next node implicitly selected by load balancer.
--         *
--         * @throws IgniteCheckedException If sending of a word failed.
           */
--        private void sendWord() throws IgniteCheckedException {
++        private void sendWord() {
              // Remove first word from the queue.
              String word = words.poll();
  

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/examples/src/main/java/org/apache/ignite/examples/compute/ComputeFibonacciContinuationExample.java
----------------------------------------------------------------------
diff --cc examples/src/main/java/org/apache/ignite/examples/compute/ComputeFibonacciContinuationExample.java
index 9301686,9301686..882f0eb
--- a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeFibonacciContinuationExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeFibonacciContinuationExample.java
@@@ -87,10 -87,10 +87,10 @@@ public final class ComputeFibonacciCont
       */
      private static class FibonacciClosure implements IgniteClosure<Long, BigInteger> {
          /** Future for spawned task. */
--        private IgniteInternalFuture<BigInteger> fut1;
++        private IgniteFuture<BigInteger> fut1;
  
          /** Future for spawned task. */
--        private IgniteInternalFuture<BigInteger> fut2;
++        private IgniteFuture<BigInteger> fut2;
  
          /** Auto-inject job context. */
          @IgniteJobContextResource
@@@ -112,78 -112,78 +112,73 @@@
  
          /** {@inheritDoc} */
          @Nullable @Override public BigInteger apply(Long n) {
--            try {
--                if (fut1 == null || fut2 == null) {
--                    System.out.println();
--                    System.out.println(">>> Starting fibonacci execution for number: " + n);
--
--                    // Make sure n is not negative.
--                    n = Math.abs(n);
--
--                    if (n <= 2)
--                        return n == 0 ? BigInteger.ZERO : BigInteger.ONE;
--
--                    // Node-local storage.
--                    ClusterNodeLocalMap<Long, IgniteInternalFuture<BigInteger>> locMap = g.cluster().nodeLocalMap();
--
--                    // Check if value is cached in node-local-map first.
--                    fut1 = locMap.get(n - 1);
--                    fut2 = locMap.get(n - 2);
--
--                    ClusterGroup p = g.cluster().forPredicate(nodeFilter);
--
--                    IgniteCompute compute = g.compute(p).withAsync();
--
--                    // If future is not cached in node-local-map, cache it.
--                    if (fut1 == null) {
--                        compute.apply(new FibonacciClosure(nodeFilter), n - 1);
--
--                        fut1 = locMap.addIfAbsent(n - 1, compute.<BigInteger>future());
--                    }
--
--                    // If future is not cached in node-local-map, cache it.
--                    if (fut2 == null) {
--                        compute.apply(new FibonacciClosure(nodeFilter), n - 2);
--
--                        fut2 = locMap.addIfAbsent(n - 2, compute.<BigInteger>future());
--                    }
--
--                    // If futures are not done, then wait asynchronously for the result
--                    if (!fut1.isDone() || !fut2.isDone()) {
--                        IgniteInClosure<IgniteInternalFuture<BigInteger>> lsnr = new IgniteInClosure<IgniteInternalFuture<BigInteger>>() {
--                            @Override public void apply(IgniteInternalFuture<BigInteger> f) {
--                                // If both futures are done, resume the continuation.
--                                if (fut1.isDone() && fut2.isDone())
--                                    // CONTINUATION:
--                                    // =============
--                                    // Resume suspended job execution.
--                                    jobCtx.callcc();
--                            }
--                        };
--
--                        // CONTINUATION:
--                        // =============
--                        // Hold (suspend) job execution.
--                        // It will be resumed in listener above via 'callcc()' call
--                        // once both futures are done.
--                        jobCtx.holdcc();
--
--                        // Attach the same listener to both futures.
--                        fut1.listenAsync(lsnr);
--                        fut2.listenAsync(lsnr);
--
--                        return null;
--                    }
++            if (fut1 == null || fut2 == null) {
++                System.out.println();
++                System.out.println(">>> Starting fibonacci execution for number: " + n);
++
++                // Make sure n is not negative.
++                n = Math.abs(n);
++
++                if (n <= 2)
++                    return n == 0 ? BigInteger.ZERO : BigInteger.ONE;
++
++                // Node-local storage.
++                ClusterNodeLocalMap<Long, IgniteFuture<BigInteger>> locMap = g.cluster().nodeLocalMap();
++
++                // Check if value is cached in node-local-map first.
++                fut1 = locMap.get(n - 1);
++                fut2 = locMap.get(n - 2);
++
++                ClusterGroup p = g.cluster().forPredicate(nodeFilter);
++
++                IgniteCompute compute = g.compute(p).withAsync();
++
++                // If future is not cached in node-local-map, cache it.
++                if (fut1 == null) {
++                    compute.apply(new FibonacciClosure(nodeFilter), n - 1);
++
++                    fut1 = locMap.addIfAbsent(n - 1, compute.<BigInteger>future());
                  }
  
--                assert fut1.isDone() && fut2.isDone();
++                // If future is not cached in node-local-map, cache it.
++                if (fut2 == null) {
++                    compute.apply(new FibonacciClosure(nodeFilter), n - 2);
  
--                // Return cached results.
--                return fut1.get().add(fut2.get());
--            }
--            catch (IgniteCheckedException e) {
--                throw new IgniteException(e);
++                    fut2 = locMap.addIfAbsent(n - 2, compute.<BigInteger>future());
++                }
++
++                // If futures are not done, then wait asynchronously for the result
++                if (!fut1.isDone() || !fut2.isDone()) {
++                    IgniteInClosure<IgniteFuture<BigInteger>> lsnr = new IgniteInClosure<IgniteFuture<BigInteger>>() {
++                        @Override public void apply(IgniteFuture<BigInteger> f) {
++                            // If both futures are done, resume the continuation.
++                            if (fut1.isDone() && fut2.isDone())
++                                // CONTINUATION:
++                                // =============
++                                // Resume suspended job execution.
++                                jobCtx.callcc();
++                        }
++                    };
++
++                    // CONTINUATION:
++                    // =============
++                    // Hold (suspend) job execution.
++                    // It will be resumed in listener above via 'callcc()' call
++                    // once both futures are done.
++                    jobCtx.holdcc();
++
++                    // Attach the same listener to both futures.
++                    fut1.listenAsync(lsnr);
++                    fut2.listenAsync(lsnr);
++
++                    return null;
++                }
              }
++
++            assert fut1.isDone() && fut2.isDone();
++
++            // Return cached results.
++            return fut1.get().add(fut2.get());
          }
      }
  }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/examples/src/main/java/org/apache/ignite/examples/compute/ComputeRunnableExample.java
----------------------------------------------------------------------
diff --cc examples/src/main/java/org/apache/ignite/examples/compute/ComputeRunnableExample.java
index a7dfad0,a7dfad0..88118e3
--- a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeRunnableExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeRunnableExample.java
@@@ -45,7 -45,7 +45,7 @@@ public class ComputeRunnableExample 
              System.out.println();
              System.out.println("Compute runnable example started.");
  
--            Collection<IgniteInternalFuture> futs = new ArrayList<>();
++            Collection<IgniteFuture> futs = new ArrayList<>();
  
              // Enable asynchronous mode.
              IgniteCompute compute = g.compute().withAsync();
@@@ -64,7 -64,7 +64,7 @@@
              }
  
              // Wait for all futures to complete.
--            for (IgniteInternalFuture<?> f : futs)
++            for (IgniteFuture<?> f : futs)
                  f.get();
  
              System.out.println();

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/examples/src/main/java/org/apache/ignite/examples/compute/ComputeScheduleExample.java
----------------------------------------------------------------------
diff --cc examples/src/main/java/org/apache/ignite/examples/compute/ComputeScheduleExample.java
index 07f2fa6,07f2fa6..d99af11
--- a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeScheduleExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeScheduleExample.java
@@@ -55,19 -55,19 +55,14 @@@ public class ComputeScheduleExample 
                      @Override public Integer call() {
                          invocations++;
  
--                        try {
--                            g.compute().broadcast(
--                                new IgniteRunnable() {
--                                    @Override public void run() {
--                                        System.out.println();
--                                        System.out.println("Howdy! :) ");
--                                    }
++                        g.compute().broadcast(
++                            new IgniteRunnable() {
++                                @Override public void run() {
++                                    System.out.println();
++                                    System.out.println("Howdy! :) ");
                                  }
--                            );
--                        }
--                        catch (IgniteCheckedException e) {
--                            throw new IgniteException(e);
--                        }
++                            }
++                        );
  
                          return invocations;
                      }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/examples/src/main/java/org/apache/ignite/examples/compute/failover/ComputeFailoverExample.java
----------------------------------------------------------------------
diff --cc examples/src/main/java/org/apache/ignite/examples/compute/failover/ComputeFailoverExample.java
index fa065aa,fa065aa..f01d6d7
--- a/examples/src/main/java/org/apache/ignite/examples/compute/failover/ComputeFailoverExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/compute/failover/ComputeFailoverExample.java
@@@ -91,44 -91,44 +91,39 @@@ public class ComputeFailoverExample 
  
              final String cpKey = checkpointKey();
  
--            try {
--                IgniteBiTuple<Integer, Integer> state = jobSes.loadCheckpoint(cpKey);
++            IgniteBiTuple<Integer, Integer> state = jobSes.loadCheckpoint(cpKey);
  
--                int idx = 0;
--                int sum = 0;
++            int idx = 0;
++            int sum = 0;
  
--                if (state != null) {
--                    this.state = state;
++            if (state != null) {
++                this.state = state;
  
--                    // Last processed word index and total length.
--                    idx = state.get1();
--                    sum = state.get2();
--                }
++                // Last processed word index and total length.
++                idx = state.get1();
++                sum = state.get2();
++            }
  
--                for (int i = idx; i < words.size(); i++) {
--                    sum += words.get(i).length();
++            for (int i = idx; i < words.size(); i++) {
++                sum += words.get(i).length();
  
--                    this.state = new IgniteBiTuple<>(i + 1, sum);
++                this.state = new IgniteBiTuple<>(i + 1, sum);
  
--                    // Save checkpoint with scope of task execution.
--                    // It will be automatically removed when task completes.
--                    jobSes.saveCheckpoint(cpKey, this.state);
++                // Save checkpoint with scope of task execution.
++                // It will be automatically removed when task completes.
++                jobSes.saveCheckpoint(cpKey, this.state);
  
--                    // For example purposes, we fail on purpose after first stage.
--                    // This exception will cause job to be failed over to another node.
--                    if (i == 0) {
--                        System.out.println();
--                        System.out.println(">>> Job will be failed over to another node.");
++                // For example purposes, we fail on purpose after first stage.
++                // This exception will cause job to be failed over to another node.
++                if (i == 0) {
++                    System.out.println();
++                    System.out.println(">>> Job will be failed over to another node.");
  
--                        throw new ComputeJobFailoverException("Expected example job exception.");
--                    }
++                    throw new ComputeJobFailoverException("Expected example job exception.");
                  }
--
--                return sum;
--            }
--            catch (IgniteCheckedException e) {
--                throw new GridClosureException(e);
              }
++
++            return sum;
          }
  
          /**

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/examples/src/main/java/org/apache/ignite/examples/ggfs/GgfsMapReduceExample.java
----------------------------------------------------------------------
diff --cc examples/src/main/java/org/apache/ignite/examples/ggfs/GgfsMapReduceExample.java
index 1ba193f,1ba193f..0e6f7d3
--- a/examples/src/main/java/org/apache/ignite/examples/ggfs/GgfsMapReduceExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/ggfs/GgfsMapReduceExample.java
@@@ -129,12 -129,12 +129,12 @@@ public class GgfsMapReduceExample 
      private static class GrepTask extends IgniteFsTask<String, Collection<Line>> {
          /** {@inheritDoc} */
          @Override public IgniteFsJob createJob(IgniteFsPath path, IgniteFsFileRange range,
--            IgniteFsTaskArgs<String> args) throws IgniteCheckedException {
++            IgniteFsTaskArgs<String> args) {
              return new GrepJob(args.userArgument());
          }
  
          /** {@inheritDoc} */
--        @Override public Collection<Line> reduce(List<ComputeJobResult> results) throws IgniteCheckedException {
++        @Override public Collection<Line> reduce(List<ComputeJobResult> results) {
              Collection<Line> lines = new TreeSet<>(new Comparator<Line>() {
                  @Override public int compare(Line line1, Line line2) {
                      return line1.rangePosition() < line2.rangePosition() ? -1 :
@@@ -173,7 -173,7 +173,7 @@@
          }
  
          /**  {@inheritDoc} */
--        @Override public Object execute(IgniteFs ggfs, IgniteFsRangeInputStream in) throws IgniteCheckedException, IOException {
++        @Override public Object execute(IgniteFs ggfs, IgniteFsRangeInputStream in) throws IgniteException, IOException {
              Collection<Line> res = null;
  
              long start = in.startOffset();

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/examples/src/main/java/org/apache/ignite/examples/misc/deployment/DeploymentExample.java
----------------------------------------------------------------------
diff --cc examples/src/main/java/org/apache/ignite/examples/misc/deployment/DeploymentExample.java
index 873a63f,873a63f..25cb036
--- a/examples/src/main/java/org/apache/ignite/examples/misc/deployment/DeploymentExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/misc/deployment/DeploymentExample.java
@@@ -104,7 -104,7 +104,7 @@@ public final class DeploymentExample 
      @ComputeTaskName(TASK_NAME)
      public static class ExampleTask extends ComputeTaskSplitAdapter<String, Object> {
          /** {@inheritDoc} */
--        @Override protected Collection<? extends ComputeJob> split(int gridSize, String arg) throws IgniteCheckedException {
++        @Override protected Collection<? extends ComputeJob> split(int gridSize, String arg) {
              Collection<ComputeJob> jobs = new ArrayList<>(gridSize);
  
              for (int i = 0; i < gridSize; i++) {
@@@ -122,7 -122,7 +122,7 @@@
          }
  
          /** {@inheritDoc} */
--        @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException {
++        @Override public Object reduce(List<ComputeJobResult> results) {
              return null;
          }
      }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/examples/src/main/java/org/apache/ignite/examples/streaming/StreamingCheckInExample.java
----------------------------------------------------------------------
diff --cc examples/src/main/java/org/apache/ignite/examples/streaming/StreamingCheckInExample.java
index 758ec3b,758ec3b..da4e5e8
--- a/examples/src/main/java/org/apache/ignite/examples/streaming/StreamingCheckInExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/streaming/StreamingCheckInExample.java
@@@ -221,7 -221,7 +221,7 @@@ public class StreamingCheckInExample 
  
                      System.out.print(sb.toString());
                  }
--                catch (IgniteCheckedException e) {
++                catch (IgniteException e) {
                      e.printStackTrace();
                  }
              }
@@@ -431,7 -431,7 +431,7 @@@
  
          /** {@inheritDoc} */
          @Nullable @Override public Map<String, Collection<?>> run(
--            StreamerContext ctx, Collection<CheckInEvent> evts) throws IgniteCheckedException {
++            StreamerContext ctx, Collection<CheckInEvent> evts) {
              StreamerWindow<CheckInEvent> win = ctx.window(name());
  
              assert win != null;
@@@ -447,7 -447,7 +447,7 @@@
  
                      evts0.add(evt);
                  }
--                catch (IgniteCheckedException e) {
++                catch (IgniteException e) {
                      if (e.getMessage().contains("Index unique key violation"))
                          System.err.println("Cannot check-in twice within the specified period of time [evt=" + evt + ']');
                      else
@@@ -479,7 -479,7 +479,7 @@@
  
          /** {@inheritDoc} */
          @Nullable @Override public Map<String, Collection<?>> run(StreamerContext ctx,
--            Collection<CheckInEvent> evts) throws IgniteCheckedException {
++            Collection<CheckInEvent> evts) {
              StreamerWindow<LocationInfo> win = ctx.window(name());
  
              assert win != null;
@@@ -529,15 -529,15 +529,14 @@@
          }
  
          /** {@inheritDoc} */
--        @Nullable @Override
--        public Location initialValue(CheckInEvent evt, String key) {
++        @Nullable @Override public Location initialValue(CheckInEvent evt, String key) {
              return evt.location(); // Index value is an event location.
          }
  
          /** {@inheritDoc} */
          @Nullable @Override public Location onAdded(
              StreamerIndexEntry<CheckInEvent, String, Location> entry,
--            CheckInEvent evt) throws IgniteCheckedException {
++            CheckInEvent evt) {
              throw new AssertionError("onAdded() shouldn't be called on unique index.");
          }
  
@@@ -560,15 -560,15 +559,14 @@@
          }
  
          /** {@inheritDoc} */
--        @Nullable @Override
--        public Place initialValue(LocationInfo info, String key) {
++        @Nullable @Override public Place initialValue(LocationInfo info, String key) {
              return info.place();
          }
  
          /** {@inheritDoc} */
          @Nullable @Override public Place onAdded(
              StreamerIndexEntry<LocationInfo, String, Place> entry,
--            LocationInfo evt) throws IgniteCheckedException {
++            LocationInfo evt) {
              throw new AssertionError("onAdded() shouldn't be called on unique index.");
          }
  

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/examples/src/main/java/org/apache/ignite/examples/streaming/StreamingPopularNumbersExample.java
----------------------------------------------------------------------
diff --cc examples/src/main/java/org/apache/ignite/examples/streaming/StreamingPopularNumbersExample.java
index 53ef58a,53ef58a..43d3e0e
--- a/examples/src/main/java/org/apache/ignite/examples/streaming/StreamingPopularNumbersExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/streaming/StreamingPopularNumbersExample.java
@@@ -185,7 -185,7 +185,7 @@@ public class StreamingPopularNumbersExa
  
                      System.out.println("----------------");
                  }
--                catch (IgniteCheckedException e) {
++                catch (IgniteException e) {
                      e.printStackTrace();
                  }
              }
@@@ -207,8 -207,8 +207,7 @@@
          }
  
          /** {@inheritDoc} */
--        @Nullable @Override public Map<String, Collection<?>> run(StreamerContext ctx, Collection<Integer> nums)
--            throws IgniteCheckedException {
++        @Nullable @Override public Map<String, Collection<?>> run(StreamerContext ctx, Collection<Integer> nums) {
              StreamerWindow<Integer> win = ctx.window();
  
              // Add numbers to window.

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/examples/src/main/java/org/apache/ignite/examples/streaming/StreamingPriceBarsExample.java
----------------------------------------------------------------------
diff --cc examples/src/main/java/org/apache/ignite/examples/streaming/StreamingPriceBarsExample.java
index c351bbe,c351bbe..eaaf10f
--- a/examples/src/main/java/org/apache/ignite/examples/streaming/StreamingPriceBarsExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/streaming/StreamingPriceBarsExample.java
@@@ -165,7 -165,7 +165,7 @@@ public class StreamingPriceBarsExample 
  
                      System.out.println("-----------------");
                  }
--                catch (IgniteCheckedException e) {
++                catch (IgniteException e) {
                      e.printStackTrace();
                  }
              }
@@@ -378,8 -378,8 +378,7 @@@
          }
  
          /** {@inheritDoc} */
--        @Nullable @Override public Map<String, Collection<?>> run(StreamerContext ctx, Collection<Quote> quotes)
--            throws IgniteCheckedException {
++        @Nullable @Override public Map<String, Collection<?>> run(StreamerContext ctx, Collection<Quote> quotes) {
              StreamerWindow win = ctx.window("stage1");
  
              // Add numbers to window.
@@@ -419,8 -419,8 +418,7 @@@
          }
  
          /** {@inheritDoc} */
--        @Nullable @Override public Map<String, Collection<?>> run(StreamerContext ctx, Collection<Bar> bars)
--            throws IgniteCheckedException {
++        @Nullable @Override public Map<String, Collection<?>> run(StreamerContext ctx, Collection<Bar> bars) {
              ConcurrentMap<String, Bar> loc = ctx.localSpace();
  
              StreamerWindow win = ctx.window("stage2");

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/examples/src/main/java/org/apache/ignite/examples/streaming/StreamingRunningAverageExample.java
----------------------------------------------------------------------
diff --cc examples/src/main/java/org/apache/ignite/examples/streaming/StreamingRunningAverageExample.java
index a0d51d9,a0d51d9..03408b2
--- a/examples/src/main/java/org/apache/ignite/examples/streaming/StreamingRunningAverageExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/streaming/StreamingRunningAverageExample.java
@@@ -100,7 -100,7 +100,7 @@@ public class StreamingRunningAverageExa
  
                          System.out.println("Got streamer query result [avg=" + avg + ", idealAvg=" + (rndRange / 2) + ']');
                      }
--                    catch (IgniteCheckedException e) {
++                    catch (IgniteException e) {
                          System.out.println("Failed to execute streamer query: " + e);
                      }
                  }
@@@ -117,7 -117,7 +117,7 @@@
                      try {
                          streamer.addEvent(rnd.nextInt(rndRange));
                      }
--                    catch (IgniteCheckedException e) {
++                    catch (IgniteException e) {
                          System.out.println("Failed to add streamer event: " + e);
                      }
                  }
@@@ -155,8 -155,8 +155,7 @@@
          }
  
          /** {@inheritDoc} */
--        @Nullable @Override public Map<String, Collection<?>> run(StreamerContext ctx, Collection<Integer> evts)
--            throws IgniteCheckedException {
++        @Nullable @Override public Map<String, Collection<?>> run(StreamerContext ctx, Collection<Integer> evts) {
              ConcurrentMap<String, Average> loc = ctx.localSpace();
  
              Average avg = loc.get("avg");

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarContinuationExample.scala
----------------------------------------------------------------------
diff --cc examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarContinuationExample.scala
index 7218490,7218490..4bd4bb8
--- a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarContinuationExample.scala
+++ b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarContinuationExample.scala
@@@ -19,7 -19,7 +19,7 @@@ package org.apache.ignite.scalar.exampl
  
  import org.apache.ignite.compute.ComputeJobContext
  import org.apache.ignite.internal.IgniteInternalFuture
--import org.apache.ignite.lang.IgniteClosure
++import org.apache.ignite.lang.{IgniteFuture, IgniteClosure}
  import org.apache.ignite.resources.IgniteJobContextResource
  import org.apache.ignite.scalar.scalar
  import org.apache.ignite.scalar.scalar._
@@@ -82,7 -82,7 +82,7 @@@ class FibonacciClosure 
      // However, these fields will be preserved locally while
      // this closure is being "held", i.e. while it is suspended
      // and is waiting to be continued.
--    @transient private var fut1, fut2: IgniteInternalFuture[BigInteger] = null
++    @transient private var fut1, fut2: IgniteFuture[BigInteger] = null
  
      // Auto-inject job context.
      @IgniteJobContextResource
@@@ -104,7 -104,7 +104,7 @@@
                      BigInteger.ONE
  
              // Get properly typed node-local storage.
--            val store = g.cluster().nodeLocalMap[Long, IgniteInternalFuture[BigInteger]]()
++            val store = g.cluster().nodeLocalMap[Long, IgniteFuture[BigInteger]]()
  
              // Check if value is cached in node-local store first.
              fut1 = store.get(n - 1)
@@@ -134,7 -134,7 +134,7 @@@
  
              // If futures are not done, then wait asynchronously for the result
              if (!fut1.isDone || !fut2.isDone) {
--                val lsnr = (fut: IgniteInternalFuture[BigInteger]) => {
++                val lsnr = (fut: IgniteFuture[BigInteger]) => {
                      // This method will be called twice, once for each future.
                      // On the second call - we have to have both futures to be done
                      // - therefore we can call the continuation.

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/aop/src/test/java/org/apache/ignite/gridify/BasicAopSelfTest.java
----------------------------------------------------------------------
diff --cc modules/aop/src/test/java/org/apache/ignite/gridify/BasicAopSelfTest.java
index e8af218,e8af218..dc83a57
--- a/modules/aop/src/test/java/org/apache/ignite/gridify/BasicAopSelfTest.java
+++ b/modules/aop/src/test/java/org/apache/ignite/gridify/BasicAopSelfTest.java
@@@ -65,12 -65,12 +65,12 @@@ public class BasicAopSelfTest extends G
      private static class TestTask extends GridifyTaskSplitAdapter<Void> {
          /** {@inheritDoc} */
          @Override protected Collection<? extends ComputeJob> split(int gridSize,
--            GridifyArgument arg) throws IgniteCheckedException {
++            GridifyArgument arg) {
              return null;
          }
  
          /** {@inheritDoc} */
--        @Override public Void reduce(List<ComputeJobResult> results) throws IgniteCheckedException {
++        @Override public Void reduce(List<ComputeJobResult> results) {
              return null;
          }
      }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/aop/src/test/java/org/apache/ignite/gridify/TestGridifyJob.java
----------------------------------------------------------------------
diff --cc modules/aop/src/test/java/org/apache/ignite/gridify/TestGridifyJob.java
index 3e7de86,3e7de86..d5df695
--- a/modules/aop/src/test/java/org/apache/ignite/gridify/TestGridifyJob.java
+++ b/modules/aop/src/test/java/org/apache/ignite/gridify/TestGridifyJob.java
@@@ -39,7 -39,7 +39,7 @@@ public class TestGridifyJob extends Com
      }
  
      /** {@inheritDoc} */
--    @Override public Serializable execute() throws IgniteCheckedException {
++    @Override public Serializable execute() {
          if (log.isInfoEnabled())
              log.info("Execute TestGridifyJob.execute(" + argument(0) + ')');
  

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/aop/src/test/java/org/apache/ignite/gridify/TestGridifyTask.java
----------------------------------------------------------------------
diff --cc modules/aop/src/test/java/org/apache/ignite/gridify/TestGridifyTask.java
index 78b0e86,78b0e86..5edca68
--- a/modules/aop/src/test/java/org/apache/ignite/gridify/TestGridifyTask.java
+++ b/modules/aop/src/test/java/org/apache/ignite/gridify/TestGridifyTask.java
@@@ -32,14 -32,14 +32,14 @@@ public class TestGridifyTask extends Co
      public static final String TASK_NAME = "org.apache.ignite.gridify.TestGridifyTask";
  
      /** {@inheritDoc} */
--    @Override public Collection<? extends ComputeJob> split(int gridSize, GridifyArgument arg) throws IgniteCheckedException {
++    @Override public Collection<? extends ComputeJob> split(int gridSize, GridifyArgument arg) {
          assert arg.getMethodParameters().length == 1;
  
          return Collections.singletonList(new TestGridifyJob((String)arg.getMethodParameters()[0]));
      }
  
      /** {@inheritDoc} */
--    @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException {
++    @Override public Object reduce(List<ComputeJobResult> results) {
          assert results.size() == 1;
  
          return results.get(0).getData();

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/aop/src/test/java/org/apache/loadtests/direct/singlesplit/SingleSplitTestJobTarget.java
----------------------------------------------------------------------
diff --cc modules/aop/src/test/java/org/apache/loadtests/direct/singlesplit/SingleSplitTestJobTarget.java
index 9e0eecf,9e0eecf..313ce47
--- a/modules/aop/src/test/java/org/apache/loadtests/direct/singlesplit/SingleSplitTestJobTarget.java
+++ b/modules/aop/src/test/java/org/apache/loadtests/direct/singlesplit/SingleSplitTestJobTarget.java
@@@ -30,11 -30,11 +30,10 @@@ public class SingleSplitTestJobTarget 
       * @param level Level.
       * @param jobSes Job session.
       * @return ALways returns {@code 1}.
--     * @throws IgniteCheckedException If failed.
       */
      @SuppressWarnings("unused")
      @Gridify(taskClass = GridifyLoadTestTask.class, timeout = 10000)
--    public int executeLoadTestJob(int level, ComputeTaskSession jobSes) throws IgniteCheckedException {
++    public int executeLoadTestJob(int level, ComputeTaskSession jobSes) {
          assert level > 0;
          assert jobSes != null;
  

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/aop/src/test/java/org/apache/loadtests/direct/singlesplit/SingleSplitTestTask.java
----------------------------------------------------------------------
diff --cc modules/aop/src/test/java/org/apache/loadtests/direct/singlesplit/SingleSplitTestTask.java
index 7f30f76,7f30f76..d9ed55a
--- a/modules/aop/src/test/java/org/apache/loadtests/direct/singlesplit/SingleSplitTestTask.java
+++ b/modules/aop/src/test/java/org/apache/loadtests/direct/singlesplit/SingleSplitTestTask.java
@@@ -37,7 -37,7 +37,7 @@@ public class SingleSplitTestTask extend
      private ComputeLoadBalancer balancer;
  
      /** {@inheritDoc} */
--    @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, Integer arg) throws IgniteCheckedException {
++    @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, Integer arg) {
          assert !subgrid.isEmpty() : "Subgrid cannot be empty.";
  
          Map<ComputeJobAdapter, ClusterNode> jobs = new HashMap<>(subgrid.size());
@@@ -54,7 -54,7 +54,7 @@@
                  private ComputeTaskSession jobSes;
  
                  /** {@inheritDoc} */
--                @Override public Object execute() throws IgniteCheckedException {
++                @Override public Object execute() {
                      assert jobSes != null;
  
                      Integer arg = this.<Integer>argument(0);
@@@ -80,7 -80,7 +80,7 @@@
      }
  
      /** {@inheritDoc} */
--    @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException {
++    @Override public Integer reduce(List<ComputeJobResult> results) {
          int retVal = 0;
  
          for (ComputeJobResult res : results) {

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/aop/src/test/java/org/apache/loadtests/direct/singlesplit/SingleSplitsLoadTest.java
----------------------------------------------------------------------
diff --cc modules/aop/src/test/java/org/apache/loadtests/direct/singlesplit/SingleSplitsLoadTest.java
index 7239b25,7239b25..e24a9ee
--- a/modules/aop/src/test/java/org/apache/loadtests/direct/singlesplit/SingleSplitsLoadTest.java
+++ b/modules/aop/src/test/java/org/apache/loadtests/direct/singlesplit/SingleSplitsLoadTest.java
@@@ -121,7 -121,7 +121,7 @@@ public class SingleSplitsLoadTest exten
                          if (taskCnt % 500 == 0)
                              info(stats.toString());
                      }
--                    catch (IgniteCheckedException e) {
++                    catch (IgniteException e) {
                          error("Failed to execute grid task.", e);
  
                          fail();

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/aop/src/test/java/org/apache/loadtests/gridify/GridifyLoadTestTask.java
----------------------------------------------------------------------
diff --cc modules/aop/src/test/java/org/apache/loadtests/gridify/GridifyLoadTestTask.java
index af1d708,af1d708..4c11e9f
--- a/modules/aop/src/test/java/org/apache/loadtests/gridify/GridifyLoadTestTask.java
+++ b/modules/aop/src/test/java/org/apache/loadtests/gridify/GridifyLoadTestTask.java
@@@ -29,7 -29,7 +29,7 @@@ import java.util.*
   */
  public class GridifyLoadTestTask extends ComputeTaskSplitAdapter<GridifyArgument, Integer> {
      /** {@inheritDoc} */
--    @Override protected Collection<? extends ComputeJob> split(int gridSize, GridifyArgument arg) throws IgniteCheckedException {
++    @Override protected Collection<? extends ComputeJob> split(int gridSize, GridifyArgument arg) {
          assert gridSize > 0 : "Subgrid cannot be empty.";
  
          int jobsNum = (Integer)arg.getMethodParameters()[0];
@@@ -53,12 -53,12 +53,12 @@@
      }
  
      /** {@inheritDoc} */
--    @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException {
++    @Override public Integer reduce(List<ComputeJobResult> results) {
          int retVal = 0;
  
          for (ComputeJobResult res : results) {
              if (res.getException() != null) {
--                throw new IgniteCheckedException("Received exception in reduce method (load test jobs can never fail): " + res,
++                throw new IgniteException("Received exception in reduce method (load test jobs can never fail): " + res,
                      res.getException());
              }
  

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/aop/src/test/java/org/test/gridify/ExternalGridifyTask.java
----------------------------------------------------------------------
diff --cc modules/aop/src/test/java/org/test/gridify/ExternalGridifyTask.java
index 599359c,599359c..bc0bbe6
--- a/modules/aop/src/test/java/org/test/gridify/ExternalGridifyTask.java
+++ b/modules/aop/src/test/java/org/test/gridify/ExternalGridifyTask.java
@@@ -33,7 -33,7 +33,7 @@@ public class ExternalGridifyTask extend
      public static final String TASK_NAME = "org.test.gridify.ExternalGridifyTask";
  
      /** {@inheritDoc} */
--    @Override public Collection<? extends ComputeJob> split(int gridSize, GridifyArgument arg) throws IgniteCheckedException {
++    @Override public Collection<? extends ComputeJob> split(int gridSize, GridifyArgument arg) {
          assert arg.getMethodParameters().length == 1;
  
          return Collections.singletonList(new ComputeJobAdapter((String)arg.getMethodParameters()[0]) {
@@@ -71,7 -71,7 +71,7 @@@
      }
  
      /** {@inheritDoc} */
--    @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException {
++    @Override public Object reduce(List<ComputeJobResult> results) {
          assert results.size() == 1;
  
          return results.get(0).getData();

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/clients/src/test/java/org/apache/ignite/client/ClientAbstractMultiThreadedSelfTest.java
----------------------------------------------------------------------
diff --cc modules/clients/src/test/java/org/apache/ignite/client/ClientAbstractMultiThreadedSelfTest.java
index e72e684,e72e684..ce75c32
--- a/modules/clients/src/test/java/org/apache/ignite/client/ClientAbstractMultiThreadedSelfTest.java
+++ b/modules/clients/src/test/java/org/apache/ignite/client/ClientAbstractMultiThreadedSelfTest.java
@@@ -572,8 -572,8 +572,7 @@@ public abstract class ClientAbstractMul
          private int gridSize;
  
          /** {@inheritDoc} */
--        @Override protected Collection<? extends ComputeJob> split(int gridSize, Object arg)
--            throws IgniteCheckedException {
++        @Override protected Collection<? extends ComputeJob> split(int gridSize, Object arg) {
              Collection<ComputeJobAdapter> jobs = new ArrayList<>(gridSize);
  
              this.gridSize = gridSize;
@@@ -592,7 -592,7 +591,7 @@@
          }
  
          /** {@inheritDoc} */
--        @Override public String reduce(List<ComputeJobResult> results) throws IgniteCheckedException {
++        @Override public String reduce(List<ComputeJobResult> results) {
              int sum = 0;
  
              String locNodeId = null;

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/clients/src/test/java/org/apache/ignite/client/ClientGetAffinityTask.java
----------------------------------------------------------------------
diff --cc modules/clients/src/test/java/org/apache/ignite/client/ClientGetAffinityTask.java
index c6b317d,c6b317d..03a09c7
--- a/modules/clients/src/test/java/org/apache/ignite/client/ClientGetAffinityTask.java
+++ b/modules/clients/src/test/java/org/apache/ignite/client/ClientGetAffinityTask.java
@@@ -36,7 -36,7 +36,7 @@@ public class ClientGetAffinityTask exte
      private transient Ignite ignite;
  
      /** {@inheritDoc} */
--    @Override protected Object executeJob(int gridSize, String arg) throws IgniteCheckedException {
++    @Override protected Object executeJob(int gridSize, String arg) {
          A.notNull(arg, "task argument");
  
          String[] split = arg.split(":", 2);
@@@ -55,7 -55,7 +55,7 @@@
      }
  
      /** {@inheritDoc} */
--    @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) throws IgniteCheckedException {
++    @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) {
          if (res.getException() != null)
              return FAILOVER;
  

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/clients/src/test/java/org/apache/ignite/client/ClientHttpTask.java
----------------------------------------------------------------------
diff --cc modules/clients/src/test/java/org/apache/ignite/client/ClientHttpTask.java
index c3f466c,c3f466c..83188f9
--- a/modules/clients/src/test/java/org/apache/ignite/client/ClientHttpTask.java
+++ b/modules/clients/src/test/java/org/apache/ignite/client/ClientHttpTask.java
@@@ -35,7 -35,7 +35,7 @@@ public class ClientHttpTask extends Com
      private final ClientTcpTask delegate = new ClientTcpTask();
  
      /** {@inheritDoc} */
--    @Override protected Collection<? extends ComputeJob> split(int gridSize, String arg) throws IgniteCheckedException {
++    @Override protected Collection<? extends ComputeJob> split(int gridSize, String arg) {
          JSON json = JSONSerializer.toJSON(arg);
  
          List list = json.isArray() ? JSONArray.toList((JSONArray)json, String.class, new JsonConfig()) : null;
@@@ -45,12 -45,12 +45,12 @@@
      }
  
      /** {@inheritDoc} */
--    @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException {
++    @Override public Integer reduce(List<ComputeJobResult> results) {
          return delegate.reduce(results);
      }
  
      /** {@inheritDoc} */
--    @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) throws IgniteCheckedException {
++    @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) {
          if (res.getException() != null)
              return FAILOVER;
  

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/clients/src/test/java/org/apache/ignite/client/ClientPortableArgumentTask.java
----------------------------------------------------------------------
diff --cc modules/clients/src/test/java/org/apache/ignite/client/ClientPortableArgumentTask.java
index a137fe1,a137fe1..c7b5f29
--- a/modules/clients/src/test/java/org/apache/ignite/client/ClientPortableArgumentTask.java
+++ b/modules/clients/src/test/java/org/apache/ignite/client/ClientPortableArgumentTask.java
@@@ -27,7 -27,7 +27,7 @@@ import java.util.*
   */
  public class ClientPortableArgumentTask extends TaskSingleJobSplitAdapter {
      /** {@inheritDoc} */
--    @Override protected Object executeJob(int gridSize, Object arg) throws IgniteCheckedException {
++    @Override protected Object executeJob(int gridSize, Object arg) {
          Collection args = (Collection)arg;
  
          Iterator<Object> it = args.iterator();

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/clients/src/test/java/org/apache/ignite/client/ClientPutPortableTask.java
----------------------------------------------------------------------
diff --cc modules/clients/src/test/java/org/apache/ignite/client/ClientPutPortableTask.java
index cd5f85c,cd5f85c..8d383ac
--- a/modules/clients/src/test/java/org/apache/ignite/client/ClientPutPortableTask.java
+++ b/modules/clients/src/test/java/org/apache/ignite/client/ClientPutPortableTask.java
@@@ -30,10 -30,10 +30,10 @@@ public class ClientPutPortableTask exte
      private Ignite ignite;
  
      /** {@inheritDoc} */
--    @Override protected Object executeJob(int gridSize, Object arg) throws IgniteCheckedException {
++    @Override protected Object executeJob(int gridSize, Object arg) {
          String cacheName = (String)arg;
  
--        GridCache<Object, Object> cache = ignite.cache(cacheName);
++        IgniteCache<Object, Object> cache = ignite.jcache(cacheName);
  
          ClientTestPortable p = new ClientTestPortable(100, true);
  

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/clients/src/test/java/org/apache/ignite/client/ClientStartNodeTask.java
----------------------------------------------------------------------
diff --cc modules/clients/src/test/java/org/apache/ignite/client/ClientStartNodeTask.java
index 5560593,5560593..2a1cfde
--- a/modules/clients/src/test/java/org/apache/ignite/client/ClientStartNodeTask.java
+++ b/modules/clients/src/test/java/org/apache/ignite/client/ClientStartNodeTask.java
@@@ -60,7 -60,7 +60,7 @@@ public class ClientStartNodeTask extend
      private transient Ignite ignite;
  
      /** {@inheritDoc} */
--    @Override protected Object executeJob(int gridSize, String type) throws IgniteCheckedException {
++    @Override protected Object executeJob(int gridSize, String type) {
          log.info(">>> Starting new grid node [currGridSize=" + gridSize + ", arg=" + type + "]");
  
          if (type == null)
@@@ -84,7 -84,7 +84,7 @@@
  
      /** {@inheritDoc} */
      @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd)
--        throws IgniteCheckedException {
++        {
          if (res.getException() != null)
              return FAILOVER;
  

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/clients/src/test/java/org/apache/ignite/client/ClientStopNodeTask.java
----------------------------------------------------------------------
diff --cc modules/clients/src/test/java/org/apache/ignite/client/ClientStopNodeTask.java
index 364c05b,364c05b..b5d5820
--- a/modules/clients/src/test/java/org/apache/ignite/client/ClientStopNodeTask.java
+++ b/modules/clients/src/test/java/org/apache/ignite/client/ClientStopNodeTask.java
@@@ -43,7 -43,7 +43,7 @@@ public class ClientStopNodeTask extend
      private transient Ignite ignite;
  
      /** {@inheritDoc} */
--    @Override protected Collection<? extends ComputeJob> split(int gridSize, String arg) throws IgniteCheckedException {
++    @Override protected Collection<? extends ComputeJob> split(int gridSize, String arg) {
          Collection<ComputeJob> jobs = new ArrayList<>();
  
          for (int i = 0; i < gridSize; i++)
@@@ -53,7 -53,7 +53,7 @@@
      }
  
      /** {@inheritDoc} */
--    @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) throws IgniteCheckedException {
++    @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) {
          ComputeJobResultPolicy superRes = super.result(res, rcvd);
  
          // Deny failover.
@@@ -64,7 -64,7 +64,7 @@@
      }
  
      /** {@inheritDoc} */
--    @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException {
++    @Override public Integer reduce(List<ComputeJobResult> results) {
          int stoppedCnt = 0;
  
          for (ComputeJobResult res : results)

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/clients/src/test/java/org/apache/ignite/client/ClientStringLengthTask.java
----------------------------------------------------------------------
diff --cc modules/clients/src/test/java/org/apache/ignite/client/ClientStringLengthTask.java
index 7e292d9,7e292d9..2bbd49c
--- a/modules/clients/src/test/java/org/apache/ignite/client/ClientStringLengthTask.java
+++ b/modules/clients/src/test/java/org/apache/ignite/client/ClientStringLengthTask.java
@@@ -31,7 -31,7 +31,7 @@@ import static org.apache.ignite.compute
   */
  public class ClientStringLengthTask extends ComputeTaskSplitAdapter<String, Integer> {
      /** {@inheritDoc} */
--    @Override protected Collection<? extends ComputeJob> split(int gridSize, String arg) throws IgniteCheckedException {
++    @Override protected Collection<? extends ComputeJob> split(int gridSize, String arg) {
          Collection<ComputeJobAdapter> jobs = new ArrayList<>();
  
          if (arg != null)
@@@ -53,7 -53,7 +53,7 @@@
      }
  
      /** {@inheritDoc} */
--    @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException {
++    @Override public Integer reduce(List<ComputeJobResult> results) {
          int sum = 0;
  
          for (ComputeJobResult res : results)
@@@ -64,7 -64,7 +64,7 @@@
  
      /** {@inheritDoc} */
      @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd)
--        throws IgniteCheckedException {
++        {
          if (res.getException() != null)
              return FAILOVER;
  

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/clients/src/test/java/org/apache/ignite/client/ClientTcpTask.java
----------------------------------------------------------------------
diff --cc modules/clients/src/test/java/org/apache/ignite/client/ClientTcpTask.java
index 6f0e362,6f0e362..1eae9db
--- a/modules/clients/src/test/java/org/apache/ignite/client/ClientTcpTask.java
+++ b/modules/clients/src/test/java/org/apache/ignite/client/ClientTcpTask.java
@@@ -32,7 -32,7 +32,7 @@@ import static org.apache.ignite.compute
  public class ClientTcpTask extends ComputeTaskSplitAdapter<List<Object>, Integer> {
      /** {@inheritDoc} */
      @Override protected Collection<? extends ComputeJob> split(int gridSize, List<Object> list)
--        throws IgniteCheckedException {
++        {
          Collection<ComputeJobAdapter> jobs = new ArrayList<>();
  
          if (list != null)
@@@ -54,7 -54,7 +54,7 @@@
      }
  
      /** {@inheritDoc} */
--    @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException {
++    @Override public Integer reduce(List<ComputeJobResult> results) {
          int sum = 0;
  
          for (ComputeJobResult res : results)
@@@ -64,7 -64,7 +64,7 @@@
      }
  
      /** {@inheritDoc} */
--    @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) throws IgniteCheckedException {
++    @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) {
          if (res.getException() != null)
              return FAILOVER;
  

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/clients/src/test/java/org/apache/ignite/client/ClientTestPortableAffinityKeyTask.java
----------------------------------------------------------------------
diff --cc modules/clients/src/test/java/org/apache/ignite/client/ClientTestPortableAffinityKeyTask.java
index 855c3d2,855c3d2..cde3a0d
--- a/modules/clients/src/test/java/org/apache/ignite/client/ClientTestPortableAffinityKeyTask.java
+++ b/modules/clients/src/test/java/org/apache/ignite/client/ClientTestPortableAffinityKeyTask.java
@@@ -36,30 -36,30 +36,30 @@@ public class ClientTestPortableAffinity
  
      /** {@inheritDoc} */
      @Nullable @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> clusterNodes,
--        @Nullable final Object arg) throws IgniteCheckedException {
++        @Nullable final Object arg) {
          for (ClusterNode node : clusterNodes) {
              if (node.isLocal())
                  return Collections.singletonMap(new ComputeJobAdapter() {
--                    @Override public Object execute() throws IgniteCheckedException {
++                    @Override public Object execute() {
                          return executeJob(arg);
                      }
                  }, node);
          }
  
--        throw new IgniteCheckedException("Failed to find local node in task topology: " + clusterNodes);
++        throw new IgniteException("Failed to find local node in task topology: " + clusterNodes);
      }
  
      /** {@inheritDoc} */
--    @Nullable @Override public Boolean reduce(List<ComputeJobResult> results) throws IgniteCheckedException {
++    @Nullable @Override public Boolean reduce(List<ComputeJobResult> results) {
          return results.get(0).getData();
      }
  
      /**
       * @param arg Argument.
       * @return Execution result.
--     * @throws IgniteCheckedException If failed.
++     * @throws IgniteException If failed.
       */
--     protected Boolean executeJob(Object arg) throws IgniteCheckedException {
++     protected Boolean executeJob(Object arg) throws IgniteException {
          Collection args = (Collection)arg;
  
          Iterator<Object> it = args.iterator();
@@@ -75,10 -75,10 +75,10 @@@
          Object affKey = ignite.cache(cacheName).affinity().affinityKey(obj);
  
          if (!expAffKey.equals(affKey))
--            throw new IgniteCheckedException("Unexpected affinity key: " + affKey);
++            throw new IgniteException("Unexpected affinity key: " + affKey);
  
          if (!ignite.cache(cacheName).affinity().mapKeyToNode(obj).isLocal())
--            throw new IgniteCheckedException("Job is not run on primary node.");
++            throw new IgniteException("Job is not run on primary node.");
  
          return true;
      }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/clients/src/test/java/org/apache/ignite/client/SleepTestTask.java
----------------------------------------------------------------------
diff --cc modules/clients/src/test/java/org/apache/ignite/client/SleepTestTask.java
index f59d16e,f59d16e..6dd2974
--- a/modules/clients/src/test/java/org/apache/ignite/client/SleepTestTask.java
+++ b/modules/clients/src/test/java/org/apache/ignite/client/SleepTestTask.java
@@@ -31,7 -31,7 +31,7 @@@ import static org.apache.ignite.compute
  public class SleepTestTask extends ComputeTaskSplitAdapter<String, Integer> {
      /** {@inheritDoc} */
      @Override public Collection<? extends ComputeJob> split(int gridSize, String arg)
--        throws IgniteCheckedException {
++        {
          return Collections.singleton(new ComputeJobAdapter(arg) {
              @Override public Object execute() {
                  try {
@@@ -49,7 -49,7 +49,7 @@@
      }
  
      /** {@inheritDoc} */
--    @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException {
++    @Override public Integer reduce(List<ComputeJobResult> results) {
          int sum = 0;
  
          for (ComputeJobResult res : results)
@@@ -59,7 -59,7 +59,7 @@@
      }
  
      /** {@inheritDoc} */
--    @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) throws IgniteCheckedException {
++    @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) {
          if (res.getException() != null)
              return FAILOVER;
  

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/clients/src/test/java/org/apache/ignite/client/TaskSingleJobSplitAdapter.java
----------------------------------------------------------------------
diff --cc modules/clients/src/test/java/org/apache/ignite/client/TaskSingleJobSplitAdapter.java
index 13b0687,13b0687..780eb37
--- a/modules/clients/src/test/java/org/apache/ignite/client/TaskSingleJobSplitAdapter.java
+++ b/modules/clients/src/test/java/org/apache/ignite/client/TaskSingleJobSplitAdapter.java
@@@ -36,22 -36,22 +36,22 @@@ public abstract class TaskSingleJobSpli
      }
  
      /** {@inheritDoc} */
--    @Override protected Collection<? extends ComputeJob> split(final int gridSize, final T arg) throws IgniteCheckedException {
++    @Override protected Collection<? extends ComputeJob> split(final int gridSize, final T arg) {
          return Collections.singleton(new ComputeJobAdapter() {
--            @Override public Object execute() throws IgniteCheckedException {
++            @Override public Object execute() {
                  return executeJob(gridSize, arg);
              }
          });
      }
  
      /** {@inheritDoc} */
--    @Override public R reduce(List<ComputeJobResult> results) throws IgniteCheckedException {
++    @Override public R reduce(List<ComputeJobResult> results) {
          assert results.size() == 1;
  
          ComputeJobResult res = results.get(0);
  
          if (res.isCancelled())
--            throw new IgniteCheckedException("Reduce receives failed job.");
++            throw new IgniteException("Reduce receives failed job.");
  
          return res.getData();
      }
@@@ -65,11 -65,11 +65,6 @@@
       * @return Job execution result (possibly {@code null}). This result will be returned
       *      in {@link org.apache.ignite.compute.ComputeJobResult#getData()} method passed into
       *      {@link org.apache.ignite.compute.ComputeTask#result(org.apache.ignite.compute.ComputeJobResult, List)} method into task on caller node.
--     * @throws IgniteCheckedException If job execution caused an exception. This exception will be
--     *      returned in {@link org.apache.ignite.compute.ComputeJobResult#getException()} method passed into
--     *      {@link org.apache.ignite.compute.ComputeTask#result(org.apache.ignite.compute.ComputeJobResult, List)} method into task on caller node.
--     *      If execution produces a {@link RuntimeException} or {@link Error}, then
--     *      it will be wrapped into {@link IgniteCheckedException}.
       */
--    protected abstract Object executeJob(int gridSize, T arg) throws IgniteCheckedException;
++    protected abstract Object executeJob(int gridSize, T arg);
  }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/clients/src/test/java/org/apache/ignite/client/integration/ClientAbstractMultiNodeSelfTest.java
----------------------------------------------------------------------
diff --cc modules/clients/src/test/java/org/apache/ignite/client/integration/ClientAbstractMultiNodeSelfTest.java
index d1f3319,d1f3319..de1a398
--- a/modules/clients/src/test/java/org/apache/ignite/client/integration/ClientAbstractMultiNodeSelfTest.java
+++ b/modules/clients/src/test/java/org/apache/ignite/client/integration/ClientAbstractMultiNodeSelfTest.java
@@@ -706,7 -706,7 +706,7 @@@ public abstract class ClientAbstractMul
  
          /** {@inheritDoc} */
          @Override protected Collection<? extends ComputeJob> split(int gridSize, Object arg)
--            throws IgniteCheckedException {
++            {
              Collection<ComputeJobAdapter> jobs = new ArrayList<>(gridSize);
  
              this.gridSize = gridSize;
@@@ -733,7 -733,7 +733,7 @@@
          }
  
          /** {@inheritDoc} */
--        @Override public String reduce(List<ComputeJobResult> results) throws IgniteCheckedException {
++        @Override public String reduce(List<ComputeJobResult> results) {
              int sum = 0;
  
              String locNodeId = null;

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cb2b9eaa/modules/clients/src/test/java/org/apache/ignite/client/integration/ClientAbstractSelfTest.java
----------------------------------------------------------------------
diff --cc modules/clients/src/test/java/org/apache/ignite/client/integration/ClientAbstractSelfTest.java
index cee7608,cee7608..4dc447a
--- a/modules/clients/src/test/java/org/apache/ignite/client/integration/ClientAbstractSelfTest.java
+++ b/modules/clients/src/test/java/org/apache/ignite/client/integration/ClientAbstractSelfTest.java
@@@ -1455,7 -1455,7 +1455,7 @@@ public abstract class ClientAbstractSel
      private static class TestTask extends ComputeTaskSplitAdapter<List<Object>, Integer> {
          /** {@inheritDoc} */
          @Override protected Collection<? extends ComputeJob> split(int gridSize, List<Object> list)
--            throws IgniteCheckedException {
++            {
              Collection<ComputeJobAdapter> jobs = new ArrayList<>();
  
              if (list != null)
@@@ -1477,7 -1477,7 +1477,7 @@@
          }
  
          /** {@inheritDoc} */
--        @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException {
++        @Override public Integer reduce(List<ComputeJobResult> results) {
              int sum = 0;
  
              for (ComputeJobResult res : results)
@@@ -1493,7 -1493,7 +1493,7 @@@
      private static class SleepTestTask extends ComputeTaskSplitAdapter<List<Object>, Integer> {
          /** {@inheritDoc} */
          @Override protected Collection<? extends ComputeJob> split(int gridSize, List<Object> list)
--            throws IgniteCheckedException {
++            {
              Collection<ComputeJobAdapter> jobs = new ArrayList<>();
  
              if (list != null)
@@@ -1515,7 -1515,7 +1515,7 @@@
          }
  
          /** {@inheritDoc} */
--        @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException {
++        @Override public Integer reduce(List<ComputeJobResult> results) {
              int sum = 0;
  
              for (ComputeJobResult res : results)
@@@ -1533,7 -1533,7 +1533,7 @@@
  
          /** {@inheritDoc} */
          @SuppressWarnings("unchecked")
--        @Override protected Collection<? extends ComputeJob> split(int gridSize, String arg) throws IgniteCheckedException {
++        @Override protected Collection<? extends ComputeJob> split(int gridSize, String arg) {
              if (arg.endsWith("intercepted"))
                  arg = arg.substring(0, arg.length() - 11);
  
@@@ -1545,7 -1545,7 +1545,7 @@@
          }
  
          /** {@inheritDoc} */
--        @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException {
++        @Override public Integer reduce(List<ComputeJobResult> results) {
              return delegate.reduce(results);
          }
      }
@@@ -1558,7 -1558,7 +1558,7 @@@
  
          /** {@inheritDoc} */
          @SuppressWarnings("unchecked")
--        @Override protected Collection<? extends ComputeJob> split(int gridSize, String arg) throws IgniteCheckedException {
++        @Override protected Collection<? extends ComputeJob> split(int gridSize, String arg) {
              JSON json = JSONSerializer.toJSON(arg);
  
              List list = json.isArray() ? JSONArray.toList((JSONArray)json, String.class, new JsonConfig()) : null;
@@@ -1567,7 -1567,7 +1567,7 @@@
          }
  
          /** {@inheritDoc} */
--        @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException {
++        @Override public Integer reduce(List<ComputeJobResult> results) {
              return delegate.reduce(results);
          }
      }


Mime
View raw message