[jira] [Commented] (CASSANDRA-4324) Implement Lucene FST in for key index

2012-07-14 Thread Jason Rutherglen (JIRA)

[ 
https://issues.apache.org/jira/browse/CASSANDRA-4324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13414561#comment-13414561
 ] 

Jason Rutherglen commented on CASSANDRA-4324:
-

Also the last results are for 100,000 keys rather than 1 mil.

> Implement Lucene FST in for key index
> -
>
> Key: CASSANDRA-4324
> URL: https://issues.apache.org/jira/browse/CASSANDRA-4324
> Project: Cassandra
>  Issue Type: Improvement
>Reporter: Jason Rutherglen
>Assignee: Jason Rutherglen
>Priority: Minor
> Fix For: 1.2
>
> Attachments: CASSANDRA-4324.patch, CASSANDRA-4324.patch, 
> CASSANDRA-4324.patch, lucene-core-4.0-SNAPSHOT.jar
>
>
> The Lucene FST data structure offers a compact and fast system for indexing 
> Cassandra keys.  More keys may be loaded which in turn should seeks faster.
> * Update the IndexSummary class to make use of the Lucene FST, overriding the 
> serialization mechanism.
> * Alter SSTableReader to make use of the FST seek mechanism

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: 
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira




[jira] [Updated] (CASSANDRA-4324) Implement Lucene FST in for key index

