1 package org.apache.helix.integration;
2
3 /*
4 * Licensed to the Apache Software Foundation (ASF) under one
5 * or more contributor license agreements. See the NOTICE file
6 * distributed with this work for additional information
7 * regarding copyright ownership. The ASF licenses this file
8 * to you under the Apache License, Version 2.0 (the
9 * "License"); you may not use this file except in compliance
10 * with the License. You may obtain a copy of the License at
11 *
12 * http://www.apache.org/licenses/LICENSE-2.0
13 *
14 * Unless required by applicable law or agreed to in writing,
15 * software distributed under the License is distributed on an
16 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
17 * KIND, either express or implied. See the License for the
18 * specific language governing permissions and limitations
19 * under the License.
20 */
21
22 import java.util.Date;
23
24 import org.testng.annotations.Test;
25
26 public class TestCMWithFailParticipant extends ZkIntegrationTestBase
27 {
28 // ZkClient _zkClient;
29 //
30 // @BeforeClass ()
31 // public void beforeClass() throws Exception
32 // {
33 // _zkClient = new ZkClient(ZK_ADDR);
34 // _zkClient.setZkSerializer(new ZNRecordSerializer());
35 // }
36 //
37 //
38 // @AfterClass
39 // public void afterClass()
40 // {
41 // _zkClient.close();
42 // }
43
44 @Test()
45 public void testCMWithFailParticipant() throws Exception
46 {
47 int numResources = 1;
48 int numPartitionsPerResource = 10;
49 int numInstance = 5;
50 int replica = 3;
51
52 String uniqClusterName = "TestFail_" + "rg" + numResources + "_p" + numPartitionsPerResource
53 + "_n" + numInstance + "_r" + replica;
54 System.out.println("START " + uniqClusterName + " at " + new Date(System.currentTimeMillis()));
55
56 TestDriver.setupCluster(uniqClusterName, ZK_ADDR, numResources, numPartitionsPerResource,
57 numInstance, replica);
58
59 for (int i = 0; i < numInstance; i++)
60 {
61 TestDriver.startDummyParticipant(uniqClusterName, i);
62 }
63 TestDriver.startController(uniqClusterName);
64
65 TestDriver.stopDummyParticipant(uniqClusterName, 2000, 0);
66 TestDriver.verifyCluster(uniqClusterName, 3000, 50 * 1000);
67 TestDriver.stopCluster(uniqClusterName);
68
69 System.out.println("END " + uniqClusterName + " at " + new Date(System.currentTimeMillis()));
70
71 }
72 }