|
@@ -40,6 +40,7 @@ import org.apache.curator.retry.RetryNTimes;
|
|
|
import org.apache.hadoop.classification.InterfaceAudience.Private;
|
|
|
import org.apache.hadoop.classification.InterfaceStability.Unstable;
|
|
|
import org.apache.hadoop.conf.Configuration;
|
|
|
+import org.apache.hadoop.io.IOUtils;
|
|
|
import org.apache.hadoop.security.token.delegation.DelegationKey;
|
|
|
import org.apache.hadoop.util.ZKUtil;
|
|
|
import org.apache.hadoop.yarn.api.records.ApplicationAttemptId;
|
|
@@ -312,7 +313,7 @@ public class ZKRMStateStore extends RMStateStore {
|
|
|
verifyActiveStatusThread.interrupt();
|
|
|
verifyActiveStatusThread.join(1000);
|
|
|
}
|
|
|
- curatorFramework.close();
|
|
|
+ IOUtils.closeStream(curatorFramework);
|
|
|
}
|
|
|
|
|
|
@Override
|