mirror of https://github.com/apache/cassandra
Merge branch 'cassandra-1.0' into trunk
This commit is contained in:
commit
cfd9399dce
14
NEWS.txt
14
NEWS.txt
|
|
@ -74,6 +74,13 @@ Upgrading
|
||||||
---------
|
---------
|
||||||
- Nothing specific to 1.0.7, please report to instruction for 1.0.6
|
- Nothing specific to 1.0.7, please report to instruction for 1.0.6
|
||||||
|
|
||||||
|
Other
|
||||||
|
-----
|
||||||
|
- Adds new setstreamthroughput to nodetool to configure streaming
|
||||||
|
throttling
|
||||||
|
- Adds JMX property to get/set rpc_timeout_in_ms at runtime
|
||||||
|
- Allow configuring (per-CF) bloom_filter_fp_chance
|
||||||
|
|
||||||
|
|
||||||
1.0.6
|
1.0.6
|
||||||
=====
|
=====
|
||||||
|
|
@ -88,13 +95,6 @@ Upgrading
|
||||||
setting the right value and then run scrub on the column family.
|
setting the right value and then run scrub on the column family.
|
||||||
- Please report to instruction for 1.0.5 if coming from an older version.
|
- Please report to instruction for 1.0.5 if coming from an older version.
|
||||||
|
|
||||||
Other
|
|
||||||
-----
|
|
||||||
- Adds new setstreamthroughput to nodetool to configure streaming
|
|
||||||
throttling
|
|
||||||
- Adds JMX property to get/set rpc_timeout_in_ms at runtime
|
|
||||||
- Allow configuring (per-CF) bloom_filter_fp_chance
|
|
||||||
|
|
||||||
|
|
||||||
1.0.5
|
1.0.5
|
||||||
=====
|
=====
|
||||||
|
|
|
||||||
|
|
@ -179,7 +179,7 @@ public class HintedHandOffManager implements HintedHandOffManagerMBean
|
||||||
{
|
{
|
||||||
logger_.info("Deleting any stored hints for " + endpoint);
|
logger_.info("Deleting any stored hints for " + endpoint);
|
||||||
rm.apply();
|
rm.apply();
|
||||||
hintStore.forceFlush();
|
hintStore.forceBlockingFlush();
|
||||||
CompactionManager.instance.submitMaximal(hintStore, Integer.MAX_VALUE);
|
CompactionManager.instance.submitMaximal(hintStore, Integer.MAX_VALUE);
|
||||||
}
|
}
|
||||||
catch (Exception e)
|
catch (Exception e)
|
||||||
|
|
@ -359,9 +359,9 @@ public class HintedHandOffManager implements HintedHandOffManagerMBean
|
||||||
|
|
||||||
if (rowsReplayed > 0)
|
if (rowsReplayed > 0)
|
||||||
{
|
{
|
||||||
hintStore.forceFlush();
|
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
|
hintStore.forceBlockingFlush();
|
||||||
CompactionManager.instance.submitMaximal(hintStore, Integer.MAX_VALUE).get();
|
CompactionManager.instance.submitMaximal(hintStore, Integer.MAX_VALUE).get();
|
||||||
}
|
}
|
||||||
catch (Exception e)
|
catch (Exception e)
|
||||||
|
|
|
||||||
|
|
@ -382,7 +382,7 @@ public class SystemTable
|
||||||
QueryFilter filter = QueryFilter.getNamesFilter(decorate(ByteBufferUtil.bytes(table)),
|
QueryFilter filter = QueryFilter.getNamesFilter(decorate(ByteBufferUtil.bytes(table)),
|
||||||
new QueryPath(INDEX_CF),
|
new QueryPath(INDEX_CF),
|
||||||
ByteBufferUtil.bytes(indexName));
|
ByteBufferUtil.bytes(indexName));
|
||||||
return cfs.getColumnFamily(filter) != null;
|
return ColumnFamilyStore.removeDeleted(cfs.getColumnFamily(filter), Integer.MAX_VALUE) != null;
|
||||||
}
|
}
|
||||||
|
|
||||||
public static void setIndexBuilt(String table, String indexName)
|
public static void setIndexBuilt(String table, String indexName)
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue