[Cassandra Wiki] Trivial Update of HarveyHam by HarveyHam
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The HarveyHam page has been changed by HarveyHam: http://wiki.apache.org/cassandra/HarveyHam New page: Your personality further friendly, because of freshman to help you quite often visit connect with others FOHT via several areas, try to communicate, very good interaction with folks.BR Leisure time or for a good Native american summer months, part-time language translation or perhaps pot, operate the marketplace. ( the guy Relating to organization around Guangzhou ) in addition found the pup as well as sanctioned company, your guests sent back your home, retain FSPEG experience of me personally even.BR BR We come in contact with the product marketplace more widely, invitations, sacks, synthetic leather, furniture, parfum decorations, lights etcetera.,BR Self-learning skill, fantastic at contemplating, hard-working, decent YABGH conversation talents, efficient at getting as well as people, packed with group mood, passion for competitive sports. And yet men and women are not really excellent, many people have various BVP faults, in many attributes including experience, sociable experience; but I imagine everyone of these may by their very own goals IDK to better the learning, Furthermore are usually relocating it direction!BR KLADBR BR Feel free to visit my webpage [[http://mychanelbagsshop.webs.com|chanel bag]]
[Cassandra Wiki] Trivial Update of ElvaLevin by ElvaLevin
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The ElvaLevin page has been changed by ElvaLevin: http://wiki.apache.org/cassandra/ElvaLevin New page: I don't particularly like sending my picture to pen pals or posting it online given it gets some unwanted and somewhat rude commentary going on. Social Media Expert Gini Dietrich recently shared of her experience moderating a panel of credentialed professionals representing various companies. As websites be a little more socially focused, a growing number of of them have links to social networking and bookmarking services, including Facebook, Twitter, Digg and lots of others. Spend a little while getting to know the possibilities on Facebook and the way customizable the friendship options are. You can confirm the visibility of your current content by using Facebook's 'View Profile as' function.BR BR BR When you enter the Facebook settings you can then select Push Notifications, which will offer you a whole array of options. There are several different ways in which you'll be able to add widgets for a website or blog as a way to get website visitors to further your Facebook presence. Along with photos, videos and (bad. I bring this up not because I think many of us should abide in the same way Facebook want us to, but because Facebook does reserve the authority to close your account should you violate their Terms. As an added bonus, nosey friends will spam all of your friends list with friend invites - in order to start their nosey shenanigans throughout again. BR BR Send 'friend requests' on the people with whom you want to connect. Vitamin Water. Also what do you want to do with that love. It was more than I could ask for. As such, you should constantly be vigilant and on your own guard while using the website. BR BR Never drop links on people's walls, and don't send links via private messages. However, whether your kids is younger than this or older, there are a couple of factors to consider whenever you make your decision with this matter. We post pictures of ourselves on facebook, and spend hours trying to get people from high school graduation. We want to work with clients that are Data savvy and appreciate the need for ROI based marketing We have dealt with multiple brands on social websites and already have got 4 from Top 30 brands in Facebook India. If you deny a buddy request, the requester can identify the next time they search your company name, because Facebook provides them while using option to provide you as a pal, again. BR BR So in the event you like using FB chat then you might actually consider utilising this program. As businesses increase their use of social networking to attract new customers to many and services, Facebook could be a valuable tool for attracting your ideal client. Here are a few tips for attracting fans. If the horse isn't fast enough then build the car.BR Facebook easily allows you to definitely customize what information is shown to others by the way of simple to manage drop down tabs like so:.BR BR Here is my webpage [[http://www.preachr.com/blogs/user/LenoreOtt|http://www.preachr.com/blogs/user/LenoreOtt]]
[Cassandra Wiki] Trivial Update of MarshallX by MarshallX
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The MarshallX page has been changed by MarshallX: http://wiki.apache.org/cassandra/MarshallX New page: Good day, most people.BR BR Of course, I'm:Cpz JnlgdBR BR Take place the following, We were rather delighted, given that I could in your iwpyr cutting edge natural environment, to uncover latest friends.BR BR I am a finding out in most cases, general overall look, natural general introverted individuals.BR BR We're calm, model, is also somewhat zj superior, everybody can make friends beside me.BR I love browse the sunday paper.BR BR Oh, anybody thought I have been numerous persons the main advantages of the software, however i jvvdi was in fact relaxing, hmmm, here is the destination I personally powerless oh. ypeBR BR In future analysis klvbcmn lifespan, provide merge collectively, research tricky, for very own near future and relax a good schedule, people do their best at the same time! Thank you.BR BR Visit my blog post ... [[http://www.dressebest.com|wedding dress]]
[Cassandra Wiki] Trivial Update of MinnaHull by MinnaHull
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The MinnaHull page has been changed by MinnaHull: http://wiki.apache.org/cassandra/MinnaHull New page: Most people are fine, That i may be a rainy day, for the reason that just yea was given birth to at a day you need it, dad is merely a further designate is certainly the summer months, thus Inch day you need it In to commence, in addition to folks likewise trust I prefer bamboo bedding limbs from originate damp, help make fwxvqidbd advance regularly!BR This individual subsequently due to the fact some individuals are unable to deal with in to the full of sunshine temperature to be able to name us a rainy day, to prevent this In . disorder , coupled with to make sure you reject the straightforward name on the character, holiday to Inch play name Inches. Throughout southern california simple, the truth is, is a Half inch after that Centimeter term, given that the evening I had been delivered really will be the mother and father wed a couple of abwpvz ever moment secondary. Inch Xia Yi homophonic written text about Ningbo wonderful In, develop our enjoyment towards, oh yeah, a bit of Inch after that Inches message overly genteel, placed it all the way down, feather way up directly into one divides into two.BR Absolutely everyone shows I am a the sun's rays woman, since So i am pleased. That i really do not stay, lol lol, turn into buddies having a smallish seat, is definitely a professor plus my very own srjllq mother and father is currently the main intend. I like party, nevertheless the wise to pursue their own song party, not even according to the specifications associated with tutors to rehearse the essential abilities; I recommend painting like a pro, but it is better to doodle, typically the baby's facial skin coloured earth-friendly even let alone; I enjoy skating, however the most interesting is approximately several 5 associates, in concert to learn the best way to struggling . zwdBR Grow older, Let me become melted bowls in the w master, of course, Through experience i miss the ideal college or university.BR BR Also visit my web-site: [[http://www.stuffchanelbags.com|chanel wallet]]
[Cassandra Wiki] Trivial Update of AntwanMer by AntwanMer
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The AntwanMer page has been changed by AntwanMer: http://wiki.apache.org/cassandra/AntwanMer New page: Hi !! I am SIBYL MCLEOD. Soon i will turn 44.BR I work as a Beekeeper. I like to do Dominoes. My father name is Stephen and he is a Jurist. My mother is a Falconer.BR BR my weblog [[http://www.bestgoodwatches.com|watches replica]]
[Cassandra Wiki] Trivial Update of JohnnieNo by JohnnieNo
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The JohnnieNo page has been changed by JohnnieNo: http://wiki.apache.org/cassandra/JohnnieNo New page: She is acknowledged by the title of Gabriele Perrone. Vermont is wherever she and her spouse are living.BR Her task is a inventory command and purchase filler. What she really enjoys carrying out is drawing but she's been having on new issues these days. Examine out the most current information on her web site: http://binaryoptionstrading654.com
[Cassandra Wiki] Trivial Update of Lynwood82 by Lynwood82
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The Lynwood82 page has been changed by Lynwood82: http://wiki.apache.org/cassandra/Lynwood82 New page: Wassp People !! The name is ELADIA DAVIS. This feb i will be 40.BR I want to study at The Awful Academy which has a branch in North Las Vegas. My papa name is Neil and he is a Software Engineer. My momy is a Estate Agent.BR BR My web page; [[http://www.packchanelbags.com|chanel replica]]
[jira] [Commented] (CASSANDRA-5376) CQL3: IN clause on last key not working when schema includes set,list or map
[
https://issues.apache.org/jira/browse/CASSANDRA-5376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13615065#comment-13615065
]
Aleksey Yeschenko commented on CASSANDRA-5376:
--
+1
CQL3: IN clause on last key not working when schema includes set,list or map
Key: CASSANDRA-5376
URL: https://issues.apache.org/jira/browse/CASSANDRA-5376
Project: Cassandra
Issue Type: Bug
Components: Core
Affects Versions: 1.2.3
Reporter: Christiaan Willemsen
Assignee: Sylvain Lebresne
Priority: Minor
Fix For: 1.2.4
Attachments: 5376.txt
This is an exception on the fix of
https://issues.apache.org/jira/browse/CASSANDRA-5230
Looks like any schema using map,list or set won't work with IN clauses on the
last key (in this example c)
Schema:
{code}
CREATE TABLE foo2 (
key text,
c bigint,
v text,
x settext,
PRIMARY KEY (key, c)
);
{code}
Query:
{code}select * from foo2 where key = 'foo' and c in (1,3,4) ;{code}
This will lead to an assertion error on the nodes:
{code}java.lang.AssertionError
at
org.apache.cassandra.cql3.statements.SelectStatement.buildBound(SelectStatement.java:540)
at
org.apache.cassandra.cql3.statements.SelectStatement.getRequestedBound(SelectStatement.java:568)
at
org.apache.cassandra.cql3.statements.SelectStatement.makeFilter(SelectStatement.java:308)
at
org.apache.cassandra.cql3.statements.SelectStatement.getSliceCommands(SelectStatement.java:219)
at
org.apache.cassandra.cql3.statements.SelectStatement.execute(SelectStatement.java:132)
at
org.apache.cassandra.cql3.statements.SelectStatement.execute(SelectStatement.java:62)
at
org.apache.cassandra.cql3.QueryProcessor.processStatement(QueryProcessor.java:132)
at
org.apache.cassandra.cql3.QueryProcessor.process(QueryProcessor.java:143)
at
org.apache.cassandra.thrift.CassandraServer.execute_cql3_query(CassandraServer.java:1726)
at
org.apache.cassandra.thrift.Cassandra$Processor$execute_cql3_query.getResult(Cassandra.java:4074)
at
org.apache.cassandra.thrift.Cassandra$Processor$execute_cql3_query.getResult(Cassandra.java:4062)
at org.apache.thrift.ProcessFunction.process(ProcessFunction.java:32)
at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:34)
at
org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:199)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:722)
{code}
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
git commit: Invalid streamId in cql binary protocol when using invalid CL
Updated Branches:
refs/heads/cassandra-1.2 01bc564bb - b14fc6d0c
Invalid streamId in cql binary protocol when using invalid CL
patch by slebresne; reviewed by pchalamet for CASSANDRA-5164
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/b14fc6d0
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/b14fc6d0
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/b14fc6d0
Branch: refs/heads/cassandra-1.2
Commit: b14fc6d0cda035633590dbe495e9ba08c21d26cc
Parents: 01bc564
Author: Sylvain Lebresne sylv...@datastax.com
Authored: Wed Mar 27 10:51:05 2013 +0100
Committer: Sylvain Lebresne sylv...@datastax.com
Committed: Wed Mar 27 10:51:05 2013 +0100
--
CHANGES.txt|1 +
.../org/apache/cassandra/transport/Message.java| 38 +--
.../cassandra/transport/messages/ErrorMessage.java | 34 -
3 files changed, 56 insertions(+), 17 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/cassandra/blob/b14fc6d0/CHANGES.txt
--
diff --git a/CHANGES.txt b/CHANGES.txt
index 184e70d..3722f2d 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -9,6 +9,7 @@
* Validate that provided CQL3 collection value are 64K (CASSANDRA-5355)
* Make upgradeSSTable skip current version sstables by default
(CASSANDRA-5366)
* Optimize min/max timestamp collection (CASSANDRA-5373)
+ * Invalid streamId in cql binary protocol when using invalid CL
(CASSANDRA-5164)
Merged from 1.1:
* cli: Quote ks and cf names in schema output when needed (CASSANDRA-5052)
* Fix bad default for min/max timestamp in SSTableMetadata (CASSANDRA-5372)
http://git-wip-us.apache.org/repos/asf/cassandra/blob/b14fc6d0/src/java/org/apache/cassandra/transport/Message.java
--
diff --git a/src/java/org/apache/cassandra/transport/Message.java
b/src/java/org/apache/cassandra/transport/Message.java
index d4d3da6..8aec501 100644
--- a/src/java/org/apache/cassandra/transport/Message.java
+++ b/src/java/org/apache/cassandra/transport/Message.java
@@ -205,25 +205,33 @@ public abstract class Message
UUID tracingId = isRequest || !isTracing ? null :
CBUtil.readUuid(frame.body);
-Message message = frame.header.type.codec.decode(frame.body);
-message.setStreamId(frame.header.streamId);
-
-if (isRequest)
+try
{
-assert message instanceof Request;
-Request req = (Request)message;
-req.attach(frame.connection);
-if (isTracing)
-req.setTracingRequested();
+Message message = frame.header.type.codec.decode(frame.body);
+message.setStreamId(frame.header.streamId);
+
+if (isRequest)
+{
+assert message instanceof Request;
+Request req = (Request)message;
+req.attach(frame.connection);
+if (isTracing)
+req.setTracingRequested();
+}
+else
+{
+assert message instanceof Response;
+if (isTracing)
+((Response)message).setTracingId(tracingId);
+}
+
+return message;
}
-else
+catch (Exception ex)
{
-assert message instanceof Response;
-if (isTracing)
-((Response)message).setTracingId(tracingId);
+// Remember the streamId
+throw ErrorMessage.wrap(ex, frame.header.streamId);
}
-
-return message;
}
}
http://git-wip-us.apache.org/repos/asf/cassandra/blob/b14fc6d0/src/java/org/apache/cassandra/transport/messages/ErrorMessage.java
--
diff --git a/src/java/org/apache/cassandra/transport/messages/ErrorMessage.java
b/src/java/org/apache/cassandra/transport/messages/ErrorMessage.java
index 0751584..dd685fa 100644
--- a/src/java/org/apache/cassandra/transport/messages/ErrorMessage.java
+++ b/src/java/org/apache/cassandra/transport/messages/ErrorMessage.java
@@ -188,14 +188,27 @@ public class ErrorMessage extends Message.Response
this.error = error;
}
+private ErrorMessage(TransportException error, int streamId)
+{
+this(error);
+setStreamId(streamId);
+}
+
public static ErrorMessage fromException(Throwable e)
{
+int streamId = 0;
+if (e instanceof WrappedException)
+{
+streamId =
[1/2] git commit: Invalid streamId in cql binary protocol when using invalid CL
Updated Branches:
refs/heads/trunk 29564517a - f6106a18a
Invalid streamId in cql binary protocol when using invalid CL
patch by slebresne; reviewed by pchalamet for CASSANDRA-5164
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/b14fc6d0
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/b14fc6d0
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/b14fc6d0
Branch: refs/heads/trunk
Commit: b14fc6d0cda035633590dbe495e9ba08c21d26cc
Parents: 01bc564
Author: Sylvain Lebresne sylv...@datastax.com
Authored: Wed Mar 27 10:51:05 2013 +0100
Committer: Sylvain Lebresne sylv...@datastax.com
Committed: Wed Mar 27 10:51:05 2013 +0100
--
CHANGES.txt|1 +
.../org/apache/cassandra/transport/Message.java| 38 +--
.../cassandra/transport/messages/ErrorMessage.java | 34 -
3 files changed, 56 insertions(+), 17 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/cassandra/blob/b14fc6d0/CHANGES.txt
--
diff --git a/CHANGES.txt b/CHANGES.txt
index 184e70d..3722f2d 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -9,6 +9,7 @@
* Validate that provided CQL3 collection value are 64K (CASSANDRA-5355)
* Make upgradeSSTable skip current version sstables by default
(CASSANDRA-5366)
* Optimize min/max timestamp collection (CASSANDRA-5373)
+ * Invalid streamId in cql binary protocol when using invalid CL
(CASSANDRA-5164)
Merged from 1.1:
* cli: Quote ks and cf names in schema output when needed (CASSANDRA-5052)
* Fix bad default for min/max timestamp in SSTableMetadata (CASSANDRA-5372)
http://git-wip-us.apache.org/repos/asf/cassandra/blob/b14fc6d0/src/java/org/apache/cassandra/transport/Message.java
--
diff --git a/src/java/org/apache/cassandra/transport/Message.java
b/src/java/org/apache/cassandra/transport/Message.java
index d4d3da6..8aec501 100644
--- a/src/java/org/apache/cassandra/transport/Message.java
+++ b/src/java/org/apache/cassandra/transport/Message.java
@@ -205,25 +205,33 @@ public abstract class Message
UUID tracingId = isRequest || !isTracing ? null :
CBUtil.readUuid(frame.body);
-Message message = frame.header.type.codec.decode(frame.body);
-message.setStreamId(frame.header.streamId);
-
-if (isRequest)
+try
{
-assert message instanceof Request;
-Request req = (Request)message;
-req.attach(frame.connection);
-if (isTracing)
-req.setTracingRequested();
+Message message = frame.header.type.codec.decode(frame.body);
+message.setStreamId(frame.header.streamId);
+
+if (isRequest)
+{
+assert message instanceof Request;
+Request req = (Request)message;
+req.attach(frame.connection);
+if (isTracing)
+req.setTracingRequested();
+}
+else
+{
+assert message instanceof Response;
+if (isTracing)
+((Response)message).setTracingId(tracingId);
+}
+
+return message;
}
-else
+catch (Exception ex)
{
-assert message instanceof Response;
-if (isTracing)
-((Response)message).setTracingId(tracingId);
+// Remember the streamId
+throw ErrorMessage.wrap(ex, frame.header.streamId);
}
-
-return message;
}
}
http://git-wip-us.apache.org/repos/asf/cassandra/blob/b14fc6d0/src/java/org/apache/cassandra/transport/messages/ErrorMessage.java
--
diff --git a/src/java/org/apache/cassandra/transport/messages/ErrorMessage.java
b/src/java/org/apache/cassandra/transport/messages/ErrorMessage.java
index 0751584..dd685fa 100644
--- a/src/java/org/apache/cassandra/transport/messages/ErrorMessage.java
+++ b/src/java/org/apache/cassandra/transport/messages/ErrorMessage.java
@@ -188,14 +188,27 @@ public class ErrorMessage extends Message.Response
this.error = error;
}
+private ErrorMessage(TransportException error, int streamId)
+{
+this(error);
+setStreamId(streamId);
+}
+
public static ErrorMessage fromException(Throwable e)
{
+int streamId = 0;
+if (e instanceof WrappedException)
+{
+streamId =
[2/2] git commit: Merge branch 'cassandra-1.2' into trunk
Merge branch 'cassandra-1.2' into trunk Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/f6106a18 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/f6106a18 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/f6106a18 Branch: refs/heads/trunk Commit: f6106a18a2b4fee8e7041fe5f28227dd015b67a1 Parents: 2956451 b14fc6d Author: Sylvain Lebresne sylv...@datastax.com Authored: Wed Mar 27 10:52:44 2013 +0100 Committer: Sylvain Lebresne sylv...@datastax.com Committed: Wed Mar 27 10:52:44 2013 +0100 -- CHANGES.txt|1 + .../org/apache/cassandra/transport/Message.java| 38 +-- .../cassandra/transport/messages/ErrorMessage.java | 34 - 3 files changed, 56 insertions(+), 17 deletions(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/f6106a18/CHANGES.txt -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/f6106a18/src/java/org/apache/cassandra/transport/Message.java --
[jira] [Commented] (CASSANDRA-4775) Counters 2.0
[ https://issues.apache.org/jira/browse/CASSANDRA-4775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13615076#comment-13615076 ] Staņislavs Koikovs commented on CASSANDRA-4775: --- I think you could simplify counter implementation a little bit by creating 2 counters internally instead of 1 (increment counter and decrement counter). So with RF=3 each counter replica would keep track of 6 sub-counters (2 local and 4 remote). To get counter value you sum all sub-counters and for conflict resolution you take a sub-counter with higher value. I hope this makes sense. Counters 2.0 Key: CASSANDRA-4775 URL: https://issues.apache.org/jira/browse/CASSANDRA-4775 Project: Cassandra Issue Type: New Feature Components: Core Reporter: Arya Goudarzi Labels: counters Fix For: 2.0 The existing partitioned counters remain a source of frustration for most users almost two years after being introduced. The remaining problems are inherent in the design, not something that can be fixed given enough time/eyeballs. Ideally a solution would give us - similar performance - less special cases in the code - potential for a retry mechanism -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[Cassandra Wiki] Trivial Update of Trista543 by Trista543
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The Trista543 page has been changed by Trista543: http://wiki.apache.org/cassandra/Trista543 New page: Zinc has been regarded for a very long time to aid in the production of semen.BR BR BR Here is my web page; [[http://zetaclear01.blogspot.com/2013/03/zetaclear.html|source for this article]]
[jira] [Updated] (CASSANDRA-5383) Windows 7 deleting/renaming files problem
[
https://issues.apache.org/jira/browse/CASSANDRA-5383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Marcus Eriksson updated CASSANDRA-5383:
---
Attachment: 0001-use-Java7-apis-for-deleting-and-moving-files-and-cre.patch
not yet tested on windows due to CASSANDRA-5388
Windows 7 deleting/renaming files problem
-
Key: CASSANDRA-5383
URL: https://issues.apache.org/jira/browse/CASSANDRA-5383
Project: Cassandra
Issue Type: Bug
Components: Tests
Affects Versions: 2.0
Reporter: Ryan McGuire
Assignee: Marcus Eriksson
Fix For: 2.0
Attachments:
0001-use-Java7-apis-for-deleting-and-moving-files-and-cre.patch
Two unit tests are failing on Windows 7 due to errors in renaming/deleting
files:
org.apache.cassandra.db.ColumnFamilyStoreTest:
{code}
[junit] Testsuite: org.apache.cassandra.db.ColumnFamilyStoreTest
[junit] Tests run: 27, Failures: 0, Errors: 2, Skipped: 0, Time elapsed:
13.904 sec
[junit]
[junit] - Standard Error -
[junit] ERROR 13:06:46,058 Unable to delete
build\test\cassandra\data\Keyspace1\Indexed2\Keyspace1-Indexed2.birthdate_index-ja-1-Data.db
(it will be removed on server restart; we'll also retry after GC)
[junit] ERROR 13:06:48,508 Fatal exception in thread
Thread[NonPeriodicTasks:1,5,main]
[junit] java.lang.RuntimeException: Tried to hard link to file that does
not exist
build\test\cassandra\data\Keyspace1\Standard1\Keyspace1-Standard1-ja-7-Statistics.db
[junit] at
org.apache.cassandra.io.util.FileUtils.createHardLink(FileUtils.java:72)
[junit] at
org.apache.cassandra.io.sstable.SSTableReader.createLinks(SSTableReader.java:1057)
[junit] at
org.apache.cassandra.db.DataTracker$1.run(DataTracker.java:168)
[junit] at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
[junit] at
java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
[junit] at java.util.concurrent.FutureTask.run(FutureTask.java:138)
[junit] at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:98)
[junit] at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:206)
[junit] at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
[junit] at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
[junit] at java.lang.Thread.run(Thread.java:662)
[junit] - ---
[junit] Testcase:
testSliceByNamesCommandOldMetatada(org.apache.cassandra.db.ColumnFamilyStoreTest):
Caused an ERROR
[junit] Failed to rename
build\test\cassandra\data\Keyspace1\Standard1\Keyspace1-Standard1-ja-6-Statistics.db-tmp
to
build\test\cassandra\data\Keyspace1\Standard1\Keyspace1-Standard1-ja-6-Statistics.db
[junit] java.lang.RuntimeException: Failed to rename
build\test\cassandra\data\Keyspace1\Standard1\Keyspace1-Standard1-ja-6-Statistics.db-tmp
to
build\test\cassandra\data\Keyspace1\Standard1\Keyspace1-Standard1-ja-6-Statistics.db
[junit] at
org.apache.cassandra.io.util.FileUtils.renameWithConfirm(FileUtils.java:133)
[junit] at
org.apache.cassandra.io.util.FileUtils.renameWithConfirm(FileUtils.java:122)
[junit] at
org.apache.cassandra.db.compaction.LeveledManifest.mutateLevel(LeveledManifest.java:575)
[junit] at
org.apache.cassandra.db.ColumnFamilyStore.loadNewSSTables(ColumnFamilyStore.java:589)
[junit] at
org.apache.cassandra.db.ColumnFamilyStoreTest.testSliceByNamesCommandOldMetatada(ColumnFamilyStoreTest.java:885)
[junit]
[junit]
[junit] Testcase:
testRemoveUnifinishedCompactionLeftovers(org.apache.cassandra.db.ColumnFamilyStoreTest):
Caused an ERROR
[junit] java.io.IOException: Failed to delete
c:\Users\Ryan\git\cassandra\build\test\cassandra\data\Keyspace1\Standard3\Keyspace1-Standard3-ja-2-Data.db
[junit] FSWriteError in
build\test\cassandra\data\Keyspace1\Standard3\Keyspace1-Standard3-ja-2-Data.db
[junit] at
org.apache.cassandra.io.util.FileUtils.deleteWithConfirm(FileUtils.java:112)
[junit] at
org.apache.cassandra.io.util.FileUtils.deleteWithConfirm(FileUtils.java:103)
[junit] at
org.apache.cassandra.io.sstable.SSTable.delete(SSTable.java:139)
[junit] at
org.apache.cassandra.db.ColumnFamilyStore.removeUnfinishedCompactionLeftovers(ColumnFamilyStore.java:507)
[junit] at
org.apache.cassandra.db.ColumnFamilyStoreTest.testRemoveUnifinishedCompactionLeftovers(ColumnFamilyStoreTest.java:1246)
[junit] Caused by: java.io.IOException:
[jira] [Updated] (CASSANDRA-5386) CQL Not Handling Descending Clustering Order On A timeuuid Correctly
[
https://issues.apache.org/jira/browse/CASSANDRA-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sylvain Lebresne updated CASSANDRA-5386:
Reviewer: (was: slebresne)
CQL Not Handling Descending Clustering Order On A timeuuid Correctly
Key: CASSANDRA-5386
URL: https://issues.apache.org/jira/browse/CASSANDRA-5386
Project: Cassandra
Issue Type: Bug
Affects Versions: 1.2.3
Environment: Apache Cassandra 1.2.3, Mac OS X (Lion), cql 3
Reporter: Gareth Collins
Assignee: Sylvain Lebresne
Fix For: 1.2.4
Attachments: 5386.txt
I raised this issue as a question in the mailing list:
http://www.mail-archive.com/user@cassandra.apache.org/msg28787.html
If I create a table (cqlsh) with the following schema:
CREATE TABLE mytable ( column1 text,
column2 text,
messageId timeuuid,
message blob,
PRIMARY KEY ((column1, column2), messageId));
I can quite happily add rows to this table:
insert into client_queue (column1,column2,messageId,message) VALUES
('string1','string2',now(),'ABCCDCC123');
If I however create a table with a desc clustering order on messageid:
CREATE TABLE mytable ( column1 text,
column2 text,
messageId timeuuid,
message blob,
PRIMARY KEY ((column1, column2), messageId)) WITH CLUSTERING
ORDER BY (messageId DESC);
Inserts are failing. I am getting the following error:
insert into client_queue2 (column1,column2,messageId,message) VALUES
('string1','string2',now(),'ABCCDCC123');
I get the following error:
Bad Request: Type error: cannot assign result of function now (type
timeuuid) to messageid (type
'org.apache.cassandra.db.marshal.ReversedType(org.apache.cassandra.db.marshal.TimeUUIDType)')
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (CASSANDRA-5386) CQL Not Handling Descending Clustering Order On A timeuuid Correctly
[
https://issues.apache.org/jira/browse/CASSANDRA-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sylvain Lebresne updated CASSANDRA-5386:
Attachment: 5386.txt
Patch attached to fix (to ignore ReversedType when we do a type comparison).
CQL Not Handling Descending Clustering Order On A timeuuid Correctly
Key: CASSANDRA-5386
URL: https://issues.apache.org/jira/browse/CASSANDRA-5386
Project: Cassandra
Issue Type: Bug
Affects Versions: 1.2.3
Environment: Apache Cassandra 1.2.3, Mac OS X (Lion), cql 3
Reporter: Gareth Collins
Attachments: 5386.txt
I raised this issue as a question in the mailing list:
http://www.mail-archive.com/user@cassandra.apache.org/msg28787.html
If I create a table (cqlsh) with the following schema:
CREATE TABLE mytable ( column1 text,
column2 text,
messageId timeuuid,
message blob,
PRIMARY KEY ((column1, column2), messageId));
I can quite happily add rows to this table:
insert into client_queue (column1,column2,messageId,message) VALUES
('string1','string2',now(),'ABCCDCC123');
If I however create a table with a desc clustering order on messageid:
CREATE TABLE mytable ( column1 text,
column2 text,
messageId timeuuid,
message blob,
PRIMARY KEY ((column1, column2), messageId)) WITH CLUSTERING
ORDER BY (messageId DESC);
Inserts are failing. I am getting the following error:
insert into client_queue2 (column1,column2,messageId,message) VALUES
('string1','string2',now(),'ABCCDCC123');
I get the following error:
Bad Request: Type error: cannot assign result of function now (type
timeuuid) to messageid (type
'org.apache.cassandra.db.marshal.ReversedType(org.apache.cassandra.db.marshal.TimeUUIDType)')
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
[Cassandra Wiki] Trivial Update of FranklinC by FranklinC
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The FranklinC page has been changed by FranklinC: http://wiki.apache.org/cassandra/FranklinC New page: Hi there! I'm michael duivis: Ugsw K. JfznxkiBR I love to make friends, v whichever land, k the specific area do you find yourself j via.BR And I also s want to go through several advertisements, literature. Discover a number of manner parts of individual.BR My own get hold of is definitely:803 ' 2556186BR BR Also visit my web page: [[http://www.dressebest.com|plus size wedding dresses]]
[1/2] git commit: Fix validation for IN where clauses with collection
Updated Branches:
refs/heads/cassandra-1.2 b14fc6d0c - 61e329f7a
Fix validation for IN where clauses with collection
patch by slebresne; reviewed by iamaleksey for CASSANDRA-5376
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/193e5660
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/193e5660
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/193e5660
Branch: refs/heads/cassandra-1.2
Commit: 193e56607bc26d8cbba404fd4197ec279bc073b8
Parents: b14fc6d
Author: Sylvain Lebresne sylv...@datastax.com
Authored: Wed Mar 27 11:30:33 2013 +0100
Committer: Sylvain Lebresne sylv...@datastax.com
Committed: Wed Mar 27 11:30:33 2013 +0100
--
CHANGES.txt|1 +
.../cassandra/cql3/statements/SelectStatement.java | 25 --
2 files changed, 22 insertions(+), 4 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/cassandra/blob/193e5660/CHANGES.txt
--
diff --git a/CHANGES.txt b/CHANGES.txt
index 3722f2d..7eaefaa 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -10,6 +10,7 @@
* Make upgradeSSTable skip current version sstables by default
(CASSANDRA-5366)
* Optimize min/max timestamp collection (CASSANDRA-5373)
* Invalid streamId in cql binary protocol when using invalid CL
(CASSANDRA-5164)
+ * Fix validation for IN where clauses with collections (CASSANDRA-5376)
Merged from 1.1:
* cli: Quote ks and cf names in schema output when needed (CASSANDRA-5052)
* Fix bad default for min/max timestamp in SSTableMetadata (CASSANDRA-5372)
http://git-wip-us.apache.org/repos/asf/cassandra/blob/193e5660/src/java/org/apache/cassandra/cql3/statements/SelectStatement.java
--
diff --git a/src/java/org/apache/cassandra/cql3/statements/SelectStatement.java
b/src/java/org/apache/cassandra/cql3/statements/SelectStatement.java
index d5a7425..b218975 100644
--- a/src/java/org/apache/cassandra/cql3/statements/SelectStatement.java
+++ b/src/java/org/apache/cassandra/cql3/statements/SelectStatement.java
@@ -406,7 +406,7 @@ public class SelectStatement implements CQLStatement
return false;
// However, collections always entails one
-if (cfDef.hasCollections)
+if (selectACollection())
return true;
// Otherwise, it is a range query if it has at least one the column
alias
@@ -473,7 +473,7 @@ public class SelectStatement implements CQLStatement
{
// Collections require doing a slice query because a given
collection is a
// non-know set of columns, so we shouldn't get there
-assert !cfDef.hasCollections;
+assert !selectACollection();
SortedSetByteBuffer columns = new
TreeSetByteBuffer(cfDef.cfm.comparator);
@@ -505,6 +505,20 @@ public class SelectStatement implements CQLStatement
}
}
+private boolean selectACollection()
+{
+if (!cfDef.hasCollections)
+return false;
+
+for (CFDefinition.Name name : selection.getColumnsList())
+{
+if (name.type instanceof CollectionType)
+return true;
+}
+
+return false;
+}
+
private static ByteBuffer buildBound(Bound bound,
CollectionCFDefinition.Name names,
Restriction[] restrictions,
@@ -986,9 +1000,12 @@ public class SelectStatement implements CQLStatement
}
// We only support IN for the last name so far
// TODO: #3885 allows us to extend to other parts (cf. #4762)
-else if (restriction.eqValues.size() 1 i !=
stmt.columnRestrictions.length - 1)
+else if (restriction.eqValues.size() 1)
{
-throw new InvalidRequestException(String.format(PRIMARY
KEY part %s cannot be restricted by IN relation, cname));
+if (i != stmt.columnRestrictions.length - 1)
+throw new
InvalidRequestException(String.format(PRIMARY KEY part %s cannot be restricted
by IN relation, cname));
+else if (stmt.selectACollection())
+throw new
InvalidRequestException(String.format(Cannot restrict PRIMARY KEY part %s by
IN relation as a collection is selected by the query, cname));
}
previous = cname;
[2/2] git commit: Copy ResultSet on count query to avoid ConcurrentModificationException
Copy ResultSet on count query to avoid ConcurrentModificationException
patch by slebresne; reviewed by jbellis for CASSANDRA-5282
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/61e329f7
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/61e329f7
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/61e329f7
Branch: refs/heads/cassandra-1.2
Commit: 61e329f7aea6a502c274277ca448c6207072a376
Parents: 193e566
Author: Sylvain Lebresne sylv...@datastax.com
Authored: Wed Mar 27 11:41:36 2013 +0100
Committer: Sylvain Lebresne sylv...@datastax.com
Committed: Wed Mar 27 11:41:36 2013 +0100
--
CHANGES.txt |1 +
src/java/org/apache/cassandra/cql3/ResultSet.java | 11 +--
2 files changed, 6 insertions(+), 6 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/cassandra/blob/61e329f7/CHANGES.txt
--
diff --git a/CHANGES.txt b/CHANGES.txt
index 7eaefaa..26b2360 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -11,6 +11,7 @@
* Optimize min/max timestamp collection (CASSANDRA-5373)
* Invalid streamId in cql binary protocol when using invalid CL
(CASSANDRA-5164)
* Fix validation for IN where clauses with collections (CASSANDRA-5376)
+ * Copy resultSet on count query to avoid ConcurrentModificationException
(CASSANDRA-5382)
Merged from 1.1:
* cli: Quote ks and cf names in schema output when needed (CASSANDRA-5052)
* Fix bad default for min/max timestamp in SSTableMetadata (CASSANDRA-5372)
http://git-wip-us.apache.org/repos/asf/cassandra/blob/61e329f7/src/java/org/apache/cassandra/cql3/ResultSet.java
--
diff --git a/src/java/org/apache/cassandra/cql3/ResultSet.java
b/src/java/org/apache/cassandra/cql3/ResultSet.java
index 290653f..3ddfdc4 100644
--- a/src/java/org/apache/cassandra/cql3/ResultSet.java
+++ b/src/java/org/apache/cassandra/cql3/ResultSet.java
@@ -96,13 +96,12 @@ public class ResultSet
{
String ksName = metadata.names.get(0).ksName;
String cfName = metadata.names.get(0).cfName;
-metadata.names.clear();
-metadata.names.add(new ColumnSpecification(ksName, cfName,
COUNT_COLUMN, LongType.instance));
-
long count = rows.size();
-rows.clear();
-rows.add(Collections.singletonList(ByteBufferUtil.bytes(count)));
-return this;
+
+Metadata newMetadata = new Metadata(Collections.singletonList(new
ColumnSpecification(ksName, cfName, COUNT_COLUMN, LongType.instance)));
+ListListByteBuffer newRows =
Collections.singletonList(Collections.singletonList(ByteBufferUtil.bytes(count)));
+
+return new ResultSet(newMetadata, newRows);
}
public CqlResult toThriftResult()
[3/3] git commit: Merge branch 'cassandra-1.2' into trunk
Merge branch 'cassandra-1.2' into trunk Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/1527fabf Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/1527fabf Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/1527fabf Branch: refs/heads/trunk Commit: 1527fabfce29483cdc62bd98ffeaff7fc7d40903 Parents: f6106a1 61e329f Author: Sylvain Lebresne sylv...@datastax.com Authored: Wed Mar 27 11:42:26 2013 +0100 Committer: Sylvain Lebresne sylv...@datastax.com Committed: Wed Mar 27 11:42:26 2013 +0100 -- CHANGES.txt|2 + src/java/org/apache/cassandra/cql3/ResultSet.java | 11 +++--- .../cassandra/cql3/statements/SelectStatement.java | 25 -- 3 files changed, 28 insertions(+), 10 deletions(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/1527fabf/CHANGES.txt -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/1527fabf/src/java/org/apache/cassandra/cql3/statements/SelectStatement.java --
[2/3] git commit: Copy ResultSet on count query to avoid ConcurrentModificationException
Copy ResultSet on count query to avoid ConcurrentModificationException
patch by slebresne; reviewed by jbellis for CASSANDRA-5282
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/61e329f7
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/61e329f7
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/61e329f7
Branch: refs/heads/trunk
Commit: 61e329f7aea6a502c274277ca448c6207072a376
Parents: 193e566
Author: Sylvain Lebresne sylv...@datastax.com
Authored: Wed Mar 27 11:41:36 2013 +0100
Committer: Sylvain Lebresne sylv...@datastax.com
Committed: Wed Mar 27 11:41:36 2013 +0100
--
CHANGES.txt |1 +
src/java/org/apache/cassandra/cql3/ResultSet.java | 11 +--
2 files changed, 6 insertions(+), 6 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/cassandra/blob/61e329f7/CHANGES.txt
--
diff --git a/CHANGES.txt b/CHANGES.txt
index 7eaefaa..26b2360 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -11,6 +11,7 @@
* Optimize min/max timestamp collection (CASSANDRA-5373)
* Invalid streamId in cql binary protocol when using invalid CL
(CASSANDRA-5164)
* Fix validation for IN where clauses with collections (CASSANDRA-5376)
+ * Copy resultSet on count query to avoid ConcurrentModificationException
(CASSANDRA-5382)
Merged from 1.1:
* cli: Quote ks and cf names in schema output when needed (CASSANDRA-5052)
* Fix bad default for min/max timestamp in SSTableMetadata (CASSANDRA-5372)
http://git-wip-us.apache.org/repos/asf/cassandra/blob/61e329f7/src/java/org/apache/cassandra/cql3/ResultSet.java
--
diff --git a/src/java/org/apache/cassandra/cql3/ResultSet.java
b/src/java/org/apache/cassandra/cql3/ResultSet.java
index 290653f..3ddfdc4 100644
--- a/src/java/org/apache/cassandra/cql3/ResultSet.java
+++ b/src/java/org/apache/cassandra/cql3/ResultSet.java
@@ -96,13 +96,12 @@ public class ResultSet
{
String ksName = metadata.names.get(0).ksName;
String cfName = metadata.names.get(0).cfName;
-metadata.names.clear();
-metadata.names.add(new ColumnSpecification(ksName, cfName,
COUNT_COLUMN, LongType.instance));
-
long count = rows.size();
-rows.clear();
-rows.add(Collections.singletonList(ByteBufferUtil.bytes(count)));
-return this;
+
+Metadata newMetadata = new Metadata(Collections.singletonList(new
ColumnSpecification(ksName, cfName, COUNT_COLUMN, LongType.instance)));
+ListListByteBuffer newRows =
Collections.singletonList(Collections.singletonList(ByteBufferUtil.bytes(count)));
+
+return new ResultSet(newMetadata, newRows);
}
public CqlResult toThriftResult()
[1/3] git commit: Fix validation for IN where clauses with collection
Updated Branches:
refs/heads/trunk f6106a18a - 1527fabfc
Fix validation for IN where clauses with collection
patch by slebresne; reviewed by iamaleksey for CASSANDRA-5376
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/193e5660
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/193e5660
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/193e5660
Branch: refs/heads/trunk
Commit: 193e56607bc26d8cbba404fd4197ec279bc073b8
Parents: b14fc6d
Author: Sylvain Lebresne sylv...@datastax.com
Authored: Wed Mar 27 11:30:33 2013 +0100
Committer: Sylvain Lebresne sylv...@datastax.com
Committed: Wed Mar 27 11:30:33 2013 +0100
--
CHANGES.txt|1 +
.../cassandra/cql3/statements/SelectStatement.java | 25 --
2 files changed, 22 insertions(+), 4 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/cassandra/blob/193e5660/CHANGES.txt
--
diff --git a/CHANGES.txt b/CHANGES.txt
index 3722f2d..7eaefaa 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -10,6 +10,7 @@
* Make upgradeSSTable skip current version sstables by default
(CASSANDRA-5366)
* Optimize min/max timestamp collection (CASSANDRA-5373)
* Invalid streamId in cql binary protocol when using invalid CL
(CASSANDRA-5164)
+ * Fix validation for IN where clauses with collections (CASSANDRA-5376)
Merged from 1.1:
* cli: Quote ks and cf names in schema output when needed (CASSANDRA-5052)
* Fix bad default for min/max timestamp in SSTableMetadata (CASSANDRA-5372)
http://git-wip-us.apache.org/repos/asf/cassandra/blob/193e5660/src/java/org/apache/cassandra/cql3/statements/SelectStatement.java
--
diff --git a/src/java/org/apache/cassandra/cql3/statements/SelectStatement.java
b/src/java/org/apache/cassandra/cql3/statements/SelectStatement.java
index d5a7425..b218975 100644
--- a/src/java/org/apache/cassandra/cql3/statements/SelectStatement.java
+++ b/src/java/org/apache/cassandra/cql3/statements/SelectStatement.java
@@ -406,7 +406,7 @@ public class SelectStatement implements CQLStatement
return false;
// However, collections always entails one
-if (cfDef.hasCollections)
+if (selectACollection())
return true;
// Otherwise, it is a range query if it has at least one the column
alias
@@ -473,7 +473,7 @@ public class SelectStatement implements CQLStatement
{
// Collections require doing a slice query because a given
collection is a
// non-know set of columns, so we shouldn't get there
-assert !cfDef.hasCollections;
+assert !selectACollection();
SortedSetByteBuffer columns = new
TreeSetByteBuffer(cfDef.cfm.comparator);
@@ -505,6 +505,20 @@ public class SelectStatement implements CQLStatement
}
}
+private boolean selectACollection()
+{
+if (!cfDef.hasCollections)
+return false;
+
+for (CFDefinition.Name name : selection.getColumnsList())
+{
+if (name.type instanceof CollectionType)
+return true;
+}
+
+return false;
+}
+
private static ByteBuffer buildBound(Bound bound,
CollectionCFDefinition.Name names,
Restriction[] restrictions,
@@ -986,9 +1000,12 @@ public class SelectStatement implements CQLStatement
}
// We only support IN for the last name so far
// TODO: #3885 allows us to extend to other parts (cf. #4762)
-else if (restriction.eqValues.size() 1 i !=
stmt.columnRestrictions.length - 1)
+else if (restriction.eqValues.size() 1)
{
-throw new InvalidRequestException(String.format(PRIMARY
KEY part %s cannot be restricted by IN relation, cname));
+if (i != stmt.columnRestrictions.length - 1)
+throw new
InvalidRequestException(String.format(PRIMARY KEY part %s cannot be restricted
by IN relation, cname));
+else if (stmt.selectACollection())
+throw new
InvalidRequestException(String.format(Cannot restrict PRIMARY KEY part %s by
IN relation as a collection is selected by the query, cname));
}
previous = cname;
[jira] [Resolved] (CASSANDRA-5382) ConcurrentModificantionException on server when multiple CQL3 read requests received on single column family simultaneously.
[ https://issues.apache.org/jira/browse/CASSANDRA-5382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sylvain Lebresne resolved CASSANDRA-5382. - Resolution: Fixed Fix Version/s: 1.2.4 Reviewer: jbellis Assignee: Sylvain Lebresne Committed, thanks ConcurrentModificantionException on server when multiple CQL3 read requests received on single column family simultaneously. Key: CASSANDRA-5382 URL: https://issues.apache.org/jira/browse/CASSANDRA-5382 Project: Cassandra Issue Type: Bug Affects Versions: 1.2.3 Environment: SLES, Sun JDK 1.6.0_43 Reporter: Jason Reber Assignee: Sylvain Lebresne Priority: Minor Fix For: 1.2.4 Attachments: 0001-Copy-ResultSet-in-makeCountResult.txt The exception below is thrown on the server when two reads are performed at the exact same time on the same column family. This causes the query to fail. The problem appears to be caused by the 'name' list in org.apache.cassandra.cql3.ResultSet$Metadata. The reference is passed in to the constructor and iterated without copying and without a synch block. When two of these ResultSet instances are created from the same metadata list at the same time, a ConcurrentModificationException is thrown. The error: ERROR [Thrift:860] 2013-03-25 09:27:39,467 CustomTThreadPoolServer.java (line 217) Error occurred during processing of message. java.util.ConcurrentModificationException at java.util.AbstractList$Itr.checkForComodification(AbstractList.java:372) at java.util.AbstractList$Itr.next(AbstractList.java:343) at org.apache.cassandra.cql3.ResultSet$Metadata.allInSameCF(ResultSet.java:237) at org.apache.cassandra.cql3.ResultSet$Metadata.init(ResultSet.java:219) at org.apache.cassandra.cql3.ResultSet.init(ResultSet.java:47) at org.apache.cassandra.cql3.statements.Selection$ResultSetBuilder.init(Selection.java:239) at org.apache.cassandra.cql3.statements.Selection$ResultSetBuilder.init(Selection.java:221) at org.apache.cassandra.cql3.statements.Selection.resultSetBuilder(Selection.java:211) at org.apache.cassandra.cql3.statements.SelectStatement.process(SelectStatement.java:655) at org.apache.cassandra.cql3.statements.SelectStatement.processResults(SelectStatement.java:147) at org.apache.cassandra.cql3.statements.SelectStatement.execute(SelectStatement.java:136) at org.apache.cassandra.cql3.statements.SelectStatement.execute(SelectStatement.java:62) at org.apache.cassandra.cql3.QueryProcessor.processStatement(QueryProcessor.java:132) at org.apache.cassandra.cql3.QueryProcessor.processPrepared(QueryProcessor.java:254) at org.apache.cassandra.thrift.CassandraServer.execute_prepared_cql3_query(CassandraServer.java:1851) at org.apache.cassandra.thrift.Cassandra$Processor$execute_prepared_cql3_query.getResult(Cassandra.java:4166) at org.apache.cassandra.thrift.Cassandra$Processor$execute_prepared_cql3_query.getResult(Cassandra.java:4154) at org.apache.thrift.ProcessFunction.process(ProcessFunction.java:32) at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:34) at org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:199) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918) at java.lang.Thread.run(Thread.java:662) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[Cassandra Wiki] Trivial Update of DorrisFla by DorrisFla
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The DorrisFla page has been changed by DorrisFla: http://wiki.apache.org/cassandra/DorrisFla New page: I open The Fathave Up Diane KressDo Blooms Svelte Commonminus kilocalorie Foods And Fab - AllOf breakfast For gimcrack Phen375BR BR Also visit my web-site ... [[http://phen375-pill.com|buy phen375]]
[Cassandra Wiki] Trivial Update of GordonDur by GordonDur
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The GordonDur page has been changed by GordonDur: http://wiki.apache.org/cassandra/GordonDur New page: Latosha Perona publishes articles web content related to [[http://www.themaidsdurham.ca/hiring-a-maid-service-durham-on|themaidsdurham.ca]][[http://www.themaidsdurham.ca/maid-services-durham-on|maid service durham on]] ca/a.
[Cassandra Wiki] Trivial Update of OCUTammar by OCUTammar
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The OCUTammar page has been changed by OCUTammar: http://wiki.apache.org/cassandra/OCUTammar New page: Not much to write about myself really.BR BR My site - [[http://www.facebookpeace.com/profile/chasesaxto|just click the next website page]]
[Cassandra Wiki] Trivial Update of DoraGreen by DoraGreen
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The DoraGreen page has been changed by DoraGreen: http://wiki.apache.org/cassandra/DoraGreen New page: Not much to tell about myself really.BR BR Review my webpage - [[http://www.bojler.co|bojler kospel]]
[jira] [Commented] (CASSANDRA-5381) java.io.EOFException exception while executing nodetool repair with compression enabled
[ https://issues.apache.org/jira/browse/CASSANDRA-5381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13615171#comment-13615171 ] Mathijs Vogelzang commented on CASSANDRA-5381: -- We have the same issue where all streaming between nodes fails with an EOFException and then too many retries. This started when we upgraded from 1.1.7 to 1.2.2, and didn't go away on subsequent upgrade to 1.2.3. We tried running with/without internode compression and encryption, and found out that when encryption is off, everything works fine (also WITH compression on). With encryption on, it doesn't work, also with internode compression turned off, so for us it definitely has something to do with streaming while internode encryption is enabled. java.io.EOFException exception while executing nodetool repair with compression enabled --- Key: CASSANDRA-5381 URL: https://issues.apache.org/jira/browse/CASSANDRA-5381 Project: Cassandra Issue Type: Bug Components: Core Affects Versions: 1.2.3 Environment: Linux Virtual Machines, Red Hat Enterprise release 6.4, kernel version 2.6.32-358.2.1.el6.x86_64. Each VM has 8GB memory and 4vCPUS. Reporter: Neil Thomson Priority: Minor Very similar to issue reported in CASSANDRA-5105. I have 3 nodes configured in a cluster. The nodes are configured with compression enabled. When attempting a nodetool repair on one node, i get exceptions in the other nodes in the cluster. Disabling compression on the column family allows nodetool repair to run without error. Exception: INFO [Streaming to /3.69.211.179:2] 2013-03-25 12:30:27,874 StreamReplyVerbHandler.java (line 50) Need to re-stream file /var/lib/cassandra/data/rt/values/rt-values-ib-1-Data.db to /3.69.211.179 INFO [Streaming to /3.69.211.179:2] 2013-03-25 12:30:27,991 StreamReplyVerbHandler.java (line 50) Need to re-stream file /var/lib/cassandra/data/rt/values/rt-values-ib-1-Data.db to /3.69.211.179 ERROR [Streaming to /3.69.211.179:2] 2013-03-25 12:30:28,113 CassandraDaemon.java (line 164) Exception in thread Thread[Streaming to /3.69.211.179:2,5,main] java.lang.RuntimeException: java.io.EOFException at com.google.common.base.Throwables.propagate(Throwables.java:160) at org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:32) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) at java.lang.Thread.run(Unknown Source) Caused by: java.io.EOFException at java.io.DataInputStream.readInt(Unknown Source) at org.apache.cassandra.streaming.FileStreamTask.receiveReply(FileStreamTask.java:193) at org.apache.cassandra.streaming.compress.CompressedFileStreamTask.stream(CompressedFileStreamTask.java:114) at org.apache.cassandra.streaming.FileStreamTask.runMayThrow(FileStreamTask.java:91) at org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:28) ... 3 more Keyspace configuration is as follows: Keyspace: rt: Replication Strategy: org.apache.cassandra.locator.SimpleStrategy Durable Writes: true Options: [replication_factor:3] Column Families: ColumnFamily: tagname Key Validation Class: org.apache.cassandra.db.marshal.BytesType Default column value validator: org.apache.cassandra.db.marshal.BytesType Columns sorted by: org.apache.cassandra.db.marshal.BytesType GC grace seconds: 864000 Compaction min/max thresholds: 4/32 Read repair chance: 0.1 DC Local Read repair chance: 0.0 Populate IO Cache on flush: false Replicate on write: true Caching: KEYS_ONLY Bloom Filter FP chance: default Built indexes: [] Compaction Strategy: org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy ColumnFamily: values Key Validation Class: org.apache.cassandra.db.marshal.BytesType Default column value validator: org.apache.cassandra.db.marshal.BytesType Columns sorted by: org.apache.cassandra.db.marshal.BytesType GC grace seconds: 864000 Compaction min/max thresholds: 4/32 Read repair chance: 0.1 DC Local Read repair chance: 0.0 Populate IO Cache on flush: false Replicate on write: true Caching: KEYS_ONLY Bloom Filter FP chance: default Built indexes: [] Compaction Strategy: org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA,
[Cassandra Wiki] Trivial Update of WendiG23 by WendiG23
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The WendiG23 page has been changed by WendiG23: http://wiki.apache.org/cassandra/WendiG23 New page: Hiya! I'm: Tgwj C. RffeqhiBR I prefer to make friends, t no matter which land, s the specific area are you currently y with.BR I t choose to look at numerous magazines, novels. Understand a number of way aspects of the subject.BR This make contact with is usually:478 ' 7514075BR BR Stop by my web blog ... [[http://www.justchaneloutlet.com|chanel replica]]
[Cassandra Wiki] Trivial Update of Dexter450 by Dexter450
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The Dexter450 page has been changed by Dexter450: http://wiki.apache.org/cassandra/Dexter450 New page: Ms. TASHIA EVANS is protective Artist who has Systematized many publications about of aforesaid topic.BR She lives in The Useful Academy in Aurora in Seattle. The orator has an familiarity of 5 years. For more information click hereBR BR my page [[http://www.justchaneloutlet.com|chanel wallet]]
[jira] [Commented] (CASSANDRA-5386) CQL Not Handling Descending Clustering Order On A timeuuid Correctly
[
https://issues.apache.org/jira/browse/CASSANDRA-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13615184#comment-13615184
]
Jonathan Ellis commented on CASSANDRA-5386:
---
+1
CQL Not Handling Descending Clustering Order On A timeuuid Correctly
Key: CASSANDRA-5386
URL: https://issues.apache.org/jira/browse/CASSANDRA-5386
Project: Cassandra
Issue Type: Bug
Affects Versions: 1.2.3
Environment: Apache Cassandra 1.2.3, Mac OS X (Lion), cql 3
Reporter: Gareth Collins
Assignee: Sylvain Lebresne
Fix For: 1.2.4
Attachments: 5386.txt
I raised this issue as a question in the mailing list:
http://www.mail-archive.com/user@cassandra.apache.org/msg28787.html
If I create a table (cqlsh) with the following schema:
CREATE TABLE mytable ( column1 text,
column2 text,
messageId timeuuid,
message blob,
PRIMARY KEY ((column1, column2), messageId));
I can quite happily add rows to this table:
insert into client_queue (column1,column2,messageId,message) VALUES
('string1','string2',now(),'ABCCDCC123');
If I however create a table with a desc clustering order on messageid:
CREATE TABLE mytable ( column1 text,
column2 text,
messageId timeuuid,
message blob,
PRIMARY KEY ((column1, column2), messageId)) WITH CLUSTERING
ORDER BY (messageId DESC);
Inserts are failing. I am getting the following error:
insert into client_queue2 (column1,column2,messageId,message) VALUES
('string1','string2',now(),'ABCCDCC123');
I get the following error:
Bad Request: Type error: cannot assign result of function now (type
timeuuid) to messageid (type
'org.apache.cassandra.db.marshal.ReversedType(org.apache.cassandra.db.marshal.TimeUUIDType)')
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
[Cassandra Wiki] Trivial Update of HowardHRP by HowardHRP
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The HowardHRP page has been changed by HowardHRP: http://wiki.apache.org/cassandra/HowardHRP New page: Yo guys !! I am ROSALVA LOWE. Soon i will turn 33. I go to night school at The Profitable School of Interesting Education situated in Port St.BR Lucie. My daddy name is Jason and he is a Importer. My mom is a Engine-driver.BR BR Review my web-site; [[http://www.buildchanelbags.com|chanel purses]]
[Cassandra Wiki] Trivial Update of JoannaMan by JoannaMan
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The JoannaMan page has been changed by JoannaMan: http://wiki.apache.org/cassandra/JoannaMan New page: Jr. MADDIE ROBBINS is fearless Accountant who has Automated many textbooks on of this topic.BR He belongs to The Unconditional Finishing School built at Normal in Modesto. The writer has an exposure of 46 months. Reach him atBR BR Look into my website; [[http://www.buildchanelbags.com|chanel wallet]]
[Cassandra Wiki] Trivial Update of Humberto5 by Humberto5
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The Humberto5 page has been changed by Humberto5: http://wiki.apache.org/cassandra/Humberto5 New page: You'll even have to explain to the banker what you may need the amount of money for, which can be embarrassing and invasive. In the first 1990s the baby-boomer cohorts with the population were of working age and would remain so until roughly 65 years from 1947 4 seasons through which the birth rate peaked, which is, until 2012. We started the corporation to help those as you Cash America Cash Advance , people like us use a place to go which is stress free, simple to work with, fast and efficient. Usually, lenders frown at customers who may have low credit score histories. If your bills are mounting up, you are more frantic inside your search for that magic financial bullet.BR BR my page [[http://paydayloanlendersapproval.co.uk/|pay day loan lenders]]
[jira] [Commented] (CASSANDRA-5234) Table created through CQL3 are not accessble to Pig 0.10
[ https://issues.apache.org/jira/browse/CASSANDRA-5234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13615231#comment-13615231 ] Cyril Scetbon commented on CASSANDRA-5234: -- It means that CQL3 column families are not accessible through thrift and for me it's an issue (I do not agree with your Resolution label). That's why Pig 0.11 cannot use it. Is there a way to solve it ? I can help you if necessary Table created through CQL3 are not accessble to Pig 0.10 Key: CASSANDRA-5234 URL: https://issues.apache.org/jira/browse/CASSANDRA-5234 Project: Cassandra Issue Type: Bug Components: Hadoop Affects Versions: 1.2.1 Environment: Red hat linux 5 Reporter: Shamim Ahmed Fix For: 1.2.2 Hi, i have faced a bug when creating table through CQL3 and trying to load data through pig 0.10 as follows: java.lang.RuntimeException: Column family 'abc' not found in keyspace 'XYZ' at org.apache.cassandra.hadoop.pig.CassandraStorage.initSchema(CassandraStorage.java:1112) at org.apache.cassandra.hadoop.pig.CassandraStorage.setLocation(CassandraStorage.java:615). This effects from Simple table to table with compound key. -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Created] (CASSANDRA-5390) Cassandra doesn't respect internode compression settings
Ondřej Černoš created CASSANDRA-5390:
Summary: Cassandra doesn't respect internode compression settings
Key: CASSANDRA-5390
URL: https://issues.apache.org/jira/browse/CASSANDRA-5390
Project: Cassandra
Issue Type: Bug
Components: Core
Affects Versions: 1.2.3
Environment: $ /etc/alternatives/jre_1.6.0/bin/java -version
java version 1.6.0_23
Java(TM) SE Runtime Environment (build 1.6.0_23-b05)
Java HotSpot(TM) 64-Bit Server VM (build 19.0-b09, mixed mode)
$ uname -a
Linux hostname 2.6.32-358.2.1.el6.x86_64 #1 SMP Tue Mar 12 14:18:09 CDT 2013
x86_64 x86_64 x86_64 GNU/Linux
$ cat /etc/redhat-release
Scientific Linux release 6.3 (Carbon)
$ facter | grep ec2
...
ec2_placement = availability_zone=us-east-1d
...
$ rpm -qi cassandra
cassandra-1.2.3-1.el6.cmp1.noarch
(custom built rpm from cassandra tarball distribution)
Reporter: Ondřej Černoš
Priority: Critical
I run into strange SSL/snappy errors in my multipledatacenter setup. (More on
that in related issue).
During debugging the issue I switched the internode communication compression
off:
{noformat}
~ grep internode_compression /etc/cassandra/cassandra.yaml
# internode_compression controls whether traffic between nodes is
internode_compression: none
{noformat}
on all nodes in both datacenters. However I still get the very same exception
with snappy in the stacktrace and compression error message:
{noformat}
2013-03-27 14:06:03.605+0100 [Thread-146] [DEBUG]
IncomingTcpConnection.java(91) org.apache.cassandra.net.IncomingTcpConnection:
component=c4 IOException reading from socket; closing
java.io.IOException: FAILED_TO_UNCOMPRESS(5)
at org.xerial.snappy.SnappyNative.throw_error(SnappyNative.java:78)
at org.xerial.snappy.SnappyNative.rawUncompress(Native Method)
at org.xerial.snappy.Snappy.rawUncompress(Snappy.java:391)
at
org.apache.cassandra.io.compress.SnappyCompressor.uncompress(SnappyCompressor.java:93)
at
org.apache.cassandra.streaming.compress.CompressedInputStream.decompress(CompressedInputStream.java:101)
at
org.apache.cassandra.streaming.compress.CompressedInputStream.read(CompressedInputStream.java:79)
at java.io.DataInputStream.readUnsignedShort(DataInputStream.java:320)
at
org.apache.cassandra.utils.BytesReadTracker.readUnsignedShort(BytesReadTracker.java:140)
at
org.apache.cassandra.utils.ByteBufferUtil.readShortLength(ByteBufferUtil.java:361)
at
org.apache.cassandra.utils.ByteBufferUtil.readWithShortLength(ByteBufferUtil.java:371)
at
org.apache.cassandra.streaming.IncomingStreamReader.streamIn(IncomingStreamReader.java:160)
at
org.apache.cassandra.streaming.IncomingStreamReader.read(IncomingStreamReader.java:122)
at
org.apache.cassandra.net.IncomingTcpConnection.stream(IncomingTcpConnection.java:238)
at
org.apache.cassandra.net.IncomingTcpConnection.handleStream(IncomingTcpConnection.java:178)
at
org.apache.cassandra.net.IncomingTcpConnection.run(IncomingTcpConnection.java:78)
{noformat}
The exception is raised from this snappy cpp code:
{code}
JNIEXPORT jint JNICALL
Java_org_xerial_snappy_SnappyNative_rawUncompress__Ljava_lang_Object_2IILjava_lang_Object_2I
(JNIEnv * env, jobject self, jobject input, jint inputOffset, jint inputLength,
jobject output, jint outputOffset)
{
char* in = (char*) env-GetPrimitiveArrayCritical((jarray) input, 0);
char* out = (char*) env-GetPrimitiveArrayCritical((jarray) output, 0);
if(in == 0 || out == 0) {
// out of memory
throw_exception(env, self, 4);
return 0;
}
size_t uncompressedLength;
snappy::GetUncompressedLength(in + inputOffset, (size_t) inputLength,
uncompressedLength);
bool ret = snappy::RawUncompress(in + inputOffset, (size_t)
inputLength, out + outputOffset);
env-ReleasePrimitiveArrayCritical((jarray) input, in, 0);
env-ReleasePrimitiveArrayCritical((jarray) output, out, 0);
if(!ret) {
throw_exception(env, self, 5);
return 0;
}
return (jint) uncompressedLength;
}
{code}
Which looks like the communication was still compressed, or at least Cassandra
tried to decompress the stream.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Assigned] (CASSANDRA-5390) Cassandra doesn't respect internode compression settings
[
https://issues.apache.org/jira/browse/CASSANDRA-5390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jonathan Ellis reassigned CASSANDRA-5390:
-
Assignee: Marcus Eriksson
Cassandra doesn't respect internode compression settings
Key: CASSANDRA-5390
URL: https://issues.apache.org/jira/browse/CASSANDRA-5390
Project: Cassandra
Issue Type: Bug
Components: Core
Affects Versions: 1.2.3
Environment: $ /etc/alternatives/jre_1.6.0/bin/java -version
java version 1.6.0_23
Java(TM) SE Runtime Environment (build 1.6.0_23-b05)
Java HotSpot(TM) 64-Bit Server VM (build 19.0-b09, mixed mode)
$ uname -a
Linux hostname 2.6.32-358.2.1.el6.x86_64 #1 SMP Tue Mar 12 14:18:09 CDT 2013
x86_64 x86_64 x86_64 GNU/Linux
$ cat /etc/redhat-release
Scientific Linux release 6.3 (Carbon)
$ facter | grep ec2
...
ec2_placement = availability_zone=us-east-1d
...
$ rpm -qi cassandra
cassandra-1.2.3-1.el6.cmp1.noarch
(custom built rpm from cassandra tarball distribution)
Reporter: Ondřej Černoš
Assignee: Marcus Eriksson
Priority: Critical
I run into strange SSL/snappy errors in my multipledatacenter setup. (More on
that in related issue).
During debugging the issue I switched the internode communication compression
off:
{noformat}
~ grep internode_compression /etc/cassandra/cassandra.yaml
# internode_compression controls whether traffic between nodes is
internode_compression: none
{noformat}
on all nodes in both datacenters. However I still get the very same exception
with snappy in the stacktrace and compression error message:
{noformat}
2013-03-27 14:06:03.605+0100 [Thread-146] [DEBUG]
IncomingTcpConnection.java(91)
org.apache.cassandra.net.IncomingTcpConnection: component=c4 IOException
reading from socket; closing
java.io.IOException: FAILED_TO_UNCOMPRESS(5)
at org.xerial.snappy.SnappyNative.throw_error(SnappyNative.java:78)
at org.xerial.snappy.SnappyNative.rawUncompress(Native Method)
at org.xerial.snappy.Snappy.rawUncompress(Snappy.java:391)
at
org.apache.cassandra.io.compress.SnappyCompressor.uncompress(SnappyCompressor.java:93)
at
org.apache.cassandra.streaming.compress.CompressedInputStream.decompress(CompressedInputStream.java:101)
at
org.apache.cassandra.streaming.compress.CompressedInputStream.read(CompressedInputStream.java:79)
at java.io.DataInputStream.readUnsignedShort(DataInputStream.java:320)
at
org.apache.cassandra.utils.BytesReadTracker.readUnsignedShort(BytesReadTracker.java:140)
at
org.apache.cassandra.utils.ByteBufferUtil.readShortLength(ByteBufferUtil.java:361)
at
org.apache.cassandra.utils.ByteBufferUtil.readWithShortLength(ByteBufferUtil.java:371)
at
org.apache.cassandra.streaming.IncomingStreamReader.streamIn(IncomingStreamReader.java:160)
at
org.apache.cassandra.streaming.IncomingStreamReader.read(IncomingStreamReader.java:122)
at
org.apache.cassandra.net.IncomingTcpConnection.stream(IncomingTcpConnection.java:238)
at
org.apache.cassandra.net.IncomingTcpConnection.handleStream(IncomingTcpConnection.java:178)
at
org.apache.cassandra.net.IncomingTcpConnection.run(IncomingTcpConnection.java:78)
{noformat}
The exception is raised from this snappy cpp code:
{code}
JNIEXPORT jint JNICALL
Java_org_xerial_snappy_SnappyNative_rawUncompress__Ljava_lang_Object_2IILjava_lang_Object_2I
(JNIEnv * env, jobject self, jobject input, jint inputOffset, jint
inputLength, jobject output, jint outputOffset)
{
char* in = (char*) env-GetPrimitiveArrayCritical((jarray) input, 0);
char* out = (char*) env-GetPrimitiveArrayCritical((jarray) output,
0);
if(in == 0 || out == 0) {
// out of memory
throw_exception(env, self, 4);
return 0;
}
size_t uncompressedLength;
snappy::GetUncompressedLength(in + inputOffset, (size_t) inputLength,
uncompressedLength);
bool ret = snappy::RawUncompress(in + inputOffset, (size_t)
inputLength, out + outputOffset);
env-ReleasePrimitiveArrayCritical((jarray) input, in, 0);
env-ReleasePrimitiveArrayCritical((jarray) output, out, 0);
if(!ret) {
throw_exception(env, self, 5);
return 0;
}
return (jint) uncompressedLength;
}
{code}
Which looks like the communication was still compressed, or at least
Cassandra tried to decompress the stream.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
[Cassandra Wiki] Trivial Update of KristaLow by KristaLow
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The KristaLow page has been changed by KristaLow: http://wiki.apache.org/cassandra/KristaLow New page: Name: Krista LowellBR Age: 19BR Country: Great BritainBR Town: Ealand BR Post code: DN17 9ZXBR Address: 93 Hindhead RoadBR BR My blog post: [[http://wiki.sinergiafc.com/index.php?title=Usuario:MelissaHa|mouse click the up coming website]]
[jira] [Updated] (CASSANDRA-4047) Bulk hinting
[ https://issues.apache.org/jira/browse/CASSANDRA-4047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Carl Yeksigian updated CASSANDRA-4047: -- Assignee: Brandon Williams (was: Carl Yeksigian) Bulk hinting Key: CASSANDRA-4047 URL: https://issues.apache.org/jira/browse/CASSANDRA-4047 Project: Cassandra Issue Type: Improvement Components: Core Reporter: Brandon Williams Assignee: Brandon Williams Fix For: 2.0 With the introduction of the BulkOutputFormat, there may be cases where someone would like to tolerate node failures and have the job complete, but afterwards since we streamed they have to repair or rely on read repair. We don't currently have any way of hinting streams, but a node could take a snapshot before acknowledging the stream session, then remember to send the files in the snapshot to the unavailable nodes when they come back up. This isn't quite ideal since of course the node may have compacted these files, however it's much simpler than any sort of key tracking at this scale. -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Created] (CASSANDRA-5391) SSL problems with inter-DC communication
Ondřej Černoš created CASSANDRA-5391:
Summary: SSL problems with inter-DC communication
Key: CASSANDRA-5391
URL: https://issues.apache.org/jira/browse/CASSANDRA-5391
Project: Cassandra
Issue Type: Bug
Components: Core
Affects Versions: 1.2.3
Environment: $ /etc/alternatives/jre_1.6.0/bin/java -version
java version 1.6.0_23
Java(TM) SE Runtime Environment (build 1.6.0_23-b05)
Java HotSpot(TM) 64-Bit Server VM (build 19.0-b09, mixed mode)
$ uname -a
Linux hostname 2.6.32-358.2.1.el6.x86_64 #1 SMP Tue Mar 12 14:18:09 CDT 2013
x86_64 x86_64 x86_64 GNU/Linux
$ cat /etc/redhat-release
Scientific Linux release 6.3 (Carbon)
$ facter | grep ec2
...
ec2_placement = availability_zone=us-east-1d
...
$ rpm -qi cassandra
cassandra-1.2.3-1.el6.cmp1.noarch
(custom built rpm from cassandra tarball distribution)
Reporter: Ondřej Černoš
Priority: Blocker
I get SSL and snappy compression errors in multiple datacenter setup.
The setup is simple: 3 nodes in AWS east, 3 nodes in Rackspace. I use slightly
modified Ec2MultiRegionSnitch in Rackspace (I just added a regex able to parse
the Rackspace/Openstack availability zone which happens to be in unusual
format).
During {{nodetool rebuild}} tests I managed to (consistently) trigger the
following error:
{noformat}
2013-03-19 12:42:16.059+0100 [Thread-13] [DEBUG] IncomingTcpConnection.java(79)
org.apache.cassandra.net.IncomingTcpConnection: IOException reading from
socket; closing
java.io.IOException: FAILED_TO_UNCOMPRESS(5)
at org.xerial.snappy.SnappyNative.throw_error(SnappyNative.java:78)
at org.xerial.snappy.SnappyNative.rawUncompress(Native Method)
at org.xerial.snappy.Snappy.rawUncompress(Snappy.java:391)
at
org.apache.cassandra.io.compress.SnappyCompressor.uncompress(SnappyCompressor.java:93)
at
org.apache.cassandra.streaming.compress.CompressedInputStream.decompress(CompressedInputStream.java:101)
at
org.apache.cassandra.streaming.compress.CompressedInputStream.read(CompressedInputStream.java:79)
at java.io.DataInputStream.readUnsignedShort(DataInputStream.java:337)
at
org.apache.cassandra.utils.BytesReadTracker.readUnsignedShort(BytesReadTracker.java:140)
at
org.apache.cassandra.utils.ByteBufferUtil.readShortLength(ByteBufferUtil.java:361)
at
org.apache.cassandra.utils.ByteBufferUtil.readWithShortLength(ByteBufferUtil.java:371)
at
org.apache.cassandra.streaming.IncomingStreamReader.streamIn(IncomingStreamReader.java:160)
at
org.apache.cassandra.streaming.IncomingStreamReader.read(IncomingStreamReader.java:122)
at
org.apache.cassandra.net.IncomingTcpConnection.stream(IncomingTcpConnection.java:226)
at
org.apache.cassandra.net.IncomingTcpConnection.handleStream(IncomingTcpConnection.java:166)
at
org.apache.cassandra.net.IncomingTcpConnection.run(IncomingTcpConnection.java:66)
{noformat}
The exception is raised during DB file download. What is strange is the
following:
* the exception is raised only when rebuildig from AWS into Rackspace
* the exception is raised only when all nodes are up and running in AWS (all
3). In other words, if I bootstrap from one or two nodes in AWS, the command
succeeds.
Packet-level inspection revealed malformed packets _on both ends of
communication_, so - at least for the moment - it doesn't seem to be networking
problem.
Further investigation raised two more concerns:
* We managed to get another stacktrace when testing the scenario. The exception
was raised only once during the tests and was raised when I throttled the
inter-datacenter bandwidth to 1Mbps.
{noformat}
java.lang.RuntimeException: javax.net.ssl.SSLException: bad record MAC
at com.google.common.base.Throwables.propagate(Throwables.java:160)
at
org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:32)
at java.lang.Thread.run(Thread.java:662)
Caused by: javax.net.ssl.SSLException: bad record MAC
at com.sun.net.ssl.internal.ssl.Alerts.getSSLException(Alerts.java:190)
at
com.sun.net.ssl.internal.ssl.SSLSocketImpl.fatal(SSLSocketImpl.java:1649)
at
com.sun.net.ssl.internal.ssl.SSLSocketImpl.fatal(SSLSocketImpl.java:1607)
at
com.sun.net.ssl.internal.ssl.SSLSocketImpl.readRecord(SSLSocketImpl.java:859)
at
com.sun.net.ssl.internal.ssl.SSLSocketImpl.readDataRecord(SSLSocketImpl.java:755)
at
com.sun.net.ssl.internal.ssl.AppInputStream.read(AppInputStream.java:75)
at
org.apache.cassandra.streaming.compress.CompressedInputStream$Reader.runMayThrow(CompressedInputStream.java:151)
at
org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:28)
... 1 more
{noformat}
This is pure SSL error with no snappy interference.
* I managed to trigger the exception
[jira] [Updated] (CASSANDRA-5390) Cassandra doesn't respect internode compression settings
[
https://issues.apache.org/jira/browse/CASSANDRA-5390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ondřej Černoš updated CASSANDRA-5390:
-
Description:
I run into strange SSL/snappy errors in my multipledatacenter setup. (More on
that in CASSANDRA-5391).
During debugging the issue I switched the internode communication compression
off:
{noformat}
~ grep internode_compression /etc/cassandra/cassandra.yaml
# internode_compression controls whether traffic between nodes is
internode_compression: none
{noformat}
on all nodes in both datacenters. However I still get the very same exception
with snappy in the stacktrace and compression error message:
{noformat}
2013-03-27 14:06:03.605+0100 [Thread-146] [DEBUG]
IncomingTcpConnection.java(91) org.apache.cassandra.net.IncomingTcpConnection:
component=c4 IOException reading from socket; closing
java.io.IOException: FAILED_TO_UNCOMPRESS(5)
at org.xerial.snappy.SnappyNative.throw_error(SnappyNative.java:78)
at org.xerial.snappy.SnappyNative.rawUncompress(Native Method)
at org.xerial.snappy.Snappy.rawUncompress(Snappy.java:391)
at
org.apache.cassandra.io.compress.SnappyCompressor.uncompress(SnappyCompressor.java:93)
at
org.apache.cassandra.streaming.compress.CompressedInputStream.decompress(CompressedInputStream.java:101)
at
org.apache.cassandra.streaming.compress.CompressedInputStream.read(CompressedInputStream.java:79)
at java.io.DataInputStream.readUnsignedShort(DataInputStream.java:320)
at
org.apache.cassandra.utils.BytesReadTracker.readUnsignedShort(BytesReadTracker.java:140)
at
org.apache.cassandra.utils.ByteBufferUtil.readShortLength(ByteBufferUtil.java:361)
at
org.apache.cassandra.utils.ByteBufferUtil.readWithShortLength(ByteBufferUtil.java:371)
at
org.apache.cassandra.streaming.IncomingStreamReader.streamIn(IncomingStreamReader.java:160)
at
org.apache.cassandra.streaming.IncomingStreamReader.read(IncomingStreamReader.java:122)
at
org.apache.cassandra.net.IncomingTcpConnection.stream(IncomingTcpConnection.java:238)
at
org.apache.cassandra.net.IncomingTcpConnection.handleStream(IncomingTcpConnection.java:178)
at
org.apache.cassandra.net.IncomingTcpConnection.run(IncomingTcpConnection.java:78)
{noformat}
The exception is raised from this snappy cpp code:
{code}
JNIEXPORT jint JNICALL
Java_org_xerial_snappy_SnappyNative_rawUncompress__Ljava_lang_Object_2IILjava_lang_Object_2I
(JNIEnv * env, jobject self, jobject input, jint inputOffset, jint inputLength,
jobject output, jint outputOffset)
{
char* in = (char*) env-GetPrimitiveArrayCritical((jarray) input, 0);
char* out = (char*) env-GetPrimitiveArrayCritical((jarray) output, 0);
if(in == 0 || out == 0) {
// out of memory
throw_exception(env, self, 4);
return 0;
}
size_t uncompressedLength;
snappy::GetUncompressedLength(in + inputOffset, (size_t) inputLength,
uncompressedLength);
bool ret = snappy::RawUncompress(in + inputOffset, (size_t)
inputLength, out + outputOffset);
env-ReleasePrimitiveArrayCritical((jarray) input, in, 0);
env-ReleasePrimitiveArrayCritical((jarray) output, out, 0);
if(!ret) {
throw_exception(env, self, 5);
return 0;
}
return (jint) uncompressedLength;
}
{code}
Which looks like the communication was still compressed, or at least Cassandra
tried to decompress the stream.
was:
I run into strange SSL/snappy errors in my multipledatacenter setup. (More on
that in related issue).
During debugging the issue I switched the internode communication compression
off:
{noformat}
~ grep internode_compression /etc/cassandra/cassandra.yaml
# internode_compression controls whether traffic between nodes is
internode_compression: none
{noformat}
on all nodes in both datacenters. However I still get the very same exception
with snappy in the stacktrace and compression error message:
{noformat}
2013-03-27 14:06:03.605+0100 [Thread-146] [DEBUG]
IncomingTcpConnection.java(91) org.apache.cassandra.net.IncomingTcpConnection:
component=c4 IOException reading from socket; closing
java.io.IOException: FAILED_TO_UNCOMPRESS(5)
at org.xerial.snappy.SnappyNative.throw_error(SnappyNative.java:78)
at org.xerial.snappy.SnappyNative.rawUncompress(Native Method)
at org.xerial.snappy.Snappy.rawUncompress(Snappy.java:391)
at
org.apache.cassandra.io.compress.SnappyCompressor.uncompress(SnappyCompressor.java:93)
at
org.apache.cassandra.streaming.compress.CompressedInputStream.decompress(CompressedInputStream.java:101)
at
org.apache.cassandra.streaming.compress.CompressedInputStream.read(CompressedInputStream.java:79)
at
[Cassandra Wiki] Trivial Update of Bobajrpnu by Bobajrpnu
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The Bobajrpnu page has been changed by Bobajrpnu: http://wiki.apache.org/cassandra/Bobajrpnu New page: Nothing to say about me really.BR Hurrey Im here and a member of this site.BR I really wish I'm useful in some way .BR BR My weblog; [[http://english.inhangzhou.com/groups/airport-parking-for-our-friends/|bristol airport parking]]
[jira] [Resolved] (CASSANDRA-5390) Cassandra doesn't respect internode compression settings
[
https://issues.apache.org/jira/browse/CASSANDRA-5390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Marcus Eriksson resolved CASSANDRA-5390.
Resolution: Invalid
this is streaming related, where internode_compression has no meaning
this looks like a case where you have snappy-compressed sstables on a node and
try to stream them to another node, where they are decompressed
please reopen if you don't have any compressed sstables at all
Cassandra doesn't respect internode compression settings
Key: CASSANDRA-5390
URL: https://issues.apache.org/jira/browse/CASSANDRA-5390
Project: Cassandra
Issue Type: Bug
Components: Core
Affects Versions: 1.2.3
Environment: $ /etc/alternatives/jre_1.6.0/bin/java -version
java version 1.6.0_23
Java(TM) SE Runtime Environment (build 1.6.0_23-b05)
Java HotSpot(TM) 64-Bit Server VM (build 19.0-b09, mixed mode)
$ uname -a
Linux hostname 2.6.32-358.2.1.el6.x86_64 #1 SMP Tue Mar 12 14:18:09 CDT 2013
x86_64 x86_64 x86_64 GNU/Linux
$ cat /etc/redhat-release
Scientific Linux release 6.3 (Carbon)
$ facter | grep ec2
...
ec2_placement = availability_zone=us-east-1d
...
$ rpm -qi cassandra
cassandra-1.2.3-1.el6.cmp1.noarch
(custom built rpm from cassandra tarball distribution)
Reporter: Ondřej Černoš
Assignee: Marcus Eriksson
Priority: Critical
I run into strange SSL/snappy errors in my multipledatacenter setup. (More on
that in CASSANDRA-5391).
During debugging the issue I switched the internode communication compression
off:
{noformat}
~ grep internode_compression /etc/cassandra/cassandra.yaml
# internode_compression controls whether traffic between nodes is
internode_compression: none
{noformat}
on all nodes in both datacenters. However I still get the very same exception
with snappy in the stacktrace and compression error message:
{noformat}
2013-03-27 14:06:03.605+0100 [Thread-146] [DEBUG]
IncomingTcpConnection.java(91)
org.apache.cassandra.net.IncomingTcpConnection: component=c4 IOException
reading from socket; closing
java.io.IOException: FAILED_TO_UNCOMPRESS(5)
at org.xerial.snappy.SnappyNative.throw_error(SnappyNative.java:78)
at org.xerial.snappy.SnappyNative.rawUncompress(Native Method)
at org.xerial.snappy.Snappy.rawUncompress(Snappy.java:391)
at
org.apache.cassandra.io.compress.SnappyCompressor.uncompress(SnappyCompressor.java:93)
at
org.apache.cassandra.streaming.compress.CompressedInputStream.decompress(CompressedInputStream.java:101)
at
org.apache.cassandra.streaming.compress.CompressedInputStream.read(CompressedInputStream.java:79)
at java.io.DataInputStream.readUnsignedShort(DataInputStream.java:320)
at
org.apache.cassandra.utils.BytesReadTracker.readUnsignedShort(BytesReadTracker.java:140)
at
org.apache.cassandra.utils.ByteBufferUtil.readShortLength(ByteBufferUtil.java:361)
at
org.apache.cassandra.utils.ByteBufferUtil.readWithShortLength(ByteBufferUtil.java:371)
at
org.apache.cassandra.streaming.IncomingStreamReader.streamIn(IncomingStreamReader.java:160)
at
org.apache.cassandra.streaming.IncomingStreamReader.read(IncomingStreamReader.java:122)
at
org.apache.cassandra.net.IncomingTcpConnection.stream(IncomingTcpConnection.java:238)
at
org.apache.cassandra.net.IncomingTcpConnection.handleStream(IncomingTcpConnection.java:178)
at
org.apache.cassandra.net.IncomingTcpConnection.run(IncomingTcpConnection.java:78)
{noformat}
The exception is raised from this snappy cpp code:
{code}
JNIEXPORT jint JNICALL
Java_org_xerial_snappy_SnappyNative_rawUncompress__Ljava_lang_Object_2IILjava_lang_Object_2I
(JNIEnv * env, jobject self, jobject input, jint inputOffset, jint
inputLength, jobject output, jint outputOffset)
{
char* in = (char*) env-GetPrimitiveArrayCritical((jarray) input, 0);
char* out = (char*) env-GetPrimitiveArrayCritical((jarray) output,
0);
if(in == 0 || out == 0) {
// out of memory
throw_exception(env, self, 4);
return 0;
}
size_t uncompressedLength;
snappy::GetUncompressedLength(in + inputOffset, (size_t) inputLength,
uncompressedLength);
bool ret = snappy::RawUncompress(in + inputOffset, (size_t)
inputLength, out + outputOffset);
env-ReleasePrimitiveArrayCritical((jarray) input, in, 0);
env-ReleasePrimitiveArrayCritical((jarray) output, out, 0);
if(!ret) {
throw_exception(env, self, 5);
return 0;
}
return (jint) uncompressedLength;
}
{code}
Which looks like the communication was still compressed, or at least
Cassandra
[Cassandra Wiki] Trivial Update of Kerry49J by Kerry49J
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The Kerry49J page has been changed by Kerry49J: http://wiki.apache.org/cassandra/Kerry49J New page: My personal personality alot more ecstatic, via freshman to make sure you usually go out to connect with others XZSB as a result of different countries around the world, attempt to communicate, wonderful verbal exchanges with folks.BR Extra time or some sort of Native american indian summer season, part-time interpretation or containers, dash industry. ( your dog Relating to business around Guangzhou ) likewise gained your pet together with sanctioned friends, your attendees returned household, keep on TJLYT contact with me personally moreover.BR When i are exposed to the merchandise market extensively, stationery, carriers, household leather, pieces of furniture, perfume ornaments, lighting effects for example.,BR Self-learning capability, great at wondering, hard-working, very good GNAUW contact knowledge, great at gaining coupled with many people, complete with crew soul, passion for athletics. Although citizens are not best, these still have some AKM faults, in many elements for example expertise, public knowledge; but I consider these types of can easily via the efforts EYY to enhance the educational, In addition, i really are opting it guidance!BR FQJUBR BR Also visit my blog: [[http://www.justchaneloutlet.com|chanel outlet]]
[jira] [Commented] (CASSANDRA-5391) SSL problems with inter-DC communication
[
https://issues.apache.org/jira/browse/CASSANDRA-5391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13615303#comment-13615303
]
Ondřej Černoš commented on CASSANDRA-5391:
--
With SSL switched off all the scenarios work well.
SSL problems with inter-DC communication
Key: CASSANDRA-5391
URL: https://issues.apache.org/jira/browse/CASSANDRA-5391
Project: Cassandra
Issue Type: Bug
Components: Core
Affects Versions: 1.2.3
Environment: $ /etc/alternatives/jre_1.6.0/bin/java -version
java version 1.6.0_23
Java(TM) SE Runtime Environment (build 1.6.0_23-b05)
Java HotSpot(TM) 64-Bit Server VM (build 19.0-b09, mixed mode)
$ uname -a
Linux hostname 2.6.32-358.2.1.el6.x86_64 #1 SMP Tue Mar 12 14:18:09 CDT 2013
x86_64 x86_64 x86_64 GNU/Linux
$ cat /etc/redhat-release
Scientific Linux release 6.3 (Carbon)
$ facter | grep ec2
...
ec2_placement = availability_zone=us-east-1d
...
$ rpm -qi cassandra
cassandra-1.2.3-1.el6.cmp1.noarch
(custom built rpm from cassandra tarball distribution)
Reporter: Ondřej Černoš
Priority: Blocker
I get SSL and snappy compression errors in multiple datacenter setup.
The setup is simple: 3 nodes in AWS east, 3 nodes in Rackspace. I use
slightly modified Ec2MultiRegionSnitch in Rackspace (I just added a regex
able to parse the Rackspace/Openstack availability zone which happens to be
in unusual format).
During {{nodetool rebuild}} tests I managed to (consistently) trigger the
following error:
{noformat}
2013-03-19 12:42:16.059+0100 [Thread-13] [DEBUG]
IncomingTcpConnection.java(79)
org.apache.cassandra.net.IncomingTcpConnection: IOException reading from
socket; closing
java.io.IOException: FAILED_TO_UNCOMPRESS(5)
at org.xerial.snappy.SnappyNative.throw_error(SnappyNative.java:78)
at org.xerial.snappy.SnappyNative.rawUncompress(Native Method)
at org.xerial.snappy.Snappy.rawUncompress(Snappy.java:391)
at
org.apache.cassandra.io.compress.SnappyCompressor.uncompress(SnappyCompressor.java:93)
at
org.apache.cassandra.streaming.compress.CompressedInputStream.decompress(CompressedInputStream.java:101)
at
org.apache.cassandra.streaming.compress.CompressedInputStream.read(CompressedInputStream.java:79)
at java.io.DataInputStream.readUnsignedShort(DataInputStream.java:337)
at
org.apache.cassandra.utils.BytesReadTracker.readUnsignedShort(BytesReadTracker.java:140)
at
org.apache.cassandra.utils.ByteBufferUtil.readShortLength(ByteBufferUtil.java:361)
at
org.apache.cassandra.utils.ByteBufferUtil.readWithShortLength(ByteBufferUtil.java:371)
at
org.apache.cassandra.streaming.IncomingStreamReader.streamIn(IncomingStreamReader.java:160)
at
org.apache.cassandra.streaming.IncomingStreamReader.read(IncomingStreamReader.java:122)
at
org.apache.cassandra.net.IncomingTcpConnection.stream(IncomingTcpConnection.java:226)
at
org.apache.cassandra.net.IncomingTcpConnection.handleStream(IncomingTcpConnection.java:166)
at
org.apache.cassandra.net.IncomingTcpConnection.run(IncomingTcpConnection.java:66)
{noformat}
The exception is raised during DB file download. What is strange is the
following:
* the exception is raised only when rebuildig from AWS into Rackspace
* the exception is raised only when all nodes are up and running in AWS (all
3). In other words, if I bootstrap from one or two nodes in AWS, the command
succeeds.
Packet-level inspection revealed malformed packets _on both ends of
communication_, so - at least for the moment - it doesn't seem to be
networking problem.
Further investigation raised two more concerns:
* We managed to get another stacktrace when testing the scenario. The
exception was raised only once during the tests and was raised when I
throttled the inter-datacenter bandwidth to 1Mbps.
{noformat}
java.lang.RuntimeException: javax.net.ssl.SSLException: bad record MAC
at com.google.common.base.Throwables.propagate(Throwables.java:160)
at
org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:32)
at java.lang.Thread.run(Thread.java:662)
Caused by: javax.net.ssl.SSLException: bad record MAC
at com.sun.net.ssl.internal.ssl.Alerts.getSSLException(Alerts.java:190)
at
com.sun.net.ssl.internal.ssl.SSLSocketImpl.fatal(SSLSocketImpl.java:1649)
at
com.sun.net.ssl.internal.ssl.SSLSocketImpl.fatal(SSLSocketImpl.java:1607)
at
com.sun.net.ssl.internal.ssl.SSLSocketImpl.readRecord(SSLSocketImpl.java:859)
at
com.sun.net.ssl.internal.ssl.SSLSocketImpl.readDataRecord(SSLSocketImpl.java:755)
at
com.sun.net.ssl.internal.ssl.AppInputStream.read(AppInputStream.java:75)
at
[jira] [Commented] (CASSANDRA-5390) Cassandra doesn't respect internode compression settings
[
https://issues.apache.org/jira/browse/CASSANDRA-5390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13615315#comment-13615315
]
Ondřej Černoš commented on CASSANDRA-5390:
--
OK, thanks for making this clear.
Cassandra doesn't respect internode compression settings
Key: CASSANDRA-5390
URL: https://issues.apache.org/jira/browse/CASSANDRA-5390
Project: Cassandra
Issue Type: Bug
Components: Core
Affects Versions: 1.2.3
Environment: $ /etc/alternatives/jre_1.6.0/bin/java -version
java version 1.6.0_23
Java(TM) SE Runtime Environment (build 1.6.0_23-b05)
Java HotSpot(TM) 64-Bit Server VM (build 19.0-b09, mixed mode)
$ uname -a
Linux hostname 2.6.32-358.2.1.el6.x86_64 #1 SMP Tue Mar 12 14:18:09 CDT 2013
x86_64 x86_64 x86_64 GNU/Linux
$ cat /etc/redhat-release
Scientific Linux release 6.3 (Carbon)
$ facter | grep ec2
...
ec2_placement = availability_zone=us-east-1d
...
$ rpm -qi cassandra
cassandra-1.2.3-1.el6.cmp1.noarch
(custom built rpm from cassandra tarball distribution)
Reporter: Ondřej Černoš
Assignee: Marcus Eriksson
Priority: Critical
I run into strange SSL/snappy errors in my multipledatacenter setup. (More on
that in CASSANDRA-5391).
During debugging the issue I switched the internode communication compression
off:
{noformat}
~ grep internode_compression /etc/cassandra/cassandra.yaml
# internode_compression controls whether traffic between nodes is
internode_compression: none
{noformat}
on all nodes in both datacenters. However I still get the very same exception
with snappy in the stacktrace and compression error message:
{noformat}
2013-03-27 14:06:03.605+0100 [Thread-146] [DEBUG]
IncomingTcpConnection.java(91)
org.apache.cassandra.net.IncomingTcpConnection: component=c4 IOException
reading from socket; closing
java.io.IOException: FAILED_TO_UNCOMPRESS(5)
at org.xerial.snappy.SnappyNative.throw_error(SnappyNative.java:78)
at org.xerial.snappy.SnappyNative.rawUncompress(Native Method)
at org.xerial.snappy.Snappy.rawUncompress(Snappy.java:391)
at
org.apache.cassandra.io.compress.SnappyCompressor.uncompress(SnappyCompressor.java:93)
at
org.apache.cassandra.streaming.compress.CompressedInputStream.decompress(CompressedInputStream.java:101)
at
org.apache.cassandra.streaming.compress.CompressedInputStream.read(CompressedInputStream.java:79)
at java.io.DataInputStream.readUnsignedShort(DataInputStream.java:320)
at
org.apache.cassandra.utils.BytesReadTracker.readUnsignedShort(BytesReadTracker.java:140)
at
org.apache.cassandra.utils.ByteBufferUtil.readShortLength(ByteBufferUtil.java:361)
at
org.apache.cassandra.utils.ByteBufferUtil.readWithShortLength(ByteBufferUtil.java:371)
at
org.apache.cassandra.streaming.IncomingStreamReader.streamIn(IncomingStreamReader.java:160)
at
org.apache.cassandra.streaming.IncomingStreamReader.read(IncomingStreamReader.java:122)
at
org.apache.cassandra.net.IncomingTcpConnection.stream(IncomingTcpConnection.java:238)
at
org.apache.cassandra.net.IncomingTcpConnection.handleStream(IncomingTcpConnection.java:178)
at
org.apache.cassandra.net.IncomingTcpConnection.run(IncomingTcpConnection.java:78)
{noformat}
The exception is raised from this snappy cpp code:
{code}
JNIEXPORT jint JNICALL
Java_org_xerial_snappy_SnappyNative_rawUncompress__Ljava_lang_Object_2IILjava_lang_Object_2I
(JNIEnv * env, jobject self, jobject input, jint inputOffset, jint
inputLength, jobject output, jint outputOffset)
{
char* in = (char*) env-GetPrimitiveArrayCritical((jarray) input, 0);
char* out = (char*) env-GetPrimitiveArrayCritical((jarray) output,
0);
if(in == 0 || out == 0) {
// out of memory
throw_exception(env, self, 4);
return 0;
}
size_t uncompressedLength;
snappy::GetUncompressedLength(in + inputOffset, (size_t) inputLength,
uncompressedLength);
bool ret = snappy::RawUncompress(in + inputOffset, (size_t)
inputLength, out + outputOffset);
env-ReleasePrimitiveArrayCritical((jarray) input, in, 0);
env-ReleasePrimitiveArrayCritical((jarray) output, out, 0);
if(!ret) {
throw_exception(env, self, 5);
return 0;
}
return (jint) uncompressedLength;
}
{code}
Which looks like the communication was still compressed, or at least
Cassandra tried to decompress the stream.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see:
[Cassandra Wiki] Trivial Update of ChelseyWh by ChelseyWh
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The ChelseyWh page has been changed by ChelseyWh: http://wiki.apache.org/cassandra/ChelseyWh New page: My name: Florian HeffnerBR Age: 24BR Country: NetherlandsBR City: Velserbroek BR Post code: 1991 HXBR Street: Floraronde 18BR BR Look into my web page - [[http://myhomes.com.br/blog/view/13974/comparing-significant-criteria-for-airport-parking|mouse click the up coming document]]
[Cassandra Wiki] Trivial Update of MargoDens by MargoDens
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The MargoDens page has been changed by MargoDens: http://wiki.apache.org/cassandra/MargoDens New page: I am 24 years old and my name is Maybelle Harley.BR I life in Palermo (Italia).BR BR Feel free to surf to my site; [[https://www.virtualpre-k.org/en/node/38218|visit the next website page]]
git commit: Correctly typecheck in CQL3 even in presence of ReversedType
Updated Branches:
refs/heads/cassandra-1.2 61e329f7a - b72af485f
Correctly typecheck in CQL3 even in presence of ReversedType
patch by slebresne; reviewed by jbellis for CASSANDRA-5386
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/b72af485
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/b72af485
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/b72af485
Branch: refs/heads/cassandra-1.2
Commit: b72af485f625b734cecaa8556578890f346cd274
Parents: 61e329f
Author: Sylvain Lebresne sylv...@datastax.com
Authored: Wed Mar 27 16:16:10 2013 +0100
Committer: Sylvain Lebresne sylv...@datastax.com
Committed: Wed Mar 27 16:16:10 2013 +0100
--
CHANGES.txt|1 +
src/java/org/apache/cassandra/cql3/CQL3Type.java | 32 +++
src/java/org/apache/cassandra/cql3/TypeCast.java |2 +-
.../cassandra/cql3/functions/FunctionCall.java |2 +-
.../apache/cassandra/cql3/functions/Functions.java |4 +-
.../cassandra/cql3/statements/Selection.java |2 +-
.../apache/cassandra/db/marshal/ReversedType.java |7 +++
7 files changed, 45 insertions(+), 5 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/cassandra/blob/b72af485/CHANGES.txt
--
diff --git a/CHANGES.txt b/CHANGES.txt
index 26b2360..400e5c3 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -12,6 +12,7 @@
* Invalid streamId in cql binary protocol when using invalid CL
(CASSANDRA-5164)
* Fix validation for IN where clauses with collections (CASSANDRA-5376)
* Copy resultSet on count query to avoid ConcurrentModificationException
(CASSANDRA-5382)
+ * Correctly typecheck in CQL3 even with ReversedType (CASSANDRA-5386)
Merged from 1.1:
* cli: Quote ks and cf names in schema output when needed (CASSANDRA-5052)
* Fix bad default for min/max timestamp in SSTableMetadata (CASSANDRA-5372)
http://git-wip-us.apache.org/repos/asf/cassandra/blob/b72af485/src/java/org/apache/cassandra/cql3/CQL3Type.java
--
diff --git a/src/java/org/apache/cassandra/cql3/CQL3Type.java
b/src/java/org/apache/cassandra/cql3/CQL3Type.java
index 58a2fa3..d7a4e8e 100644
--- a/src/java/org/apache/cassandra/cql3/CQL3Type.java
+++ b/src/java/org/apache/cassandra/cql3/CQL3Type.java
@@ -106,6 +106,22 @@ public interface CQL3Type
}
@Override
+public final boolean equals(Object o)
+{
+if(!(o instanceof Custom))
+return false;
+
+Custom that = (Custom)o;
+return type.equals(that.type);
+}
+
+@Override
+public final int hashCode()
+{
+return type.hashCode();
+}
+
+@Override
public String toString()
{
return ' + type + ';
@@ -167,6 +183,22 @@ public interface CQL3Type
}
@Override
+public final boolean equals(Object o)
+{
+if(!(o instanceof Collection))
+return false;
+
+Collection that = (Collection)o;
+return type.equals(that.type);
+}
+
+@Override
+public final int hashCode()
+{
+return type.hashCode();
+}
+
+@Override
public String toString()
{
switch (type.kind)
http://git-wip-us.apache.org/repos/asf/cassandra/blob/b72af485/src/java/org/apache/cassandra/cql3/TypeCast.java
--
diff --git a/src/java/org/apache/cassandra/cql3/TypeCast.java
b/src/java/org/apache/cassandra/cql3/TypeCast.java
index 2fa322a..66b5300 100644
--- a/src/java/org/apache/cassandra/cql3/TypeCast.java
+++ b/src/java/org/apache/cassandra/cql3/TypeCast.java
@@ -48,7 +48,7 @@ public class TypeCast implements Term.Raw
public boolean isAssignableTo(ColumnSpecification receiver)
{
-return receiver.type.equals(type.getType());
+return receiver.type.asCQL3Type().equals(type);
}
@Override
http://git-wip-us.apache.org/repos/asf/cassandra/blob/b72af485/src/java/org/apache/cassandra/cql3/functions/FunctionCall.java
--
diff --git a/src/java/org/apache/cassandra/cql3/functions/FunctionCall.java
b/src/java/org/apache/cassandra/cql3/functions/FunctionCall.java
index 36603d6..01c26af 100644
--- a/src/java/org/apache/cassandra/cql3/functions/FunctionCall.java
+++ b/src/java/org/apache/cassandra/cql3/functions/FunctionCall.java
@@ -132,7 +132,7 @@ public class FunctionCall extends Term.NonTerminal
public boolean isAssignableTo(ColumnSpecification receiver)
[1/2] git commit: Correctly typecheck in CQL3 even in presence of ReversedType
Updated Branches:
refs/heads/trunk 1527fabfc - 4c348c422
Correctly typecheck in CQL3 even in presence of ReversedType
patch by slebresne; reviewed by jbellis for CASSANDRA-5386
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/b72af485
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/b72af485
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/b72af485
Branch: refs/heads/trunk
Commit: b72af485f625b734cecaa8556578890f346cd274
Parents: 61e329f
Author: Sylvain Lebresne sylv...@datastax.com
Authored: Wed Mar 27 16:16:10 2013 +0100
Committer: Sylvain Lebresne sylv...@datastax.com
Committed: Wed Mar 27 16:16:10 2013 +0100
--
CHANGES.txt|1 +
src/java/org/apache/cassandra/cql3/CQL3Type.java | 32 +++
src/java/org/apache/cassandra/cql3/TypeCast.java |2 +-
.../cassandra/cql3/functions/FunctionCall.java |2 +-
.../apache/cassandra/cql3/functions/Functions.java |4 +-
.../cassandra/cql3/statements/Selection.java |2 +-
.../apache/cassandra/db/marshal/ReversedType.java |7 +++
7 files changed, 45 insertions(+), 5 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/cassandra/blob/b72af485/CHANGES.txt
--
diff --git a/CHANGES.txt b/CHANGES.txt
index 26b2360..400e5c3 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -12,6 +12,7 @@
* Invalid streamId in cql binary protocol when using invalid CL
(CASSANDRA-5164)
* Fix validation for IN where clauses with collections (CASSANDRA-5376)
* Copy resultSet on count query to avoid ConcurrentModificationException
(CASSANDRA-5382)
+ * Correctly typecheck in CQL3 even with ReversedType (CASSANDRA-5386)
Merged from 1.1:
* cli: Quote ks and cf names in schema output when needed (CASSANDRA-5052)
* Fix bad default for min/max timestamp in SSTableMetadata (CASSANDRA-5372)
http://git-wip-us.apache.org/repos/asf/cassandra/blob/b72af485/src/java/org/apache/cassandra/cql3/CQL3Type.java
--
diff --git a/src/java/org/apache/cassandra/cql3/CQL3Type.java
b/src/java/org/apache/cassandra/cql3/CQL3Type.java
index 58a2fa3..d7a4e8e 100644
--- a/src/java/org/apache/cassandra/cql3/CQL3Type.java
+++ b/src/java/org/apache/cassandra/cql3/CQL3Type.java
@@ -106,6 +106,22 @@ public interface CQL3Type
}
@Override
+public final boolean equals(Object o)
+{
+if(!(o instanceof Custom))
+return false;
+
+Custom that = (Custom)o;
+return type.equals(that.type);
+}
+
+@Override
+public final int hashCode()
+{
+return type.hashCode();
+}
+
+@Override
public String toString()
{
return ' + type + ';
@@ -167,6 +183,22 @@ public interface CQL3Type
}
@Override
+public final boolean equals(Object o)
+{
+if(!(o instanceof Collection))
+return false;
+
+Collection that = (Collection)o;
+return type.equals(that.type);
+}
+
+@Override
+public final int hashCode()
+{
+return type.hashCode();
+}
+
+@Override
public String toString()
{
switch (type.kind)
http://git-wip-us.apache.org/repos/asf/cassandra/blob/b72af485/src/java/org/apache/cassandra/cql3/TypeCast.java
--
diff --git a/src/java/org/apache/cassandra/cql3/TypeCast.java
b/src/java/org/apache/cassandra/cql3/TypeCast.java
index 2fa322a..66b5300 100644
--- a/src/java/org/apache/cassandra/cql3/TypeCast.java
+++ b/src/java/org/apache/cassandra/cql3/TypeCast.java
@@ -48,7 +48,7 @@ public class TypeCast implements Term.Raw
public boolean isAssignableTo(ColumnSpecification receiver)
{
-return receiver.type.equals(type.getType());
+return receiver.type.asCQL3Type().equals(type);
}
@Override
http://git-wip-us.apache.org/repos/asf/cassandra/blob/b72af485/src/java/org/apache/cassandra/cql3/functions/FunctionCall.java
--
diff --git a/src/java/org/apache/cassandra/cql3/functions/FunctionCall.java
b/src/java/org/apache/cassandra/cql3/functions/FunctionCall.java
index 36603d6..01c26af 100644
--- a/src/java/org/apache/cassandra/cql3/functions/FunctionCall.java
+++ b/src/java/org/apache/cassandra/cql3/functions/FunctionCall.java
@@ -132,7 +132,7 @@ public class FunctionCall extends Term.NonTerminal
public boolean isAssignableTo(ColumnSpecification receiver)
{
[2/2] git commit: Merge branch 'cassandra-1.2' into trunk
Merge branch 'cassandra-1.2' into trunk Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/4c348c42 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/4c348c42 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/4c348c42 Branch: refs/heads/trunk Commit: 4c348c422153180dd08ed9b9e04e4f0bbfa27043 Parents: 1527fab b72af48 Author: Sylvain Lebresne sylv...@datastax.com Authored: Wed Mar 27 16:18:44 2013 +0100 Committer: Sylvain Lebresne sylv...@datastax.com Committed: Wed Mar 27 16:18:44 2013 +0100 -- CHANGES.txt|1 + src/java/org/apache/cassandra/cql3/CQL3Type.java | 32 +++ src/java/org/apache/cassandra/cql3/TypeCast.java |2 +- .../cassandra/cql3/functions/FunctionCall.java |2 +- .../apache/cassandra/cql3/functions/Functions.java |4 +- .../cassandra/cql3/statements/Selection.java |2 +- .../apache/cassandra/db/marshal/ReversedType.java |7 +++ 7 files changed, 45 insertions(+), 5 deletions(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/4c348c42/CHANGES.txt -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/4c348c42/src/java/org/apache/cassandra/cql3/statements/Selection.java --
[jira] [Commented] (CASSANDRA-5391) SSL problems with inter-DC communication
[
https://issues.apache.org/jira/browse/CASSANDRA-5391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13615380#comment-13615380
]
Ondřej Černoš commented on CASSANDRA-5391:
--
After clarifying CASSANDRA-5390 I tried to switch to {{DeflateCompressor}}
SSTable compression algorithm. The problem is compression-algorithm independent:
{noformat}
2013-03-27 16:19:57.633+0100 [Thread-31] [INFO] StreamInSession.java(136)
org.apache.cassandra.streaming.StreamInSession: component=c4 Streaming of file
/mnt/ebs/cassandra/data/c4/user_profile_settings/c4-user_profile_settings-ib-2-Data.db
sections=130 progress=0/1628502 - 0% for
org.apache.cassandra.streaming.StreamInSession@20f92649 failed: requesting a
retry.
2013-03-27 16:19:57.633+0100 [Thread-31] [DEBUG] IncomingTcpConnection.java(91)
org.apache.cassandra.net.IncomingTcpConnection: component=c4 IOException
reading from socket; closing
java.io.IOException: CRC unmatched
at
org.apache.cassandra.streaming.compress.CompressedInputStream.decompress(CompressedInputStream.java:111)
at
org.apache.cassandra.streaming.compress.CompressedInputStream.read(CompressedInputStream.java:79)
at java.io.DataInputStream.readUnsignedShort(DataInputStream.java:320)
at
org.apache.cassandra.utils.BytesReadTracker.readUnsignedShort(BytesReadTracker.java:140)
at
org.apache.cassandra.utils.ByteBufferUtil.readShortLength(ByteBufferUtil.java:361)
at
org.apache.cassandra.utils.ByteBufferUtil.readWithShortLength(ByteBufferUtil.java:371)
at
org.apache.cassandra.streaming.IncomingStreamReader.streamIn(IncomingStreamReader.java:160)
at
org.apache.cassandra.streaming.IncomingStreamReader.read(IncomingStreamReader.java:122)
at
org.apache.cassandra.net.IncomingTcpConnection.stream(IncomingTcpConnection.java:238)
at
org.apache.cassandra.net.IncomingTcpConnection.handleStream(IncomingTcpConnection.java:178)
at
org.apache.cassandra.net.IncomingTcpConnection.run(IncomingTcpConnection.java:78)
{noformat}
SSL problems with inter-DC communication
Key: CASSANDRA-5391
URL: https://issues.apache.org/jira/browse/CASSANDRA-5391
Project: Cassandra
Issue Type: Bug
Components: Core
Affects Versions: 1.2.3
Environment: $ /etc/alternatives/jre_1.6.0/bin/java -version
java version 1.6.0_23
Java(TM) SE Runtime Environment (build 1.6.0_23-b05)
Java HotSpot(TM) 64-Bit Server VM (build 19.0-b09, mixed mode)
$ uname -a
Linux hostname 2.6.32-358.2.1.el6.x86_64 #1 SMP Tue Mar 12 14:18:09 CDT 2013
x86_64 x86_64 x86_64 GNU/Linux
$ cat /etc/redhat-release
Scientific Linux release 6.3 (Carbon)
$ facter | grep ec2
...
ec2_placement = availability_zone=us-east-1d
...
$ rpm -qi cassandra
cassandra-1.2.3-1.el6.cmp1.noarch
(custom built rpm from cassandra tarball distribution)
Reporter: Ondřej Černoš
Priority: Blocker
I get SSL and snappy compression errors in multiple datacenter setup.
The setup is simple: 3 nodes in AWS east, 3 nodes in Rackspace. I use
slightly modified Ec2MultiRegionSnitch in Rackspace (I just added a regex
able to parse the Rackspace/Openstack availability zone which happens to be
in unusual format).
During {{nodetool rebuild}} tests I managed to (consistently) trigger the
following error:
{noformat}
2013-03-19 12:42:16.059+0100 [Thread-13] [DEBUG]
IncomingTcpConnection.java(79)
org.apache.cassandra.net.IncomingTcpConnection: IOException reading from
socket; closing
java.io.IOException: FAILED_TO_UNCOMPRESS(5)
at org.xerial.snappy.SnappyNative.throw_error(SnappyNative.java:78)
at org.xerial.snappy.SnappyNative.rawUncompress(Native Method)
at org.xerial.snappy.Snappy.rawUncompress(Snappy.java:391)
at
org.apache.cassandra.io.compress.SnappyCompressor.uncompress(SnappyCompressor.java:93)
at
org.apache.cassandra.streaming.compress.CompressedInputStream.decompress(CompressedInputStream.java:101)
at
org.apache.cassandra.streaming.compress.CompressedInputStream.read(CompressedInputStream.java:79)
at java.io.DataInputStream.readUnsignedShort(DataInputStream.java:337)
at
org.apache.cassandra.utils.BytesReadTracker.readUnsignedShort(BytesReadTracker.java:140)
at
org.apache.cassandra.utils.ByteBufferUtil.readShortLength(ByteBufferUtil.java:361)
at
org.apache.cassandra.utils.ByteBufferUtil.readWithShortLength(ByteBufferUtil.java:371)
at
org.apache.cassandra.streaming.IncomingStreamReader.streamIn(IncomingStreamReader.java:160)
at
org.apache.cassandra.streaming.IncomingStreamReader.read(IncomingStreamReader.java:122)
at
org.apache.cassandra.net.IncomingTcpConnection.stream(IncomingTcpConnection.java:226)
at
[jira] [Updated] (CASSANDRA-5391) SSL problems with inter-DC communication
[
https://issues.apache.org/jira/browse/CASSANDRA-5391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ondřej Černoš updated CASSANDRA-5391:
-
Description:
I get SSL and snappy compression errors in multiple datacenter setup.
The setup is simple: 3 nodes in AWS east, 3 nodes in Rackspace. I use slightly
modified Ec2MultiRegionSnitch in Rackspace (I just added a regex able to parse
the Rackspace/Openstack availability zone which happens to be in unusual
format).
During {{nodetool rebuild}} tests I managed to (consistently) trigger the
following error:
{noformat}
2013-03-19 12:42:16.059+0100 [Thread-13] [DEBUG] IncomingTcpConnection.java(79)
org.apache.cassandra.net.IncomingTcpConnection: IOException reading from
socket; closing
java.io.IOException: FAILED_TO_UNCOMPRESS(5)
at org.xerial.snappy.SnappyNative.throw_error(SnappyNative.java:78)
at org.xerial.snappy.SnappyNative.rawUncompress(Native Method)
at org.xerial.snappy.Snappy.rawUncompress(Snappy.java:391)
at
org.apache.cassandra.io.compress.SnappyCompressor.uncompress(SnappyCompressor.java:93)
at
org.apache.cassandra.streaming.compress.CompressedInputStream.decompress(CompressedInputStream.java:101)
at
org.apache.cassandra.streaming.compress.CompressedInputStream.read(CompressedInputStream.java:79)
at java.io.DataInputStream.readUnsignedShort(DataInputStream.java:337)
at
org.apache.cassandra.utils.BytesReadTracker.readUnsignedShort(BytesReadTracker.java:140)
at
org.apache.cassandra.utils.ByteBufferUtil.readShortLength(ByteBufferUtil.java:361)
at
org.apache.cassandra.utils.ByteBufferUtil.readWithShortLength(ByteBufferUtil.java:371)
at
org.apache.cassandra.streaming.IncomingStreamReader.streamIn(IncomingStreamReader.java:160)
at
org.apache.cassandra.streaming.IncomingStreamReader.read(IncomingStreamReader.java:122)
at
org.apache.cassandra.net.IncomingTcpConnection.stream(IncomingTcpConnection.java:226)
at
org.apache.cassandra.net.IncomingTcpConnection.handleStream(IncomingTcpConnection.java:166)
at
org.apache.cassandra.net.IncomingTcpConnection.run(IncomingTcpConnection.java:66)
{noformat}
The exception is raised during DB file download. What is strange is the
following:
* the exception is raised only when rebuildig from AWS into Rackspace
* the exception is raised only when all nodes are up and running in AWS (all
3). In other words, if I bootstrap from one or two nodes in AWS, the command
succeeds.
Packet-level inspection revealed malformed packets _on both ends of
communication_ (the packet is considered malformed on the machine it originates
on).
Further investigation raised two more concerns:
* We managed to get another stacktrace when testing the scenario. The exception
was raised only once during the tests and was raised when I throttled the
inter-datacenter bandwidth to 1Mbps.
{noformat}
java.lang.RuntimeException: javax.net.ssl.SSLException: bad record MAC
at com.google.common.base.Throwables.propagate(Throwables.java:160)
at
org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:32)
at java.lang.Thread.run(Thread.java:662)
Caused by: javax.net.ssl.SSLException: bad record MAC
at com.sun.net.ssl.internal.ssl.Alerts.getSSLException(Alerts.java:190)
at
com.sun.net.ssl.internal.ssl.SSLSocketImpl.fatal(SSLSocketImpl.java:1649)
at
com.sun.net.ssl.internal.ssl.SSLSocketImpl.fatal(SSLSocketImpl.java:1607)
at
com.sun.net.ssl.internal.ssl.SSLSocketImpl.readRecord(SSLSocketImpl.java:859)
at
com.sun.net.ssl.internal.ssl.SSLSocketImpl.readDataRecord(SSLSocketImpl.java:755)
at
com.sun.net.ssl.internal.ssl.AppInputStream.read(AppInputStream.java:75)
at
org.apache.cassandra.streaming.compress.CompressedInputStream$Reader.runMayThrow(CompressedInputStream.java:151)
at
org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:28)
... 1 more
{noformat}
This is pure SSL error with no snappy interference.
* I managed to trigger the exception during {{nodetool repair}} tests when
replacing dead node with a new one _on the aws side_, which means the problem
is not restricted to the one-way scenario only.
{noformat}
2013-03-27 14:06:03.033+0100 [Thread-137] [INFO] StreamInSession.java(136)
org.apache.cassandra.streaming.StreamInSession: Streaming of file
/path/to/cassandra/data/ks/cf/ks-cf-ib-2-Data.db sections=3 progress=0/20513 -
0% for org.apache.cassandra.streaming.StreamInSession@14450ae7 failed:
requesting a retry.
2013-03-27 14:06:03.033+0100 [Thread-138] [DEBUG] FileUtils.java(110)
org.apache.cassandra.io.util.FileUtils: Deleting ks-cf-tmp-ib-98-Data.db
2013-03-27 14:06:03.033+0100 [Thread-138] [DEBUG] FileUtils.java(110)
org.apache.cassandra.io.util.FileUtils: Deleting ks-cf-tmp-ib-98-Filter.db
2013-03-27
[jira] [Created] (CASSANDRA-5392) cassandra-all 1.2.0 pom missing netty dependency
Sean Bridges created CASSANDRA-5392: --- Summary: cassandra-all 1.2.0 pom missing netty dependency Key: CASSANDRA-5392 URL: https://issues.apache.org/jira/browse/CASSANDRA-5392 Project: Cassandra Issue Type: Bug Components: Packaging Affects Versions: 1.2.3 Reporter: Sean Bridges Fix For: 1.2.4 It seems that cassandra depends on netty now, however the pom excludes this dependency. This was previously reported as CASSANDRA-5181, but the fix for 5181 added netty to the dependency-management section of the pom, not the depencies section -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (CASSANDRA-5392) cassandra-all 1.2.0 pom missing netty dependency
[ https://issues.apache.org/jira/browse/CASSANDRA-5392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Bridges updated CASSANDRA-5392: Attachment: CASSANDRA-5392.txt cassandra-all 1.2.0 pom missing netty dependency Key: CASSANDRA-5392 URL: https://issues.apache.org/jira/browse/CASSANDRA-5392 Project: Cassandra Issue Type: Bug Components: Packaging Affects Versions: 1.2.3 Reporter: Sean Bridges Fix For: 1.2.4 Attachments: CASSANDRA-5392.txt It seems that cassandra depends on netty now, however the pom excludes this dependency. This was previously reported as CASSANDRA-5181, but the fix for 5181 added netty to the dependency-management section of the pom, not the depencies section -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[Cassandra Wiki] Trivial Update of Lois54A by Lois54A
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The Lois54A page has been changed by Lois54A: http://wiki.apache.org/cassandra/Lois54A New page: Got nothing to write about me at all.BR BR Also visit my blog: [[http://Z.cs.utexas.edu/wiki/emulab.wiki/Shane7760|z.cs.utexas.edu]]
[Cassandra Wiki] Trivial Update of LaurenAnd by LaurenAnd
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The LaurenAnd page has been changed by LaurenAnd: http://wiki.apache.org/cassandra/LaurenAnd New page: 次、あなた ルイヴィトン の履物をすすぐ内部はソフト方法。熟考しているどのようにショップこれら財布のためのあなた家族メンバー？BR BR Also visit my website ... [[http://www.ruivitonshinpin.com/|ヴィトン 財布]]
[jira] [Commented] (CASSANDRA-5389) Deserialize to arrays instead of trees
[ https://issues.apache.org/jira/browse/CASSANDRA-5389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13615437#comment-13615437 ] Sylvain Lebresne commented on CASSANDRA-5389: - +1, as near as I can tell :). Tests are passing and I can't either find a place where we add columns out of order expect for memtables where we use an AtomicSortedColumns anyway. Deserialize to arrays instead of trees -- Key: CASSANDRA-5389 URL: https://issues.apache.org/jira/browse/CASSANDRA-5389 Project: Cassandra Issue Type: Improvement Components: Core Reporter: Jonathan Ellis Assignee: Jonathan Ellis Priority: Minor Fix For: 2.0 Attachments: 5389.txt As near as I can tell, there's no reason to deserialize CFs to trees anymore. On the write path, we move it into an Atomic collection in the Memtable; on the read path, we also create a new clone when merging different results. -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (CASSANDRA-5391) SSL problems with inter-DC communication
[
https://issues.apache.org/jira/browse/CASSANDRA-5391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13615442#comment-13615442
]
Ondřej Černoš commented on CASSANDRA-5391:
--
Update:
With SSTable compression switched off the bug disappears. When I run nodetool
rebuild us-east on a Rackspace node, it fetches the data correctly and when I
compare the md5 of the DB file on an AWS node (after flush and compaction), it
is exactly the same as on the Rackspace node.
It means the problem is only with compressed SSTables, but the problem is
independent on chosen compression algorithm. And only with SSL switched on for
inter-DC communication.
SSL problems with inter-DC communication
Key: CASSANDRA-5391
URL: https://issues.apache.org/jira/browse/CASSANDRA-5391
Project: Cassandra
Issue Type: Bug
Components: Core
Affects Versions: 1.2.3
Environment: $ /etc/alternatives/jre_1.6.0/bin/java -version
java version 1.6.0_23
Java(TM) SE Runtime Environment (build 1.6.0_23-b05)
Java HotSpot(TM) 64-Bit Server VM (build 19.0-b09, mixed mode)
$ uname -a
Linux hostname 2.6.32-358.2.1.el6.x86_64 #1 SMP Tue Mar 12 14:18:09 CDT 2013
x86_64 x86_64 x86_64 GNU/Linux
$ cat /etc/redhat-release
Scientific Linux release 6.3 (Carbon)
$ facter | grep ec2
...
ec2_placement = availability_zone=us-east-1d
...
$ rpm -qi cassandra
cassandra-1.2.3-1.el6.cmp1.noarch
(custom built rpm from cassandra tarball distribution)
Reporter: Ondřej Černoš
Priority: Blocker
I get SSL and snappy compression errors in multiple datacenter setup.
The setup is simple: 3 nodes in AWS east, 3 nodes in Rackspace. I use
slightly modified Ec2MultiRegionSnitch in Rackspace (I just added a regex
able to parse the Rackspace/Openstack availability zone which happens to be
in unusual format).
During {{nodetool rebuild}} tests I managed to (consistently) trigger the
following error:
{noformat}
2013-03-19 12:42:16.059+0100 [Thread-13] [DEBUG]
IncomingTcpConnection.java(79)
org.apache.cassandra.net.IncomingTcpConnection: IOException reading from
socket; closing
java.io.IOException: FAILED_TO_UNCOMPRESS(5)
at org.xerial.snappy.SnappyNative.throw_error(SnappyNative.java:78)
at org.xerial.snappy.SnappyNative.rawUncompress(Native Method)
at org.xerial.snappy.Snappy.rawUncompress(Snappy.java:391)
at
org.apache.cassandra.io.compress.SnappyCompressor.uncompress(SnappyCompressor.java:93)
at
org.apache.cassandra.streaming.compress.CompressedInputStream.decompress(CompressedInputStream.java:101)
at
org.apache.cassandra.streaming.compress.CompressedInputStream.read(CompressedInputStream.java:79)
at java.io.DataInputStream.readUnsignedShort(DataInputStream.java:337)
at
org.apache.cassandra.utils.BytesReadTracker.readUnsignedShort(BytesReadTracker.java:140)
at
org.apache.cassandra.utils.ByteBufferUtil.readShortLength(ByteBufferUtil.java:361)
at
org.apache.cassandra.utils.ByteBufferUtil.readWithShortLength(ByteBufferUtil.java:371)
at
org.apache.cassandra.streaming.IncomingStreamReader.streamIn(IncomingStreamReader.java:160)
at
org.apache.cassandra.streaming.IncomingStreamReader.read(IncomingStreamReader.java:122)
at
org.apache.cassandra.net.IncomingTcpConnection.stream(IncomingTcpConnection.java:226)
at
org.apache.cassandra.net.IncomingTcpConnection.handleStream(IncomingTcpConnection.java:166)
at
org.apache.cassandra.net.IncomingTcpConnection.run(IncomingTcpConnection.java:66)
{noformat}
The exception is raised during DB file download. What is strange is the
following:
* the exception is raised only when rebuildig from AWS into Rackspace
* the exception is raised only when all nodes are up and running in AWS (all
3). In other words, if I bootstrap from one or two nodes in AWS, the command
succeeds.
Packet-level inspection revealed malformed packets _on both ends of
communication_ (the packet is considered malformed on the machine it
originates on).
Further investigation raised two more concerns:
* We managed to get another stacktrace when testing the scenario. The
exception was raised only once during the tests and was raised when I
throttled the inter-datacenter bandwidth to 1Mbps.
{noformat}
java.lang.RuntimeException: javax.net.ssl.SSLException: bad record MAC
at com.google.common.base.Throwables.propagate(Throwables.java:160)
at
org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:32)
at java.lang.Thread.run(Thread.java:662)
Caused by: javax.net.ssl.SSLException: bad record MAC
at com.sun.net.ssl.internal.ssl.Alerts.getSSLException(Alerts.java:190)
at
[jira] [Assigned] (CASSANDRA-5391) SSL problems with inter-DC communication
[
https://issues.apache.org/jira/browse/CASSANDRA-5391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jonathan Ellis reassigned CASSANDRA-5391:
-
Assignee: T Jake Luciani
Can you shed any light, Jake?
SSL problems with inter-DC communication
Key: CASSANDRA-5391
URL: https://issues.apache.org/jira/browse/CASSANDRA-5391
Project: Cassandra
Issue Type: Bug
Components: Core
Affects Versions: 1.2.3
Environment: $ /etc/alternatives/jre_1.6.0/bin/java -version
java version 1.6.0_23
Java(TM) SE Runtime Environment (build 1.6.0_23-b05)
Java HotSpot(TM) 64-Bit Server VM (build 19.0-b09, mixed mode)
$ uname -a
Linux hostname 2.6.32-358.2.1.el6.x86_64 #1 SMP Tue Mar 12 14:18:09 CDT 2013
x86_64 x86_64 x86_64 GNU/Linux
$ cat /etc/redhat-release
Scientific Linux release 6.3 (Carbon)
$ facter | grep ec2
...
ec2_placement = availability_zone=us-east-1d
...
$ rpm -qi cassandra
cassandra-1.2.3-1.el6.cmp1.noarch
(custom built rpm from cassandra tarball distribution)
Reporter: Ondřej Černoš
Assignee: T Jake Luciani
Priority: Blocker
I get SSL and snappy compression errors in multiple datacenter setup.
The setup is simple: 3 nodes in AWS east, 3 nodes in Rackspace. I use
slightly modified Ec2MultiRegionSnitch in Rackspace (I just added a regex
able to parse the Rackspace/Openstack availability zone which happens to be
in unusual format).
During {{nodetool rebuild}} tests I managed to (consistently) trigger the
following error:
{noformat}
2013-03-19 12:42:16.059+0100 [Thread-13] [DEBUG]
IncomingTcpConnection.java(79)
org.apache.cassandra.net.IncomingTcpConnection: IOException reading from
socket; closing
java.io.IOException: FAILED_TO_UNCOMPRESS(5)
at org.xerial.snappy.SnappyNative.throw_error(SnappyNative.java:78)
at org.xerial.snappy.SnappyNative.rawUncompress(Native Method)
at org.xerial.snappy.Snappy.rawUncompress(Snappy.java:391)
at
org.apache.cassandra.io.compress.SnappyCompressor.uncompress(SnappyCompressor.java:93)
at
org.apache.cassandra.streaming.compress.CompressedInputStream.decompress(CompressedInputStream.java:101)
at
org.apache.cassandra.streaming.compress.CompressedInputStream.read(CompressedInputStream.java:79)
at java.io.DataInputStream.readUnsignedShort(DataInputStream.java:337)
at
org.apache.cassandra.utils.BytesReadTracker.readUnsignedShort(BytesReadTracker.java:140)
at
org.apache.cassandra.utils.ByteBufferUtil.readShortLength(ByteBufferUtil.java:361)
at
org.apache.cassandra.utils.ByteBufferUtil.readWithShortLength(ByteBufferUtil.java:371)
at
org.apache.cassandra.streaming.IncomingStreamReader.streamIn(IncomingStreamReader.java:160)
at
org.apache.cassandra.streaming.IncomingStreamReader.read(IncomingStreamReader.java:122)
at
org.apache.cassandra.net.IncomingTcpConnection.stream(IncomingTcpConnection.java:226)
at
org.apache.cassandra.net.IncomingTcpConnection.handleStream(IncomingTcpConnection.java:166)
at
org.apache.cassandra.net.IncomingTcpConnection.run(IncomingTcpConnection.java:66)
{noformat}
The exception is raised during DB file download. What is strange is the
following:
* the exception is raised only when rebuildig from AWS into Rackspace
* the exception is raised only when all nodes are up and running in AWS (all
3). In other words, if I bootstrap from one or two nodes in AWS, the command
succeeds.
Packet-level inspection revealed malformed packets _on both ends of
communication_ (the packet is considered malformed on the machine it
originates on).
Further investigation raised two more concerns:
* We managed to get another stacktrace when testing the scenario. The
exception was raised only once during the tests and was raised when I
throttled the inter-datacenter bandwidth to 1Mbps.
{noformat}
java.lang.RuntimeException: javax.net.ssl.SSLException: bad record MAC
at com.google.common.base.Throwables.propagate(Throwables.java:160)
at
org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:32)
at java.lang.Thread.run(Thread.java:662)
Caused by: javax.net.ssl.SSLException: bad record MAC
at com.sun.net.ssl.internal.ssl.Alerts.getSSLException(Alerts.java:190)
at
com.sun.net.ssl.internal.ssl.SSLSocketImpl.fatal(SSLSocketImpl.java:1649)
at
com.sun.net.ssl.internal.ssl.SSLSocketImpl.fatal(SSLSocketImpl.java:1607)
at
com.sun.net.ssl.internal.ssl.SSLSocketImpl.readRecord(SSLSocketImpl.java:859)
at
com.sun.net.ssl.internal.ssl.SSLSocketImpl.readDataRecord(SSLSocketImpl.java:755)
at
com.sun.net.ssl.internal.ssl.AppInputStream.read(AppInputStream.java:75)
at
[Cassandra Wiki] Trivial Update of JamalGale by JamalGale
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The JamalGale page has been changed by JamalGale: http://wiki.apache.org/cassandra/JamalGale New page: Everybody is wonderful, When i is definitely a day you need it, due to the fact simply bgv appeared from a day you need it, dad is probably one other identity will be the summer time, thus Centimeter rainy day Inches to get started, and even mom moreover expectation I enjoy egyptian cotton shoots looking for early spring bad weather, help make hmzwwhfkt progress daily!BR He in the future because quite a few people will not endure towards the full of sun temperature that will call up me a day you need it, avoiding that In madness In ., and had to help you get out of the simple company name of the individuality, retire straight into Half inch handle Inch.BR I'm straight forward, in truth, can be a Inches following that In . message, because day I became given birth to only would be the father and mother hitched step 2 nremgg everlasting nature time of day subsequent. Xia Yi Half inch homophonic sayings from Ningbo Half inch wonderful In ., can be your pleasurable that will, oh yea, some In . following concept much too genteel, place it off, feather up inside one separates within couple of.BR Anybody says I'm a sun girlfriend, because Now i'm contented. I never sit, ' ha, turn into buddys with a little reclining chair, is actually a instructor and also my best yinxno dad and mom happens to be the largest need. I enjoy belly dancing, but the advisable to adhere to their own favorite songs show up, never according to the specifications with trainers to apply some form of techniques; I love painting like a professional, however it's best to doodle, your little one's experience painted natural also let alone; I'm keen on boarding, nonetheless the most fascinating is about some 5 close friends, at the same time to use how you can struggling . pxyBR Get older, I want to often be melted dishes for the z learn, surely, I additionally ignore the right collage.BR BR Have a look at my blog :: [[http://brandmichael-kors-outlet.webs.com|michael kors outlet]]
[jira] [Commented] (CASSANDRA-5391) SSL problems with inter-DC communication
[
https://issues.apache.org/jira/browse/CASSANDRA-5391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13615479#comment-13615479
]
T Jake Luciani commented on CASSANDRA-5391:
---
Nope, we don't use SSL. Does it work when you disable internode compression?
SSL problems with inter-DC communication
Key: CASSANDRA-5391
URL: https://issues.apache.org/jira/browse/CASSANDRA-5391
Project: Cassandra
Issue Type: Bug
Components: Core
Affects Versions: 1.2.3
Environment: $ /etc/alternatives/jre_1.6.0/bin/java -version
java version 1.6.0_23
Java(TM) SE Runtime Environment (build 1.6.0_23-b05)
Java HotSpot(TM) 64-Bit Server VM (build 19.0-b09, mixed mode)
$ uname -a
Linux hostname 2.6.32-358.2.1.el6.x86_64 #1 SMP Tue Mar 12 14:18:09 CDT 2013
x86_64 x86_64 x86_64 GNU/Linux
$ cat /etc/redhat-release
Scientific Linux release 6.3 (Carbon)
$ facter | grep ec2
...
ec2_placement = availability_zone=us-east-1d
...
$ rpm -qi cassandra
cassandra-1.2.3-1.el6.cmp1.noarch
(custom built rpm from cassandra tarball distribution)
Reporter: Ondřej Černoš
Assignee: T Jake Luciani
Priority: Blocker
I get SSL and snappy compression errors in multiple datacenter setup.
The setup is simple: 3 nodes in AWS east, 3 nodes in Rackspace. I use
slightly modified Ec2MultiRegionSnitch in Rackspace (I just added a regex
able to parse the Rackspace/Openstack availability zone which happens to be
in unusual format).
During {{nodetool rebuild}} tests I managed to (consistently) trigger the
following error:
{noformat}
2013-03-19 12:42:16.059+0100 [Thread-13] [DEBUG]
IncomingTcpConnection.java(79)
org.apache.cassandra.net.IncomingTcpConnection: IOException reading from
socket; closing
java.io.IOException: FAILED_TO_UNCOMPRESS(5)
at org.xerial.snappy.SnappyNative.throw_error(SnappyNative.java:78)
at org.xerial.snappy.SnappyNative.rawUncompress(Native Method)
at org.xerial.snappy.Snappy.rawUncompress(Snappy.java:391)
at
org.apache.cassandra.io.compress.SnappyCompressor.uncompress(SnappyCompressor.java:93)
at
org.apache.cassandra.streaming.compress.CompressedInputStream.decompress(CompressedInputStream.java:101)
at
org.apache.cassandra.streaming.compress.CompressedInputStream.read(CompressedInputStream.java:79)
at java.io.DataInputStream.readUnsignedShort(DataInputStream.java:337)
at
org.apache.cassandra.utils.BytesReadTracker.readUnsignedShort(BytesReadTracker.java:140)
at
org.apache.cassandra.utils.ByteBufferUtil.readShortLength(ByteBufferUtil.java:361)
at
org.apache.cassandra.utils.ByteBufferUtil.readWithShortLength(ByteBufferUtil.java:371)
at
org.apache.cassandra.streaming.IncomingStreamReader.streamIn(IncomingStreamReader.java:160)
at
org.apache.cassandra.streaming.IncomingStreamReader.read(IncomingStreamReader.java:122)
at
org.apache.cassandra.net.IncomingTcpConnection.stream(IncomingTcpConnection.java:226)
at
org.apache.cassandra.net.IncomingTcpConnection.handleStream(IncomingTcpConnection.java:166)
at
org.apache.cassandra.net.IncomingTcpConnection.run(IncomingTcpConnection.java:66)
{noformat}
The exception is raised during DB file download. What is strange is the
following:
* the exception is raised only when rebuildig from AWS into Rackspace
* the exception is raised only when all nodes are up and running in AWS (all
3). In other words, if I bootstrap from one or two nodes in AWS, the command
succeeds.
Packet-level inspection revealed malformed packets _on both ends of
communication_ (the packet is considered malformed on the machine it
originates on).
Further investigation raised two more concerns:
* We managed to get another stacktrace when testing the scenario. The
exception was raised only once during the tests and was raised when I
throttled the inter-datacenter bandwidth to 1Mbps.
{noformat}
java.lang.RuntimeException: javax.net.ssl.SSLException: bad record MAC
at com.google.common.base.Throwables.propagate(Throwables.java:160)
at
org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:32)
at java.lang.Thread.run(Thread.java:662)
Caused by: javax.net.ssl.SSLException: bad record MAC
at com.sun.net.ssl.internal.ssl.Alerts.getSSLException(Alerts.java:190)
at
com.sun.net.ssl.internal.ssl.SSLSocketImpl.fatal(SSLSocketImpl.java:1649)
at
com.sun.net.ssl.internal.ssl.SSLSocketImpl.fatal(SSLSocketImpl.java:1607)
at
com.sun.net.ssl.internal.ssl.SSLSocketImpl.readRecord(SSLSocketImpl.java:859)
at
com.sun.net.ssl.internal.ssl.SSLSocketImpl.readDataRecord(SSLSocketImpl.java:755)
at
[jira] [Commented] (CASSANDRA-5202) AssertionError in the backend: DecoratedKey(-1, ) != DecoratedKey(x, y) ... while querying data after bulk insert - 1M rows with 100 columns. Also failure to drop
[ https://issues.apache.org/jira/browse/CASSANDRA-5202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13615484#comment-13615484 ] Dan Peebles commented on CASSANDRA-5202: Yuki: I'll try to reduce the truncate issue we're seeing when I get some time. It definitely appears connected to this, and might suggest that there's a broader issue here. For what it's worth, we're now randomly also getting the following error message, as described in the closely related CASSANDRA-4687 bug: Caused by: java.io.EOFException: unable to seek to position X in Y (Z bytes) in read-only mode also cured by clearing the key caches. AssertionError in the backend: DecoratedKey(-1, ) != DecoratedKey(x, y) ... while querying data after bulk insert - 1M rows with 100 columns. Also failure to drop column families Key: CASSANDRA-5202 URL: https://issues.apache.org/jira/browse/CASSANDRA-5202 Project: Cassandra Issue Type: Bug Components: Core Affects Versions: 1.1.9 Environment: OS: Windows 7, Server: Cassandra 1.1.9 release drop Client: astyanax 1.56.21, JVM: Sun/Oracle JVM 64 bit (jdk1.6.0_27) Reporter: Marat Bedretdinov Assignee: Yuki Morishita Labels: test Attachments: 5202-1.1.txt, astyanax-stress-driver.zip Attached is a driver that sequentially: 1. Drops keyspace 2. Creates keyspace 4. Creates 2 column families 5. Seeds 1M rows with 100 columns 6. Queries these 2 column families The above steps are repeated 1000 times. The following exception is observed at random (race - SEDA?): ERROR [ReadStage:55] 2013-01-29 19:24:52,676 AbstractCassandraDaemon.java (line 135) Exception in thread Thread[ReadStage:55,5,main] java.lang.AssertionError: DecoratedKey(-1, ) != DecoratedKey(62819832764241410631599989027761269388, 313a31) in C:\var\lib\cassandra\data\user_role_reverse_index\business_entity_role\user_role_reverse_index-business_entity_role-hf-1-Data.db at org.apache.cassandra.db.columniterator.SSTableSliceIterator.init(SSTableSliceIterator.java:60) at org.apache.cassandra.db.filter.SliceQueryFilter.getSSTableColumnIterator(SliceQueryFilter.java:67) at org.apache.cassandra.db.filter.QueryFilter.getSSTableColumnIterator(QueryFilter.java:79) at org.apache.cassandra.db.CollationController.collectAllData(CollationController.java:256) at org.apache.cassandra.db.CollationController.getTopLevelColumns(CollationController.java:64) at org.apache.cassandra.db.ColumnFamilyStore.getTopLevelColumns(ColumnFamilyStore.java:1367) at org.apache.cassandra.db.ColumnFamilyStore.getColumnFamily(ColumnFamilyStore.java:1229) at org.apache.cassandra.db.ColumnFamilyStore.getColumnFamily(ColumnFamilyStore.java:1164) at org.apache.cassandra.db.Table.getRow(Table.java:378) at org.apache.cassandra.db.SliceFromReadCommand.getRow(SliceFromReadCommand.java:69) at org.apache.cassandra.service.StorageProxy$LocalReadRunnable.runMayThrow(StorageProxy.java:822) at org.apache.cassandra.service.StorageProxy$DroppableRunnable.run(StorageProxy.java:1271) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) at java.lang.Thread.run(Thread.java:662) This exception appears in the server at the time of client submitting a query request (row slice) and not at the time data is seeded. The client times out and this data can no longer be queried as the same exception would always occur from there on. Also on iteration 201, it appears that dropping column families failed and as a result their recreation failed with unique column family name violation (see exception below). Note that the data files are actually gone, so it appears that the server runtime responsible for creating column family was out of sync with the piece that dropped them: Starting dropping column families Dropped column families Starting dropping keyspace Dropped keyspace Starting creating column families Created column families Starting seeding data Total rows inserted: 100 in 5105 ms Iteration: 200; Total running time for 1000 queries is 232; Average running time of 1000 queries is 0 ms Starting dropping column families Dropped column families Starting dropping keyspace Dropped keyspace Starting creating column families Created column families Starting seeding data Total rows inserted: 100 in 5361 ms Iteration: 201; Total running time for 1000 queries is 222; Average running time of
[jira] [Commented] (CASSANDRA-5391) SSL problems with inter-DC communication
[
https://issues.apache.org/jira/browse/CASSANDRA-5391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13615499#comment-13615499
]
Ondřej Černoš commented on CASSANDRA-5391:
--
Internode compression settings didn't have any influence on the problem. The
case is very strange:
* it happens only when SSTables are compressed (see the update above)
* it is independent on SSTable compression implementation however (also see
above)
* it happens only when enough (all 3) nodes are switched on in AWS. With 2 or
1 only the problem disappears
Do you have a recommendation on what to investigate further? I already asked
the network team to check networking - they say all is ok - and our operations,
who also cannot identify anything, except for the fact MTU is different in
Rackspace and AWS, so packet from AWS to Rackspace get fragmented.
SSL problems with inter-DC communication
Key: CASSANDRA-5391
URL: https://issues.apache.org/jira/browse/CASSANDRA-5391
Project: Cassandra
Issue Type: Bug
Components: Core
Affects Versions: 1.2.3
Environment: $ /etc/alternatives/jre_1.6.0/bin/java -version
java version 1.6.0_23
Java(TM) SE Runtime Environment (build 1.6.0_23-b05)
Java HotSpot(TM) 64-Bit Server VM (build 19.0-b09, mixed mode)
$ uname -a
Linux hostname 2.6.32-358.2.1.el6.x86_64 #1 SMP Tue Mar 12 14:18:09 CDT 2013
x86_64 x86_64 x86_64 GNU/Linux
$ cat /etc/redhat-release
Scientific Linux release 6.3 (Carbon)
$ facter | grep ec2
...
ec2_placement = availability_zone=us-east-1d
...
$ rpm -qi cassandra
cassandra-1.2.3-1.el6.cmp1.noarch
(custom built rpm from cassandra tarball distribution)
Reporter: Ondřej Černoš
Assignee: T Jake Luciani
Priority: Blocker
I get SSL and snappy compression errors in multiple datacenter setup.
The setup is simple: 3 nodes in AWS east, 3 nodes in Rackspace. I use
slightly modified Ec2MultiRegionSnitch in Rackspace (I just added a regex
able to parse the Rackspace/Openstack availability zone which happens to be
in unusual format).
During {{nodetool rebuild}} tests I managed to (consistently) trigger the
following error:
{noformat}
2013-03-19 12:42:16.059+0100 [Thread-13] [DEBUG]
IncomingTcpConnection.java(79)
org.apache.cassandra.net.IncomingTcpConnection: IOException reading from
socket; closing
java.io.IOException: FAILED_TO_UNCOMPRESS(5)
at org.xerial.snappy.SnappyNative.throw_error(SnappyNative.java:78)
at org.xerial.snappy.SnappyNative.rawUncompress(Native Method)
at org.xerial.snappy.Snappy.rawUncompress(Snappy.java:391)
at
org.apache.cassandra.io.compress.SnappyCompressor.uncompress(SnappyCompressor.java:93)
at
org.apache.cassandra.streaming.compress.CompressedInputStream.decompress(CompressedInputStream.java:101)
at
org.apache.cassandra.streaming.compress.CompressedInputStream.read(CompressedInputStream.java:79)
at java.io.DataInputStream.readUnsignedShort(DataInputStream.java:337)
at
org.apache.cassandra.utils.BytesReadTracker.readUnsignedShort(BytesReadTracker.java:140)
at
org.apache.cassandra.utils.ByteBufferUtil.readShortLength(ByteBufferUtil.java:361)
at
org.apache.cassandra.utils.ByteBufferUtil.readWithShortLength(ByteBufferUtil.java:371)
at
org.apache.cassandra.streaming.IncomingStreamReader.streamIn(IncomingStreamReader.java:160)
at
org.apache.cassandra.streaming.IncomingStreamReader.read(IncomingStreamReader.java:122)
at
org.apache.cassandra.net.IncomingTcpConnection.stream(IncomingTcpConnection.java:226)
at
org.apache.cassandra.net.IncomingTcpConnection.handleStream(IncomingTcpConnection.java:166)
at
org.apache.cassandra.net.IncomingTcpConnection.run(IncomingTcpConnection.java:66)
{noformat}
The exception is raised during DB file download. What is strange is the
following:
* the exception is raised only when rebuildig from AWS into Rackspace
* the exception is raised only when all nodes are up and running in AWS (all
3). In other words, if I bootstrap from one or two nodes in AWS, the command
succeeds.
Packet-level inspection revealed malformed packets _on both ends of
communication_ (the packet is considered malformed on the machine it
originates on).
Further investigation raised two more concerns:
* We managed to get another stacktrace when testing the scenario. The
exception was raised only once during the tests and was raised when I
throttled the inter-datacenter bandwidth to 1Mbps.
{noformat}
java.lang.RuntimeException: javax.net.ssl.SSLException: bad record MAC
at com.google.common.base.Throwables.propagate(Throwables.java:160)
at
org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:32)
[Cassandra Wiki] Trivial Update of OmarSearc by OmarSearc
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The OmarSearc page has been changed by OmarSearc: http://wiki.apache.org/cassandra/OmarSearc New page: Name: Omar SearcyBR My age: 33BR Country: FranceBR Home town: Wattrelos BR ZIP: 59150BR Address: 36 Rue BonnetBR BR Look into my webpage: [[http://truthaboutsixpackabsreviews.com/truth-about-six-pack-abs-all-secrets-revealed/|Visit Website]]
[Cassandra Wiki] Trivial Update of RobynCard by RobynCard
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The RobynCard page has been changed by RobynCard: http://wiki.apache.org/cassandra/RobynCard New page: Guten Tag everyone BR Throughout southern california Azla Vwhdud Hey !! I am LACI DELACRUZ. BR xkyBR BR Jr. MONIKA HANEY is likeable Teacher who has Decided many albums around the concept of aforesaid topic. He stays in The Tiny Institute which has a branch in Riverside in Washington. The writer has an exposure of 57 weeks. Read more on his site about BR I live in North Charleston. BR I am 46. BR My school's name is The Fascinating Preparatory situated in Bellevue. BR I have a job as Cook. BR I like to do Cross-Stitch. BR My papa name is Peter and he is a Soldier. My mother is a Guitarist.BR BR my web site ... [[http://www.holdcheapbeatsbydre.com|beats monster]]
[Cassandra Wiki] Trivial Update of NilaMicha by NilaMicha
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The NilaMicha page has been changed by NilaMicha: http://wiki.apache.org/cassandra/NilaMicha New page: My name is Nila Michaud. I life in Cocata (Australia).BR BR BR BR My weblog: [[http://www.fameb.ufba.br/ead/user/view.php?id=14551course=1|airport parking]]
[jira] [Created] (CASSANDRA-5393) Add an Ack/Retry for merkle tree sending
Jeremiah Jordan created CASSANDRA-5393:
--
Summary: Add an Ack/Retry for merkle tree sending
Key: CASSANDRA-5393
URL: https://issues.apache.org/jira/browse/CASSANDRA-5393
Project: Cassandra
Issue Type: Bug
Reporter: Jeremiah Jordan
Can we add an Ack/Retry around passing merle tree's around in repair? If the
following fails, the repair hangs for ever on the coordinating node.
https://github.com/apache/cassandra/blob/cassandra-1.1.10/src/java/org/apache/cassandra/service/AntiEntropyService.java#L242
{noformat}
Message message = TreeResponseVerbHandler.makeVerb(local,
validator);
if
(!validator.request.endpoint.equals(FBUtilities.getBroadcastAddress()))
logger.info(String.format([repair #%s] Sending completed
merkle tree to %s for %s, validator.request.sessionid,
validator.request.endpoint, validator.request.cf));
ms.sendOneWay(message, validator.request.endpoint);
{noformat}
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (CASSANDRA-5393) Add an Ack/Retry for merkle tree sending
[
https://issues.apache.org/jira/browse/CASSANDRA-5393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeremiah Jordan updated CASSANDRA-5393:
---
Description:
Can we add an Ack/Retry around passing merle tree's around in repair? If the
following fails, the repair hangs for ever on the coordinating node.
https://github.com/apache/cassandra/blob/cassandra-1.1.10/src/java/org/apache/cassandra/service/AntiEntropyService.java#L242
{noformat}
Message message = TreeResponseVerbHandler.makeVerb(local,
validator);
if
(!validator.request.endpoint.equals(FBUtilities.getBroadcastAddress()))
logger.info(String.format([repair #%s] Sending completed
merkle tree to %s for %s, validator.request.sessionid,
validator.request.endpoint, validator.request.cf));
ms.sendOneWay(message, validator.request.endpoint);
{noformat}
If the message asking for merkle tree's gets lost, coordinating node hangs for
ever as well.
was:
Can we add an Ack/Retry around passing merle tree's around in repair? If the
following fails, the repair hangs for ever on the coordinating node.
https://github.com/apache/cassandra/blob/cassandra-1.1.10/src/java/org/apache/cassandra/service/AntiEntropyService.java#L242
{noformat}
Message message = TreeResponseVerbHandler.makeVerb(local,
validator);
if
(!validator.request.endpoint.equals(FBUtilities.getBroadcastAddress()))
logger.info(String.format([repair #%s] Sending completed
merkle tree to %s for %s, validator.request.sessionid,
validator.request.endpoint, validator.request.cf));
ms.sendOneWay(message, validator.request.endpoint);
{noformat}
Add an Ack/Retry for merkle tree sending
Key: CASSANDRA-5393
URL: https://issues.apache.org/jira/browse/CASSANDRA-5393
Project: Cassandra
Issue Type: Bug
Reporter: Jeremiah Jordan
Can we add an Ack/Retry around passing merle tree's around in repair? If the
following fails, the repair hangs for ever on the coordinating node.
https://github.com/apache/cassandra/blob/cassandra-1.1.10/src/java/org/apache/cassandra/service/AntiEntropyService.java#L242
{noformat}
Message message = TreeResponseVerbHandler.makeVerb(local,
validator);
if
(!validator.request.endpoint.equals(FBUtilities.getBroadcastAddress()))
logger.info(String.format([repair #%s] Sending completed
merkle tree to %s for %s, validator.request.sessionid,
validator.request.endpoint, validator.request.cf));
ms.sendOneWay(message, validator.request.endpoint);
{noformat}
If the message asking for merkle tree's gets lost, coordinating node hangs
for ever as well.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
[Cassandra Wiki] Trivial Update of TimmyEog by TimmyEog
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The TimmyEog page has been changed by TimmyEog: http://wiki.apache.org/cassandra/TimmyEog New page: Wassp People !! I am BABETTE COMBS. My age is 48.BR I and my sister go to The Easily Boarding School of Lifetime People built at Grayslake. My daddy name is Cllifford and he is a Corrector. My mummy is a Corrector.BR BR my web-site :: [[http://www.stuffchanelbags.com|chanel handbags]]
[Cassandra Wiki] Trivial Update of chanel_bags_h5S3 by TimmyEog
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The chanel_bags_h5S3 page has been changed by TimmyEog: http://wiki.apache.org/cassandra/chanel_bags_h5S3 New page: ful for Middlesex we can easily [[http://www.stuffchanelbags.com|chanel replica]] check out broad versions. You can find manors which you'll find definitely worth ?5 and also there are manors which are not well worth any amount of shillings. The archbishop's grand manor with Harrow seems to have secure regarding 80 competitors;(35*) typically the Westminster manor involved with Cowley offers territory pertaining to but one organization along with the sole people on doing it happen to be 2 villeins.(36*) But significantly greater types as opposed to runners should be located. Let's check one or two big manors. Leominster around Herefordshire has been stored by Double Edith coupled with seventeen subscribers.(37*) What they are called these folks pick up therefore we found it existing concerning spanning a large tract associated with Herefordshire. From this way with their individuals there had been 70 hides. On the demesne there was 50 groupings. There was Ten reeves not to mention 17 beadles as well as Seven radknights and then 238 villeins, 5 bordiers in addition to Eighty two male and female serfs. Such in most have 230 squads; to make certain that aided by the demesne groups there are not less than 260. Further more there were Norman barons repaying rental prices to this way. Ralph de Mortemer as an example given 15s and even Hugh environnant les Lacy 6s. 8d. It can be enable for you to farm building in the purchase about ?7 together with moreover it's to help a building involving nuns; have been the idea free of this kind of task, it may possibly, hence senses all the district, come to be permit with a purchase about ?20 or so. This is the best manor, meant for developed effective history of an elegant symmetrical program: -- witness that 18 people, Six reeves, Seven radknights, Of sixteen beadles; rather more than likely it comes with a Welsh schedule.(38*) Nevertheless we now have this particular destination to be aware that it is called the manor, plus specific purposes it's treated as being a singular total. For which uses? Very well, commercials can't, it's always enable towards plantation as the solitary whole entire. The, in spite of this, is of no really great importance, designed for property managers in addition to growers might make the things good deals these you should. Additionally it is it will be after tax for a single full. It can be rated at the great over heroes from 70 conceals. Believe it or not handsome while worth more might be Berkeley within Gloucestershire.(39*) That made possible a new book for ?50 with highly processed hard earned cash. That obtained 20 paid members which are sent out in foreign lands over thus diverse an area than a specifically brand of twenty five stretches would most likely not really work with their own uttermost factors.(40*) 'All the aforesaid users are a member of Berkeley.Wi There was clearly Up to 30 radknights, 162 villeins, 147 bordiers, 22 coliberts, 161 female and male serfs, moreover certain unenumerated men of all ages within the radknights; for the demesne acreage have been Fifty-four 1/2 competitors; plus the property owners had 192. Tewkesbury also is a fantastic manor. 'When it was actually on whe whole inside King Edward's time it was in fact valued at ?00,Ha nonetheless currently still ?Zero at most can be found as a result ! as well as in that catastrophe belonging to the Cure her significance decreased to successfully ?Only two.(41*) It was subsequently a fabulous dispersed model, but still it's one for monetary reasons. It was reckoned to help include 89 pelts, yet the 48 which throughout demesne are stop trying associated with geld, and additionally matters ended up and so placed that most of all the geld in the keeping Sixty hides from view experienced, for the reason that involving the jesus along with his several renters, happened to be Tewkesbury; the actual customers ended up being sent out in foreign lands; still 'they gelded found in Tewkesbury.Ha(42*) Virtually no directory amazing manors might be finished with not a recognize involved with Taunton.(43*) 'The bishop involved with Winchester supports Tantone and even incorporates a mansion called Tantone.
[jira] [Created] (CASSANDRA-5394) Allow assigning disk quotas by keyspace
J.B. Langston created CASSANDRA-5394: Summary: Allow assigning disk quotas by keyspace Key: CASSANDRA-5394 URL: https://issues.apache.org/jira/browse/CASSANDRA-5394 Project: Cassandra Issue Type: New Feature Reporter: J.B. Langston Priority: Minor A customer is requesting this. They are implementing a multi-tenant Cassandra Service offering. They want to limit the amount of diskspace that a user or application can consume. They would also want to be able to modify the quota after the keyspace is set up as well. -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (CASSANDRA-5394) Allow assigning disk quotas by keyspace
[ https://issues.apache.org/jira/browse/CASSANDRA-5394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] J.B. Langston updated CASSANDRA-5394: - Description: A customer is requesting this. They are implementing a multi-tenant Cassandra Service offering. They want to limit the amount of diskspace that a user or application can consume. They would also want to be able to modify the quota after the keyspace is set up. (was: A customer is requesting this. They are implementing a multi-tenant Cassandra Service offering. They want to limit the amount of diskspace that a user or application can consume. They would also want to be able to modify the quota after the keyspace is set up as well.) Allow assigning disk quotas by keyspace --- Key: CASSANDRA-5394 URL: https://issues.apache.org/jira/browse/CASSANDRA-5394 Project: Cassandra Issue Type: New Feature Reporter: J.B. Langston Priority: Minor A customer is requesting this. They are implementing a multi-tenant Cassandra Service offering. They want to limit the amount of diskspace that a user or application can consume. They would also want to be able to modify the quota after the keyspace is set up. -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Resolved] (CASSANDRA-5394) Allow assigning disk quotas by keyspace
[ https://issues.apache.org/jira/browse/CASSANDRA-5394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Ellis resolved CASSANDRA-5394. --- Resolution: Won't Fix One of our long-standing design goals is, don't require read before write. But strict quota check before write -- where Cassandra rejects over-quota writes at insert time -- would effectively require this, since I don't know if inserting record X will increase my space used, unless I check and see if X already exists, and if so, what the space-used delta would be. You can achieve probably good enough checking by summing sstable sizes and disabling writes at the application level if it's over quota. You can do this with the existing Metrics that Cassandra exposes. Allow assigning disk quotas by keyspace --- Key: CASSANDRA-5394 URL: https://issues.apache.org/jira/browse/CASSANDRA-5394 Project: Cassandra Issue Type: New Feature Reporter: J.B. Langston Priority: Minor A customer is requesting this. They are implementing a multi-tenant Cassandra Service offering. They want to limit the amount of diskspace that a user or application can consume. They would also want to be able to modify the quota after the keyspace is set up. -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[Cassandra Wiki] Trivial Update of Marcy8982 by Marcy8982
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The Marcy8982 page has been changed by Marcy8982: http://wiki.apache.org/cassandra/Marcy8982 New page: Wassp People !! I am TRESSA HALL. I am turning 30. My school's name is The Cheerful Military School which has a branch in Richmond. My papa name is Steve and he is a Physiognomist. My momy is a Baker.BR BR My weblog - [[http://www.buildchanelbags.com|chanel replica]]
[jira] [Created] (CASSANDRA-5395) Compaction doesn't remove index entries as designed
Jonathan Ellis created CASSANDRA-5395: - Summary: Compaction doesn't remove index entries as designed Key: CASSANDRA-5395 URL: https://issues.apache.org/jira/browse/CASSANDRA-5395 Project: Cassandra Issue Type: Bug Components: Core Affects Versions: 1.2.0 Reporter: Jonathan Ellis Priority: Minor Fix For: 1.2.4 PerColumnIndexUpdater ignores updates where the new value is a tombstone. It should still remove the index entry on oldColumn. (Note that this will not affect user-visible correctness, since KeysSearcher/CompositeSearcher will issue deletes against stale index entries, but having more stale entries than we should could affect performance.) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (CASSANDRA-5395) Compaction doesn't remove index entries as designed
[ https://issues.apache.org/jira/browse/CASSANDRA-5395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Ellis updated CASSANDRA-5395: -- Attachment: 5395.txt Compaction doesn't remove index entries as designed --- Key: CASSANDRA-5395 URL: https://issues.apache.org/jira/browse/CASSANDRA-5395 Project: Cassandra Issue Type: Bug Components: Core Affects Versions: 1.2.0 Reporter: Jonathan Ellis Priority: Minor Fix For: 1.2.4 Attachments: 5395.txt PerColumnIndexUpdater ignores updates where the new value is a tombstone. It should still remove the index entry on oldColumn. (Note that this will not affect user-visible correctness, since KeysSearcher/CompositeSearcher will issue deletes against stale index entries, but having more stale entries than we should could affect performance.) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (CASSANDRA-5395) Compaction doesn't remove index entries as designed
[ https://issues.apache.org/jira/browse/CASSANDRA-5395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Ellis updated CASSANDRA-5395: -- Attachment: 5395-2.txt second patch attached (on top of the first) that also avoids creating duplicate index entries during PrecompactedRow.merge. (Calling indexer.update(A, B) would remove the entry for A and add one for B, but since we're compacting we know that an entry for B already exists.) switched to a merge-column-at-a-time approach similar to what LCR uses. also tweaked LCR's reducer to short-circuit the column lookup if there is no index involved. Compaction doesn't remove index entries as designed --- Key: CASSANDRA-5395 URL: https://issues.apache.org/jira/browse/CASSANDRA-5395 Project: Cassandra Issue Type: Bug Components: Core Affects Versions: 1.2.0 Reporter: Jonathan Ellis Priority: Minor Fix For: 1.2.4 Attachments: 5395-2.txt, 5395.txt PerColumnIndexUpdater ignores updates where the new value is a tombstone. It should still remove the index entry on oldColumn. (Note that this will not affect user-visible correctness, since KeysSearcher/CompositeSearcher will issue deletes against stale index entries, but having more stale entries than we should could affect performance.) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[Cassandra Wiki] Trivial Update of SULLatany by SULLatany
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The SULLatany page has been changed by SULLatany: http://wiki.apache.org/cassandra/SULLatany New page: Hi !! My name is EVIA SANCHEZ. I am staying at Chula Vista.BR I am turning 30. I might join The Helpful Institute of Spotted People located in Corpus Christi. I am self employed as a Governess. I like Quilting. My papa name is Chris and he is a Desktop publisher. My mom is a Model. lvffiqwBR BR Visit my webpage - [[http://www.dressebest.com|bridesmaids dresses]]
[Cassandra Wiki] Trivial Update of Sarah77C by Sarah77C
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The Sarah77C page has been changed by Sarah77C: http://wiki.apache.org/cassandra/Sarah77C New page: Name: Sarah McleanBR Age: 34BR Country: SwitzerlandBR Home town: Villnachern BR Post code: 5213BR Address: Piazza Rezzonico 49BR BR my weblog ... [[http://www.outdoor-fx.net/outdoor-fireplace-columbus-ohio.html|simply click the following site]]
git commit: Deserialize to arrays instead of trees patch by jbellis; reviewed by slebresne for CASSANDRA-5389
Updated Branches:
refs/heads/trunk 4c348c422 - d21556f4f
Deserialize to arrays instead of trees
patch by jbellis; reviewed by slebresne for CASSANDRA-5389
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/d21556f4
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/d21556f4
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/d21556f4
Branch: refs/heads/trunk
Commit: d21556f4f53d4b59c3e2ae1d3571fb1fba6bf5ed
Parents: 4c348c4
Author: Jonathan Ellis jbel...@apache.org
Authored: Wed Mar 27 11:27:20 2013 -0500
Committer: Jonathan Ellis jbel...@apache.org
Committed: Wed Mar 27 11:27:34 2013 -0500
--
.../cassandra/db/ColumnFamilySerializer.java |6 +++---
src/java/org/apache/cassandra/db/ReadResponse.java |2 +-
src/java/org/apache/cassandra/db/Row.java |6 +++---
src/java/org/apache/cassandra/db/RowMutation.java |2 +-
4 files changed, 8 insertions(+), 8 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/cassandra/blob/d21556f4/src/java/org/apache/cassandra/db/ColumnFamilySerializer.java
--
diff --git a/src/java/org/apache/cassandra/db/ColumnFamilySerializer.java
b/src/java/org/apache/cassandra/db/ColumnFamilySerializer.java
index 3c88b54..0a1db4e 100644
--- a/src/java/org/apache/cassandra/db/ColumnFamilySerializer.java
+++ b/src/java/org/apache/cassandra/db/ColumnFamilySerializer.java
@@ -88,15 +88,15 @@ public class ColumnFamilySerializer implements
IVersionedSerializerColumnFamily
public ColumnFamily deserialize(DataInput in, int version) throws
IOException
{
-return deserialize(in, ColumnSerializer.Flag.LOCAL,
TreeMapBackedSortedColumns.factory(), version);
+return deserialize(in, ColumnSerializer.Flag.LOCAL, version);
}
-public ColumnFamily deserialize(DataInput in, ColumnSerializer.Flag flag,
ISortedColumns.Factory factory, int version) throws IOException
+public ColumnFamily deserialize(DataInput in, ColumnSerializer.Flag flag,
int version) throws IOException
{
if (!in.readBoolean())
return null;
-ColumnFamily cf = ColumnFamily.create(deserializeCfId(in, version),
factory);
+ColumnFamily cf = ColumnFamily.create(deserializeCfId(in, version),
ArrayBackedSortedColumns.factory());
int expireBefore = (int) (System.currentTimeMillis() / 1000);
if (cf.metadata().isSuper() version MessagingService.VERSION_20)
http://git-wip-us.apache.org/repos/asf/cassandra/blob/d21556f4/src/java/org/apache/cassandra/db/ReadResponse.java
--
diff --git a/src/java/org/apache/cassandra/db/ReadResponse.java
b/src/java/org/apache/cassandra/db/ReadResponse.java
index c4cb96b..0afb27b 100644
--- a/src/java/org/apache/cassandra/db/ReadResponse.java
+++ b/src/java/org/apache/cassandra/db/ReadResponse.java
@@ -93,7 +93,7 @@ class ReadResponseSerializer implements
IVersionedSerializerReadResponse
if (!isDigest)
{
// This is coming from a remote host
-row = Row.serializer.deserialize(in, version,
ColumnSerializer.Flag.FROM_REMOTE, ArrayBackedSortedColumns.factory());
+row = Row.serializer.deserialize(in, version,
ColumnSerializer.Flag.FROM_REMOTE);
}
return isDigest ? new ReadResponse(ByteBuffer.wrap(digest)) : new
ReadResponse(row);
http://git-wip-us.apache.org/repos/asf/cassandra/blob/d21556f4/src/java/org/apache/cassandra/db/Row.java
--
diff --git a/src/java/org/apache/cassandra/db/Row.java
b/src/java/org/apache/cassandra/db/Row.java
index d6435ba..785b058 100644
--- a/src/java/org/apache/cassandra/db/Row.java
+++ b/src/java/org/apache/cassandra/db/Row.java
@@ -61,15 +61,15 @@ public class Row
ColumnFamily.serializer.serialize(row.cf, out, version);
}
-public Row deserialize(DataInput in, int version,
ColumnSerializer.Flag flag, ISortedColumns.Factory factory) throws IOException
+public Row deserialize(DataInput in, int version,
ColumnSerializer.Flag flag) throws IOException
{
return new
Row(StorageService.getPartitioner().decorateKey(ByteBufferUtil.readWithShortLength(in)),
- ColumnFamily.serializer.deserialize(in, flag,
factory, version));
+ ColumnFamily.serializer.deserialize(in, flag,
version));
}
public Row deserialize(DataInput in, int version) throws IOException
{
-return deserialize(in, version, ColumnSerializer.Flag.LOCAL,
TreeMapBackedSortedColumns.factory());
+return deserialize(in,
[Cassandra Wiki] Trivial Update of CarrollAs by CarrollAs
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The CarrollAs page has been changed by CarrollAs: http://wiki.apache.org/cassandra/CarrollAs New page: Kumusta all people $BR Throughout southern california Cumf Jonfpw Howdy !! I am FAITH BROCK.BR BR edsBR BR Jr. LAVERA GOMEZ is agreeable Politician who has Maximized many brochures concerning of the topic. She lives in The Mammoth Boarding School situated in Cedar Rapids in Amarillo. The speaker has an history of 24 months. Reach him at BR I am staying at Huntington Beach. BR This autumun iam going to be 21. BR I and my sister go to The Wise Finishing School of Frozen People located in Boston. BR I work as a Organizer. BR I am a fan of Frisbee Golf - Frolf. BR My dad name is Adam and he is a Political Scientist. My momy is a Welder.BR BR Also visit my weblog; [[http://www.justchaneloutlet.com|chanel replica]]
[Cassandra Wiki] Trivial Update of VeldaGadd by VeldaGadd
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The VeldaGadd page has been changed by VeldaGadd: http://wiki.apache.org/cassandra/VeldaGadd New page: Jag uppskattar att anteckna och sprida mina kunskaper om hälsa och olika hälsofrågor.BR ..BR BR Also visit my blog post; [[http://www.tatueringsmotiv.se/Kategorier/tatueringsmotiv-2/stjarnor/|mouse click the next article]]
[Cassandra Wiki] Trivial Update of MarlonTem by MarlonTem
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The MarlonTem page has been changed by MarlonTem: http://wiki.apache.org/cassandra/MarlonTem New page: Everyone is fine, I really can be a rainy day, given that just aoy was created in a very day you need it, daddy is exactly an additional designate is without a doubt summer months, hence In .BR day you need it Inches to get started, along with mama as well hope I love egyptian cotton tries for a takedown from a early spring storm, try to make uiuuihavq progress day by day! They later simply because most people are unable to bear on the inviting weather conditions to help you telephone me a day you need it, to prevent the particular In bedlam Centimeter, coupled with to help get out of the easy term of one's persona, holiday towards In . play name In .. I am hassle-free, for that matter, can be described as then In . term, since morning I'm given birth to just simply will be the mother and father wedded 2 sermvz husband's time of day secondary. Inches Xia Yi Inches homophonic key phrases regarding Ningbo Inches wonderful Inch, really is endless your pleasurable towards, oh yea, a little In then Inches word as well genteel, input it downward, feather up within one isolates in to 2.BR Everyone states I'm a sun gal, due to the fact So i am completely happy. It's my job to you should never take a seat, lol ha, may be people accompanied by a smallish office chair, can be described as trainer not to mention your zbbsyr parent currently is very large intend. I recommend grooving, nonetheless the advisable to pursue their personal new music move, definitely not according to the needs from educators to employ the usual competencies; I favor ideas for painting, but it's far better to doodle, this infant's experience handcrafted eco-friendly also let alone; I enjoy skating, nevertheless the most interesting is about about three several mates, in concert to rehearse ways to play fighting . iccBR Grow up, I have to get toast pots and pans of the x professional, keep in mind, Also i overlook the right school.BR BR Here is my website; [[http://www.packchanelbags.com|chanel bags]]
[Cassandra Wiki] Trivial Update of RoseanneK by RoseanneK
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The RoseanneK page has been changed by RoseanneK: http://wiki.apache.org/cassandra/RoseanneK New page: My character further friendly, coming from freshman to help regularly go out to socialize WPHL by several states, and try to keep in touch, excellent connection with normal folks.BR Sparetime and a powerful Native indian the summer season, part-time translation or maybe jar, work the forex market. ( she I have got business for Guangzhou ) additionally found them not to mention accredited people, the attendees went back property, continue BIPZW expertise of everyone at the same time.BR My spouse and i are exposed to the merchandise world extensively, paper, bags, natural leather, house furniture, aroma ornaments, lamps for example.,BR Self-learning power, helpful to considering, hard-working, good OAEQX connecting talents, capable at obtaining and also others, loaded with company mood, passion for sporting activities. Yet persons are never appropriate, some people still have quite a few JKC errors, a number of factors just like experience, ethnical encounter; but I believe that every one of these will be able to as a result of their own individual efforts PGL to further improve the educational, Also are actually transferring this approach course!BR FCGIBR BR Feel free to surf to my web-site: [[http://www.stuffchanelbags.com|chanel replica]]
[Cassandra Wiki] Trivial Update of FJOFreder by FJOFreder
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The FJOFreder page has been changed by FJOFreder: http://wiki.apache.org/cassandra/FJOFreder New page: Most people are superior, That i is actually a day you need it, considering that just simply yva was born at a rainy day, my dad is merely a second term is usually summer, and so Half inch rainy day In to start, not to mention new mother in addition optimism I love bamboo launches after having a summer bad weather, get zmnattbah progress each day!BR He or she afterward considering many people can't carry to your bright temperature to be able to telephone us a day you need it, in order to avoid the In pandemonium In, along with to help you forego be simple label of an persona, vacation straight into Inches play name . Throughout southern california straight forward, in reality, is usually a In then Half inch message, since the day time I became developed only just stands out as the father and mother betrothed step 2 bdvbsa ever day secondary. In Xia Yi Centimeter homophonic terms involving Ningbo great Inch, produce your own . our recreational that will, oh yea, slightly Centimeter subsequent word way too genteel, use it affordable, feather upward to a divides inside 2.BR Anybody says I am a sun female, since We are joyful. That i don't sit, ' haya, may be pals that has a minimal easy chair, is a tutor along with my hwyhlp mom and dad has become the best wish. I want moving, nonetheless wise to carry out their particular tracks dance, never in accordance with the specifications connected with tutors to use the usual ability; I want portray, it really is far better doodle, the particular infant's skin displayed environment friendly furthermore don't worry; I prefer skateboarding, nonetheless best is around some a few pals, collectively to apply the best way to struggling . hcuBR Age, I would like to become toast food from the b control, needless to say, Alongside this pass-up the right higher education.BR BR Here is my web-site - [[http://www.justchaneloutlet.com|chanel handbags]]
[jira] [Commented] (CASSANDRA-5395) Compaction doesn't remove index entries as designed
[ https://issues.apache.org/jira/browse/CASSANDRA-5395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13615816#comment-13615816 ] Jonathan Ellis commented on CASSANDRA-5395: --- Fixed a test failure and pushed to http://github.com/jbellis/cassandra/tree/5395. (Original patches were also half 1.2, half trunk. Now both against 1.2.) Compaction doesn't remove index entries as designed --- Key: CASSANDRA-5395 URL: https://issues.apache.org/jira/browse/CASSANDRA-5395 Project: Cassandra Issue Type: Bug Components: Core Affects Versions: 1.2.0 Reporter: Jonathan Ellis Priority: Minor Fix For: 1.2.4 Attachments: 5395-2.txt, 5395.txt PerColumnIndexUpdater ignores updates where the new value is a tombstone. It should still remove the index entry on oldColumn. (Note that this will not affect user-visible correctness, since KeysSearcher/CompositeSearcher will issue deletes against stale index entries, but having more stale entries than we should could affect performance.) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Created] (CASSANDRA-5396) Repair process is a joke leading to a downward spiralling and eventually unusable cluster
David Berkman created CASSANDRA-5396: Summary: Repair process is a joke leading to a downward spiralling and eventually unusable cluster Key: CASSANDRA-5396 URL: https://issues.apache.org/jira/browse/CASSANDRA-5396 Project: Cassandra Issue Type: Bug Components: Core Affects Versions: 1.2.3 Environment: all Reporter: David Berkman Priority: Critical Fix For: 2.1 Let's review the repair process... 1) It's mandatory to run repair. 2) Repair has a high impact and can take hours. 3) Repair provides no estimation of completion time and no progress indicator. 4) Repair is extremely fragile, and can fail to complete, or become stuck quite easily in real operating environments. 5) When repair fails it provides no feedback whatsoever of the problem or possible resolution. 6) A failed repair operation saddles the effected nodes with a huge amount of extra data (judging from node size). 7) There is no way to rid the node of the extra data associated with a failed repair short of completely rebuilding the node. 8) The extra data from a failed repair makes any subsequent repair take longer and increases the likelihood that it will simply become stuck or fail, leading to yet more node corruption. 9) Eventually no repair operation will complete successfully, and node operations will eventually become impacted leading to a failing cluster. Who would design such a system for a service meant to operate as a fault tolerant clustered data store operating on a lot of commodity hardware? Solution... 1) Repair must be robust. 2) Repair must *never* become 'stuck'. 3) Failure to complete must result in reasonable feedback. 4) Failure to complete must not result in a node whose state is worse than before the operation began. 5) Repair must provide some means of determining completion percentage. 6) It would be nice if repair could estimate its run time, even if it could do so only based upon previous runs. -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Resolved] (CASSANDRA-5396) Repair process is a joke leading to a downward spiralling and eventually unusable cluster
[ https://issues.apache.org/jira/browse/CASSANDRA-5396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Ellis resolved CASSANDRA-5396. --- Resolution: Invalid Fix Version/s: (was: 2.1) I suggest you try again with some actionable problem analysis (here is what causes repair to become stuck; here is how we should fix that) and without the everyone but me is an idiot attitude. Repair process is a joke leading to a downward spiralling and eventually unusable cluster - Key: CASSANDRA-5396 URL: https://issues.apache.org/jira/browse/CASSANDRA-5396 Project: Cassandra Issue Type: Bug Components: Core Affects Versions: 1.2.3 Environment: all Reporter: David Berkman Priority: Critical Let's review the repair process... 1) It's mandatory to run repair. 2) Repair has a high impact and can take hours. 3) Repair provides no estimation of completion time and no progress indicator. 4) Repair is extremely fragile, and can fail to complete, or become stuck quite easily in real operating environments. 5) When repair fails it provides no feedback whatsoever of the problem or possible resolution. 6) A failed repair operation saddles the effected nodes with a huge amount of extra data (judging from node size). 7) There is no way to rid the node of the extra data associated with a failed repair short of completely rebuilding the node. 8) The extra data from a failed repair makes any subsequent repair take longer and increases the likelihood that it will simply become stuck or fail, leading to yet more node corruption. 9) Eventually no repair operation will complete successfully, and node operations will eventually become impacted leading to a failing cluster. Who would design such a system for a service meant to operate as a fault tolerant clustered data store operating on a lot of commodity hardware? Solution... 1) Repair must be robust. 2) Repair must *never* become 'stuck'. 3) Failure to complete must result in reasonable feedback. 4) Failure to complete must not result in a node whose state is worse than before the operation began. 5) Repair must provide some means of determining completion percentage. 6) It would be nice if repair could estimate its run time, even if it could do so only based upon previous runs. -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[Cassandra Wiki] Trivial Update of LannyZSCI by LannyZSCI
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The LannyZSCI page has been changed by LannyZSCI: http://wiki.apache.org/cassandra/LannyZSCI New page: The school a few years instance, to ensure that goczfniesn I'll be shown a great number of understanding, didn't know in advance of, whether or not inside the cerebral limit, or perhaps your growing of non-public properties are generally gained people, identify, essential technological know-how.BR Most definitely i'll throughout their particular projects, recreate strict requires upon on their own, I think you will the firm makes my family function these, as I get a favourable, industriousness along with tolerance, not afraid with labor and look mentality, likewise in the hope that one are able to get more know-how, hx to expand the industry of imaginative and prescient vision, grasp the possibility to workout their unique to make sure you practice desires . Allow me to gain in competition, in the exact very difficult challenge, allow me to dvg being seated undermine expansion, keenly ka await with your within direction in the enterprise, hjxf could have better progress. gjdxaBR BR Feel free to visit my site [[http://mychanelbagsshop.webs.com|chanel bags]]
[Cassandra Wiki] Trivial Update of Alfonso08 by Alfonso08
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The Alfonso08 page has been changed by Alfonso08: http://wiki.apache.org/cassandra/Alfonso08 New page: College or university bit by bit gone on an additional, Gu secondary education, in the guide additionally, the lessons that belongs to them very hard study, I have productively concluded experienced curriculums,, not to mention establish a wonderful habit of serious investigation and additionally work!BR . May well hard-working, dependable as well as go through the theory bz associated with honesty along with stability, typically the courage so that you can struggle independently along with produce their unique prospective;BR Come up with an involved particular person, the effort keenness, to personally own objective to carry out the points you are looking for seriously inside induce;BR Have a very good xxyi character, able to connect with people today, coping with communities, is usually fairly steer verbal exchanges with others, potent organization management abilities and then a nature regarding assistance individuals, be capable to positively have interaction to realize organization goals and objectives;BR Be a master at studying, homework along with pragmatism, assiduously, contain extensive fascination nba and intensely wealthy understanding, tough opportunity to get used, tq to help assimilate in a different area at a time, to adapt to your ex and hang her to perform;BR BR Feel free to visit my site; [[http://www.packchanelbags.com|chanel purses]]
[Cassandra Wiki] Trivial Update of RobtClint by RobtClint
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The RobtClint page has been changed by RobtClint: http://wiki.apache.org/cassandra/RobtClint New page: Name: Tiffany DempseyBR Age: 37BR Country: AustraliaBR Town: Doncaster Heights BR Post code: 3109BR Address: 74 Lane StreetBR BR Check out my blog: [[http://lutonairportparking.blogspot.com/|luton airport]]
[Cassandra Wiki] Trivial Update of .Undercover_Airport_Parking_Rates by TrinaMarr
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The .Undercover_Airport_Parking_Rates page has been changed by TrinaMarr: http://wiki.apache.org/cassandra/.Undercover_Airport_Parking_Rates New page: More than often, airports offer different levels of parking and the rates vary based on the parking area. If you are planning to use the parking space on your next trip, make sure to look around for companies that provide cheaper [[http://bristolairportparking.blogspot.co.uk/|click the following document]] facilities. In this manner, you will be able to save some precious bristols. The good news is that some companies do not shy away from offering discounts on parking space to consumers due to the stiff competition prevailing in the market. They offer discount coupons every now and then in order to attract customers. Consumers can benefit due to the competition, and thereby stay immune from the high airport parking rates.BR Valet parking service is secure, well-managed and of high standard. Once you reach at airport, a qualified and attentive driver will receive you gladly and park your vehicle in a secured parking zone.BR How about taking one of their coaches down to the airport? It will be a lot cheaper and you can leave your car in your garage. If you really want to take it, then it's better to get 4 online coupons. Better yet, give econopark a call and ask them if that's what you need to do.BR Examine prices. There is not a monopoly on airport parking. You'll be able to park in a couple of different industrial lots in so much cities and the costs might be very comparable. Shop around ahead of you park, and even call around and take a look at to seek out the best deal. Searching for airport parking isn't rocket technological know-how and it truly should not be that tough to discover a good deal. No matter what town you are in. Also, test online. Many different airport parking corporations have internet sites the place you can compare their prices.BR Parking at bristol Airport features a good range of options and rates for both business and pleasure travelers. The most economical on-site New Jersey airport parking is the Long Term Parking Lot P6, reached by free shuttle bus running every 10-15 minutes during daylight hours and every 20 minutes during the night. Rates are £12 a day and a good option if you have the extra time it takes to transfer to the bus to take you to your proper terminal for departure.BR • Rate comparisons between different parking facilities at different airports. The table is comprehensive and you can then choose a site at a rate that is suitable to you. Tabulated rates indicate that the economy parking charges at airport lots are nearly double that of most other off-airport facilities. One can be an informed and discerning consumer and know where to spend and how to make a saving for services that are no different.BR Before heading to park at bristol Liberty International Airport, making one-toll free call can save you time and hassle. The free Parking Information line reached at 1-888-397-4636 will alert you to current parking conditions at the airport and can even connect you to a live person if you have additional questions.BR Off-site parking isn't a new thing. At first, it was people who owned the fields around international airports that would rent off space, which obviously left a lot to be desired. Often these were empty fields where your cars were parked, with virtually no amenities or security. Luckily, everything has changed drastically for the better and there are many new options available.
[Cassandra Wiki] Trivial Update of CarmonVog by CarmonVog
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The CarmonVog page has been changed by CarmonVog: http://wiki.apache.org/cassandra/CarmonVog New page: My name: Rod ReganBR My age: 37BR Country: AustraliaBR Town: Alkimos BR ZIP: 6038BR Street: 24 Daly TerraceBR BR Look into my webpage ... [[http://carparkingmanchesterairport.blogspot.co.uk/2013/03/get-best-value-when-you-park-your-car.html|manchester airport parking]]
[Cassandra Wiki] Trivial Update of AnnmarieG by AnnmarieG
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The AnnmarieG page has been changed by AnnmarieG: http://wiki.apache.org/cassandra/AnnmarieG New page: A better Day-BR I am a fan of Digital Photography. BR My daddy name is Bruce and he is a Musician. My momy is a Chiropodist.BR BR BR I work as a Stage Designer. BR I might take night schooling in The Dizzy Institute of Refundable Children situated in Abilene. BR I am 32. BR I am from High Point. BR Yo bros !! The name is LEOMA WALTER.BR BR Feel free to surf to my page :: [[http://justchanelbags.webs.com|chanel bag]]
[Cassandra Wiki] Trivial Update of CarriBatt by CarriBatt
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The CarriBatt page has been changed by CarriBatt: http://wiki.apache.org/cassandra/CarriBatt New page: I have been your productive not to mention content little girl.BR BR I throw a exquisite african american frizzy hair, a couple smart xqgb face, very long which has a minimal cherry oral. Medium assemble, big.BR I'm keen on your lotus, that take a position subtly vertical on the beach, a bit like a lovely person. I want painting them, singing, grooving ... I will be highly sensible, well - written message, and yet, Through experience i learn to really Yue Xiang, strive for extra development! ueBR I throw a massive amount gains, as an illustration We come up with not to mention momentum, together with top quality, operate in chance to compose. This system is excellent, my personal bench is actually slowly, your dog tpeuwu didn't remember to help dictation of written text, I could report to him or her.BR When I came up the place to find dinner time, I'll help your mom and dad up . Even so, there is absolutely no ideal man or women, I have a great number of shortcomings, along the lines of I enjoy view television, have fun laptop computer at. Even so, in an effort to examine, I would strive, very hard, hard! I want to go to faculty, vdyu college or possibly which helped me to offer the to make sure you the girl's woman.BR BR Good, consider it really embarrassed! I ought to find out improved. My sports is extremely terrible, mainly ping pong. Now That i look at possibly even around 60 to 70 not to, and also infrequent! Heya, it appears my personal nxiaz sports activities isn't!BR This can be me personally, a lovely my spouse and i!BR BR Feel free to visit my blog post ... [[http://www.holdcheapbeatsbydre.com|beat by dr dre]]
[Cassandra Wiki] Update of ArchitectureInternals by JonathanEllis
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The ArchitectureInternals page has been changed by JonathanEllis: http://wiki.apache.org/cassandra/ArchitectureInternals?action=diffrev1=28rev2=29 Comment: add note on names * !AbstractReplicationStrategy controls what nodes get secondary, tertiary, etc. replicas of each key range. Primary replica is always determined by the token ring (in !TokenMetadata) but you can do a lot of variation with the others. !SimpleStrategy just puts replicas on the next N-1 nodes in the ring. !NetworkTopologyStrategy allows the user to define how many replicas to place in each datacenter, and then takes rack locality into account for each DC -- we want to avoid multiple replicas on the same rack, if possible. * !MessagingService handles connection pooling and running internal commands on the appropriate stage (basically, a threaded executorservice). Stages are set up in !StageManager; currently there are read, write, and stream stages. (Streaming is for when one node copies large sections of its SSTables to another, for bootstrap or relocation on the ring.) The internal commands are defined in !StorageService; look for `registerVerbHandlers`. * Configuration for the node (administrative stuff, such as which directories to store data in, as well as global configuration, such as which global partitioner to use) is held by !DatabaseDescriptor. Per-KS, per-CF, and per-Column metadata are all stored as parts of the Schema: !KSMetadata, !CFMetadata, !ColumnDefinition. See also ConfigurationNotes. + + = Some historial baggage = + * Some classes have misleading names, notably !ColumnFamily (which represents a single row, not a table of data) and !Table (which represents a keyspace). = Write path = * !StorageProxy gets the nodes responsible for replicas of the keys from the !ReplicationStrategy, then sends !RowMutation messages to them.
[Cassandra Wiki] Trivial Update of MagdaBats by MagdaBats
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The MagdaBats page has been changed by MagdaBats: http://wiki.apache.org/cassandra/MagdaBats New page: My name is Magda Batson. I life in Pedavena (Italia).BR BR BR my blog - [[http://oliver-green1.livejournal.com/565.html|click through the up coming internet page]]
[jira] [Commented] (CASSANDRA-5395) Compaction doesn't remove index entries as designed
[ https://issues.apache.org/jira/browse/CASSANDRA-5395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13615972#comment-13615972 ] Jonathan Ellis commented on CASSANDRA-5395: --- ... And pushed a 3rd commit applying the fix in patch to to ParallelCompactionIterable. This also has the side effect of switching from TSM to ABSM for PrecompactedRow and ParallelCompactionIterable, so there may be a performance improvement. Compaction doesn't remove index entries as designed --- Key: CASSANDRA-5395 URL: https://issues.apache.org/jira/browse/CASSANDRA-5395 Project: Cassandra Issue Type: Bug Components: Core Affects Versions: 1.2.0 Reporter: Jonathan Ellis Priority: Minor Fix For: 1.2.4 Attachments: 5395-2.txt, 5395.txt PerColumnIndexUpdater ignores updates where the new value is a tombstone. It should still remove the index entry on oldColumn. (Note that this will not affect user-visible correctness, since KeysSearcher/CompositeSearcher will issue deletes against stale index entries, but having more stale entries than we should could affect performance.) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[Cassandra Wiki] Trivial Update of LucianaD5 by LucianaD5
Dear Wiki user, You have subscribed to a wiki page or wiki category on Cassandra Wiki for change notification. The LucianaD5 page has been changed by LucianaD5: http://wiki.apache.org/cassandra/LucianaD5 New page: Name: Luciana McwhorterBR Age: 31BR Country: AustraliaBR Home town: Bowen Mountain BR ZIP: 2753BR Address: 56 Cambridge StreetBR BR Feel free to visit my web page: [[http://www.youtube.com/watch?v=SgjGM1mCOB4|http://www.youtube.com/]]
