test_class.file: modules/core/src/test/java/org/apache/ignite/internal/processors/cache/checker/tasks/CollectPartitionKeysByRecheckRequestTaskTest.java
test_class.identifier: CollectPartitionKeysByRecheckRequestTaskTest
test_class.superclass: extends CollectPartitionInfoAbstractTest
test_case.body: @Test
      public void testRemovedKeyShouldReturnEmptyResult() throws Exception {
          IgniteEx node = startGrids(2);
  
          node.cluster().active(true);
  
          Collection<ClusterNode> nodes = node.affinity(DEFAULT_CACHE_NAME)
              .mapPartitionToPrimaryAndBackups(FIRST_PARTITION);
  
          List<KeyCacheObject> recheckKeys = new ArrayList<>();
  
          String keyRow = "test-key";
          KeyCacheObjectImpl key = key(keyRow, node.cachex(DEFAULT_CACHE_NAME).context().cacheObjectContext());
  
          recheckKeys.add(key);
  
          Map<KeyCacheObject, Map<UUID, VersionedValue>> res = node.compute(group(node, nodes)).execute(
              CollectPartitionKeysByRecheckRequestTask.class,
              new RecheckRequest(ReconciliationExecutionContext.IGNORE_JOB_PERMITS_SESSION_ID, UUID.randomUUID(),
                  recheckKeys, DEFAULT_CACHE_NAME, FIRST_PARTITION, lastTopologyVersion(node))
          ).result();
  
          assertTrue(res.isEmpty());
      }
test_case.class_method_signature: CollectPartitionKeysByRecheckRequestTaskTest.testRemovedKeyShouldReturnEmptyResult()
test_case.full_signature: @Test public void testRemovedKeyShouldReturnEmptyResult()
test_case.identifier: testRemovedKeyShouldReturnEmptyResult
test_case.invocations: startGrids active cluster mapPartitionToPrimaryAndBackups affinity key cacheObjectContext context cachex add result execute compute group randomUUID lastTopologyVersion assertTrue isEmpty
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testRemovedKeyShouldReturnEmptyResult()
focal_class.declarator: serialVersionUID = 0L
focal_class.modifier: private static final
focal_class.original_string: private static final long serialVersionUID = 0L;
focal_class.type: long
focal_class.var_name: serialVersionUID
focal_class.declarator: log
focal_class.modifier: @LoggerResource
      private
focal_class.original_string: @LoggerResource
      private IgniteLogger log;
focal_class.type: IgniteLogger
focal_class.var_name: log
focal_class.declarator: ignite
focal_class.modifier: @IgniteInstanceResource
      private
focal_class.original_string: @IgniteInstanceResource
      private IgniteEx ignite;
focal_class.type: IgniteEx
focal_class.var_name: ignite
focal_class.declarator: recheckReq
focal_class.modifier: private
focal_class.original_string: private RecheckRequest recheckReq;
focal_class.type: RecheckRequest
focal_class.var_name: recheckReq
focal_class.file: modules/core/src/main/java/org/apache/ignite/internal/processors/cache/checker/tasks/CollectPartitionKeysByRecheckRequestTask.java
focal_class.identifier: CollectPartitionKeysByRecheckRequestTask
focal_class.class_method_signature: CollectPartitionKeysByRecheckRequestTask.map(List<ClusterNode> subgrid,
          RecheckRequest arg)
focal_class.full_signature: @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid,
          RecheckRequest arg)
focal_class.identifier: map
focal_class.modifiers: @Override public
focal_class.parameters: (List<ClusterNode> subgrid,
          RecheckRequest arg)
focal_class.return: Map<? extends ComputeJob, ClusterNode>
focal_class.signature: Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid,
          RecheckRequest arg)
focal_class.class_method_signature: CollectPartitionKeysByRecheckRequestTask.result(ComputeJobResult res, List<ComputeJobResult> rcvd)
focal_class.full_signature: @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd)
focal_class.identifier: result
focal_class.modifiers: @Override public
focal_class.parameters: (ComputeJobResult res, List<ComputeJobResult> rcvd)
focal_class.return: ComputeJobResultPolicy
focal_class.signature: ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd)
focal_class.class_method_signature: CollectPartitionKeysByRecheckRequestTask.reduce(
          List<ComputeJobResult> results)
focal_class.full_signature: @Override public ExecutionResult<Map<KeyCacheObject, Map<UUID, VersionedValue>>> reduce(
          List<ComputeJobResult> results)
focal_class.identifier: reduce
focal_class.modifiers: @Override public
focal_class.parameters: (
          List<ComputeJobResult> results)
focal_class.return: ExecutionResult<Map<KeyCacheObject, Map<UUID, VersionedValue>>>
focal_class.signature: ExecutionResult<Map<KeyCacheObject, Map<UUID, VersionedValue>>> reduce(
          List<ComputeJobResult> results)
focal_class.superclass: extends ComputeTaskAdapter<RecheckRequest, ExecutionResult<Map<KeyCacheObject, Map<UUID, VersionedValue>>>>
focal_method.body: @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) {
          ComputeJobResultPolicy superRes = super.result(res, rcvd);
  
          // Deny failover.
          if (superRes == ComputeJobResultPolicy.FAILOVER) {
              superRes = ComputeJobResultPolicy.WAIT;
  
              log.warning("CollectPartitionEntryHashesJob failed on node " +
                  "[consistentId=" + res.getNode().consistentId() + "]", res.getException());
          }
  
          return superRes;
      }
focal_method.class_method_signature: CollectPartitionKeysByRecheckRequestTask.result(ComputeJobResult res, List<ComputeJobResult> rcvd)
focal_method.full_signature: @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd)
focal_method.identifier: result
focal_method.invocations: result warning consistentId getNode getException
focal_method.modifiers: @Override public
focal_method.parameters: (ComputeJobResult res, List<ComputeJobResult> rcvd)
focal_method.return: ComputeJobResultPolicy
focal_method.signature: ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd)