Package net.sf.katta.protocol.metadata

Examples of net.sf.katta.protocol.metadata.IndexDeployError

115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
      zkClient.getEventLock().unlock();
      IndexState indexState = deployFuture.joinDeployment();
      assertEquals("" + deployClient.getIndexMetaData(indexName).getDeployError(), IndexState.DEPLOYED, indexState);

      if (indexState == IndexState.ERROR) {
        IndexDeployError deployError = protocol.getIndexMD(indexName).getDeployError();
        Set<Shard> shards = protocol.getIndexMD(indexName).getShards();
        for (Shard shard : shards) {
          List<Exception> shardErrors = deployError.getShardErrors(shard.getName());
          for (Exception exception : shardErrors) {
            exception.printStackTrace();
          }
        }
        deployError.getException().printStackTrace();
      }
    }
  }
View Full Code Here
179
180
181
182
183
184
185
186
187
188
    if (e instanceof IndexDeployException) {
      errorType = ((IndexDeployException) e).getErrorType();
    } else {
      errorType = ErrorType.UNKNOWN;
    }
    IndexDeployError deployError = new IndexDeployError(indexMD.getName(), errorType);
    deployError.setException(e);
    indexMD.setDeployError(deployError);
    protocol.updateIndexMD(indexMD);
  }
View Full Code Here
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
      // we ignore possible shard errors
      if (canAndShouldRegulateReplication(context.getProtocol(), replicationReport)) {
        context.getProtocol().addMasterOperation(new BalanceIndexOperation(indexMD.getName()));
      }
    } else {
      IndexDeployError deployError = new IndexDeployError(indexMD.getName(), ErrorType.SHARDS_NOT_DEPLOYABLE);
      for (OperationResult operationResult : results) {
        if (operationResult != null) {// node-crashed produces null
          DeployResult deployResult = (DeployResult) operationResult;
          for (Entry<String, Exception> entry : deployResult.getShardExceptions().entrySet()) {
            deployError.addShardError(entry.getKey(), entry.getValue());
          }
        }
      }
      indexMD.setDeployError(deployError);
    }
View Full Code Here
42
43
44
45
46
47
48
49
50
    String indexName = "indexA";
    IndexDeployFuture deployFuture = new IndexDeployFuture(_protocol, indexName);
    assertEquals(IndexState.DEPLOYING, deployFuture.joinDeployment(200));

    IndexMetaData indexMD = new IndexMetaData(indexName, "path", 1);
    indexMD.setDeployError(new IndexDeployError(indexName, ErrorType.NO_NODES_AVAILIBLE));
    _protocol.publishIndex(indexMD);
    assertEquals(IndexState.ERROR, deployFuture.joinDeployment(200));
  }
View Full Code Here
64
65
66
67
68
69
70
71
72
73
74
75
76
    // check results
    assertEquals(1, _protocol.getIndices().size());
    IndexMetaData indexMD = _protocol.getIndexMD(_indexName);
    assertNotNull(indexMD);
    assertTrue(indexMD.hasDeployError());
    IndexDeployError error = indexMD.getDeployError();
    assertNotNull(error);
    assertEquals(errorType, error.getErrorType());
    Set<Shard> shards = indexMD.getShards();
    assertEquals(shardCount, shards.size());
    for (Shard shard : shards) {
      assertTrue(_protocol.getShardNodes(shard.getName()).isEmpty());
    }
View Full Code Here
117
118
119
120
121
122
123
124
125
126
127
    operation.nodeOperationsComplete(_context, results);
    checkDeployError(ErrorType.SHARDS_NOT_DEPLOYABLE, _shardCount);

    IndexMetaData indexMD = _protocol.getIndexMD(_indexName);
    IndexDeployError error = indexMD.getDeployError();
    Set<Shard> shards = indexMD.getShards();
    for (Shard shard : shards) {
      assertEquals(3, error.getShardErrors(shard.getName()).size());
    }
  }
View Full Code Here
TOP

Related Classes of net.sf.katta.protocol.metadata.IndexDeployError

  • net.sf.katta.client.IndexDeployFutureTest
  • net.sf.katta.integrationTest.FailoverTest
  • net.sf.katta.operation.master.AbstractIndexOperation
  • net.sf.katta.operation.master.IndexDeployOperationTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.