2012-07-14 Thread Jason Rutherglen (JIRA)

 [ 
https://issues.apache.org/jira/browse/CASSANDRA-4324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Jason Rutherglen updated CASSANDRA-4324:


Attachment: CASSANDRA-4324.patch

Reran with sorting the keys:

Reran 

FST: 3,564,246
IndexSummary: 4,399,624

The FST is 19% smaller, if the IndexSummary mem calculation is correct.

> Implement Lucene FST in for key index
> -
>
> Key: CASSANDRA-4324
> URL: https://issues.apache.org/jira/browse/CASSANDRA-4324
> Project: Cassandra
>  Issue Type: Improvement
>Reporter: Jason Rutherglen
>Assignee: Jason Rutherglen
>Priority: Minor
> Fix For: 1.2
>
> Attachments: CASSANDRA-4324.patch, CASSANDRA-4324.patch, 
> CASSANDRA-4324.patch, lucene-core-4.0-SNAPSHOT.jar
>
>
> The Lucene FST data structure offers a compact and fast system for indexing 
> Cassandra keys.  More keys may be loaded which in turn should seeks faster.
> * Update the IndexSummary class to make use of the Lucene FST, overriding the 
> serialization mechanism.
> * Alter SSTableReader to make use of the FST seek mechanism

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: 
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira




[jira] [Commented] (CASSANDRA-4324) Implement Lucene FST in for key index

2012-07-14 Thread Jason Rutherglen (JIRA)

[ 
https://issues.apache.org/jira/browse/CASSANDRA-4324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13414558#comment-13414558
 ] 

Jason Rutherglen commented on CASSANDRA-4324:
-

Can you verify the mem size calculation for the IndexSummary is correct?

I realized the keys should be sorted?  Where is the code that sorts the keys?

> Implement Lucene FST in for key index
> -
>
> Key: CASSANDRA-4324
> URL: https://issues.apache.org/jira/browse/CASSANDRA-4324
> Project: Cassandra
>  Issue Type: Improvement
>Reporter: Jason Rutherglen
>Assignee: Jason Rutherglen
>Priority: Minor
> Fix For: 1.2
>
> Attachments: CASSANDRA-4324.patch, CASSANDRA-4324.patch, 
> lucene-core-4.0-SNAPSHOT.jar
>
>
> The Lucene FST data structure offers a compact and fast system for indexing 
> Cassandra keys.  More keys may be loaded which in turn should seeks faster.
> * Update the IndexSummary class to make use of the Lucene FST, overriding the 
> serialization mechanism.
> * Alter SSTableReader to make use of the FST seek mechanism

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: 
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira




[jira] [Updated] (CASSANDRA-4324) Implement Lucene FST in for key index

2012-07-14 Thread Jason Rutherglen (JIRA)

 [ 
https://issues.apache.org/jira/browse/CASSANDRA-4324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Jason Rutherglen updated CASSANDRA-4324:


Attachment: lucene-core-4.0-SNAPSHOT.jar
CASSANDRA-4324.patch

FSTMemUsage compares the memory usage of the FST vs. IndexSummary.  

On 1 million keys these are the results:

FST: 39,032,383 bytes
IndexSummary: 43,996,068 bytes

A difference of about 4 megabytes.  FST w would be far smaller if the MD5 hash 
was not being applied to the key, eg, it does best to with keys that are 
sequential so that prefix compression may be applied.

To run FSTMemUsage, the lucene-core-4.0-SNAPSHOT.jar needs to be added to the 
lib/ directory.  

The patch was generated using 'git diff HEAD~1..HEAD' because 'git diff' after 
'git add' did not work.

> Implement Lucene FST in for key index
> -
>
> Key: CASSANDRA-4324
> URL: https://issues.apache.org/jira/browse/CASSANDRA-4324
> Project: Cassandra
>  Issue Type: Improvement
>Reporter: Jason Rutherglen
>Assignee: Jason Rutherglen
>Priority: Minor
> Fix For: 1.2
>
> Attachments: CASSANDRA-4324.patch, CASSANDRA-4324.patch, 
> lucene-core-4.0-SNAPSHOT.jar
>
>
> The Lucene FST data structure offers a compact and fast system for indexing 
> Cassandra keys.  More keys may be loaded which in turn should seeks faster.
> * Update the IndexSummary class to make use of the Lucene FST, overriding the 
> serialization mechanism.
> * Alter SSTableReader to make use of the FST seek mechanism

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: 
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira




[2/3] git commit: cqlsh: don't suggest CL.ANY on selects Patch by paul cannon, reviewed by brandonwilliams for CASSANDRA-4074

2012-07-14 Thread brandonwilliams
cqlsh: don't suggest CL.ANY on selects
Patch by paul cannon, reviewed by brandonwilliams for CASSANDRA-4074


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/9f32efa7
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/9f32efa7
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/9f32efa7

Branch: refs/heads/trunk
Commit: 9f32efa727e4298784231a8ebb2d7e3f48630fd0
Parents: 7f6cc5e
Author: Brandon Williams 
Authored: Sat Jul 14 16:21:27 2012 -0500
Committer: Brandon Williams 
Committed: Sat Jul 14 16:21:27 2012 -0500

--
 pylib/cqlshlib/cql3handling.py |   28 ++--
 pylib/cqlshlib/cqlhandling.py  |6 +-
 2 files changed, 23 insertions(+), 11 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/cassandra/blob/9f32efa7/pylib/cqlshlib/cql3handling.py
--
diff --git a/pylib/cqlshlib/cql3handling.py b/pylib/cqlshlib/cql3handling.py
index 1628c66..5099322 100644
--- a/pylib/cqlshlib/cql3handling.py
+++ b/pylib/cqlshlib/cql3handling.py
@@ -205,15 +205,15 @@ JUNK ::= /([ 
\t\r\f\v]+|(--|[/][/])[^\n\r]*([\n\r]|$)|[/][*].*?[*][/])/ ;
   | 
   ;
 
- ::= 
- | 
- | 
- | 
- | 
- | 
- | 
- | 
- ;
+ ::= cl=( 
+  | 
+  | 
+  | 
+  | 
+  | 
+  | 
+  |  )
+  ;
 
  ::= typename=(  |  ) ;
 
@@ -239,6 +239,10 @@ JUNK ::= /([ 
\t\r\f\v]+|(--|[/][/])[^\n\r]*([\n\r]|$)|[/][*].*?[*][/])/ ;
   ;
 '''
 
+@completer_for('consistencylevel', 'cl')
+def consistencylevel_cl_completer(ctxt, cass):
+return CqlRuleSet.consistency_levels
+
 @completer_for('extendedTerm', 'token')
 def token_word_completer(ctxt, cass):
 return ['TOKEN(']
@@ -285,7 +289,7 @@ syntax_rules += r'''
  ;
  ::= "SELECT" 
 "FROM" cf=
-  ("USING" "CONSISTENCY" )?
+  ("USING" "CONSISTENCY" selcl=)?
   ("WHERE" )?
   ("ORDER" "BY"  ( ","  
)* )?
   ("LIMIT" )?
@@ -304,6 +308,10 @@ syntax_rules += r'''
   ;
 '''
 
+@completer_for('selectStatement', 'selcl')
+def select_statement_consistencylevel(ctxt, cass):
+return [cl for cl in CqlRuleSet.consistency_levels if cl != 'ANY']
+
 @completer_for('orderByClause', 'ordercol')
 def select_order_column_completer(ctxt, cass):
 prev_order_cols = ctxt.get_binding('ordercol', ())

http://git-wip-us.apache.org/repos/asf/cassandra/blob/9f32efa7/pylib/cqlshlib/cqlhandling.py
--
diff --git a/pylib/cqlshlib/cqlhandling.py b/pylib/cqlshlib/cqlhandling.py
index aa29c60..715f6f9 100644
--- a/pylib/cqlshlib/cqlhandling.py
+++ b/pylib/cqlshlib/cqlhandling.py
@@ -576,7 +576,7 @@ syntax_rules += r'''
  ;
  ::= "SELECT" 
 "FROM" cf=
-  ("USING" "CONSISTENCY" )?
+  ("USING" "CONSISTENCY" selcl=)?
   ("WHERE" )?
   ("LIMIT" )?
 ;
@@ -592,6 +592,10 @@ syntax_rules += r'''
  ;
 '''
 
+@completer_for('selectStatement', 'selcl')
+def select_statement_consistencylevel(ctxt, cass):
+return [cl for cl in CqlRuleSet.consistency_levels if cl != 'ANY']
+
 @completer_for('selectWhereClause', 'keyname')
 def select_where_keyname_completer(ctxt, cass):
 cfdef = get_cfdef(ctxt, cass)



[3/3] git commit: cqlsh: don't suggest CL.ANY on selects Patch by paul cannon, reviewed by brandonwilliams for CASSANDRA-4074

2012-07-14 Thread brandonwilliams
cqlsh: don't suggest CL.ANY on selects
Patch by paul cannon, reviewed by brandonwilliams for CASSANDRA-4074


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/9f32efa7
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/9f32efa7
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/9f32efa7

Branch: refs/heads/cassandra-1.1
Commit: 9f32efa727e4298784231a8ebb2d7e3f48630fd0
Parents: 7f6cc5e
Author: Brandon Williams 
Authored: Sat Jul 14 16:21:27 2012 -0500
Committer: Brandon Williams 
Committed: Sat Jul 14 16:21:27 2012 -0500

--
 pylib/cqlshlib/cql3handling.py |   28 ++--
 pylib/cqlshlib/cqlhandling.py  |6 +-
 2 files changed, 23 insertions(+), 11 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/cassandra/blob/9f32efa7/pylib/cqlshlib/cql3handling.py
--
diff --git a/pylib/cqlshlib/cql3handling.py b/pylib/cqlshlib/cql3handling.py
index 1628c66..5099322 100644
--- a/pylib/cqlshlib/cql3handling.py
+++ b/pylib/cqlshlib/cql3handling.py
@@ -205,15 +205,15 @@ JUNK ::= /([ 
\t\r\f\v]+|(--|[/][/])[^\n\r]*([\n\r]|$)|[/][*].*?[*][/])/ ;
   | 
   ;
 
- ::= 
- | 
- | 
- | 
- | 
- | 
- | 
- | 
- ;
+ ::= cl=( 
+  | 
+  | 
+  | 
+  | 
+  | 
+  | 
+  |  )
+  ;
 
  ::= typename=(  |  ) ;
 
@@ -239,6 +239,10 @@ JUNK ::= /([ 
\t\r\f\v]+|(--|[/][/])[^\n\r]*([\n\r]|$)|[/][*].*?[*][/])/ ;
   ;
 '''
 
+@completer_for('consistencylevel', 'cl')
+def consistencylevel_cl_completer(ctxt, cass):
+return CqlRuleSet.consistency_levels
+
 @completer_for('extendedTerm', 'token')
 def token_word_completer(ctxt, cass):
 return ['TOKEN(']
@@ -285,7 +289,7 @@ syntax_rules += r'''
  ;
  ::= "SELECT" 
 "FROM" cf=
-  ("USING" "CONSISTENCY" )?
+  ("USING" "CONSISTENCY" selcl=)?
   ("WHERE" )?
   ("ORDER" "BY"  ( ","  
)* )?
   ("LIMIT" )?
@@ -304,6 +308,10 @@ syntax_rules += r'''
   ;
 '''
 
+@completer_for('selectStatement', 'selcl')
+def select_statement_consistencylevel(ctxt, cass):
+return [cl for cl in CqlRuleSet.consistency_levels if cl != 'ANY']
+
 @completer_for('orderByClause', 'ordercol')
 def select_order_column_completer(ctxt, cass):
 prev_order_cols = ctxt.get_binding('ordercol', ())

http://git-wip-us.apache.org/repos/asf/cassandra/blob/9f32efa7/pylib/cqlshlib/cqlhandling.py
--
diff --git a/pylib/cqlshlib/cqlhandling.py b/pylib/cqlshlib/cqlhandling.py
index aa29c60..715f6f9 100644
--- a/pylib/cqlshlib/cqlhandling.py
+++ b/pylib/cqlshlib/cqlhandling.py
@@ -576,7 +576,7 @@ syntax_rules += r'''
  ;
  ::= "SELECT" 
 "FROM" cf=
-  ("USING" "CONSISTENCY" )?
+  ("USING" "CONSISTENCY" selcl=)?
   ("WHERE" )?
   ("LIMIT" )?
 ;
@@ -592,6 +592,10 @@ syntax_rules += r'''
  ;
 '''
 
+@completer_for('selectStatement', 'selcl')
+def select_statement_consistencylevel(ctxt, cass):
+return [cl for cl in CqlRuleSet.consistency_levels if cl != 'ANY']
+
 @completer_for('selectWhereClause', 'keyname')
 def select_where_keyname_completer(ctxt, cass):
 cfdef = get_cfdef(ctxt, cass)



[1/3] git commit: Merge branch 'cassandra-1.1' into trunk

2012-07-14 Thread brandonwilliams
Updated Branches:
  refs/heads/cassandra-1.1 7f6cc5ef6 -> 9f32efa72
  refs/heads/trunk 1cb0ad5c4 -> 3c92afdd8


Merge branch 'cassandra-1.1' into trunk


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/3c92afdd
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/3c92afdd
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/3c92afdd

Branch: refs/heads/trunk
Commit: 3c92afdd8a6d75a23e66cb9d26f616b544112e50
Parents: 1cb0ad5 9f32efa
Author: Brandon Williams 
Authored: Sat Jul 14 16:22:14 2012 -0500
Committer: Brandon Williams 
Committed: Sat Jul 14 16:22:14 2012 -0500

--
 pylib/cqlshlib/cql3handling.py |   28 ++--
 pylib/cqlshlib/cqlhandling.py  |6 +-
 2 files changed, 23 insertions(+), 11 deletions(-)
--




[jira] [Comment Edited] (CASSANDRA-4434) add COPY TO

2012-07-14 Thread Brandon Williams (JIRA)

[ 
https://issues.apache.org/jira/browse/CASSANDRA-4434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13414501#comment-13414501
 ] 

Brandon Williams edited comment on CASSANDRA-4434 at 7/14/12 9:05 PM:
--

At a quick glance, I think linesource is only defined for FROM:

{noformat}
cqlsh:Keyspace1> copy "Standard1" to 'foo.csv';
global name 'linesource' is not defined
cqlsh:Keyspace1> 
{noformat}

  was (Author: brandon.williams):
At a quick glance, I think linesource is only defined for TO:

{noformat}
cqlsh:Keyspace1> copy "Standard1" to 'foo.csv';
global name 'linesource' is not defined
cqlsh:Keyspace1> 
{noformat}
  
> add COPY TO
> ---
>
> Key: CASSANDRA-4434
> URL: https://issues.apache.org/jira/browse/CASSANDRA-4434
> Project: Cassandra
>  Issue Type: New Feature
>Reporter: Jonathan Ellis
>Assignee: paul cannon
>  Labels: cqlsh
> Fix For: 1.1.3
>
> Attachments: 0001-cqlsh-implement-COPY-TO.patch
>
>
> CASSANDRA-4012 added COPY FROM; this is a ticket to add the inverse.

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: 
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira




[jira] [Commented] (CASSANDRA-4434) add COPY TO

2012-07-14 Thread Brandon Williams (JIRA)

[ 
https://issues.apache.org/jira/browse/CASSANDRA-4434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13414501#comment-13414501
 ] 

Brandon Williams commented on CASSANDRA-4434:
-

At a quick glance, I think linesource is only defined for TO:

{noformat}
cqlsh:Keyspace1> copy "Standard1" to 'foo.csv';
global name 'linesource' is not defined
cqlsh:Keyspace1> 
{noformat}

> add COPY TO
> ---
>
> Key: CASSANDRA-4434
> URL: https://issues.apache.org/jira/browse/CASSANDRA-4434
> Project: Cassandra
>  Issue Type: New Feature
>Reporter: Jonathan Ellis
>Assignee: paul cannon
>  Labels: cqlsh
> Fix For: 1.1.3
>
> Attachments: 0001-cqlsh-implement-COPY-TO.patch
>
>
> CASSANDRA-4012 added COPY FROM; this is a ticket to add the inverse.

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: 
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira




[Cassandra Wiki] Update of "Streaming" by Pas

2012-07-14 Thread Apache Wiki
Dear Wiki user,

You have subscribed to a wiki page or wiki category on "Cassandra Wiki" for 
change notification.

The "Streaming" page has been changed by Pas:
http://wiki.apache.org/cassandra/Streaming?action=diff&rev1=7&rev2=8

Comment:
nodetool streams is replaced by nodetool netstats

  
  Monitoring the status of streaming on both Source and Destination nodes can 
be found under the `org.apache.cassandra.streaming.StreamingService` MBean.  
The `Status` attribute gives an easy indication of what a node is doing with 
respect to streaming. The operations `getOutgoingFiles(host)` and 
`getIncomingFiles(host)` each return a list of strings describing the status of 
individual files being streamed to and from a given host. Each string follows 
this format:  `[path to file] [bytes sent/received]/[file size]` If you think 
that streaming is taking too long on your cluster, the first thing you should 
do is check `StreamSources` or `StreamDestinations` to figure out which hosts 
are streaming files.  Use those hosts as inputs to `getOutgoingFiles()` or 
`getIncomingFiles()` to check on the status of individual files from the 
problematic source and destination nodes.  Streaming is conducted in 32MB 
chunks, so you should refresh the file status after a few seconds to see if the 
sent/received values change.  If they do not change, or change more slowly than 
you'd like, something is wrong.
  
- The streaming status can also be monitored using {{{nodetool -h  
streams}}}
+ The streaming status can also be monitored using {{{nodetool -h  
-p  netstats}}}
  


[jira] [Commented] (CASSANDRA-4411) Assertion with LCS compaction

2012-07-14 Thread Rudolf VanderLeeden (JIRA)

[ 
https://issues.apache.org/jira/browse/CASSANDRA-4411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13414429#comment-13414429
 ] 

Rudolf VanderLeeden commented on CASSANDRA-4411:


The file assertion.moreinfo.system.log has been attached. 

The assertion ERROR could be reproduced by doing the following:
(1) Bulk load 200 SSTables from a snapshot into a new 3-node cluster
(2) Run nodetool compact and repair
(3) Add ~500 SSTables from the same snapshot
(4) Run nodetool repair

RESULT: 
- we see immediately a StackOverflowError (from the repair command)
- after 2 minutes compaction starts
- after 11 minutes there is the AssertionError


> Assertion with LCS compaction
> -
>
> Key: CASSANDRA-4411
> URL: https://issues.apache.org/jira/browse/CASSANDRA-4411
> Project: Cassandra
>  Issue Type: Bug
>  Components: Core
>Affects Versions: 1.1.2
>Reporter: Anton Winter
> Fix For: 1.1.3
>
> Attachments: 0001-Add-debugging-info-for-LCS.txt, 
> assertion.moreinfo.system.log, system.log
>
>
> As instructed in CASSANDRA-4321 I have raised this issue as a continuation of 
> that issue as it appears the problem still exists.
> I have repeatedly run sstablescrub across all my nodes after the 1.1.2 
> upgrade until sstablescrub shows no errors.  The exceptions described in 
> CASSANDRA-4321 do not occur as frequently now but the integrity check still 
> throws exceptions on a number of nodes.  Once those exceptions occur 
> compactionstats shows a large number of pending tasks with no progression 
> afterwards.
> {code}
> ERROR [CompactionExecutor:150] 2012-07-05 04:26:15,570 
> AbstractCassandraDaemon.java (line 134) Exception in thread 
> Thread[CompactionExecutor:150,1,main]
> java.lang.AssertionError
> at 
> org.apache.cassandra.db.compaction.LeveledManifest.promote(LeveledManifest.java:214)
> at 
> org.apache.cassandra.db.compaction.LeveledCompactionStrategy.handleNotification(LeveledCompactionStrategy.java:158)
> at 
> org.apache.cassandra.db.DataTracker.notifySSTablesChanged(DataTracker.java:531)
> at 
> org.apache.cassandra.db.DataTracker.replaceCompactedSSTables(DataTracker.java:254)
> at 
> org.apache.cassandra.db.ColumnFamilyStore.replaceCompactedSSTables(ColumnFamilyStore.java:978)
> at 
> org.apache.cassandra.db.compaction.CompactionTask.execute(CompactionTask.java:200)
> at 
> org.apache.cassandra.db.compaction.LeveledCompactionTask.execute(LeveledCompactionTask.java:50)
> at 
> org.apache.cassandra.db.compaction.CompactionManager$1.runMayThrow(CompactionManager.java:150)
> at 
> org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:30)
> at 
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
> at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334)
> at java.util.concurrent.FutureTask.run(FutureTask.java:166)
> at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
> at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
> at java.lang.Thread.run(Thread.java:636)
> {code}

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: 
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira




