# IGNITE-26 Replaced IgniteCheckedException with IgniteException on public API.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/8bc850c2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/8bc850c2 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/8bc850c2 Branch: refs/heads/ignite-26 Commit: 8bc850c2d352df52ce95e69c9aba99bdcb3d5102 Parents: 3cbcf92 Author: sevdokimov <sevdoki...@gridgain.com> Authored: Tue Dec 16 18:12:41 2014 +0300 Committer: sevdokimov <sevdoki...@gridgain.com> Committed: Tue Dec 16 18:12:42 2014 +0300 ---------------------------------------------------------------------- .../compute/ComputeContinuousMapperExample.java | 6 +- .../examples/ggfs/GgfsMapReduceExample.java | 6 +- .../MessagingPingPongListenActorExample.java | 4 +- .../misc/deployment/DeploymentExample.java | 4 +- .../streaming/StreamingCheckInExample.java | 8 +- .../StreamingPopularNumbersExample.java | 2 +- .../streaming/StreamingPriceBarsExample.java | 4 +- .../StreamingRunningAverageExample.java | 2 +- .../grid/gridify/GridBasicAopSelfTest.java | 4 +- .../grid/gridify/GridTestGridifyJob.java | 2 +- .../grid/gridify/GridTestGridifyTask.java | 4 +- .../singlesplit/GridSingleSplitTestTask.java | 6 +- .../loadtests/gridify/GridifyLoadTestTask.java | 4 +- .../test/gridify/GridExternalGridifyTask.java | 4 +- ...GridClientAbstractMultiThreadedSelfTest.java | 4 +- .../client/GridClientGetAffinityTask.java | 2 +- .../org/gridgain/client/GridClientHttpTask.java | 6 +- .../client/GridClientStartNodeTask.java | 2 +- .../gridgain/client/GridClientStopNodeTask.java | 6 +- .../client/GridClientStringLengthTask.java | 6 +- .../org/gridgain/client/GridClientTcpTask.java | 6 +- .../GridClientTestPortableAffinityKeyTask.java | 6 +- .../org/gridgain/client/GridSleepTestTask.java | 6 +- .../client/GridTaskSingleJobSplitAdapter.java | 6 +- .../GridClientAbstractMultiNodeSelfTest.java | 4 +- .../integration/GridClientAbstractSelfTest.java | 16 +- .../GridClientPreferDirectSelfTest.java | 4 +- .../router/GridClientFailedInitSelfTest.java | 4 +- .../kernal/GridTaskEventSubjectIdSelfTest.java | 12 +- .../rest/GridRestBinaryProtocolSelfTest.java | 4 +- .../rest/GridTaskCommandHandlerSelfTest.java | 4 +- .../grid/kernal/processors/rest/TestTask1.java | 4 +- .../grid/kernal/processors/rest/TestTask2.java | 4 +- .../java/org/apache/ignite/IgniteCluster.java | 32 ++-- .../java/org/apache/ignite/IgniteCompute.java | 72 ++++----- .../org/apache/ignite/IgniteDataLoader.java | 32 ++-- .../java/org/apache/ignite/IgniteEvents.java | 20 +-- .../main/java/org/apache/ignite/IgniteFs.java | 80 +++++----- .../java/org/apache/ignite/IgniteManaged.java | 28 ++-- .../java/org/apache/ignite/IgniteMessaging.java | 20 +-- .../java/org/apache/ignite/IgniteStreamer.java | 16 +- .../main/java/org/apache/ignite/Ignition.java | 45 ++++-- .../cache/query/QueryContinuousPredicate.java | 2 +- .../org/apache/ignite/cluster/ClusterGroup.java | 4 +- .../cluster/ClusterTopologyException.java | 2 +- .../ComputeExecutionRejectedException.java | 2 +- .../org/apache/ignite/compute/ComputeJob.java | 6 +- .../compute/ComputeJobContinuationAdapter.java | 6 +- .../compute/ComputeJobMasterLeaveAware.java | 4 +- .../apache/ignite/compute/ComputeJobResult.java | 4 +- .../ignite/compute/ComputeJobSibling.java | 4 +- .../ignite/compute/ComputeLoadBalancer.java | 10 +- .../org/apache/ignite/compute/ComputeTask.java | 20 +-- .../ignite/compute/ComputeTaskAdapter.java | 12 +- .../compute/ComputeTaskCancelledException.java | 2 +- .../compute/ComputeTaskContinuousMapper.java | 16 +- .../ignite/compute/ComputeTaskFuture.java | 6 +- .../ignite/compute/ComputeTaskSession.java | 40 ++--- .../ignite/compute/ComputeTaskSplitAdapter.java | 14 +- .../compute/ComputeTaskTimeoutException.java | 2 +- .../compute/ComputeUserUndeclaredException.java | 2 +- .../apache/ignite/compute/gridify/Gridify.java | 2 +- .../compute/gridify/GridifyInterceptor.java | 4 +- .../gridify/aop/GridifyDefaultRangeTask.java | 8 +- .../compute/gridify/aop/GridifyDefaultTask.java | 4 +- .../configuration/IgniteAddressResolver.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 | 14 +- .../IgniteFsByteDelimiterRecordResolver.java | 3 +- .../IgniteFsFixedLengthRecordResolver.java | 2 +- .../ignite/lang/IgniteAsyncSupportAdapter.java | 4 +- .../org/apache/ignite/lang/IgniteFuture.java | 32 ++-- .../lang/IgniteFutureCancelledException.java | 2 +- .../lang/IgniteFutureTimeoutException.java | 2 +- .../apache/ignite/lifecycle/LifecycleAware.java | 8 +- .../apache/ignite/lifecycle/LifecycleBean.java | 4 +- .../marshaller/IgniteAbstractMarshaller.java | 4 +- .../ignite/marshaller/IgniteMarshaller.java | 16 +- .../marshaller/jdk/IgniteJdkMarshaller.java | 10 +- .../optimized/IgniteOptimizedMarshaller.java | 32 ++-- .../apache/ignite/plugin/PluginProvider.java | 12 +- .../ignite/plugin/security/GridSecurity.java | 4 +- .../GridSecurityCredentialsBasicProvider.java | 2 +- .../GridSecurityCredentialsProvider.java | 4 +- .../segmentation/GridSegmentationResolver.java | 4 +- .../product/IgniteProductLicenseException.java | 2 +- .../ignite/product/IgniteProductVersion.java | 2 +- .../ignite/scheduler/SchedulerFuture.java | 24 +-- .../ignite/spi/IgniteSpiCloseableIterator.java | 4 +- .../apache/ignite/spi/IgniteSpiException.java | 2 +- .../AuthenticationAclProvider.java | 4 +- .../spi/checkpoint/sharedfs/SharedFsUtils.java | 8 +- .../DiscoverySpiNodeAuthenticator.java | 4 +- .../spi/discovery/tcp/TcpDiscoverySpi.java | 14 +- .../discovery/tcp/TcpDiscoverySpiAdapter.java | 4 +- .../ignite/spi/failover/FailoverContext.java | 4 +- .../spi/loadbalancing/LoadBalancingSpi.java | 4 +- .../adaptive/AdaptiveLoadBalancingSpi.java | 12 +- .../RoundRobinGlobalLoadBalancer.java | 18 +-- .../roundrobin/RoundRobinLoadBalancingSpi.java | 8 +- .../apache/ignite/streamer/StreamerContext.java | 24 +-- .../apache/ignite/streamer/StreamerStage.java | 4 +- .../apache/ignite/streamer/StreamerWindow.java | 44 +++--- .../ignite/streamer/index/StreamerIndex.java | 2 +- .../streamer/index/StreamerIndexProvider.java | 8 +- .../index/StreamerIndexProviderAdapter.java | 24 +-- .../streamer/index/StreamerIndexUpdater.java | 4 +- .../index/hash/StreamerHashIndexProvider.java | 6 +- .../index/tree/StreamerTreeIndexProvider.java | 4 +- .../window/StreamerBoundedSizeBatchWindow.java | 6 +- .../StreamerBoundedSizeWindowAdapter.java | 4 +- .../window/StreamerBoundedTimeBatchWindow.java | 8 +- .../window/StreamerBoundedTimeWindow.java | 2 +- .../streamer/window/StreamerWindowAdapter.java | 42 +++--- .../client/router/impl/GridTcpRouterImpl.java | 12 +- .../gridgain/grid/GridDeploymentException.java | 2 +- .../gridgain/grid/GridInterruptedException.java | 4 +- .../org/gridgain/grid/cache/GridCacheTx.java | 2 +- .../cache/GridCacheTxOptimisticException.java | 2 +- .../cache/query/GridCacheContinuousQuery.java | 2 +- .../grid/cache/query/GridCacheQueryFuture.java | 12 +- .../grid/hadoop/GridHadoopSerialization.java | 2 +- .../grid/hadoop/GridHadoopTaskInput.java | 2 +- .../grid/hadoop/GridHadoopTaskOutput.java | 2 +- .../grid/kernal/ClusterGroupAdapter.java | 2 +- .../gridgain/grid/kernal/GridComponentType.java | 34 ++--- .../grid/kernal/GridInternalException.java | 2 +- .../grid/kernal/GridJobExecuteResponse.java | 12 +- .../gridgain/grid/kernal/GridJobResultImpl.java | 6 +- .../grid/kernal/GridJobSessionImpl.java | 59 ++++++-- .../grid/kernal/GridJobSiblingImpl.java | 12 +- .../org/gridgain/grid/kernal/GridKernal.java | 47 ++++-- .../org/gridgain/grid/kernal/GridKillTask.java | 6 +- .../gridgain/grid/kernal/GridLoggerProxy.java | 4 +- .../grid/kernal/GridTaskFutureImpl.java | 2 +- .../grid/kernal/GridTaskSessionImpl.java | 50 ++++--- .../grid/kernal/IgniteClusterAsyncImpl.java | 27 ++-- .../gridgain/grid/kernal/IgniteComputeImpl.java | 39 ++--- .../gridgain/grid/kernal/IgniteEventsImpl.java | 10 +- .../gridgain/grid/kernal/IgniteManagedImpl.java | 15 +- .../grid/kernal/IgniteMessagingImpl.java | 31 +++- .../managers/communication/GridIoManager.java | 2 +- .../deployment/GridDeploymentCommunication.java | 2 +- .../discovery/GridDiscoveryManager.java | 16 +- .../eventstorage/GridEventStorageManager.java | 2 +- .../failover/GridFailoverContextImpl.java | 9 +- .../managers/indexing/GridIndexingManager.java | 4 +- .../loadbalancer/GridLoadBalancerManager.java | 21 ++- .../managers/security/GridSecurityImpl.java | 19 ++- .../affinity/GridAffinityAssignmentCache.java | 2 +- .../processors/cache/GridCacheAdapter.java | 35 +++-- .../cache/GridCacheEvictionManager.java | 2 +- .../processors/cache/GridCacheGateway.java | 2 +- .../processors/cache/GridCacheIoManager.java | 2 +- .../processors/cache/GridCacheStoreManager.java | 2 +- .../processors/cache/GridCacheSwapManager.java | 14 +- .../processors/cache/GridCacheTxAdapter.java | 19 ++- .../processors/cache/GridCacheTxHandler.java | 8 +- .../cache/GridCacheTxLocalAdapter.java | 12 +- .../processors/cache/GridCacheTxManager.java | 2 +- .../processors/cache/GridCacheTxProxyImpl.java | 2 +- .../kernal/processors/cache/GridCacheUtils.java | 2 +- .../cache/GridCacheWriteBehindStore.java | 4 +- .../GridCacheDataStructuresManager.java | 13 +- .../cache/datastructures/GridCacheSetImpl.java | 82 ++++------ .../distributed/dht/GridDhtCacheAdapter.java | 2 +- .../distributed/dht/GridDhtLockFuture.java | 2 +- .../dht/GridDhtTransactionalCacheAdapter.java | 2 +- .../distributed/dht/GridDhtTxFinishFuture.java | 4 +- .../cache/distributed/dht/GridDhtTxLocal.java | 2 +- .../distributed/dht/GridDhtTxPrepareFuture.java | 2 +- .../dht/GridPartitionedGetFuture.java | 2 +- .../dht/colocated/GridDhtColocatedCache.java | 2 +- .../dht/preloader/GridDhtForceKeysFuture.java | 2 +- .../preloader/GridDhtPartitionDemandPool.java | 2 +- .../GridDhtPartitionsExchangeFuture.java | 2 +- .../distributed/near/GridNearGetFuture.java | 6 +- .../near/GridNearTxFinishFuture.java | 7 +- .../cache/distributed/near/GridNearTxLocal.java | 12 +- .../query/GridCacheDistributedQueryFuture.java | 2 +- .../cache/query/GridCacheLocalQueryFuture.java | 2 +- .../cache/query/GridCacheQueryErrorFuture.java | 4 +- .../query/GridCacheQueryFutureAdapter.java | 12 +- .../cache/query/GridCacheQueryManager.java | 57 +++---- .../GridCacheContinuousQueryAdapter.java | 2 +- .../jdbc/GridCacheQueryJdbcMetadataTask.java | 6 +- .../query/jdbc/GridCacheQueryJdbcTask.java | 14 +- .../jdbc/GridCacheQueryJdbcValidationTask.java | 4 +- .../closure/GridClosureProcessor.java | 66 ++++---- .../continuous/GridContinuousProcessor.java | 4 +- .../dataload/GridDataLoaderFuture.java | 2 +- .../dataload/GridDataLoaderProcessor.java | 8 +- .../dataload/IgniteDataLoaderImpl.java | 42 +++--- .../processors/ggfs/GridGgfsAckMessage.java | 6 +- .../processors/ggfs/GridGgfsAsyncImpl.java | 60 ++++---- .../processors/ggfs/GridGgfsDataManager.java | 29 ++-- .../grid/kernal/processors/ggfs/GridGgfsEx.java | 6 +- .../kernal/processors/ggfs/GridGgfsImpl.java | 66 ++++---- .../kernal/processors/ggfs/GridGgfsJobImpl.java | 4 +- .../kernal/processors/job/GridJobProcessor.java | 16 +- .../kernal/processors/job/GridJobWorker.java | 20 +-- .../processors/rest/GridRestProcessor.java | 2 +- .../protocols/tcp/GridTcpRestNioListener.java | 4 +- .../service/GridServiceProcessor.java | 8 +- .../streamer/GridStreamerContextDelegate.java | 12 +- .../streamer/GridStreamerContextImpl.java | 12 +- .../GridStreamerStageExecutionFuture.java | 2 +- .../processors/streamer/IgniteStreamerImpl.java | 20 +-- .../streamer/StreamerStageWrapper.java | 2 +- .../task/GridStreamerBroadcastTask.java | 8 +- .../streamer/task/GridStreamerQueryTask.java | 8 +- .../streamer/task/GridStreamerReduceTask.java | 8 +- .../processors/task/GridTaskProcessor.java | 8 +- .../kernal/processors/task/GridTaskWorker.java | 76 ++++------ .../gridgain/grid/kernal/visor/VisorJob.java | 9 +- .../grid/kernal/visor/VisorMultiNodeTask.java | 14 +- .../grid/kernal/visor/VisorOneNodeTask.java | 2 +- .../cache/VisorCacheMetricsCollectorTask.java | 2 +- .../compute/VisorComputeCancelSessionsTask.java | 2 +- .../VisorComputeToggleMonitoringTask.java | 2 +- .../kernal/visor/log/VisorLogSearchTask.java | 2 +- .../grid/kernal/visor/misc/VisorAckTask.java | 2 +- .../grid/kernal/visor/misc/VisorNopTask.java | 8 +- .../visor/node/VisorNodeDataCollectorTask.java | 10 +- .../node/VisorNodeEventsCollectorTask.java | 2 +- .../grid/kernal/visor/node/VisorNodeGcTask.java | 2 +- .../kernal/visor/node/VisorNodePingTask.java | 4 +- .../kernal/visor/node/VisorNodeRestartTask.java | 2 +- .../kernal/visor/node/VisorNodeStopTask.java | 2 +- .../visor/query/VisorQueryCleanupTask.java | 4 +- .../grid/util/GridCloseableIteratorAdapter.java | 6 +- .../util/GridCloseableIteratorAdapterEx.java | 6 +- .../grid/util/GridEmptyCloseableIterator.java | 2 +- .../util/GridSpiCloseableIteratorWrapper.java | 2 +- .../java/org/gridgain/grid/util/GridUtils.java | 149 ++++++++++++------- .../gridgain/grid/util/GridWeakIterator.java | 4 +- .../grid/util/future/GridCompoundFuture.java | 6 +- .../grid/util/future/GridEmbeddedFuture.java | 2 +- .../grid/util/future/GridFinishedFuture.java | 6 +- .../grid/util/future/GridFinishedFutureEx.java | 6 +- .../grid/util/future/GridFutureAdapter.java | 11 +- .../grid/util/future/GridFutureAdapterEx.java | 12 +- .../grid/util/gridify/GridifyJobAdapter.java | 2 +- .../grid/util/lang/GridCloseableIterator.java | 4 +- .../grid/util/lang/GridComputeJobWrapper.java | 2 +- .../grid/util/offheap/unsafe/GridUnsafeMap.java | 10 +- .../unsafe/GridUnsafePartitionedMap.java | 4 +- .../grid/util/worker/GridWorkerFuture.java | 2 +- .../optimized/GridOptimizedMarshallerTest.java | 2 +- .../collision/GridTestCollisionTaskSession.java | 12 +- .../tcp/GridOrderedMessageCancelSelfTest.java | 10 +- .../local/GridLocalDeploymentSpiSelfTest.java | 8 +- .../spi/failover/GridFailoverTestContext.java | 2 +- .../index/GridStreamerIndexSelfTest.java | 2 +- .../java/org/gridgain/grid/GridTestJob.java | 2 +- .../java/org/gridgain/grid/GridTestTask.java | 2 +- .../org/gridgain/grid/GridTestTaskSession.java | 10 +- .../GridAlwaysFailoverSpiFailSelfTest.java | 4 +- .../kernal/GridCancelOnGridStopSelfTest.java | 6 +- .../kernal/GridCancelUnusedJobSelfTest.java | 4 +- .../GridCancelledJobsMetricsSelfTest.java | 2 +- .../GridContinuousJobAnnotationSelfTest.java | 8 +- .../GridContinuousJobSiblingsSelfTest.java | 8 +- .../grid/kernal/GridContinuousTaskSelfTest.java | 18 +-- .../GridDeploymentMultiThreadedSelfTest.java | 4 +- .../grid/kernal/GridDeploymentSelfTest.java | 12 +- .../GridEventStorageCheckAllEventsSelfTest.java | 8 +- .../grid/kernal/GridEventStorageSelfTest.java | 6 +- .../GridExplicitImplicitDeploymentSelfTest.java | 6 +- .../GridFailoverCustomTopologySelfTest.java | 6 +- .../grid/kernal/GridFailoverSelfTest.java | 8 +- .../GridFailoverTaskWithPredicateSelfTest.java | 8 +- .../kernal/GridFailoverTopologySelfTest.java | 8 +- .../GridJobCheckpointCleanupSelfTest.java | 6 +- .../grid/kernal/GridJobContextSelfTest.java | 4 +- .../kernal/GridJobMasterLeaveAwareSelfTest.java | 14 +- .../grid/kernal/GridJobStealingSelfTest.java | 8 +- .../GridJobStealingZeroActiveJobsSelfTest.java | 6 +- .../grid/kernal/GridJobSubjectIdSelfTest.java | 6 +- .../grid/kernal/GridLifecycleAwareSelfTest.java | 12 +- .../grid/kernal/GridLifecycleBeanSelfTest.java | 4 +- .../grid/kernal/GridListenActorSelfTest.java | 4 +- .../grid/kernal/GridManagementJobSelfTest.java | 4 +- .../grid/kernal/GridMultipleSpisSelfTest.java | 8 +- .../GridMultipleVersionsDeploymentSelfTest.java | 6 +- .../GridMultithreadedJobStealingSelfTest.java | 6 +- .../kernal/GridNonHistoryMetricsSelfTest.java | 2 +- .../grid/kernal/GridProjectionAbstractTest.java | 6 +- .../kernal/GridRuntimeExceptionSelfTest.java | 6 +- .../grid/kernal/GridStopWithCancelSelfTest.java | 4 +- .../grid/kernal/GridStopWithWaitSelfTest.java | 12 +- .../GridTaskCancelSingleNodeSelfTest.java | 2 +- .../GridTaskContinuousMapperSelfTest.java | 16 +- .../GridTaskExecutionContextSelfTest.java | 6 +- .../grid/kernal/GridTaskFailoverSelfTest.java | 2 +- .../GridTaskFutureImplStopGridSelfTest.java | 4 +- .../GridTaskInstanceExecutionSelfTest.java | 4 +- .../kernal/GridTaskInstantiationSelfTest.java | 2 +- .../grid/kernal/GridTaskJobRejectSelfTest.java | 2 +- .../grid/kernal/GridTaskListenerSelfTest.java | 2 +- .../grid/kernal/GridTaskMapAsyncSelfTest.java | 8 +- .../kernal/GridTaskNameAnnotationSelfTest.java | 6 +- .../kernal/GridTaskResultCacheSelfTest.java | 10 +- .../grid/kernal/GridTaskTimeoutSelfTest.java | 4 +- .../GridCheckpointManagerAbstractSelfTest.java | 20 +-- .../checkpoint/GridCheckpointTaskSelfTest.java | 12 +- ...idCommunicationManagerListenersSelfTest.java | 4 +- .../cache/GridCacheAbstractFullApiSelfTest.java | 4 +- .../cache/GridCacheAffinityRoutingSelfTest.java | 6 +- .../GridCacheConcurrentTxMultiNodeTest.java | 8 +- .../cache/GridCacheGroupLockPutTask.java | 6 +- .../processors/cache/GridCachePutAllTask.java | 8 +- .../GridCacheQueryIndexingDisabledSelfTest.java | 6 +- .../cache/GridCacheTxMultiNodeAbstractTest.java | 8 +- ...cheAtomicReferenceMultiNodeAbstractTest.java | 12 +- ...GridCacheQueueMultiNodeAbstractSelfTest.java | 8 +- ...CacheQueueRotativeMultiNodeAbstractTest.java | 10 +- ...dCacheSequenceMultiNodeAbstractSelfTest.java | 4 +- ...dCachePartitionedQueueEntryMoveSelfTest.java | 4 +- .../dht/GridCacheDhtPreloadBigDataSelfTest.java | 2 +- .../dht/GridCacheDhtPreloadUnloadSelfTest.java | 2 +- ...achePartitionedMultiNodeCounterSelfTest.java | 2 +- ...achePartitionedPreloadLifecycleSelfTest.java | 2 +- ...CacheReplicatedPreloadLifecycleSelfTest.java | 2 +- .../GridCacheRandomEvictionPolicySelfTest.java | 2 +- .../clock/GridTimeSyncProcessorSelfTest.java | 2 +- .../ggfs/GridGgfsFileInfoSelfTest.java | 2 +- .../processors/ggfs/GridGgfsTaskSelfTest.java | 6 +- .../processors/streamer/GridTestStage.java | 2 +- .../grid/loadtest/GridSingleExecutionTest.java | 14 +- .../grid/p2p/GridP2PJobClassLoaderSelfTest.java | 6 +- .../p2p/GridP2PLocalDeploymentSelfTest.java | 6 +- .../grid/p2p/GridP2PRecursionTaskSelfTest.java | 6 +- .../p2p/GridP2PRemoteClassLoadersSelfTest.java | 6 +- .../org/gridgain/grid/p2p/GridP2PTestJob.java | 2 +- .../org/gridgain/grid/p2p/GridP2PTestTask.java | 4 +- ...SessionCancelSiblingsFromFutureSelfTest.java | 6 +- ...ridSessionCancelSiblingsFromJobSelfTest.java | 8 +- ...idSessionCancelSiblingsFromTaskSelfTest.java | 6 +- .../GridSessionCheckpointAbstractSelfTest.java | 6 +- .../GridSessionCollisionSpiSelfTest.java | 4 +- ...idSessionFutureWaitJobAttributeSelfTest.java | 8 +- ...dSessionFutureWaitTaskAttributeSelfTest.java | 6 +- .../session/GridSessionJobFailoverSelfTest.java | 8 +- ...GridSessionJobWaitTaskAttributeSelfTest.java | 8 +- .../grid/session/GridSessionLoadSelfTest.java | 6 +- .../GridSessionSetFutureAttributeSelfTest.java | 8 +- ...nSetFutureAttributeWaitListenerSelfTest.java | 8 +- .../GridSessionSetJobAttribute2SelfTest.java | 6 +- ...GridSessionSetJobAttributeOrderSelfTest.java | 6 +- .../GridSessionSetJobAttributeSelfTest.java | 8 +- ...sionSetJobAttributeWaitListenerSelfTest.java | 8 +- .../GridSessionSetTaskAttributeSelfTest.java | 8 +- ...GridSessionTaskWaitJobAttributeSelfTest.java | 8 +- .../GridSessionWaitAttributeSelfTest.java | 6 +- .../offheap/GridOffHeapMapAbstractSelfTest.java | 2 +- .../loadtests/GridCacheLoadPopulationTask.java | 6 +- .../colocation/GridTestLifecycleBean.java | 2 +- .../direct/multisplit/GridLoadTestJob.java | 2 +- .../direct/multisplit/GridLoadTestTask.java | 4 +- .../GridSingleSplitNewNodesTestTask.java | 6 +- .../direct/session/GridSessionLoadTestJob.java | 2 +- .../direct/session/GridSessionLoadTestTask.java | 4 +- .../stealing/GridStealingLoadTestJob.java | 2 +- .../stealing/GridStealingLoadTestTask.java | 4 +- .../loadtests/dsi/GridDsiLifecycleBean.java | 2 +- .../loadtests/dsi/GridDsiRequestTask.java | 4 +- .../loadtests/dsi/GridDsiResponseTask.java | 4 +- .../job/GridJobExecutionLoadTestJob.java | 2 +- .../job/GridJobExecutionLoadTestTask.java | 6 +- .../job/GridJobExecutionSingleNodeLoadTest.java | 10 +- ...JobExecutionSingleNodeSemaphoreLoadTest.java | 8 +- .../loadtests/job/GridJobLoadTestJob.java | 2 +- .../loadtests/job/GridJobLoadTestTask.java | 6 +- .../mapper/GridContinuousMapperTask1.java | 6 +- .../mapper/GridContinuousMapperTask2.java | 6 +- .../mergesort/GridMergeSortLoadTask.java | 2 +- .../loadtests/streamer/average/TestStage.java | 2 +- .../gridgain/testframework/GridTestUtils.java | 2 +- .../cache/GridAbstractCacheStoreSelfTest.java | 2 +- .../tests/p2p/GridCacheDeploymentTestTask1.java | 6 +- .../tests/p2p/GridCacheDeploymentTestTask2.java | 4 +- .../tests/p2p/GridCacheDeploymentTestTask3.java | 6 +- .../p2p/GridP2PContinuousDeploymentTask1.java | 6 +- .../p2p/GridP2PContinuousDeploymentTask2.java | 4 +- .../tests/p2p/GridP2PTestTaskExternalPath1.java | 6 +- .../tests/p2p/GridP2PTestTaskExternalPath2.java | 6 +- .../grid/tests/p2p/GridSingleSplitTestTask.java | 4 +- .../grid/tests/p2p/JobStealingTask.java | 6 +- .../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 +- .../hadoop/GridGgfsHadoopFileSystemWrapper.java | 28 ++-- .../hadoop/jobtracker/GridHadoopJobTracker.java | 2 +- .../proto/GridHadoopProtocolTaskAdapter.java | 8 +- .../hadoop/shuffle/GridHadoopShuffleJob.java | 4 +- .../GridHadoopConcurrentHashMultimap.java | 4 +- .../collections/GridHadoopHashMultimapBase.java | 2 +- .../collections/GridHadoopMultimapBase.java | 4 +- .../shuffle/collections/GridHadoopSkipList.java | 4 +- .../taskexecutor/GridHadoopRunnableTask.java | 2 +- .../v2/GridHadoopSerializationWrapper.java | 2 +- ...idHadoopDefaultMapReducePlannerSelfTest.java | 70 ++++----- .../GridHibernateAccessStrategyAdapter.java | 2 +- .../query/h2/GridH2ResultSetIterator.java | 2 +- .../query/h2/opt/GridLuceneIndex.java | 2 +- .../processors/schedule/ScheduleFutureImpl.java | 24 +-- .../resource/GridUserExternalResourceTask1.java | 6 +- .../resource/GridUserExternalResourceTask2.java | 4 +- .../grid/kernal/GridFactorySelfTest.java | 6 +- .../GridResourceConcurrentUndeploySelfTest.java | 4 +- .../GridResourceEventFilterSelfTest.java | 4 +- .../GridResourceFieldInjectionSelfTest.java | 20 +-- ...dResourceFieldOverrideInjectionSelfTest.java | 4 +- .../resource/GridResourceIocSelfTest.java | 8 +- ...GridResourceIsolatedClassLoaderSelfTest.java | 16 +- .../GridResourceIsolatedTaskSelfTest.java | 16 +- .../GridResourceMethodInjectionSelfTest.java | 8 +- ...ResourceMethodOverrideInjectionSelfTest.java | 4 +- .../resource/GridResourceProcessorSelfTest.java | 4 +- .../GridResourceSharedUndeploySelfTest.java | 8 +- .../GridP2PContinuousLocalDeploySelfTest.java | 8 +- ...riDeploymentClassloaderRegisterSelfTest.java | 4 +- .../uri/GridUriDeploymentSimpleSelfTest.java | 8 +- 441 files changed, 2079 insertions(+), 1947 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/examples/src/main/java/org/gridgain/examples/compute/ComputeContinuousMapperExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/gridgain/examples/compute/ComputeContinuousMapperExample.java b/examples/src/main/java/org/gridgain/examples/compute/ComputeContinuousMapperExample.java index e32664b..339ae09 100644 --- a/examples/src/main/java/org/gridgain/examples/compute/ComputeContinuousMapperExample.java +++ b/examples/src/main/java/org/gridgain/examples/compute/ComputeContinuousMapperExample.java @@ -81,7 +81,7 @@ public class ComputeContinuousMapperExample { /** {@inheritDoc} */ @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> grid, String phrase) - throws IgniteCheckedException { + throws IgniteException { if (phrase == null || phrase.isEmpty()) throw new IgniteCheckedException("Phrase is empty."); @@ -98,7 +98,7 @@ public class ComputeContinuousMapperExample { /** {@inheritDoc} */ @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) - throws IgniteCheckedException { + throws IgniteException { // If there is an error, fail-over to another node. if (res.getException() != null) return super.result(res, rcvd); @@ -113,7 +113,7 @@ public class ComputeContinuousMapperExample { } /** {@inheritDoc} */ - @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteException { return totalChrCnt.get(); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/examples/src/main/java/org/gridgain/examples/ggfs/GgfsMapReduceExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/gridgain/examples/ggfs/GgfsMapReduceExample.java b/examples/src/main/java/org/gridgain/examples/ggfs/GgfsMapReduceExample.java index f73fb28..005a3fa 100644 --- a/examples/src/main/java/org/gridgain/examples/ggfs/GgfsMapReduceExample.java +++ b/examples/src/main/java/org/gridgain/examples/ggfs/GgfsMapReduceExample.java @@ -122,12 +122,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) throws IgniteException { return new GrepJob(args.userArgument()); } /** {@inheritDoc} */ - @Override public Collection<Line> reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Collection<Line> reduce(List<ComputeJobResult> results) throws IgniteException { Collection<Line> lines = new TreeSet<>(new Comparator<Line>() { @Override public int compare(Line line1, Line line2) { return line1.rangePosition() < line2.rangePosition() ? -1 : @@ -166,7 +166,7 @@ public class GgfsMapReduceExample { } /** {@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/8bc850c2/examples/src/main/java/org/gridgain/examples/messaging/MessagingPingPongListenActorExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/gridgain/examples/messaging/MessagingPingPongListenActorExample.java b/examples/src/main/java/org/gridgain/examples/messaging/MessagingPingPongListenActorExample.java index 175e960..cae4690 100644 --- a/examples/src/main/java/org/gridgain/examples/messaging/MessagingPingPongListenActorExample.java +++ b/examples/src/main/java/org/gridgain/examples/messaging/MessagingPingPongListenActorExample.java @@ -57,7 +57,7 @@ public class MessagingPingPongListenActorExample { // Set up remote player. g.message(nodeB).remoteListen(null, new MessagingListenActor<String>() { - @Override public void receive(UUID nodeId, String rcvMsg) throws IgniteCheckedException { + @Override public void receive(UUID nodeId, String rcvMsg) throws IgniteException { System.out.println(rcvMsg); if ("PING".equals(rcvMsg)) @@ -73,7 +73,7 @@ public class MessagingPingPongListenActorExample { // Set up local player. g.message().localListen(null, new MessagingListenActor<String>() { - @Override protected void receive(UUID nodeId, String rcvMsg) throws IgniteCheckedException { + @Override protected void receive(UUID nodeId, String rcvMsg) throws IgniteException { System.out.println(rcvMsg); if (cnt.getCount() == 1) http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/examples/src/main/java/org/gridgain/examples/misc/deployment/DeploymentExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/gridgain/examples/misc/deployment/DeploymentExample.java b/examples/src/main/java/org/gridgain/examples/misc/deployment/DeploymentExample.java index fc59f83..9e44f46 100644 --- a/examples/src/main/java/org/gridgain/examples/misc/deployment/DeploymentExample.java +++ b/examples/src/main/java/org/gridgain/examples/misc/deployment/DeploymentExample.java @@ -97,7 +97,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) throws IgniteException { Collection<ComputeJob> jobs = new ArrayList<>(gridSize); for (int i = 0; i < gridSize; i++) { @@ -115,7 +115,7 @@ public final class DeploymentExample { } /** {@inheritDoc} */ - @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { return null; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/examples/src/main/java/org/gridgain/examples/streaming/StreamingCheckInExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/gridgain/examples/streaming/StreamingCheckInExample.java b/examples/src/main/java/org/gridgain/examples/streaming/StreamingCheckInExample.java index 28fc25d..d0826e9 100644 --- a/examples/src/main/java/org/gridgain/examples/streaming/StreamingCheckInExample.java +++ b/examples/src/main/java/org/gridgain/examples/streaming/StreamingCheckInExample.java @@ -424,7 +424,7 @@ public class StreamingCheckInExample { /** {@inheritDoc} */ @Nullable @Override public Map<String, Collection<?>> run( - StreamerContext ctx, Collection<CheckInEvent> evts) throws IgniteCheckedException { + StreamerContext ctx, Collection<CheckInEvent> evts) throws IgniteException { StreamerWindow<CheckInEvent> win = ctx.window(name()); assert win != null; @@ -472,7 +472,7 @@ public class StreamingCheckInExample { /** {@inheritDoc} */ @Nullable @Override public Map<String, Collection<?>> run(StreamerContext ctx, - Collection<CheckInEvent> evts) throws IgniteCheckedException { + Collection<CheckInEvent> evts) throws IgniteException { StreamerWindow<LocationInfo> win = ctx.window(name()); assert win != null; @@ -530,7 +530,7 @@ public class StreamingCheckInExample { /** {@inheritDoc} */ @Nullable @Override public Location onAdded( StreamerIndexEntry<CheckInEvent, String, Location> entry, - CheckInEvent evt) throws IgniteCheckedException { + CheckInEvent evt) throws IgniteException { throw new AssertionError("onAdded() shouldn't be called on unique index."); } @@ -561,7 +561,7 @@ public class StreamingCheckInExample { /** {@inheritDoc} */ @Nullable @Override public Place onAdded( StreamerIndexEntry<LocationInfo, String, Place> entry, - LocationInfo evt) throws IgniteCheckedException { + LocationInfo evt) throws IgniteException { throw new AssertionError("onAdded() shouldn't be called on unique index."); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/examples/src/main/java/org/gridgain/examples/streaming/StreamingPopularNumbersExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/gridgain/examples/streaming/StreamingPopularNumbersExample.java b/examples/src/main/java/org/gridgain/examples/streaming/StreamingPopularNumbersExample.java index 2415195..e4bf863 100644 --- a/examples/src/main/java/org/gridgain/examples/streaming/StreamingPopularNumbersExample.java +++ b/examples/src/main/java/org/gridgain/examples/streaming/StreamingPopularNumbersExample.java @@ -201,7 +201,7 @@ public class StreamingPopularNumbersExample { /** {@inheritDoc} */ @Nullable @Override public Map<String, Collection<?>> run(StreamerContext ctx, Collection<Integer> nums) - throws IgniteCheckedException { + throws IgniteException { StreamerWindow<Integer> win = ctx.window(); // Add numbers to window. http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/examples/src/main/java/org/gridgain/examples/streaming/StreamingPriceBarsExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/gridgain/examples/streaming/StreamingPriceBarsExample.java b/examples/src/main/java/org/gridgain/examples/streaming/StreamingPriceBarsExample.java index 14d4885..23e9443 100644 --- a/examples/src/main/java/org/gridgain/examples/streaming/StreamingPriceBarsExample.java +++ b/examples/src/main/java/org/gridgain/examples/streaming/StreamingPriceBarsExample.java @@ -372,7 +372,7 @@ public class StreamingPriceBarsExample { /** {@inheritDoc} */ @Nullable @Override public Map<String, Collection<?>> run(StreamerContext ctx, Collection<Quote> quotes) - throws IgniteCheckedException { + throws IgniteException { StreamerWindow win = ctx.window("stage1"); // Add numbers to window. @@ -413,7 +413,7 @@ public class StreamingPriceBarsExample { /** {@inheritDoc} */ @Nullable @Override public Map<String, Collection<?>> run(StreamerContext ctx, Collection<Bar> bars) - throws IgniteCheckedException { + throws IgniteException { ConcurrentMap<String, Bar> loc = ctx.localSpace(); StreamerWindow win = ctx.window("stage2"); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/examples/src/main/java/org/gridgain/examples/streaming/StreamingRunningAverageExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/gridgain/examples/streaming/StreamingRunningAverageExample.java b/examples/src/main/java/org/gridgain/examples/streaming/StreamingRunningAverageExample.java index 3eff875..cd29378 100644 --- a/examples/src/main/java/org/gridgain/examples/streaming/StreamingRunningAverageExample.java +++ b/examples/src/main/java/org/gridgain/examples/streaming/StreamingRunningAverageExample.java @@ -149,7 +149,7 @@ public class StreamingRunningAverageExample { /** {@inheritDoc} */ @Nullable @Override public Map<String, Collection<?>> run(StreamerContext ctx, Collection<Integer> evts) - throws IgniteCheckedException { + throws IgniteException { ConcurrentMap<String, Average> loc = ctx.localSpace(); Average avg = loc.get("avg"); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/aop/src/test/java/org/gridgain/grid/gridify/GridBasicAopSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/aop/src/test/java/org/gridgain/grid/gridify/GridBasicAopSelfTest.java b/modules/aop/src/test/java/org/gridgain/grid/gridify/GridBasicAopSelfTest.java index 4bdd81d..dda27ba 100644 --- a/modules/aop/src/test/java/org/gridgain/grid/gridify/GridBasicAopSelfTest.java +++ b/modules/aop/src/test/java/org/gridgain/grid/gridify/GridBasicAopSelfTest.java @@ -57,12 +57,12 @@ public class GridBasicAopSelfTest extends GridCommonAbstractTest { private static class TestTask extends GridifyTaskSplitAdapter<Void> { /** {@inheritDoc} */ @Override protected Collection<? extends ComputeJob> split(int gridSize, - GridifyArgument arg) throws IgniteCheckedException { + GridifyArgument arg) throws IgniteException { return null; } /** {@inheritDoc} */ - @Override public Void reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Void reduce(List<ComputeJobResult> results) throws IgniteException { return null; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/aop/src/test/java/org/gridgain/grid/gridify/GridTestGridifyJob.java ---------------------------------------------------------------------- diff --git a/modules/aop/src/test/java/org/gridgain/grid/gridify/GridTestGridifyJob.java b/modules/aop/src/test/java/org/gridgain/grid/gridify/GridTestGridifyJob.java index 948b147..ff2030f 100644 --- a/modules/aop/src/test/java/org/gridgain/grid/gridify/GridTestGridifyJob.java +++ b/modules/aop/src/test/java/org/gridgain/grid/gridify/GridTestGridifyJob.java @@ -32,7 +32,7 @@ public class GridTestGridifyJob extends ComputeJobAdapter { } /** {@inheritDoc} */ - @Override public Serializable execute() throws IgniteCheckedException { + @Override public Serializable execute() throws IgniteException { if (log.isInfoEnabled()) log.info("Execute GridTestGridifyJob.execute(" + argument(0) + ')'); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/aop/src/test/java/org/gridgain/grid/gridify/GridTestGridifyTask.java ---------------------------------------------------------------------- diff --git a/modules/aop/src/test/java/org/gridgain/grid/gridify/GridTestGridifyTask.java b/modules/aop/src/test/java/org/gridgain/grid/gridify/GridTestGridifyTask.java index d6339e6..4456136 100644 --- a/modules/aop/src/test/java/org/gridgain/grid/gridify/GridTestGridifyTask.java +++ b/modules/aop/src/test/java/org/gridgain/grid/gridify/GridTestGridifyTask.java @@ -23,14 +23,14 @@ public class GridTestGridifyTask extends ComputeTaskSplitAdapter<GridifyArgument public static final String TASK_NAME = "org.gridgain.grid.gridify.GridTestGridifyTask"; /** {@inheritDoc} */ - @Override public Collection<? extends ComputeJob> split(int gridSize, GridifyArgument arg) throws IgniteCheckedException { + @Override public Collection<? extends ComputeJob> split(int gridSize, GridifyArgument arg) throws IgniteException { assert arg.getMethodParameters().length == 1; return Collections.singletonList(new GridTestGridifyJob((String)arg.getMethodParameters()[0])); } /** {@inheritDoc} */ - @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { assert results.size() == 1; return results.get(0).getData(); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/aop/src/test/java/org/gridgain/loadtests/direct/singlesplit/GridSingleSplitTestTask.java ---------------------------------------------------------------------- diff --git a/modules/aop/src/test/java/org/gridgain/loadtests/direct/singlesplit/GridSingleSplitTestTask.java b/modules/aop/src/test/java/org/gridgain/loadtests/direct/singlesplit/GridSingleSplitTestTask.java index 7754928..30a81fe 100644 --- a/modules/aop/src/test/java/org/gridgain/loadtests/direct/singlesplit/GridSingleSplitTestTask.java +++ b/modules/aop/src/test/java/org/gridgain/loadtests/direct/singlesplit/GridSingleSplitTestTask.java @@ -29,7 +29,7 @@ public class GridSingleSplitTestTask extends ComputeTaskAdapter<Integer, Integer 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) throws IgniteException { assert !subgrid.isEmpty() : "Subgrid cannot be empty."; Map<ComputeJobAdapter, ClusterNode> jobs = new HashMap<>(subgrid.size()); @@ -46,7 +46,7 @@ public class GridSingleSplitTestTask extends ComputeTaskAdapter<Integer, Integer private ComputeTaskSession jobSes; /** {@inheritDoc} */ - @Override public Object execute() throws IgniteCheckedException { + @Override public Object execute() throws IgniteException { assert jobSes != null; Integer arg = this.<Integer>argument(0); @@ -72,7 +72,7 @@ public class GridSingleSplitTestTask extends ComputeTaskAdapter<Integer, Integer } /** {@inheritDoc} */ - @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteException { int retVal = 0; for (ComputeJobResult res : results) { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/aop/src/test/java/org/gridgain/loadtests/gridify/GridifyLoadTestTask.java ---------------------------------------------------------------------- diff --git a/modules/aop/src/test/java/org/gridgain/loadtests/gridify/GridifyLoadTestTask.java b/modules/aop/src/test/java/org/gridgain/loadtests/gridify/GridifyLoadTestTask.java index a1d66a7..597e286 100644 --- a/modules/aop/src/test/java/org/gridgain/loadtests/gridify/GridifyLoadTestTask.java +++ b/modules/aop/src/test/java/org/gridgain/loadtests/gridify/GridifyLoadTestTask.java @@ -21,7 +21,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) throws IgniteException { assert gridSize > 0 : "Subgrid cannot be empty."; int jobsNum = (Integer)arg.getMethodParameters()[0]; @@ -45,7 +45,7 @@ public class GridifyLoadTestTask extends ComputeTaskSplitAdapter<GridifyArgument } /** {@inheritDoc} */ - @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteException { int retVal = 0; for (ComputeJobResult res : results) { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/aop/src/test/java/org/test/gridify/GridExternalGridifyTask.java ---------------------------------------------------------------------- diff --git a/modules/aop/src/test/java/org/test/gridify/GridExternalGridifyTask.java b/modules/aop/src/test/java/org/test/gridify/GridExternalGridifyTask.java index 82fc40a..90c6d31 100644 --- a/modules/aop/src/test/java/org/test/gridify/GridExternalGridifyTask.java +++ b/modules/aop/src/test/java/org/test/gridify/GridExternalGridifyTask.java @@ -26,7 +26,7 @@ public class GridExternalGridifyTask extends ComputeTaskSplitAdapter<GridifyArgu public static final String TASK_NAME = "org.test.gridify.GridExternalGridifyTask"; /** {@inheritDoc} */ - @Override public Collection<? extends ComputeJob> split(int gridSize, GridifyArgument arg) throws IgniteCheckedException { + @Override public Collection<? extends ComputeJob> split(int gridSize, GridifyArgument arg) throws IgniteException { assert arg.getMethodParameters().length == 1; return Collections.singletonList(new ComputeJobAdapter((String)arg.getMethodParameters()[0]) { @@ -64,7 +64,7 @@ public class GridExternalGridifyTask extends ComputeTaskSplitAdapter<GridifyArgu } /** {@inheritDoc} */ - @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { assert results.size() == 1; return results.get(0).getData(); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/clients/src/test/java/org/gridgain/client/GridClientAbstractMultiThreadedSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/clients/src/test/java/org/gridgain/client/GridClientAbstractMultiThreadedSelfTest.java b/modules/clients/src/test/java/org/gridgain/client/GridClientAbstractMultiThreadedSelfTest.java index 306764e..72551a5 100644 --- a/modules/clients/src/test/java/org/gridgain/client/GridClientAbstractMultiThreadedSelfTest.java +++ b/modules/clients/src/test/java/org/gridgain/client/GridClientAbstractMultiThreadedSelfTest.java @@ -566,7 +566,7 @@ public abstract class GridClientAbstractMultiThreadedSelfTest extends GridCommon /** {@inheritDoc} */ @Override protected Collection<? extends ComputeJob> split(int gridSize, Object arg) - throws IgniteCheckedException { + throws IgniteException { Collection<ComputeJobAdapter> jobs = new ArrayList<>(gridSize); this.gridSize = gridSize; @@ -585,7 +585,7 @@ public abstract class GridClientAbstractMultiThreadedSelfTest extends GridCommon } /** {@inheritDoc} */ - @Override public String reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public String reduce(List<ComputeJobResult> results) throws IgniteException { int sum = 0; String locNodeId = null; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/clients/src/test/java/org/gridgain/client/GridClientGetAffinityTask.java ---------------------------------------------------------------------- diff --git a/modules/clients/src/test/java/org/gridgain/client/GridClientGetAffinityTask.java b/modules/clients/src/test/java/org/gridgain/client/GridClientGetAffinityTask.java index e13b6eb..4357cb3 100644 --- a/modules/clients/src/test/java/org/gridgain/client/GridClientGetAffinityTask.java +++ b/modules/clients/src/test/java/org/gridgain/client/GridClientGetAffinityTask.java @@ -48,7 +48,7 @@ public class GridClientGetAffinityTask extends GridTaskSingleJobSplitAdapter<Str } /** {@inheritDoc} */ - @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) throws IgniteCheckedException { + @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) throws IgniteException { if (res.getException() != null) return FAILOVER; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/clients/src/test/java/org/gridgain/client/GridClientHttpTask.java ---------------------------------------------------------------------- diff --git a/modules/clients/src/test/java/org/gridgain/client/GridClientHttpTask.java b/modules/clients/src/test/java/org/gridgain/client/GridClientHttpTask.java index c018aef..26a25b0 100644 --- a/modules/clients/src/test/java/org/gridgain/client/GridClientHttpTask.java +++ b/modules/clients/src/test/java/org/gridgain/client/GridClientHttpTask.java @@ -27,7 +27,7 @@ public class GridClientHttpTask extends ComputeTaskSplitAdapter<String, Integer> private final GridClientTcpTask delegate = new GridClientTcpTask(); /** {@inheritDoc} */ - @Override protected Collection<? extends ComputeJob> split(int gridSize, String arg) throws IgniteCheckedException { + @Override protected Collection<? extends ComputeJob> split(int gridSize, String arg) throws IgniteException { JSON json = JSONSerializer.toJSON(arg); List list = json.isArray() ? JSONArray.toList((JSONArray)json, String.class, new JsonConfig()) : null; @@ -37,12 +37,12 @@ public class GridClientHttpTask extends ComputeTaskSplitAdapter<String, Integer> } /** {@inheritDoc} */ - @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteException { 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) throws IgniteException { if (res.getException() != null) return FAILOVER; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/clients/src/test/java/org/gridgain/client/GridClientStartNodeTask.java ---------------------------------------------------------------------- diff --git a/modules/clients/src/test/java/org/gridgain/client/GridClientStartNodeTask.java b/modules/clients/src/test/java/org/gridgain/client/GridClientStartNodeTask.java index ada470e..b1d649f 100644 --- a/modules/clients/src/test/java/org/gridgain/client/GridClientStartNodeTask.java +++ b/modules/clients/src/test/java/org/gridgain/client/GridClientStartNodeTask.java @@ -77,7 +77,7 @@ public class GridClientStartNodeTask extends GridTaskSingleJobSplitAdapter<Strin /** {@inheritDoc} */ @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) - throws IgniteCheckedException { + throws IgniteException { if (res.getException() != null) return FAILOVER; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/clients/src/test/java/org/gridgain/client/GridClientStopNodeTask.java ---------------------------------------------------------------------- diff --git a/modules/clients/src/test/java/org/gridgain/client/GridClientStopNodeTask.java b/modules/clients/src/test/java/org/gridgain/client/GridClientStopNodeTask.java index 70de84c..0146c81 100644 --- a/modules/clients/src/test/java/org/gridgain/client/GridClientStopNodeTask.java +++ b/modules/clients/src/test/java/org/gridgain/client/GridClientStopNodeTask.java @@ -36,7 +36,7 @@ public class GridClientStopNodeTask extends ComputeTaskSplitAdapter<String, Inte 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) throws IgniteException { Collection<ComputeJob> jobs = new ArrayList<>(); for (int i = 0; i < gridSize; i++) @@ -46,7 +46,7 @@ public class GridClientStopNodeTask extends ComputeTaskSplitAdapter<String, Inte } /** {@inheritDoc} */ - @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) throws IgniteCheckedException { + @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) throws IgniteException { ComputeJobResultPolicy superRes = super.result(res, rcvd); // Deny failover. @@ -57,7 +57,7 @@ public class GridClientStopNodeTask extends ComputeTaskSplitAdapter<String, Inte } /** {@inheritDoc} */ - @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteException { int stoppedCnt = 0; for (ComputeJobResult res : results) http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/clients/src/test/java/org/gridgain/client/GridClientStringLengthTask.java ---------------------------------------------------------------------- diff --git a/modules/clients/src/test/java/org/gridgain/client/GridClientStringLengthTask.java b/modules/clients/src/test/java/org/gridgain/client/GridClientStringLengthTask.java index d3e8030..3e2ca65 100644 --- a/modules/clients/src/test/java/org/gridgain/client/GridClientStringLengthTask.java +++ b/modules/clients/src/test/java/org/gridgain/client/GridClientStringLengthTask.java @@ -23,7 +23,7 @@ import static org.apache.ignite.compute.ComputeJobResultPolicy.*; */ public class GridClientStringLengthTask 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) throws IgniteException { Collection<ComputeJobAdapter> jobs = new ArrayList<>(); if (arg != null) @@ -45,7 +45,7 @@ public class GridClientStringLengthTask extends ComputeTaskSplitAdapter<String, } /** {@inheritDoc} */ - @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteException { int sum = 0; for (ComputeJobResult res : results) @@ -56,7 +56,7 @@ public class GridClientStringLengthTask extends ComputeTaskSplitAdapter<String, /** {@inheritDoc} */ @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) - throws IgniteCheckedException { + throws IgniteException { if (res.getException() != null) return FAILOVER; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/clients/src/test/java/org/gridgain/client/GridClientTcpTask.java ---------------------------------------------------------------------- diff --git a/modules/clients/src/test/java/org/gridgain/client/GridClientTcpTask.java b/modules/clients/src/test/java/org/gridgain/client/GridClientTcpTask.java index 3fc54b1..057f6ec 100644 --- a/modules/clients/src/test/java/org/gridgain/client/GridClientTcpTask.java +++ b/modules/clients/src/test/java/org/gridgain/client/GridClientTcpTask.java @@ -24,7 +24,7 @@ import static org.apache.ignite.compute.ComputeJobResultPolicy.*; public class GridClientTcpTask extends ComputeTaskSplitAdapter<List<Object>, Integer> { /** {@inheritDoc} */ @Override protected Collection<? extends ComputeJob> split(int gridSize, List<Object> list) - throws IgniteCheckedException { + throws IgniteException { Collection<ComputeJobAdapter> jobs = new ArrayList<>(); if (list != null) @@ -46,7 +46,7 @@ public class GridClientTcpTask extends ComputeTaskSplitAdapter<List<Object>, Int } /** {@inheritDoc} */ - @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteException { int sum = 0; for (ComputeJobResult res : results) @@ -56,7 +56,7 @@ public class GridClientTcpTask extends ComputeTaskSplitAdapter<List<Object>, Int } /** {@inheritDoc} */ - @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) throws IgniteCheckedException { + @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) throws IgniteException { if (res.getException() != null) return FAILOVER; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/clients/src/test/java/org/gridgain/client/GridClientTestPortableAffinityKeyTask.java ---------------------------------------------------------------------- diff --git a/modules/clients/src/test/java/org/gridgain/client/GridClientTestPortableAffinityKeyTask.java b/modules/clients/src/test/java/org/gridgain/client/GridClientTestPortableAffinityKeyTask.java index f997eab..ae7d11f 100644 --- a/modules/clients/src/test/java/org/gridgain/client/GridClientTestPortableAffinityKeyTask.java +++ b/modules/clients/src/test/java/org/gridgain/client/GridClientTestPortableAffinityKeyTask.java @@ -29,11 +29,11 @@ public class GridClientTestPortableAffinityKeyTask extends ComputeTaskAdapter<Ob /** {@inheritDoc} */ @Nullable @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> clusterNodes, - @Nullable final Object arg) throws IgniteCheckedException { + @Nullable final Object arg) throws IgniteException { for (ClusterNode node : clusterNodes) { if (node.isLocal()) return Collections.singletonMap(new ComputeJobAdapter() { - @Override public Object execute() throws IgniteCheckedException { + @Override public Object execute() throws IgniteException { return executeJob(arg); } }, node); @@ -43,7 +43,7 @@ public class GridClientTestPortableAffinityKeyTask extends ComputeTaskAdapter<Ob } /** {@inheritDoc} */ - @Nullable @Override public Boolean reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Nullable @Override public Boolean reduce(List<ComputeJobResult> results) throws IgniteException { return results.get(0).getData(); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/clients/src/test/java/org/gridgain/client/GridSleepTestTask.java ---------------------------------------------------------------------- diff --git a/modules/clients/src/test/java/org/gridgain/client/GridSleepTestTask.java b/modules/clients/src/test/java/org/gridgain/client/GridSleepTestTask.java index 64b6351..79278a0 100644 --- a/modules/clients/src/test/java/org/gridgain/client/GridSleepTestTask.java +++ b/modules/clients/src/test/java/org/gridgain/client/GridSleepTestTask.java @@ -14,7 +14,7 @@ import static org.apache.ignite.compute.ComputeJobResultPolicy.*; public class GridSleepTestTask extends ComputeTaskSplitAdapter<String, Integer> { /** {@inheritDoc} */ @Override public Collection<? extends ComputeJob> split(int gridSize, String arg) - throws IgniteCheckedException { + throws IgniteException { return Collections.singleton(new ComputeJobAdapter(arg) { @Override public Object execute() { try { @@ -32,7 +32,7 @@ public class GridSleepTestTask extends ComputeTaskSplitAdapter<String, Integer> } /** {@inheritDoc} */ - @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteException { int sum = 0; for (ComputeJobResult res : results) @@ -42,7 +42,7 @@ public class GridSleepTestTask extends ComputeTaskSplitAdapter<String, Integer> } /** {@inheritDoc} */ - @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) throws IgniteCheckedException { + @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) throws IgniteException { if (res.getException() != null) return FAILOVER; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/clients/src/test/java/org/gridgain/client/GridTaskSingleJobSplitAdapter.java ---------------------------------------------------------------------- diff --git a/modules/clients/src/test/java/org/gridgain/client/GridTaskSingleJobSplitAdapter.java b/modules/clients/src/test/java/org/gridgain/client/GridTaskSingleJobSplitAdapter.java index d746409..53d205d 100644 --- a/modules/clients/src/test/java/org/gridgain/client/GridTaskSingleJobSplitAdapter.java +++ b/modules/clients/src/test/java/org/gridgain/client/GridTaskSingleJobSplitAdapter.java @@ -28,16 +28,16 @@ public abstract class GridTaskSingleJobSplitAdapter<T, R> extends ComputeTaskSpl } /** {@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) throws IgniteException { return Collections.singleton(new ComputeJobAdapter() { - @Override public Object execute() throws IgniteCheckedException { + @Override public Object execute() throws IgniteException { return executeJob(gridSize, arg); } }); } /** {@inheritDoc} */ - @Override public R reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public R reduce(List<ComputeJobResult> results) throws IgniteException { assert results.size() == 1; ComputeJobResult res = results.get(0); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/clients/src/test/java/org/gridgain/client/integration/GridClientAbstractMultiNodeSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/clients/src/test/java/org/gridgain/client/integration/GridClientAbstractMultiNodeSelfTest.java b/modules/clients/src/test/java/org/gridgain/client/integration/GridClientAbstractMultiNodeSelfTest.java index 96fb9d6..e215cf0 100644 --- a/modules/clients/src/test/java/org/gridgain/client/integration/GridClientAbstractMultiNodeSelfTest.java +++ b/modules/clients/src/test/java/org/gridgain/client/integration/GridClientAbstractMultiNodeSelfTest.java @@ -697,7 +697,7 @@ public abstract class GridClientAbstractMultiNodeSelfTest extends GridCommonAbst /** {@inheritDoc} */ @Override protected Collection<? extends ComputeJob> split(int gridSize, Object arg) - throws IgniteCheckedException { + throws IgniteException { Collection<ComputeJobAdapter> jobs = new ArrayList<>(gridSize); this.gridSize = gridSize; @@ -724,7 +724,7 @@ public abstract class GridClientAbstractMultiNodeSelfTest extends GridCommonAbst } /** {@inheritDoc} */ - @Override public String reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public String reduce(List<ComputeJobResult> results) throws IgniteException { int sum = 0; String locNodeId = null; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/clients/src/test/java/org/gridgain/client/integration/GridClientAbstractSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/clients/src/test/java/org/gridgain/client/integration/GridClientAbstractSelfTest.java b/modules/clients/src/test/java/org/gridgain/client/integration/GridClientAbstractSelfTest.java index f10b9d5..1faf237 100644 --- a/modules/clients/src/test/java/org/gridgain/client/integration/GridClientAbstractSelfTest.java +++ b/modules/clients/src/test/java/org/gridgain/client/integration/GridClientAbstractSelfTest.java @@ -1435,7 +1435,7 @@ public abstract class GridClientAbstractSelfTest extends GridCommonAbstractTest private static class TestTask extends ComputeTaskSplitAdapter<List<Object>, Integer> { /** {@inheritDoc} */ @Override protected Collection<? extends ComputeJob> split(int gridSize, List<Object> list) - throws IgniteCheckedException { + throws IgniteException { Collection<ComputeJobAdapter> jobs = new ArrayList<>(); if (list != null) @@ -1457,7 +1457,7 @@ public abstract class GridClientAbstractSelfTest extends GridCommonAbstractTest } /** {@inheritDoc} */ - @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteException { int sum = 0; for (ComputeJobResult res : results) @@ -1473,7 +1473,7 @@ public abstract class GridClientAbstractSelfTest extends GridCommonAbstractTest private static class SleepTestTask extends ComputeTaskSplitAdapter<List<Object>, Integer> { /** {@inheritDoc} */ @Override protected Collection<? extends ComputeJob> split(int gridSize, List<Object> list) - throws IgniteCheckedException { + throws IgniteException { Collection<ComputeJobAdapter> jobs = new ArrayList<>(); if (list != null) @@ -1495,7 +1495,7 @@ public abstract class GridClientAbstractSelfTest extends GridCommonAbstractTest } /** {@inheritDoc} */ - @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteException { int sum = 0; for (ComputeJobResult res : results) @@ -1513,7 +1513,7 @@ public abstract class GridClientAbstractSelfTest extends GridCommonAbstractTest /** {@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) throws IgniteException { if (arg.endsWith("intercepted")) arg = arg.substring(0, arg.length() - 11); @@ -1525,7 +1525,7 @@ public abstract class GridClientAbstractSelfTest extends GridCommonAbstractTest } /** {@inheritDoc} */ - @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteException { return delegate.reduce(results); } } @@ -1538,7 +1538,7 @@ public abstract class GridClientAbstractSelfTest extends GridCommonAbstractTest /** {@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) throws IgniteException { JSON json = JSONSerializer.toJSON(arg); List list = json.isArray() ? JSONArray.toList((JSONArray)json, String.class, new JsonConfig()) : null; @@ -1547,7 +1547,7 @@ public abstract class GridClientAbstractSelfTest extends GridCommonAbstractTest } /** {@inheritDoc} */ - @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteException { return delegate.reduce(results); } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/clients/src/test/java/org/gridgain/client/integration/GridClientPreferDirectSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/clients/src/test/java/org/gridgain/client/integration/GridClientPreferDirectSelfTest.java b/modules/clients/src/test/java/org/gridgain/client/integration/GridClientPreferDirectSelfTest.java index 69b522d..68f0091 100644 --- a/modules/clients/src/test/java/org/gridgain/client/integration/GridClientPreferDirectSelfTest.java +++ b/modules/clients/src/test/java/org/gridgain/client/integration/GridClientPreferDirectSelfTest.java @@ -145,7 +145,7 @@ public class GridClientPreferDirectSelfTest extends GridCommonAbstractTest { /** {@inheritDoc} */ @Override protected Collection<? extends ComputeJob> split(int gridSize, Object arg) - throws IgniteCheckedException { + throws IgniteException { Collection<ComputeJobAdapter> jobs = new ArrayList<>(gridSize); this.gridSize = gridSize; @@ -169,7 +169,7 @@ public class GridClientPreferDirectSelfTest extends GridCommonAbstractTest { } /** {@inheritDoc} */ - @Override public String reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public String reduce(List<ComputeJobResult> results) throws IgniteException { int sum = 0; for (ComputeJobResult res : results) { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/clients/src/test/java/org/gridgain/client/router/GridClientFailedInitSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/clients/src/test/java/org/gridgain/client/router/GridClientFailedInitSelfTest.java b/modules/clients/src/test/java/org/gridgain/client/router/GridClientFailedInitSelfTest.java index 03efbb2..9ac1e18 100644 --- a/modules/clients/src/test/java/org/gridgain/client/router/GridClientFailedInitSelfTest.java +++ b/modules/clients/src/test/java/org/gridgain/client/router/GridClientFailedInitSelfTest.java @@ -250,7 +250,7 @@ public class GridClientFailedInitSelfTest extends GridCommonAbstractTest { */ private static class TestTask extends ComputeTaskSplitAdapter<String, String> { /** {@inheritDoc} */ - @Override protected Collection<? extends ComputeJob> split(int gridSize, final String arg) throws IgniteCheckedException { + @Override protected Collection<? extends ComputeJob> split(int gridSize, final String arg) throws IgniteException { return Collections.singleton(new ComputeJobAdapter() { @Override public String execute() { return arg; @@ -259,7 +259,7 @@ public class GridClientFailedInitSelfTest extends GridCommonAbstractTest { } /** {@inheritDoc} */ - @Override public String reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public String reduce(List<ComputeJobResult> results) throws IgniteException { assertEquals(1, results.size()); return results.get(0).getData(); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/clients/src/test/java/org/gridgain/grid/kernal/GridTaskEventSubjectIdSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/clients/src/test/java/org/gridgain/grid/kernal/GridTaskEventSubjectIdSelfTest.java b/modules/clients/src/test/java/org/gridgain/grid/kernal/GridTaskEventSubjectIdSelfTest.java index b188671..d294460 100644 --- a/modules/clients/src/test/java/org/gridgain/grid/kernal/GridTaskEventSubjectIdSelfTest.java +++ b/modules/clients/src/test/java/org/gridgain/grid/kernal/GridTaskEventSubjectIdSelfTest.java @@ -328,7 +328,7 @@ public class GridTaskEventSubjectIdSelfTest extends GridCommonAbstractTest { /** */ private static class SimpleTask extends ComputeTaskSplitAdapter<Object, Object> { /** {@inheritDoc} */ - @Override protected Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteCheckedException { + @Override protected Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteException { return Collections.singleton(new ComputeJobAdapter() { @Nullable @Override public Object execute() { return null; @@ -337,7 +337,7 @@ public class GridTaskEventSubjectIdSelfTest extends GridCommonAbstractTest { } /** {@inheritDoc} */ - @Nullable @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Nullable @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { return null; } } @@ -345,7 +345,7 @@ public class GridTaskEventSubjectIdSelfTest extends GridCommonAbstractTest { /** */ private static class FailedTask extends ComputeTaskSplitAdapter<Object, Object> { /** {@inheritDoc} */ - @Override protected Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteCheckedException { + @Override protected Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteException { return Collections.singleton(new ComputeJobAdapter() { @Nullable @Override public Object execute() { return null; @@ -354,7 +354,7 @@ public class GridTaskEventSubjectIdSelfTest extends GridCommonAbstractTest { } /** {@inheritDoc} */ - @Nullable @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Nullable @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { throw new IgniteCheckedException("Task failed."); } } @@ -362,7 +362,7 @@ public class GridTaskEventSubjectIdSelfTest extends GridCommonAbstractTest { /** */ private static class TimedOutTask extends ComputeTaskSplitAdapter<Object, Object> { /** {@inheritDoc} */ - @Override protected Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteCheckedException { + @Override protected Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteException { return Collections.singleton(new ComputeJobAdapter() { @Nullable @Override public Object execute() { try { @@ -378,7 +378,7 @@ public class GridTaskEventSubjectIdSelfTest extends GridCommonAbstractTest { } /** {@inheritDoc} */ - @Nullable @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Nullable @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { return null; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/clients/src/test/java/org/gridgain/grid/kernal/processors/rest/GridRestBinaryProtocolSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/clients/src/test/java/org/gridgain/grid/kernal/processors/rest/GridRestBinaryProtocolSelfTest.java b/modules/clients/src/test/java/org/gridgain/grid/kernal/processors/rest/GridRestBinaryProtocolSelfTest.java index e6439e8..8a93a10 100644 --- a/modules/clients/src/test/java/org/gridgain/grid/kernal/processors/rest/GridRestBinaryProtocolSelfTest.java +++ b/modules/clients/src/test/java/org/gridgain/grid/kernal/processors/rest/GridRestBinaryProtocolSelfTest.java @@ -590,7 +590,7 @@ public class GridRestBinaryProtocolSelfTest extends GridCommonAbstractTest { private static class TestTask extends ComputeTaskSplitAdapter<List<Object>, Integer> { /** {@inheritDoc} */ @Override protected Collection<? extends ComputeJob> split(int gridSize, List<Object> args) - throws IgniteCheckedException { + throws IgniteException { Collection<ComputeJobAdapter> jobs = new ArrayList<>(args.size()); for (final Object arg : args) { @@ -613,7 +613,7 @@ public class GridRestBinaryProtocolSelfTest extends GridCommonAbstractTest { } /** {@inheritDoc} */ - @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteException { int sum = 0; for (ComputeJobResult res : results) http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/clients/src/test/java/org/gridgain/grid/kernal/processors/rest/GridTaskCommandHandlerSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/clients/src/test/java/org/gridgain/grid/kernal/processors/rest/GridTaskCommandHandlerSelfTest.java b/modules/clients/src/test/java/org/gridgain/grid/kernal/processors/rest/GridTaskCommandHandlerSelfTest.java index be26445..7e22d8c 100644 --- a/modules/clients/src/test/java/org/gridgain/grid/kernal/processors/rest/GridTaskCommandHandlerSelfTest.java +++ b/modules/clients/src/test/java/org/gridgain/grid/kernal/processors/rest/GridTaskCommandHandlerSelfTest.java @@ -176,7 +176,7 @@ public class GridTaskCommandHandlerSelfTest extends GridCommonAbstractTest { */ private static class TestTask extends ComputeTaskSplitAdapter<String, Integer> { /** {@inheritDoc} */ - @Override protected Collection<? extends ComputeJob> split(int gridSize, final String arg) throws IgniteCheckedException { + @Override protected Collection<? extends ComputeJob> split(int gridSize, final String arg) throws IgniteException { return Collections.singletonList(new ComputeJobAdapter() { @Override public Object execute() { try { @@ -192,7 +192,7 @@ public class GridTaskCommandHandlerSelfTest extends GridCommonAbstractTest { } /** {@inheritDoc} */ - @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteException { int sum = 0; for (ComputeJobResult res : results) http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/clients/src/test/java/org/gridgain/grid/kernal/processors/rest/TestTask1.java ---------------------------------------------------------------------- diff --git a/modules/clients/src/test/java/org/gridgain/grid/kernal/processors/rest/TestTask1.java b/modules/clients/src/test/java/org/gridgain/grid/kernal/processors/rest/TestTask1.java index b82984c..04f6826 100644 --- a/modules/clients/src/test/java/org/gridgain/grid/kernal/processors/rest/TestTask1.java +++ b/modules/clients/src/test/java/org/gridgain/grid/kernal/processors/rest/TestTask1.java @@ -21,7 +21,7 @@ import java.util.*; */ class TestTask1 extends ComputeTaskSplitAdapter<String, String> { /** {@inheritDoc} */ - @Override protected Collection<? extends ComputeJob> split(int gridSize, String arg) throws IgniteCheckedException { + @Override protected Collection<? extends ComputeJob> split(int gridSize, String arg) throws IgniteException { Collection<ComputeJob> jobs = new ArrayList<>(gridSize); for (int i = 0; i < gridSize; i++) @@ -38,7 +38,7 @@ class TestTask1 extends ComputeTaskSplitAdapter<String, String> { } /** {@inheritDoc} */ - @Override public String reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public String reduce(List<ComputeJobResult> results) throws IgniteException { return null; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/clients/src/test/java/org/gridgain/grid/kernal/processors/rest/TestTask2.java ---------------------------------------------------------------------- diff --git a/modules/clients/src/test/java/org/gridgain/grid/kernal/processors/rest/TestTask2.java b/modules/clients/src/test/java/org/gridgain/grid/kernal/processors/rest/TestTask2.java index aa1f57b..7e715fc 100644 --- a/modules/clients/src/test/java/org/gridgain/grid/kernal/processors/rest/TestTask2.java +++ b/modules/clients/src/test/java/org/gridgain/grid/kernal/processors/rest/TestTask2.java @@ -23,7 +23,7 @@ class TestTask2 extends ComputeTaskSplitAdapter<String, String> { static final String RES = "Task 2 result."; /** {@inheritDoc} */ - @Override protected Collection<? extends ComputeJob> split(int gridSize, String arg) throws IgniteCheckedException { + @Override protected Collection<? extends ComputeJob> split(int gridSize, String arg) throws IgniteException { Collection<ComputeJob> jobs = new ArrayList<>(gridSize); for (int i = 0; i < gridSize; i++) @@ -40,7 +40,7 @@ class TestTask2 extends ComputeTaskSplitAdapter<String, String> { } /** {@inheritDoc} */ - @Override public String reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public String reduce(List<ComputeJobResult> results) throws IgniteException { return RES; } }
