src/java/org/apache/cassandra/service/StorageService.java
/**
     * Force a remove operation to complete. This may be necessary if a remove operation
     * blocks forever due to node/stream failure. removeToken() must be called
     * first, this is a last resort measure.  No further attempt will be made to restore replicas.
     */
Force a remove operation to complete. This may be necessary if a remove operation
blocks forever due to node/stream failure. removeToken() must be called
first, this is a last resort measure.  No further attempt will be made to restore replicas.
Force a remove operation to complete . This may be necessary if a remove operation blocks forever due to node / stream failure . removeToken () must be called first this is a last resort measure . No further attempt will be made to restore replicas .
@Override
    public void forceRemoveCompletion()
    {
        if (!replicatingNodes.isEmpty()  || !tokenMetadata_.getLeavingEndpoints().isEmpty())
        {
            logger_.warn("Removal not confirmed for for " + StringUtils.join(this.replicatingNodes, ","));
            for (InetAddress endpoint : tokenMetadata_.getLeavingEndpoints())
            {
                Gossiper.instance.advertiseTokenRemoved(endpoint, tokenMetadata_.getToken(endpoint));
                tokenMetadata_.removeEndpoint(endpoint);
            }
            replicatingNodes.clear();
        }
        else
        {
            throw new UnsupportedOperationException("No tokens to force removal on, call 'removetoken' first");
        }
    }
@ Override public void forceRemoveCompletion ( ) { if ( ! replicatingNodes . isEmpty ( ) || ! tokenMetadata_ . getLeavingEndpoints ( ) . isEmpty ( ) ) { logger_ . warn ( "Removal not confirmed for for " + StringUtils . join ( this . replicatingNodes , "," ) ) ; for ( InetAddress endpoint : tokenMetadata_ . getLeavingEndpoints ( ) ) { Gossiper . instance . advertiseTokenRemoved ( endpoint , tokenMetadata_ . getToken ( endpoint ) ) ; tokenMetadata_ . removeEndpoint ( endpoint ) ; } replicatingNodes . clear ( ) ; } else { throw new UnsupportedOperationException ( "No tokens to force removal on, call 'removetoken' first" ) ; } }
Force a remove operation to complete.
Force a remove operation to complete .