cassandra-pr mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sumanth-pasupuleti <...@git.apache.org>
Subject [GitHub] cassandra pull request #277: 12106 - blacklisting bad partitions for point r...
Date Sat, 03 Nov 2018 08:12:42 GMT
Github user sumanth-pasupuleti commented on a diff in the pull request:

    https://github.com/apache/cassandra/pull/277#discussion_r230548384
  
    --- Diff: src/java/org/apache/cassandra/repair/SystemDistributedKeyspace.java ---
    @@ -307,6 +320,55 @@ public static void setViewRemoved(String keyspaceName, String viewName)
             forceBlockingFlush(VIEW_BUILD_STATUS);
         }
     
    +    /**
    +     * Reads blacklisted partitions from system_distributed.blacklisted_partitions table.
    +     * Stops reading partitions upon exceeding the cache size limit by logging a warning.
    +     * @return
    +     */
    +    public static Set<BlacklistedPartition> getBlacklistedPartitions()
    +    {
    +        String query = "SELECT keyspace_name, columnfamily_name, partition_key FROM %s.%s";
    +        UntypedResultSet results;
    +        try
    +        {
    +            results = QueryProcessor.execute(format(query, SchemaConstants.DISTRIBUTED_KEYSPACE_NAME,
BLACKLISTED_PARTITIONS),
    +                                             ConsistencyLevel.ONE);
    +        }
    +        catch (Exception e)
    +        {
    +            logger.error("Error querying blacklisted partitions", e);
    +            return Collections.emptySet();
    +        }
    +
    +        Set<BlacklistedPartition> blacklistedPartitions = new HashSet<>();
    +        int cacheSize = 0;
    --- End diff --
    
    done


---

---------------------------------------------------------------------
To unsubscribe, e-mail: pr-unsubscribe@cassandra.apache.org
For additional commands, e-mail: pr-help@cassandra.apache.org


Mime
View raw message