1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 package org.apache.hadoop.hbase.master.handler;
20
21 import java.io.IOException;
22 import java.util.List;
23 import java.util.concurrent.ExecutorService;
24
25 import org.apache.commons.logging.Log;
26 import org.apache.commons.logging.LogFactory;
27 import org.apache.hadoop.hbase.classification.InterfaceAudience;
28 import org.apache.hadoop.hbase.CoordinatedStateException;
29 import org.apache.hadoop.hbase.TableName;
30 import org.apache.hadoop.hbase.HRegionInfo;
31 import org.apache.hadoop.hbase.Server;
32 import org.apache.hadoop.hbase.TableNotEnabledException;
33 import org.apache.hadoop.hbase.TableNotFoundException;
34 import org.apache.hadoop.hbase.MetaTableAccessor;
35 import org.apache.hadoop.hbase.constraint.ConstraintException;
36 import org.apache.hadoop.hbase.executor.EventHandler;
37 import org.apache.hadoop.hbase.executor.EventType;
38 import org.apache.hadoop.hbase.master.AssignmentManager;
39 import org.apache.hadoop.hbase.master.BulkAssigner;
40 import org.apache.hadoop.hbase.master.HMaster;
41 import org.apache.hadoop.hbase.master.MasterCoprocessorHost;
42 import org.apache.hadoop.hbase.master.RegionStates;
43 import org.apache.hadoop.hbase.master.TableLockManager;
44 import org.apache.hadoop.hbase.master.RegionState.State;
45 import org.apache.hadoop.hbase.master.TableLockManager.TableLock;
46 import org.apache.hadoop.hbase.protobuf.generated.ZooKeeperProtos;
47 import org.apache.htrace.Trace;
48
49
50
51
52 @InterfaceAudience.Private
53 public class DisableTableHandler extends EventHandler {
54 private static final Log LOG = LogFactory.getLog(DisableTableHandler.class);
55 private final TableName tableName;
56 private final AssignmentManager assignmentManager;
57 private final TableLockManager tableLockManager;
58 private final boolean skipTableStateCheck;
59 private TableLock tableLock;
60
61 public DisableTableHandler(Server server, TableName tableName,
62 AssignmentManager assignmentManager, TableLockManager tableLockManager,
63 boolean skipTableStateCheck) {
64 super(server, EventType.C_M_DISABLE_TABLE);
65 this.tableName = tableName;
66 this.assignmentManager = assignmentManager;
67 this.tableLockManager = tableLockManager;
68 this.skipTableStateCheck = skipTableStateCheck;
69 }
70
71 public DisableTableHandler prepare()
72 throws TableNotFoundException, TableNotEnabledException, IOException {
73 if(tableName.equals(TableName.META_TABLE_NAME)) {
74 throw new ConstraintException("Cannot disable catalog table");
75 }
76
77 this.tableLock = this.tableLockManager.writeLock(tableName,
78 EventType.C_M_DISABLE_TABLE.toString());
79 this.tableLock.acquire();
80
81 boolean success = false;
82 try {
83
84 if (!MetaTableAccessor.tableExists(this.server.getConnection(), tableName)) {
85 throw new TableNotFoundException(tableName);
86 }
87
88
89
90
91
92
93 if (!skipTableStateCheck) {
94 try {
95 if (!this.assignmentManager.getTableStateManager().setTableStateIfInStates(
96 this.tableName, ZooKeeperProtos.Table.State.DISABLING,
97 ZooKeeperProtos.Table.State.ENABLED)) {
98 LOG.info("Table " + tableName + " isn't enabled; skipping disable");
99 throw new TableNotEnabledException(this.tableName);
100 }
101 } catch (CoordinatedStateException e) {
102 throw new IOException("Unable to ensure that the table will be" +
103 " disabling because of a coordination engine issue", e);
104 }
105 }
106 success = true;
107 } finally {
108 if (!success) {
109 releaseTableLock();
110 }
111 }
112
113 return this;
114 }
115
116 @Override
117 public String toString() {
118 String name = "UnknownServerName";
119 if(server != null && server.getServerName() != null) {
120 name = server.getServerName().toString();
121 }
122 return getClass().getSimpleName() + "-" + name + "-" + getSeqid() + "-" +
123 tableName;
124 }
125
126 @Override
127 public void process() {
128 try {
129 LOG.info("Attempting to disable table " + this.tableName);
130 MasterCoprocessorHost cpHost = ((HMaster) this.server)
131 .getMasterCoprocessorHost();
132 if (cpHost != null) {
133 cpHost.preDisableTableHandler(this.tableName);
134 }
135 handleDisableTable();
136 if (cpHost != null) {
137 cpHost.postDisableTableHandler(this.tableName);
138 }
139 } catch (IOException e) {
140 LOG.error("Error trying to disable table " + this.tableName, e);
141 } catch (CoordinatedStateException e) {
142 LOG.error("Error trying to disable table " + this.tableName, e);
143 } finally {
144 releaseTableLock();
145 }
146 }
147
148 private void releaseTableLock() {
149 if (this.tableLock != null) {
150 try {
151 this.tableLock.release();
152 } catch (IOException ex) {
153 LOG.warn("Could not release the table lock", ex);
154 }
155 }
156 }
157
158 private void handleDisableTable() throws IOException, CoordinatedStateException {
159
160 this.assignmentManager.getTableStateManager().setTableState(this.tableName,
161 ZooKeeperProtos.Table.State.DISABLING);
162 boolean done = false;
163 while (true) {
164
165
166
167
168 final List<HRegionInfo> regions = this.assignmentManager
169 .getRegionStates().getRegionsOfTable(tableName);
170 if (regions.size() == 0) {
171 done = true;
172 break;
173 }
174 LOG.info("Offlining " + regions.size() + " regions.");
175 BulkDisabler bd = new BulkDisabler(this.server, regions);
176 try {
177 if (bd.bulkAssign()) {
178 done = true;
179 break;
180 }
181 } catch (InterruptedException e) {
182 LOG.warn("Disable was interrupted");
183
184 Thread.currentThread().interrupt();
185 break;
186 }
187 }
188
189 if (done) this.assignmentManager.getTableStateManager().setTableState(this.tableName,
190 ZooKeeperProtos.Table.State.DISABLED);
191 LOG.info("Disabled table, " + this.tableName + ", is done=" + done);
192 }
193
194
195
196
197 class BulkDisabler extends BulkAssigner {
198 private final List<HRegionInfo> regions;
199
200 BulkDisabler(final Server server, final List<HRegionInfo> regions) {
201 super(server);
202 this.regions = regions;
203 }
204
205 @Override
206 protected void populatePool(ExecutorService pool) {
207 RegionStates regionStates = assignmentManager.getRegionStates();
208 for (HRegionInfo region: regions) {
209 if (regionStates.isRegionInTransition(region)
210 && !regionStates.isRegionInState(region, State.FAILED_CLOSE)) {
211 continue;
212 }
213 final HRegionInfo hri = region;
214 pool.execute(Trace.wrap("DisableTableHandler.BulkDisabler",new Runnable() {
215 public void run() {
216 assignmentManager.unassign(hri, true);
217 }
218 }));
219 }
220 }
221
222 @Override
223 protected boolean waitUntilDone(long timeout)
224 throws InterruptedException {
225 long startTime = System.currentTimeMillis();
226 long remaining = timeout;
227 List<HRegionInfo> regions = null;
228 long lastLogTime = startTime;
229 while (!server.isStopped() && remaining > 0) {
230 Thread.sleep(waitingTimeForEvents);
231 regions = assignmentManager.getRegionStates().getRegionsOfTable(tableName);
232 long now = System.currentTimeMillis();
233
234
235 if (LOG.isDebugEnabled() && ((now - lastLogTime) > 10000)) {
236 lastLogTime = now;
237 LOG.debug("Disable waiting until done; " + remaining + " ms remaining; " + regions);
238 }
239 if (regions.isEmpty()) break;
240 remaining = timeout - (now - startTime);
241 }
242 return regions != null && regions.isEmpty();
243 }
244 }
245 }