[jira] [Updated] (CASSANDRA-4411) Assertion with LCS compaction

2012-07-14 Thread Rudolf VanderLeeden (JIRA)

 [ 
https://issues.apache.org/jira/browse/CASSANDRA-4411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Rudolf VanderLeeden updated CASSANDRA-4411:
---

Attachment: assertion.moreinfo.system.log

includes extended INFO lines from using 0001 patch

> Assertion with LCS compaction
> -
>
> Key: CASSANDRA-4411
> URL: https://issues.apache.org/jira/browse/CASSANDRA-4411
> Project: Cassandra
>  Issue Type: Bug
>  Components: Core
>Affects Versions: 1.1.2
>Reporter: Anton Winter
> Fix For: 1.1.3
>
> Attachments: 0001-Add-debugging-info-for-LCS.txt, 
> assertion.moreinfo.system.log, system.log
>
>
> As instructed in CASSANDRA-4321 I have raised this issue as a continuation of 
> that issue as it appears the problem still exists.
> I have repeatedly run sstablescrub across all my nodes after the 1.1.2 
> upgrade until sstablescrub shows no errors.  The exceptions described in 
> CASSANDRA-4321 do not occur as frequently now but the integrity check still 
> throws exceptions on a number of nodes.  Once those exceptions occur 
> compactionstats shows a large number of pending tasks with no progression 
> afterwards.
> {code}
> ERROR [CompactionExecutor:150] 2012-07-05 04:26:15,570 
> AbstractCassandraDaemon.java (line 134) Exception in thread 
> Thread[CompactionExecutor:150,1,main]
> java.lang.AssertionError
> at 
> org.apache.cassandra.db.compaction.LeveledManifest.promote(LeveledManifest.java:214)
> at 
> org.apache.cassandra.db.compaction.LeveledCompactionStrategy.handleNotification(LeveledCompactionStrategy.java:158)
> at 
> org.apache.cassandra.db.DataTracker.notifySSTablesChanged(DataTracker.java:531)
> at 
> org.apache.cassandra.db.DataTracker.replaceCompactedSSTables(DataTracker.java:254)
> at 
> org.apache.cassandra.db.ColumnFamilyStore.replaceCompactedSSTables(ColumnFamilyStore.java:978)
> at 
> org.apache.cassandra.db.compaction.CompactionTask.execute(CompactionTask.java:200)
> at 
> org.apache.cassandra.db.compaction.LeveledCompactionTask.execute(LeveledCompactionTask.java:50)
> at 
> org.apache.cassandra.db.compaction.CompactionManager$1.runMayThrow(CompactionManager.java:150)
> at 
> org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:30)
> at 
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
> at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334)
> at java.util.concurrent.FutureTask.run(FutureTask.java:166)
> at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
> at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
> at java.lang.Thread.run(Thread.java:636)
> {code}

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: 
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira




