001/** 002 * Licensed to the Apache Software Foundation (ASF) under one 003 * or more contributor license agreements. See the NOTICE file 004 * distributed with this work for additional information 005 * regarding copyright ownership. The ASF licenses this file 006 * to you under the Apache License, Version 2.0 (the 007 * "License"); you may not use this file except in compliance 008 * with the License. You may obtain a copy of the License at 009 * 010 * http://www.apache.org/licenses/LICENSE-2.0 011 * 012 * Unless required by applicable law or agreed to in writing, software 013 * distributed under the License is distributed on an "AS IS" BASIS, 014 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 015 * See the License for the specific language governing permissions and 016 * limitations under the License. 017 */ 018 019package org.apache.hadoop.hbase.chaos.factories; 020 021import org.apache.hadoop.hbase.chaos.actions.Action; 022import org.apache.hadoop.hbase.chaos.actions.DumpClusterStatusAction; 023import org.apache.hadoop.hbase.chaos.actions.ForceBalancerAction; 024import org.apache.hadoop.hbase.chaos.actions.GracefulRollingRestartRsAction; 025import org.apache.hadoop.hbase.chaos.actions.RestartActiveMasterAction; 026import org.apache.hadoop.hbase.chaos.actions.RestartRandomDataNodeAction; 027import org.apache.hadoop.hbase.chaos.actions.RestartRandomRsExceptMetaAction; 028import org.apache.hadoop.hbase.chaos.actions.RestartRandomZKNodeAction; 029import org.apache.hadoop.hbase.chaos.actions.RollingBatchRestartRsExceptMetaAction; 030import org.apache.hadoop.hbase.chaos.actions.RollingBatchSuspendResumeRsAction; 031import org.apache.hadoop.hbase.chaos.monkies.ChaosMonkey; 032import org.apache.hadoop.hbase.chaos.monkies.PolicyBasedChaosMonkey; 033import org.apache.hadoop.hbase.chaos.policies.CompositeSequentialPolicy; 034import org.apache.hadoop.hbase.chaos.policies.DoActionsOncePolicy; 035import org.apache.hadoop.hbase.chaos.policies.PeriodicRandomActionPolicy; 036 037/** 038 * Creates ChaosMonkeys for doing server restart actions, but not 039 * flush / compact / snapshot kind of actions. 040 */ 041public class ServerAndDependenciesKillingMonkeyFactory extends MonkeyFactory { 042 043 private long gracefulRollingRestartTSSLeepTime; 044 private long rollingBatchSuspendRSSleepTime; 045 private float rollingBatchSuspendtRSRatio; 046 047 @Override 048 public ChaosMonkey build() { 049 loadProperties(); 050 051 // Destructive actions to mess things around. Cannot run batch restart. 052 Action[] actions1 = new Action[]{ 053 new RestartRandomRsExceptMetaAction(60000), 054 new RestartActiveMasterAction(5000), 055 new RollingBatchRestartRsExceptMetaAction(5000, 1.0f, 2), // only allow 2 servers to be dead. 056 new ForceBalancerAction(), 057 new RestartRandomDataNodeAction(60000), 058 new RestartRandomZKNodeAction(60000), 059 new GracefulRollingRestartRsAction(gracefulRollingRestartTSSLeepTime), 060 new RollingBatchSuspendResumeRsAction(rollingBatchSuspendRSSleepTime, 061 rollingBatchSuspendtRSRatio) 062 }; 063 064 // Action to log more info for debugging 065 Action[] actions2 = new Action[]{ 066 new DumpClusterStatusAction() 067 }; 068 069 return new PolicyBasedChaosMonkey(util, 070 new CompositeSequentialPolicy( 071 new DoActionsOncePolicy(60 * 1000, actions1), 072 new PeriodicRandomActionPolicy(60 * 1000, actions1)), 073 new PeriodicRandomActionPolicy(60 * 1000, actions2)); 074 } 075 076 private void loadProperties() { 077 gracefulRollingRestartTSSLeepTime = Long.parseLong(this.properties.getProperty( 078 MonkeyConstants.GRACEFUL_RESTART_RS_SLEEP_TIME, 079 MonkeyConstants.DEFAULT_GRACEFUL_RESTART_RS_SLEEP_TIME + "")); 080 rollingBatchSuspendRSSleepTime = Long.parseLong(this.properties.getProperty( 081 MonkeyConstants.ROLLING_BATCH_SUSPEND_RS_SLEEP_TIME, 082 MonkeyConstants.DEFAULT_ROLLING_BATCH_SUSPEND_RS_SLEEP_TIME+ "")); 083 rollingBatchSuspendtRSRatio = Float.parseFloat(this.properties.getProperty( 084 MonkeyConstants.ROLLING_BATCH_SUSPEND_RS_RATIO, 085 MonkeyConstants.DEFAULT_ROLLING_BATCH_SUSPEND_RS_RATIO + "")); 086 } 087}