[jira] [Commented] (CASSANDRA-4436) Counters in columns don't preserve correct values after cluster restart

2012-07-14 Thread Peter Velas (JIRA)

[ 
https://issues.apache.org/jira/browse/CASSANDRA-4436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13414315#comment-13414315
 ] 

Peter Velas commented on CASSANDRA-4436:




create keyspace test_old
  with placement_strategy = 'SimpleStrategy'
  and strategy_options = {replication_factor : 2}
  and durable_writes = true;

use test_old;

create column family cf1_increment
  with column_type = 'Standard'
  and comparator = 'BytesType'
  and default_validation_class = 'CounterColumnType'
  and key_validation_class = 'BytesType'
  and read_repair_chance = 1.0
  and dclocal_read_repair_chance = 0.0
  and gc_grace = 864000
  and min_compaction_threshold = 4
  and max_compaction_threshold = 32
  and replicate_on_write = true
  and compaction_strategy = 
'org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy'
  and caching = 'KEYS_ONLY'
  and compression_options = {'sstable_compression' : 
'org.apache.cassandra.io.compress.SnappyCompressor'};



In version 1.0.10 am always able to reproduce with this steps.. but its not 
reproducible in 1.1.2 .

When I stop writing and shutdown node with "nodetool drain" there are some 
small commitlog files, but I don't bother to delete them just restart cassandra 
process. Maybe this is case ?

> Counters in columns don't preserve correct values after cluster restart
> ---
>
> Key: CASSANDRA-4436
> URL: https://issues.apache.org/jira/browse/CASSANDRA-4436
> Project: Cassandra
>  Issue Type: Bug
>  Components: Core
>Affects Versions: 1.0.10
>Reporter: Peter Velas
>
> Similar to #3821. but affecting normal columns. 
> Set up a 2-node cluster with rf=2.
> 1. Create a counter column family and increment a 100 keys in loop 5000 
> times. 
> 2. Then make a rolling restart to cluster. 
> 3. Again increment another 5000 times.
> 4. Make a rolling restart to cluster.
> 5. Again increment another 5000 times.
> 6. Make a rolling restart to cluster.
> After step 6 we were able to reproduce bug with bad counter values. 
> Expected values were 15 000. Values returned from cluster are higher then 
> 15000 + some random number.
> Rolling restarts are done with nodetool drain. Always waiting until second 
> node discover its down then kill java process. 

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: 
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira