[jira] [Commented] (CASSANDRA-4962) JMX bean of StorageProxy is sometimes invisible
[ https://issues.apache.org/jira/browse/CASSANDRA-4962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13496905#comment-13496905 ] Brandon Williams commented on CASSANDRA-4962: - It's not invisible so much as it doesn't exist until it's instantiated. The same is true of a number of other mbeans, most notably HintedHandOffManager which will require two nodes to appear. > JMX bean of StorageProxy is sometimes invisible > --- > > Key: CASSANDRA-4962 > URL: https://issues.apache.org/jira/browse/CASSANDRA-4962 > Project: Cassandra > Issue Type: Bug > Components: Core >Affects Versions: 1.0.7, 1.0.12 >Reporter: Shotaro Kamio > > StorageProxy exposes info via JMX bean > "org.apache.cassandra.db:type=StorageProxy". But that bean is sometimes > invisible via jmxterm nor jconsole. > Seems like it becomes visible after data comes in. -- 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-4885) Remove or rework per-row bloom filters
[ https://issues.apache.org/jira/browse/CASSANDRA-4885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13496901#comment-13496901 ] Jason Brown commented on CASSANDRA-4885: Yeah, I figured the 'whack it in the knee caps with a baseball bat' technique would work :), wasn't sure if there would be a more controlled way. Digging out the sports equipment now... > Remove or rework per-row bloom filters > -- > > Key: CASSANDRA-4885 > URL: https://issues.apache.org/jira/browse/CASSANDRA-4885 > Project: Cassandra > Issue Type: Improvement > Components: Core >Reporter: Jonathan Ellis >Assignee: Jason Brown > Fix For: 1.3 > > Attachments: 0001-CASSANRDA-4885-Remove-per-row-bloom-filter.patch > > > Per-row bloom filters may be a misfeature. > On small rows we don't create them. > On large rows we essentially only do slice queries that can't take advantage > of it. > And on very large rows if we ever did deserialize it, the performance hit of > doing so would outweigh the benefit of skipping the actual read. -- 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-4963) A cql collection 'column' doesn't own it's ttl
[
https://issues.apache.org/jira/browse/CASSANDRA-4963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dave Brosius updated CASSANDRA-4963:
Description:
if you add a collection column with a ttl, then later update the collection by
adding a new element, the 'under the covers' column representing the added
value has no ttl. It seems like ttl tombstoning should only be allowed to
remove the collection in entirety, or not touch it, but not be allowed to
modify it by removing parts.
example
cqlsh> create keyspace collections with replication =
{'class':'SimpleStrategy', 'replication_factor':1};
cqlsh> use collections;
cqlsh:collections> create table collections (key int primary key, aset
set);
cqlsh:collections> insert into collections (key, aset) values (1, {'fee',
'fi'}) using ttl 1;
cqlsh:collections> update collections set aset = aset + {'fo', 'fum'} where key
= 1;
cqlsh:collections> exit
cassandra-cli
[default@unknown] use collections
[default@collections] get collections[1];
=> (column=, value=, timestamp=1352874321877000)
=> (column=aset:666565, value=, timestamp=1352874314717000, ttl=1)
=> (column=aset:6669, value=, timestamp=1352874314717000, ttl=1)
=> (column=aset:666f, value=, timestamp=1352874321877000)
=> (column=aset:66756d, value=, timestamp=1352874321877000)
was:
if you add a collection column with a ttl, then later update the collection by
adding a new element, the 'under the covers' column representing the added
value has no ttl. It seems like ttl tombstoning should only be allowed to
remove the collection in entirety, or not touch it, but not be allowed to
modify it by removing parts.
example
cqlsh> create keyspace collections with replication =
{'class':'SimpleStrategy', 'replication_factor':1};
cqlsh> use collections;
cqlsh:collections> insert into collections (key, aset) values (1, {'fee',
'fi'}) using ttl 1;
cqlsh:collections> update collections set aset = aset + {'fo', 'fum'} where key
= 1;
cqlsh:collections> exit
cassandra-cli
[default@unknown] use collections
[default@collections] get collections[1];
=> (column=, value=, timestamp=1352874321877000)
=> (column=aset:666565, value=, timestamp=1352874314717000, ttl=1)
=> (column=aset:6669, value=, timestamp=1352874314717000, ttl=1)
=> (column=aset:666f, value=, timestamp=1352874321877000)
=> (column=aset:66756d, value=, timestamp=1352874321877000)
> A cql collection 'column' doesn't own it's ttl
> --
>
> Key: CASSANDRA-4963
> URL: https://issues.apache.org/jira/browse/CASSANDRA-4963
> Project: Cassandra
> Issue Type: Bug
> Components: Core
>Affects Versions: 1.2.0 beta 2
>Reporter: Dave Brosius
>Priority: Minor
>
> if you add a collection column with a ttl, then later update the collection
> by adding a new element, the 'under the covers' column representing the added
> value has no ttl. It seems like ttl tombstoning should only be allowed to
> remove the collection in entirety, or not touch it, but not be allowed to
> modify it by removing parts.
> example
> cqlsh> create keyspace collections with replication =
> {'class':'SimpleStrategy', 'replication_factor':1};
> cqlsh> use collections;
> cqlsh:collections> create table collections (key int primary key, aset
> set);
> cqlsh:collections> insert into collections (key, aset) values (1, {'fee',
> 'fi'}) using ttl 1;
> cqlsh:collections> update collections set aset = aset + {'fo', 'fum'} where
> key = 1;
> cqlsh:collections> exit
> cassandra-cli
> [default@unknown] use collections
> [default@collections] get collections[1];
> => (column=, value=, timestamp=1352874321877000)
> => (column=aset:666565, value=, timestamp=1352874314717000, ttl=1)
> => (column=aset:6669, value=, timestamp=1352874314717000, ttl=1)
> => (column=aset:666f, value=, timestamp=1352874321877000)
> => (column=aset:66756d, value=, timestamp=1352874321877000)
--
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-4963) A cql collection 'column' doesn't own it's ttl
[
https://issues.apache.org/jira/browse/CASSANDRA-4963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dave Brosius updated CASSANDRA-4963:
Description:
if you add a collection column with a ttl, then later update the collection by
adding a new element, the 'under the covers' column representing the added
value has no ttl. It seems like ttl tombstoning should only be allowed to
remove the collection in entirety, or not touch it, but not be allowed to
modify it by removing parts.
example
cqlsh> create keyspace collections with replication =
{'class':'SimpleStrategy', 'replication_factor':1};
cqlsh> use collections;
cqlsh:collections> insert into collections (key, aset) values (1, {'fee',
'fi'}) using ttl 1;
cqlsh:collections> update collections set aset = aset + {'fo', 'fum'} where key
= 1;
cqlsh:collections> exit
cassandra-cli
[default@unknown] use collections
[default@collections] get collections[1];
=> (column=, value=, timestamp=1352874321877000)
=> (column=aset:666565, value=, timestamp=1352874314717000, ttl=1)
=> (column=aset:6669, value=, timestamp=1352874314717000, ttl=1)
=> (column=aset:666f, value=, timestamp=1352874321877000)
=> (column=aset:66756d, value=, timestamp=1352874321877000)
was:
if you add a collection column with a ttl, then later update the collection by
adding a new element, the 'under the covers' column representing the added
value has no ttl. It seems like ttl tombstoning should only be allowed to
remove the collection in entirety, or not touch it, but not be allowed to
modify it by removing parts.
example
cqlsh> create keyspace collections with replication =
{'class':'SimpleStrategy', 'replication_factor':1};
cqlsh> use collections;
cqlsh:collections> insert into collections (key, aset) values (1, {'fee',
'fi'}) using ttl 1;
cqlsh:collections> update collections set aset = aset + {'fo', 'fum'} where key
= 1;
cqlsh:collections> exit
nodetool flush
cassandra-cli
[default@unknown] use collections
[default@collections] get collections[1];
=> (column=, value=, timestamp=1352874321877000)
=> (column=aset:666565, value=, timestamp=1352874314717000, ttl=1)
=> (column=aset:6669, value=, timestamp=1352874314717000, ttl=1)
=> (column=aset:666f, value=, timestamp=1352874321877000)
=> (column=aset:66756d, value=, timestamp=1352874321877000)
> A cql collection 'column' doesn't own it's ttl
> --
>
> Key: CASSANDRA-4963
> URL: https://issues.apache.org/jira/browse/CASSANDRA-4963
> Project: Cassandra
> Issue Type: Bug
> Components: Core
>Affects Versions: 1.2.0 beta 2
>Reporter: Dave Brosius
>Priority: Minor
>
> if you add a collection column with a ttl, then later update the collection
> by adding a new element, the 'under the covers' column representing the added
> value has no ttl. It seems like ttl tombstoning should only be allowed to
> remove the collection in entirety, or not touch it, but not be allowed to
> modify it by removing parts.
> example
> cqlsh> create keyspace collections with replication =
> {'class':'SimpleStrategy', 'replication_factor':1};
> cqlsh> use collections;
> cqlsh:collections> insert into collections (key, aset) values (1, {'fee',
> 'fi'}) using ttl 1;
> cqlsh:collections> update collections set aset = aset + {'fo', 'fum'} where
> key = 1;
> cqlsh:collections> exit
> cassandra-cli
> [default@unknown] use collections
> [default@collections] get collections[1];
> => (column=, value=, timestamp=1352874321877000)
> => (column=aset:666565, value=, timestamp=1352874314717000, ttl=1)
> => (column=aset:6669, value=, timestamp=1352874314717000, ttl=1)
> => (column=aset:666f, value=, timestamp=1352874321877000)
> => (column=aset:66756d, value=, timestamp=1352874321877000)
--
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-4963) A cql collection 'column' doesn't own it's ttl
Dave Brosius created CASSANDRA-4963:
---
Summary: A cql collection 'column' doesn't own it's ttl
Key: CASSANDRA-4963
URL: https://issues.apache.org/jira/browse/CASSANDRA-4963
Project: Cassandra
Issue Type: Bug
Components: Core
Affects Versions: 1.2.0 beta 2
Reporter: Dave Brosius
Priority: Minor
if you add a collection column with a ttl, then later update the collection by
adding a new element, the 'under the covers' column representing the added
value has no ttl. It seems like ttl tombstoning should only be allowed to
remove the collection in entirety, or not touch it, but not be allowed to
modify it by removing parts.
example
cqlsh> create keyspace collections with replication =
{'class':'SimpleStrategy', 'replication_factor':1};
cqlsh> use collections;
cqlsh:collections> insert into collections (key, aset) values (1, {'fee',
'fi'}) using ttl 1;
cqlsh:collections> update collections set aset = aset + {'fo', 'fum'} where key
= 1;
cqlsh:collections> exit
nodetool flush
cassandra-cli
[default@unknown] use collections
[default@collections] get collections[1];
=> (column=, value=, timestamp=1352874321877000)
=> (column=aset:666565, value=, timestamp=1352874314717000, ttl=1)
=> (column=aset:6669, value=, timestamp=1352874314717000, ttl=1)
=> (column=aset:666f, value=, timestamp=1352874321877000)
=> (column=aset:66756d, value=, timestamp=1352874321877000)
--
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-4962) JMX bean of StorageProxy is sometimes invisible
Shotaro Kamio created CASSANDRA-4962: Summary: JMX bean of StorageProxy is sometimes invisible Key: CASSANDRA-4962 URL: https://issues.apache.org/jira/browse/CASSANDRA-4962 Project: Cassandra Issue Type: Bug Components: Core Affects Versions: 1.0.12, 1.0.7 Reporter: Shotaro Kamio StorageProxy exposes info via JMX bean "org.apache.cassandra.db:type=StorageProxy". But that bean is sometimes invisible via jmxterm nor jconsole. Seems like it becomes visible after data comes in. -- 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
[1/2] git commit: Merge branch 'cassandra-1.2' into trunk
Updated Branches: refs/heads/trunk cee521477 -> 40599fe4d 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/40599fe4 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/40599fe4 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/40599fe4 Branch: refs/heads/trunk Commit: 40599fe4d429b5664b51dad388406b2339c247cd Parents: cee5214 5dc145f Author: Dave Brosius Authored: Wed Nov 14 00:51:04 2012 -0500 Committer: Dave Brosius Committed: Wed Nov 14 00:51:04 2012 -0500 -- .../cassandra/db/BlacklistedDirectories.java |2 +- 1 files changed, 1 insertions(+), 1 deletions(-) --
[2/2] git commit: make sure logger is initialized before ctor is called that uses it
make sure logger is initialized before ctor is called that uses it
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/5dc145f4
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/5dc145f4
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/5dc145f4
Branch: refs/heads/trunk
Commit: 5dc145f4440bc418cd289b5a8a1d46b493a5938e
Parents: 6f148e6
Author: Dave Brosius
Authored: Wed Nov 14 00:49:53 2012 -0500
Committer: Dave Brosius
Committed: Wed Nov 14 00:49:53 2012 -0500
--
.../cassandra/db/BlacklistedDirectories.java |2 +-
1 files changed, 1 insertions(+), 1 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/cassandra/blob/5dc145f4/src/java/org/apache/cassandra/db/BlacklistedDirectories.java
--
diff --git a/src/java/org/apache/cassandra/db/BlacklistedDirectories.java
b/src/java/org/apache/cassandra/db/BlacklistedDirectories.java
index 5e873c7..78f1f0c 100644
--- a/src/java/org/apache/cassandra/db/BlacklistedDirectories.java
+++ b/src/java/org/apache/cassandra/db/BlacklistedDirectories.java
@@ -32,8 +32,8 @@ import javax.management.ObjectName;
public class BlacklistedDirectories implements BlacklistedDirectoriesMBean
{
public static final String MBEAN_NAME =
"org.apache.cassandra.db:type=BlacklistedDirectories";
-private static final BlacklistedDirectories instance = new
BlacklistedDirectories();
private static final Logger logger =
LoggerFactory.getLogger(BlacklistedDirectories.class);
+private static final BlacklistedDirectories instance = new
BlacklistedDirectories();
private final Set unreadableDirectories = new
CopyOnWriteArraySet();
private final Set unwritableDirectories = new
CopyOnWriteArraySet();
git commit: make sure logger is initialized before ctor is called that uses it
Updated Branches:
refs/heads/cassandra-1.2 6f148e64c -> 5dc145f44
make sure logger is initialized before ctor is called that uses it
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/5dc145f4
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/5dc145f4
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/5dc145f4
Branch: refs/heads/cassandra-1.2
Commit: 5dc145f4440bc418cd289b5a8a1d46b493a5938e
Parents: 6f148e6
Author: Dave Brosius
Authored: Wed Nov 14 00:49:53 2012 -0500
Committer: Dave Brosius
Committed: Wed Nov 14 00:49:53 2012 -0500
--
.../cassandra/db/BlacklistedDirectories.java |2 +-
1 files changed, 1 insertions(+), 1 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/cassandra/blob/5dc145f4/src/java/org/apache/cassandra/db/BlacklistedDirectories.java
--
diff --git a/src/java/org/apache/cassandra/db/BlacklistedDirectories.java
b/src/java/org/apache/cassandra/db/BlacklistedDirectories.java
index 5e873c7..78f1f0c 100644
--- a/src/java/org/apache/cassandra/db/BlacklistedDirectories.java
+++ b/src/java/org/apache/cassandra/db/BlacklistedDirectories.java
@@ -32,8 +32,8 @@ import javax.management.ObjectName;
public class BlacklistedDirectories implements BlacklistedDirectoriesMBean
{
public static final String MBEAN_NAME =
"org.apache.cassandra.db:type=BlacklistedDirectories";
-private static final BlacklistedDirectories instance = new
BlacklistedDirectories();
private static final Logger logger =
LoggerFactory.getLogger(BlacklistedDirectories.class);
+private static final BlacklistedDirectories instance = new
BlacklistedDirectories();
private final Set unreadableDirectories = new
CopyOnWriteArraySet();
private final Set unwritableDirectories = new
CopyOnWriteArraySet();
[jira] [Commented] (CASSANDRA-4959) CQLSH insert help has typo
[
https://issues.apache.org/jira/browse/CASSANDRA-4959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13496879#comment-13496879
]
Brandon Williams commented on CASSANDRA-4959:
-
The problem is both timestamp and ttl are optional, so if you remove ttl then
timestamp is correct with 'using' but if you remove timestamp then ttl needs
'using'. That said, in light of discouraging client-supplied timestamps maybe
we should just remove the timestamp portion of the help.
> CQLSH insert help has typo
> --
>
> Key: CASSANDRA-4959
> URL: https://issues.apache.org/jira/browse/CASSANDRA-4959
> Project: Cassandra
> Issue Type: Improvement
> Components: Documentation & website
>Affects Versions: 1.2.0 beta 2
>Reporter: Edward Capriolo
>
> [cqlsh 2.3.0 | Cassandra 1.2.0-beta2-SNAPSHOT | CQL spec 3.0.0 | Thrift
> protocol 19.35.0]
> Use HELP for help.
> cqlsh> help INSERT
> INSERT INTO [.]
> ( , [, [, ...]] )
>VALUES ( , [, [, ...]] )
>[USING TIMESTAMP ]
> [AND TTL Should be.
> {quote}
> [AND TTL ]];
> {quote}
> Also it was not clear to me initially that you could just do:
> {quote}
> USING TTL
> {quote}
> But maybe that is just me.
--
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
[1/3] git commit: Merge branch 'cassandra-1.2' into trunk
Updated Branches: refs/heads/trunk e7e3d3e60 -> cee521477 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/cee52147 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/cee52147 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/cee52147 Branch: refs/heads/trunk Commit: cee5214777d8cffc7645fe67b2a46363ba83ce3e Parents: e7e3d3e 6f148e6 Author: Dave Brosius Authored: Wed Nov 14 00:33:43 2012 -0500 Committer: Dave Brosius Committed: Wed Nov 14 00:33:43 2012 -0500 -- .../cassandra/streaming/StreamInSession.java |2 +- 1 files changed, 1 insertions(+), 1 deletions(-) --
[3/3] git commit: fix String.format specifier for getSessionID (long->UUID) for logger
fix String.format specifier for getSessionID (long->UUID) for logger
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/f1ea0ab8
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/f1ea0ab8
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/f1ea0ab8
Branch: refs/heads/trunk
Commit: f1ea0ab8db5d4e1e70f4737b4be4417c19010c08
Parents: be559a3
Author: Dave Brosius
Authored: Wed Nov 14 00:30:22 2012 -0500
Committer: Dave Brosius
Committed: Wed Nov 14 00:30:22 2012 -0500
--
.../cassandra/streaming/StreamInSession.java |2 +-
1 files changed, 1 insertions(+), 1 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/cassandra/blob/f1ea0ab8/src/java/org/apache/cassandra/streaming/StreamInSession.java
--
diff --git a/src/java/org/apache/cassandra/streaming/StreamInSession.java
b/src/java/org/apache/cassandra/streaming/StreamInSession.java
index a61ceb7..a29acc7 100644
--- a/src/java/org/apache/cassandra/streaming/StreamInSession.java
+++ b/src/java/org/apache/cassandra/streaming/StreamInSession.java
@@ -127,7 +127,7 @@ public class StreamInSession extends AbstractStreamSession
retries++;
if (retries > DatabaseDescriptor.getMaxStreamingRetries())
{
-logger.error(String.format("Failed streaming session %d from %s
while receiving %s", getSessionId(), getHost().toString(), current),
+logger.error(String.format("Failed streaming session %s from %s
while receiving %s", getSessionId(), getHost().toString(), current),
new IllegalStateException("Too many retries for " +
remoteFile));
close(false);
return;
[jira] [Updated] (CASSANDRA-4959) CQLSH insert help has typo
[
https://issues.apache.org/jira/browse/CASSANDRA-4959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Edward Capriolo updated CASSANDRA-4959:
---
Description:
[cqlsh 2.3.0 | Cassandra 1.2.0-beta2-SNAPSHOT | CQL spec 3.0.0 | Thrift
protocol 19.35.0]
Use HELP for help.
cqlsh> help INSERT
INSERT INTO [.]
( , [, [, ...]] )
VALUES ( , [, [, ...]] )
[USING TIMESTAMP ]
[AND TTL ]];
{quote}
Also it was not clear to me initially that you could just do:
{quote}
USING TTL
{quote}
But maybe that is just me.
was:
[cqlsh 2.3.0 | Cassandra 1.2.0-beta2-SNAPSHOT | CQL spec 3.0.0 | Thrift
protocol 19.35.0]
Use HELP for help.
cqlsh> help INSERT
INSERT INTO [.]
( , [, [, ...]] )
VALUES ( , [, [, ...]] )
[USING TIMESTAMP ]
[AND TTL ]];
{quote}
And I thing should probably be
{quote}
[USING TIMESTAMP [AND TTL = ]];
{quote}
You should be able to set a TTL without a timestamp because c* magically does
that for regular columns, but since you cant the help should reflect the syntax
> CQLSH insert help has typo
> --
>
> Key: CASSANDRA-4959
> URL: https://issues.apache.org/jira/browse/CASSANDRA-4959
> Project: Cassandra
> Issue Type: Improvement
> Components: Documentation & website
>Affects Versions: 1.2.0 beta 2
>Reporter: Edward Capriolo
>
> [cqlsh 2.3.0 | Cassandra 1.2.0-beta2-SNAPSHOT | CQL spec 3.0.0 | Thrift
> protocol 19.35.0]
> Use HELP for help.
> cqlsh> help INSERT
> INSERT INTO [.]
> ( , [, [, ...]] )
>VALUES ( , [, [, ...]] )
>[USING TIMESTAMP ]
> [AND TTL Should be.
> {quote}
> [AND TTL ]];
> {quote}
> Also it was not clear to me initially that you could just do:
> {quote}
> USING TTL
> {quote}
> But maybe that is just me.
--
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-4960) CQL syntax should allow setting a TTL without setting timestamp
[
https://issues.apache.org/jira/browse/CASSANDRA-4960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Edward Capriolo resolved CASSANDRA-4960.
Resolution: Invalid
It does do this my mistake.
> CQL syntax should allow setting a TTL without setting timestamp
> ---
>
> Key: CASSANDRA-4960
> URL: https://issues.apache.org/jira/browse/CASSANDRA-4960
> Project: Cassandra
> Issue Type: Improvement
>Reporter: Edward Capriolo
>Priority: Minor
>
> You can not set a TTL without a timestamp
> {quote}
> INSERT INTO [.]
> ( , [, [, ...]] )
>VALUES ( , [, [, ...]] )
>[USING TIMESTAMP ]
> [AND TTL {quote}
> CQL will create timestamps for you on standard columns, it seems like you
> should not be forced to supply one with a TTL.
--
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
[2/2] git commit: fix String.format specifier for getSessionID (long->UUID) for logger
fix String.format specifier for getSessionID (long->UUID) for logger
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/f1ea0ab8
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/f1ea0ab8
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/f1ea0ab8
Branch: refs/heads/cassandra-1.2
Commit: f1ea0ab8db5d4e1e70f4737b4be4417c19010c08
Parents: be559a3
Author: Dave Brosius
Authored: Wed Nov 14 00:30:22 2012 -0500
Committer: Dave Brosius
Committed: Wed Nov 14 00:30:22 2012 -0500
--
.../cassandra/streaming/StreamInSession.java |2 +-
1 files changed, 1 insertions(+), 1 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/cassandra/blob/f1ea0ab8/src/java/org/apache/cassandra/streaming/StreamInSession.java
--
diff --git a/src/java/org/apache/cassandra/streaming/StreamInSession.java
b/src/java/org/apache/cassandra/streaming/StreamInSession.java
index a61ceb7..a29acc7 100644
--- a/src/java/org/apache/cassandra/streaming/StreamInSession.java
+++ b/src/java/org/apache/cassandra/streaming/StreamInSession.java
@@ -127,7 +127,7 @@ public class StreamInSession extends AbstractStreamSession
retries++;
if (retries > DatabaseDescriptor.getMaxStreamingRetries())
{
-logger.error(String.format("Failed streaming session %d from %s
while receiving %s", getSessionId(), getHost().toString(), current),
+logger.error(String.format("Failed streaming session %s from %s
while receiving %s", getSessionId(), getHost().toString(), current),
new IllegalStateException("Too many retries for " +
remoteFile));
close(false);
return;
git commit: fix String.format specifier for getSessionID (long->UUID) for logger
Updated Branches:
refs/heads/cassandra-1.2.0 be559a38b -> f1ea0ab8d
fix String.format specifier for getSessionID (long->UUID) for logger
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/f1ea0ab8
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/f1ea0ab8
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/f1ea0ab8
Branch: refs/heads/cassandra-1.2.0
Commit: f1ea0ab8db5d4e1e70f4737b4be4417c19010c08
Parents: be559a3
Author: Dave Brosius
Authored: Wed Nov 14 00:30:22 2012 -0500
Committer: Dave Brosius
Committed: Wed Nov 14 00:30:22 2012 -0500
--
.../cassandra/streaming/StreamInSession.java |2 +-
1 files changed, 1 insertions(+), 1 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/cassandra/blob/f1ea0ab8/src/java/org/apache/cassandra/streaming/StreamInSession.java
--
diff --git a/src/java/org/apache/cassandra/streaming/StreamInSession.java
b/src/java/org/apache/cassandra/streaming/StreamInSession.java
index a61ceb7..a29acc7 100644
--- a/src/java/org/apache/cassandra/streaming/StreamInSession.java
+++ b/src/java/org/apache/cassandra/streaming/StreamInSession.java
@@ -127,7 +127,7 @@ public class StreamInSession extends AbstractStreamSession
retries++;
if (retries > DatabaseDescriptor.getMaxStreamingRetries())
{
-logger.error(String.format("Failed streaming session %d from %s
while receiving %s", getSessionId(), getHost().toString(), current),
+logger.error(String.format("Failed streaming session %s from %s
while receiving %s", getSessionId(), getHost().toString(), current),
new IllegalStateException("Too many retries for " +
remoteFile));
close(false);
return;
[jira] [Commented] (CASSANDRA-4947) Disallow client-provided timestamps in cql3
[
https://issues.apache.org/jira/browse/CASSANDRA-4947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13496866#comment-13496866
]
Edward Capriolo commented on CASSANDRA-4947:
-1 there are people out there using different conventions.
http://wiki.apache.org/cassandra/DataModel
Timestamps can be anything you like, but microseconds since 1970 is a
convention. Whatever you use, it must be consistent across the application,
otherwise earlier changes may overwrite newer ones.
You can't unring a bell.
> Disallow client-provided timestamps in cql3
> ---
>
> Key: CASSANDRA-4947
> URL: https://issues.apache.org/jira/browse/CASSANDRA-4947
> Project: Cassandra
> Issue Type: New Feature
> Components: API
>Reporter: Jonathan Ellis
>Priority: Blocker
> Fix For: 1.2.0
>
>
> Client-provided timestamps cause a lot of pain since we can't make any
> assumptions as to client:server clock agreement. Is this worth the pain? If
> not we should rip out {{WITH TIMESTAMP}} before 1.2.0.
--
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-4961) CQL3 accepts TTL on collection types but does nothing
[
https://issues.apache.org/jira/browse/CASSANDRA-4961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Brandon Williams reassigned CASSANDRA-4961:
---
Assignee: (was: Sylvain Lebresne)
> CQL3 accepts TTL on collection types but does nothing
> -
>
> Key: CASSANDRA-4961
> URL: https://issues.apache.org/jira/browse/CASSANDRA-4961
> Project: Cassandra
> Issue Type: Bug
>Affects Versions: 1.2.0 beta 2
>Reporter: Edward Capriolo
>
> It seems like CQL will accept a TTL on a collection column but do nothing
> with it. Am I using the syntax wrong?
> {quote}
> cqlsh:movies> INSERT INTO VIDEOS (videoid, videoname, tagasset) values
> ('99051fe9-6a9c-46c2-b949-38ef78858dd0','My funny cat',{'piano'}) USING
> TIMESTAMP 11 AND TTL 1;
> cqlsh:movies> select * from videos;
> videoid | videoname| description
>| tagasset | tags | upload_date |
> username
> --+--+---+--++--+--
> 99051fe9-6a9c-46c2-b949-38ef78858dd0 | My funny cat | My cat likes to play
> the piano! So funny. | {piano} | cats,piano,lol | 2012-06-01 08:00:00+ |
>ctodd
> cqlsh:movies> select * from videos;
> videoid | videoname| description
>| tagasset | tags | upload_date |
> username
> --+--+---+--++--+--
> 99051fe9-6a9c-46c2-b949-38ef78858dd0 | My funny cat | My cat likes to play
> the piano! So funny. | {piano} | cats,piano,lol | 2012-06-01 08:00:00+ |
>ctodd
> {quote}
--
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-4961) CQL3 accepts TTL on collection types but does nothing
[
https://issues.apache.org/jira/browse/CASSANDRA-4961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Brandon Williams reassigned CASSANDRA-4961:
---
Assignee: Sylvain Lebresne
> CQL3 accepts TTL on collection types but does nothing
> -
>
> Key: CASSANDRA-4961
> URL: https://issues.apache.org/jira/browse/CASSANDRA-4961
> Project: Cassandra
> Issue Type: Bug
>Affects Versions: 1.2.0 beta 2
>Reporter: Edward Capriolo
>Assignee: Sylvain Lebresne
>
> It seems like CQL will accept a TTL on a collection column but do nothing
> with it. Am I using the syntax wrong?
> {quote}
> cqlsh:movies> INSERT INTO VIDEOS (videoid, videoname, tagasset) values
> ('99051fe9-6a9c-46c2-b949-38ef78858dd0','My funny cat',{'piano'}) USING
> TIMESTAMP 11 AND TTL 1;
> cqlsh:movies> select * from videos;
> videoid | videoname| description
>| tagasset | tags | upload_date |
> username
> --+--+---+--++--+--
> 99051fe9-6a9c-46c2-b949-38ef78858dd0 | My funny cat | My cat likes to play
> the piano! So funny. | {piano} | cats,piano,lol | 2012-06-01 08:00:00+ |
>ctodd
> cqlsh:movies> select * from videos;
> videoid | videoname| description
>| tagasset | tags | upload_date |
> username
> --+--+---+--++--+--
> 99051fe9-6a9c-46c2-b949-38ef78858dd0 | My funny cat | My cat likes to play
> the piano! So funny. | {piano} | cats,piano,lol | 2012-06-01 08:00:00+ |
>ctodd
> {quote}
--
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-4961) CQL3 accepts TTL on collection types but does nothing
[
https://issues.apache.org/jira/browse/CASSANDRA-4961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Edward Capriolo resolved CASSANDRA-4961.
Resolution: Won't Fix
My mistake. It works fine.
> CQL3 accepts TTL on collection types but does nothing
> -
>
> Key: CASSANDRA-4961
> URL: https://issues.apache.org/jira/browse/CASSANDRA-4961
> Project: Cassandra
> Issue Type: Bug
>Affects Versions: 1.2.0 beta 2
>Reporter: Edward Capriolo
>
> It seems like CQL will accept a TTL on a collection column but do nothing
> with it. Am I using the syntax wrong?
> {quote}
> cqlsh:movies> INSERT INTO VIDEOS (videoid, videoname, tagasset) values
> ('99051fe9-6a9c-46c2-b949-38ef78858dd0','My funny cat',{'piano'}) USING
> TIMESTAMP 11 AND TTL 1;
> cqlsh:movies> select * from videos;
> videoid | videoname| description
>| tagasset | tags | upload_date |
> username
> --+--+---+--++--+--
> 99051fe9-6a9c-46c2-b949-38ef78858dd0 | My funny cat | My cat likes to play
> the piano! So funny. | {piano} | cats,piano,lol | 2012-06-01 08:00:00+ |
>ctodd
> cqlsh:movies> select * from videos;
> videoid | videoname| description
>| tagasset | tags | upload_date |
> username
> --+--+---+--++--+--
> 99051fe9-6a9c-46c2-b949-38ef78858dd0 | My funny cat | My cat likes to play
> the piano! So funny. | {piano} | cats,piano,lol | 2012-06-01 08:00:00+ |
>ctodd
> {quote}
--
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-4961) CQL3 accepts TTL on collection types but does nothing
[
https://issues.apache.org/jira/browse/CASSANDRA-4961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Edward Capriolo updated CASSANDRA-4961:
---
Affects Version/s: 1.2.0 beta 2
> CQL3 accepts TTL on collection types but does nothing
> -
>
> Key: CASSANDRA-4961
> URL: https://issues.apache.org/jira/browse/CASSANDRA-4961
> Project: Cassandra
> Issue Type: Bug
>Affects Versions: 1.2.0 beta 2
>Reporter: Edward Capriolo
>
> It seems like CQL will accept a TTL on a collection column but do nothing
> with it. Am I using the syntax wrong?
> {quote}
> cqlsh:movies> INSERT INTO VIDEOS (videoid, videoname, tagasset) values
> ('99051fe9-6a9c-46c2-b949-38ef78858dd0','My funny cat',{'piano'}) USING
> TIMESTAMP 11 AND TTL 1;
> cqlsh:movies> select * from videos;
> videoid | videoname| description
>| tagasset | tags | upload_date |
> username
> --+--+---+--++--+--
> 99051fe9-6a9c-46c2-b949-38ef78858dd0 | My funny cat | My cat likes to play
> the piano! So funny. | {piano} | cats,piano,lol | 2012-06-01 08:00:00+ |
>ctodd
> cqlsh:movies> select * from videos;
> videoid | videoname| description
>| tagasset | tags | upload_date |
> username
> --+--+---+--++--+--
> 99051fe9-6a9c-46c2-b949-38ef78858dd0 | My funny cat | My cat likes to play
> the piano! So funny. | {piano} | cats,piano,lol | 2012-06-01 08:00:00+ |
>ctodd
> {quote}
--
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-4961) CQL3 accepts TTL on collection types but does nothing
Edward Capriolo created CASSANDRA-4961:
--
Summary: CQL3 accepts TTL on collection types but does nothing
Key: CASSANDRA-4961
URL: https://issues.apache.org/jira/browse/CASSANDRA-4961
Project: Cassandra
Issue Type: Bug
Reporter: Edward Capriolo
It seems like CQL will accept a TTL on a collection column but do nothing with
it. Am I using the syntax wrong?
{quote}
cqlsh:movies> INSERT INTO VIDEOS (videoid, videoname, tagasset) values
('99051fe9-6a9c-46c2-b949-38ef78858dd0','My funny cat',{'piano'}) USING
TIMESTAMP 11 AND TTL 1;
cqlsh:movies> select * from videos;
videoid | videoname| description
| tagasset | tags | upload_date |
username
--+--+---+--++--+--
99051fe9-6a9c-46c2-b949-38ef78858dd0 | My funny cat | My cat likes to play the
piano! So funny. | {piano} | cats,piano,lol | 2012-06-01 08:00:00+ |
ctodd
cqlsh:movies> select * from videos;
videoid | videoname| description
| tagasset | tags | upload_date |
username
--+--+---+--++--+--
99051fe9-6a9c-46c2-b949-38ef78858dd0 | My funny cat | My cat likes to play the
piano! So funny. | {piano} | cats,piano,lol | 2012-06-01 08:00:00+ |
ctodd
{quote}
--
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-4960) CQL syntax should allow setting a TTL without setting timestamp
Edward Capriolo created CASSANDRA-4960:
--
Summary: CQL syntax should allow setting a TTL without setting
timestamp
Key: CASSANDRA-4960
URL: https://issues.apache.org/jira/browse/CASSANDRA-4960
Project: Cassandra
Issue Type: Improvement
Reporter: Edward Capriolo
Priority: Minor
You can not set a TTL without a timestamp
{quote}
INSERT INTO [.]
( , [, [, ...]] )
VALUES ( , [, [, ...]] )
[USING TIMESTAMP ]
[AND TTL http://www.atlassian.com/software/jira
[jira] [Created] (CASSANDRA-4959) CQLSH insert help has typo
Edward Capriolo created CASSANDRA-4959:
--
Summary: CQLSH insert help has typo
Key: CASSANDRA-4959
URL: https://issues.apache.org/jira/browse/CASSANDRA-4959
Project: Cassandra
Issue Type: Improvement
Components: Documentation & website
Affects Versions: 1.2.0 beta 2
Reporter: Edward Capriolo
[cqlsh 2.3.0 | Cassandra 1.2.0-beta2-SNAPSHOT | CQL spec 3.0.0 | Thrift
protocol 19.35.0]
Use HELP for help.
cqlsh> help INSERT
INSERT INTO [.]
( , [, [, ...]] )
VALUES ( , [, [, ...]] )
[USING TIMESTAMP ]
[AND TTL ]];
{quote}
And I thing should probably be
{quote}
[USING TIMESTAMP [AND TTL = ]];
{quote}
You should be able to set a TTL without a timestamp because c* magically does
that for regular columns, but since you cant the help should reflect the syntax
--
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
[1/3] git commit: Merge branch 'cassandra-1.2' into trunk
Updated Branches: refs/heads/trunk 47fb7d534 -> e7e3d3e60 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/e7e3d3e6 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/e7e3d3e6 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/e7e3d3e6 Branch: refs/heads/trunk Commit: e7e3d3e60664dfea42b8577d46d395f7a6ae7abc Parents: 47fb7d5 35cf439 Author: Dave Brosius Authored: Tue Nov 13 23:07:08 2012 -0500 Committer: Dave Brosius Committed: Tue Nov 13 23:07:08 2012 -0500 -- src/java/org/apache/cassandra/tools/NodeCmd.java |2 ++ 1 files changed, 2 insertions(+), 0 deletions(-) --
[3/3] git commit: promote HELP to be a real nodetool command to avoid error message patch by dbrosius reviewed by jbellis for CASSANDRA-4953
promote HELP to be a real nodetool command to avoid error message
patch by dbrosius reviewed by jbellis for CASSANDRA-4953
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/be559a38
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/be559a38
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/be559a38
Branch: refs/heads/trunk
Commit: be559a38b1887ca104baefdcdd98d5f19e886acc
Parents: 9dffa57
Author: Dave Brosius
Authored: Tue Nov 13 22:52:25 2012 -0500
Committer: Dave Brosius
Committed: Tue Nov 13 22:52:25 2012 -0500
--
src/java/org/apache/cassandra/tools/NodeCmd.java |2 ++
1 files changed, 2 insertions(+), 0 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/cassandra/blob/be559a38/src/java/org/apache/cassandra/tools/NodeCmd.java
--
diff --git a/src/java/org/apache/cassandra/tools/NodeCmd.java
b/src/java/org/apache/cassandra/tools/NodeCmd.java
index ceedfec..11a78e2 100644
--- a/src/java/org/apache/cassandra/tools/NodeCmd.java
+++ b/src/java/org/apache/cassandra/tools/NodeCmd.java
@@ -113,6 +113,7 @@ public class NodeCmd
GETENDPOINTS,
GETSSTABLES,
GOSSIPINFO,
+HELP,
INFO,
INVALIDATEKEYCACHE,
INVALIDATEROWCACHE,
@@ -994,6 +995,7 @@ public class NodeCmd
switch (command)
{
+case HELP : printUsage(); break;
case RING :
if (arguments.length > 0) { nodeCmd.printRing(System.out,
arguments[0]); }
else { nodeCmd.printRing(System.out,
null); };
[2/2] git commit: promote HELP to be a real nodetool command to avoid error message patch by dbrosius reviewed by jbellis for CASSANDRA-4953
promote HELP to be a real nodetool command to avoid error message
patch by dbrosius reviewed by jbellis for CASSANDRA-4953
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/be559a38
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/be559a38
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/be559a38
Branch: refs/heads/cassandra-1.2
Commit: be559a38b1887ca104baefdcdd98d5f19e886acc
Parents: 9dffa57
Author: Dave Brosius
Authored: Tue Nov 13 22:52:25 2012 -0500
Committer: Dave Brosius
Committed: Tue Nov 13 22:52:25 2012 -0500
--
src/java/org/apache/cassandra/tools/NodeCmd.java |2 ++
1 files changed, 2 insertions(+), 0 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/cassandra/blob/be559a38/src/java/org/apache/cassandra/tools/NodeCmd.java
--
diff --git a/src/java/org/apache/cassandra/tools/NodeCmd.java
b/src/java/org/apache/cassandra/tools/NodeCmd.java
index ceedfec..11a78e2 100644
--- a/src/java/org/apache/cassandra/tools/NodeCmd.java
+++ b/src/java/org/apache/cassandra/tools/NodeCmd.java
@@ -113,6 +113,7 @@ public class NodeCmd
GETENDPOINTS,
GETSSTABLES,
GOSSIPINFO,
+HELP,
INFO,
INVALIDATEKEYCACHE,
INVALIDATEROWCACHE,
@@ -994,6 +995,7 @@ public class NodeCmd
switch (command)
{
+case HELP : printUsage(); break;
case RING :
if (arguments.length > 0) { nodeCmd.printRing(System.out,
arguments[0]); }
else { nodeCmd.printRing(System.out,
null); };
git commit: promote HELP to be a real nodetool command to avoid error message patch by dbrosius reviewed by jbellis for CASSANDRA-4953
Updated Branches:
refs/heads/cassandra-1.2.0 9dffa5736 -> be559a38b
promote HELP to be a real nodetool command to avoid error message
patch by dbrosius reviewed by jbellis for CASSANDRA-4953
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/be559a38
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/be559a38
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/be559a38
Branch: refs/heads/cassandra-1.2.0
Commit: be559a38b1887ca104baefdcdd98d5f19e886acc
Parents: 9dffa57
Author: Dave Brosius
Authored: Tue Nov 13 22:52:25 2012 -0500
Committer: Dave Brosius
Committed: Tue Nov 13 22:52:25 2012 -0500
--
src/java/org/apache/cassandra/tools/NodeCmd.java |2 ++
1 files changed, 2 insertions(+), 0 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/cassandra/blob/be559a38/src/java/org/apache/cassandra/tools/NodeCmd.java
--
diff --git a/src/java/org/apache/cassandra/tools/NodeCmd.java
b/src/java/org/apache/cassandra/tools/NodeCmd.java
index ceedfec..11a78e2 100644
--- a/src/java/org/apache/cassandra/tools/NodeCmd.java
+++ b/src/java/org/apache/cassandra/tools/NodeCmd.java
@@ -113,6 +113,7 @@ public class NodeCmd
GETENDPOINTS,
GETSSTABLES,
GOSSIPINFO,
+HELP,
INFO,
INVALIDATEKEYCACHE,
INVALIDATEROWCACHE,
@@ -994,6 +995,7 @@ public class NodeCmd
switch (command)
{
+case HELP : printUsage(); break;
case RING :
if (arguments.length > 0) { nodeCmd.printRing(System.out,
arguments[0]); }
else { nodeCmd.printRing(System.out,
null); };
[jira] [Commented] (CASSANDRA-3719) Upgrade thrift to latest release version (0.9.x)
[ https://issues.apache.org/jira/browse/CASSANDRA-3719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13496809#comment-13496809 ] Dave Brosius commented on CASSANDRA-3719: - just a reminder that this jar version has the fix for https://issues.apache.org/jira/browse/THRIFT-1121 which might be a win. > Upgrade thrift to latest release version (0.9.x) > > > Key: CASSANDRA-3719 > URL: https://issues.apache.org/jira/browse/CASSANDRA-3719 > Project: Cassandra > Issue Type: Task >Reporter: Jake Farrell >Assignee: Jake Farrell >Priority: Minor > Fix For: 1.3 > > Attachments: Cassandra-3719-v1-001-updated-source.patch, > Cassandra-3719-v1-002-thrift-jar-and-license.patch > > > In Cassandra-3213 thrift was upgraded to thrift 0.7 and not the latest 0.8 > release. This is due to THRIFT-1167 where the TNonblockingTransport in > TNonblockingServer.FrameBuffer was moved into > AbstractNonblockingServer.FrameBuffer and was changed from public to private. > This causes the transport to not be available for > SocketSessionManagementService as noted above. There is no short term > workaround for this. > I have everything ready for patching but with the above mentioned issue it > will be impossible to use Thrift 0.8.0. The fix for this is committed > (THRIFT-1464) and will be available in the next Thrift release 0.9. Adding > this to keep track of and will update with patches for the current version of > Thrift when pushing out the next release -- 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-4958) Snappy 1.0.4 doesn't work on OSX/ Java 7
Colin Taylor created CASSANDRA-4958: --- Summary: Snappy 1.0.4 doesn't work on OSX/ Java 7 Key: CASSANDRA-4958 URL: https://issues.apache.org/jira/browse/CASSANDRA-4958 Project: Cassandra Issue Type: Bug Affects Versions: 1.2.0 beta 2 Reporter: Colin Taylor Priority: Minor https://github.com/xerial/snappy-java/issues/6 -- 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-4958) Snappy 1.0.4 doesn't work on OSX/ Java 7
[ https://issues.apache.org/jira/browse/CASSANDRA-4958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin Taylor updated CASSANDRA-4958: Description: Fixed in 1.0.5-M3 see : https://github.com/xerial/snappy-java/issues/6 was: https://github.com/xerial/snappy-java/issues/6 > Snappy 1.0.4 doesn't work on OSX/ Java 7 > > > Key: CASSANDRA-4958 > URL: https://issues.apache.org/jira/browse/CASSANDRA-4958 > Project: Cassandra > Issue Type: Bug >Affects Versions: 1.2.0 beta 2 >Reporter: Colin Taylor >Priority: Minor > > Fixed in 1.0.5-M3 see : > https://github.com/xerial/snappy-java/issues/6 -- 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-4958) Snappy 1.0.4 doesn't work on OSX / Java 7
[ https://issues.apache.org/jira/browse/CASSANDRA-4958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin Taylor updated CASSANDRA-4958: Summary: Snappy 1.0.4 doesn't work on OSX / Java 7 (was: Snappy 1.0.4 doesn't work on OSX/ Java 7) > Snappy 1.0.4 doesn't work on OSX / Java 7 > - > > Key: CASSANDRA-4958 > URL: https://issues.apache.org/jira/browse/CASSANDRA-4958 > Project: Cassandra > Issue Type: Bug >Affects Versions: 1.2.0 beta 2 >Reporter: Colin Taylor >Priority: Minor > > Fixed in 1.0.5-M3 see : > https://github.com/xerial/snappy-java/issues/6 -- 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-4951) Leveled compaction manifest sometimes references nonexistent sstables in a snapshot
[ https://issues.apache.org/jira/browse/CASSANDRA-4951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brandon Williams reassigned CASSANDRA-4951: --- Assignee: Yuki Morishita > Leveled compaction manifest sometimes references nonexistent sstables in a > snapshot > --- > > Key: CASSANDRA-4951 > URL: https://issues.apache.org/jira/browse/CASSANDRA-4951 > Project: Cassandra > Issue Type: Bug > Components: Core >Affects Versions: 1.1.4 >Reporter: Oleg Kibirev >Assignee: Yuki Morishita > > After nodetool snapshot on a node under load, we sometimes see sstables not > referenced in the leveled compaction json manifest, or sstables in the > manifest which are not found on disk. There are two concerns with this: > 1. What would happened to leveled compaction and to reads if the snapshot is > restored with missing or extra sstables? > 2. Is this a sign of a snapshot not having a complete copy of the data? > To support automated restore, manifest and/or a list of links should be made > correct at snapshot time. -- 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-4885) Remove or rework per-row bloom filters
[ https://issues.apache.org/jira/browse/CASSANDRA-4885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13496706#comment-13496706 ] Jonathan Ellis commented on CASSANDRA-4885: --- Maybe reopen it at the halfway point after writing a healthy one, and scribble over 10% of it with zeros? > Remove or rework per-row bloom filters > -- > > Key: CASSANDRA-4885 > URL: https://issues.apache.org/jira/browse/CASSANDRA-4885 > Project: Cassandra > Issue Type: Improvement > Components: Core >Reporter: Jonathan Ellis >Assignee: Jason Brown > Fix For: 1.3 > > Attachments: 0001-CASSANRDA-4885-Remove-per-row-bloom-filter.patch > > > Per-row bloom filters may be a misfeature. > On small rows we don't create them. > On large rows we essentially only do slice queries that can't take advantage > of it. > And on very large rows if we ever did deserialize it, the performance hit of > doing so would outweigh the benefit of skipping the actual read. -- 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
[4/6] git commit: Use Stats.db when bulk loading if present; patch by yukim reviewed by brandonwilliams for CASSANDRA-4957
Use Stats.db when bulk loading if present; patch by yukim reviewed by
brandonwilliams for CASSANDRA-4957
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/9dffa573
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/9dffa573
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/9dffa573
Branch: refs/heads/trunk
Commit: 9dffa57360d4fc08729bb68046d45dcd535bc342
Parents: acda527
Author: Yuki Morishita
Authored: Tue Nov 13 17:53:47 2012 -0600
Committer: Yuki Morishita
Committed: Tue Nov 13 17:53:47 2012 -0600
--
CHANGES.txt|1 +
.../apache/cassandra/io/sstable/SSTableLoader.java |2 ++
2 files changed, 3 insertions(+), 0 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/cassandra/blob/9dffa573/CHANGES.txt
--
diff --git a/CHANGES.txt b/CHANGES.txt
index 4f54598..fd6ab95 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -12,6 +12,7 @@
* Better printing of AbstractBounds for tracing (CASSANDRA-4931)
* Optimize mostRecentTomstone check in CC.collectAllData (CASSANDRA-4883)
* Change stream session ID to UUID to avoid collision from same node
(CASSANDRA-4813)
+ * Use Stats.db when bulk loading if present (CASSANDRA-4957)
Merged from 1.1:
* reset getRangeSlice filter after finishing a row for get_paged_slice
(CASSANDRA-4919)
http://git-wip-us.apache.org/repos/asf/cassandra/blob/9dffa573/src/java/org/apache/cassandra/io/sstable/SSTableLoader.java
--
diff --git a/src/java/org/apache/cassandra/io/sstable/SSTableLoader.java
b/src/java/org/apache/cassandra/io/sstable/SSTableLoader.java
index 13e2b99..32dbbc3 100644
--- a/src/java/org/apache/cassandra/io/sstable/SSTableLoader.java
+++ b/src/java/org/apache/cassandra/io/sstable/SSTableLoader.java
@@ -90,6 +90,8 @@ public class SSTableLoader
components.add(Component.PRIMARY_INDEX);
if (new
File(desc.filenameFor(Component.COMPRESSION_INFO)).exists())
components.add(Component.COMPRESSION_INFO);
+if (new File(desc.filenameFor(Component.STATS)).exists())
+components.add(Component.STATS);
try
{
[6/6] git commit: Use Stats.db when bulk loading if present; patch by yukim reviewed by brandonwilliams for CASSANDRA-4957
Use Stats.db when bulk loading if present; patch by yukim reviewed by
brandonwilliams for CASSANDRA-4957
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/9dffa573
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/9dffa573
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/9dffa573
Branch: refs/heads/cassandra-1.2
Commit: 9dffa57360d4fc08729bb68046d45dcd535bc342
Parents: acda527
Author: Yuki Morishita
Authored: Tue Nov 13 17:53:47 2012 -0600
Committer: Yuki Morishita
Committed: Tue Nov 13 17:53:47 2012 -0600
--
CHANGES.txt|1 +
.../apache/cassandra/io/sstable/SSTableLoader.java |2 ++
2 files changed, 3 insertions(+), 0 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/cassandra/blob/9dffa573/CHANGES.txt
--
diff --git a/CHANGES.txt b/CHANGES.txt
index 4f54598..fd6ab95 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -12,6 +12,7 @@
* Better printing of AbstractBounds for tracing (CASSANDRA-4931)
* Optimize mostRecentTomstone check in CC.collectAllData (CASSANDRA-4883)
* Change stream session ID to UUID to avoid collision from same node
(CASSANDRA-4813)
+ * Use Stats.db when bulk loading if present (CASSANDRA-4957)
Merged from 1.1:
* reset getRangeSlice filter after finishing a row for get_paged_slice
(CASSANDRA-4919)
http://git-wip-us.apache.org/repos/asf/cassandra/blob/9dffa573/src/java/org/apache/cassandra/io/sstable/SSTableLoader.java
--
diff --git a/src/java/org/apache/cassandra/io/sstable/SSTableLoader.java
b/src/java/org/apache/cassandra/io/sstable/SSTableLoader.java
index 13e2b99..32dbbc3 100644
--- a/src/java/org/apache/cassandra/io/sstable/SSTableLoader.java
+++ b/src/java/org/apache/cassandra/io/sstable/SSTableLoader.java
@@ -90,6 +90,8 @@ public class SSTableLoader
components.add(Component.PRIMARY_INDEX);
if (new
File(desc.filenameFor(Component.COMPRESSION_INFO)).exists())
components.add(Component.COMPRESSION_INFO);
+if (new File(desc.filenameFor(Component.STATS)).exists())
+components.add(Component.STATS);
try
{
[1/6] git commit: Merge branch 'cassandra-1.2' into trunk
Updated Branches: refs/heads/cassandra-1.2 4576ccba6 -> 4208a3f56 refs/heads/cassandra-1.2.0 acda52799 -> 9dffa5736 refs/heads/trunk ac16a54a1 -> 47fb7d534 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/47fb7d53 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/47fb7d53 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/47fb7d53 Branch: refs/heads/trunk Commit: 47fb7d5349eadd2f5cb4dba6a9dc657a5ef6bdf2 Parents: ac16a54 4208a3f Author: Yuki Morishita Authored: Tue Nov 13 17:54:17 2012 -0600 Committer: Yuki Morishita Committed: Tue Nov 13 17:54:17 2012 -0600 -- CHANGES.txt|1 + .../apache/cassandra/io/sstable/SSTableLoader.java |2 ++ 2 files changed, 3 insertions(+), 0 deletions(-) --
[3/6] git commit: Merge branch 'cassandra-1.2.0' into cassandra-1.2
Merge branch 'cassandra-1.2.0' into cassandra-1.2 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/4208a3f5 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/4208a3f5 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/4208a3f5 Branch: refs/heads/trunk Commit: 4208a3f56c34723f83aa63dd5fd0f8f6a082b132 Parents: 4576ccb 9dffa57 Author: Yuki Morishita Authored: Tue Nov 13 17:54:04 2012 -0600 Committer: Yuki Morishita Committed: Tue Nov 13 17:54:04 2012 -0600 -- CHANGES.txt|1 + .../apache/cassandra/io/sstable/SSTableLoader.java |2 ++ 2 files changed, 3 insertions(+), 0 deletions(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/4208a3f5/CHANGES.txt --
[2/6] git commit: Merge branch 'cassandra-1.2.0' into cassandra-1.2
Merge branch 'cassandra-1.2.0' into cassandra-1.2 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/4208a3f5 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/4208a3f5 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/4208a3f5 Branch: refs/heads/cassandra-1.2 Commit: 4208a3f56c34723f83aa63dd5fd0f8f6a082b132 Parents: 4576ccb 9dffa57 Author: Yuki Morishita Authored: Tue Nov 13 17:54:04 2012 -0600 Committer: Yuki Morishita Committed: Tue Nov 13 17:54:04 2012 -0600 -- CHANGES.txt|1 + .../apache/cassandra/io/sstable/SSTableLoader.java |2 ++ 2 files changed, 3 insertions(+), 0 deletions(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/4208a3f5/CHANGES.txt --
[5/6] git commit: Use Stats.db when bulk loading if present; patch by yukim reviewed by brandonwilliams for CASSANDRA-4957
Use Stats.db when bulk loading if present; patch by yukim reviewed by
brandonwilliams for CASSANDRA-4957
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/9dffa573
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/9dffa573
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/9dffa573
Branch: refs/heads/cassandra-1.2.0
Commit: 9dffa57360d4fc08729bb68046d45dcd535bc342
Parents: acda527
Author: Yuki Morishita
Authored: Tue Nov 13 17:53:47 2012 -0600
Committer: Yuki Morishita
Committed: Tue Nov 13 17:53:47 2012 -0600
--
CHANGES.txt|1 +
.../apache/cassandra/io/sstable/SSTableLoader.java |2 ++
2 files changed, 3 insertions(+), 0 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/cassandra/blob/9dffa573/CHANGES.txt
--
diff --git a/CHANGES.txt b/CHANGES.txt
index 4f54598..fd6ab95 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -12,6 +12,7 @@
* Better printing of AbstractBounds for tracing (CASSANDRA-4931)
* Optimize mostRecentTomstone check in CC.collectAllData (CASSANDRA-4883)
* Change stream session ID to UUID to avoid collision from same node
(CASSANDRA-4813)
+ * Use Stats.db when bulk loading if present (CASSANDRA-4957)
Merged from 1.1:
* reset getRangeSlice filter after finishing a row for get_paged_slice
(CASSANDRA-4919)
http://git-wip-us.apache.org/repos/asf/cassandra/blob/9dffa573/src/java/org/apache/cassandra/io/sstable/SSTableLoader.java
--
diff --git a/src/java/org/apache/cassandra/io/sstable/SSTableLoader.java
b/src/java/org/apache/cassandra/io/sstable/SSTableLoader.java
index 13e2b99..32dbbc3 100644
--- a/src/java/org/apache/cassandra/io/sstable/SSTableLoader.java
+++ b/src/java/org/apache/cassandra/io/sstable/SSTableLoader.java
@@ -90,6 +90,8 @@ public class SSTableLoader
components.add(Component.PRIMARY_INDEX);
if (new
File(desc.filenameFor(Component.COMPRESSION_INFO)).exists())
components.add(Component.COMPRESSION_INFO);
+if (new File(desc.filenameFor(Component.STATS)).exists())
+components.add(Component.STATS);
try
{
[jira] [Commented] (CASSANDRA-4957) When bulk loading, validate SSTable's partitioner as much as possible
[ https://issues.apache.org/jira/browse/CASSANDRA-4957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13496671#comment-13496671 ] Brandon Williams commented on CASSANDRA-4957: - +1 > When bulk loading, validate SSTable's partitioner as much as possible > - > > Key: CASSANDRA-4957 > URL: https://issues.apache.org/jira/browse/CASSANDRA-4957 > Project: Cassandra > Issue Type: Improvement >Affects Versions: 1.1.0 >Reporter: Yuki Morishita >Assignee: Yuki Morishita >Priority: Minor > Fix For: 1.2.0 rc1 > > Attachments: 4957.txt > > > When using BulkLoader/BulkOutputFormat, sstable's partitioner is not checked > even if you have Stats.db on same directory. BulkLoader tries to stream wrong > partitioned SSTables, and produces IO error. (I found this when I used > Murmur3partitioner for BOF while cluster was setup for RandomPartitioner. see > CASSANDRA-4813.) > It will be nice to validate partitioner when Stats.db is present to avoid > causing streaming error. -- 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-4957) When bulk loading, validate SSTable's partitioner as much as possible
[ https://issues.apache.org/jira/browse/CASSANDRA-4957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuki Morishita reassigned CASSANDRA-4957: - Assignee: Yuki Morishita > When bulk loading, validate SSTable's partitioner as much as possible > - > > Key: CASSANDRA-4957 > URL: https://issues.apache.org/jira/browse/CASSANDRA-4957 > Project: Cassandra > Issue Type: Improvement >Affects Versions: 1.1.0 >Reporter: Yuki Morishita >Assignee: Yuki Morishita >Priority: Minor > Attachments: 4957.txt > > > When using BulkLoader/BulkOutputFormat, sstable's partitioner is not checked > even if you have Stats.db on same directory. BulkLoader tries to stream wrong > partitioned SSTables, and produces IO error. (I found this when I used > Murmur3partitioner for BOF while cluster was setup for RandomPartitioner. see > CASSANDRA-4813.) > It will be nice to validate partitioner when Stats.db is present to avoid > causing streaming error. -- 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-4957) When bulk loading, validate SSTable's partitioner as much as possible
[ https://issues.apache.org/jira/browse/CASSANDRA-4957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuki Morishita updated CASSANDRA-4957: -- Attachment: 4957.txt Trivial patch to add Stats.db (if available) when opening SSTable to verify partitioner. > When bulk loading, validate SSTable's partitioner as much as possible > - > > Key: CASSANDRA-4957 > URL: https://issues.apache.org/jira/browse/CASSANDRA-4957 > Project: Cassandra > Issue Type: Improvement >Affects Versions: 1.1.0 >Reporter: Yuki Morishita >Assignee: Yuki Morishita >Priority: Minor > Attachments: 4957.txt > > > When using BulkLoader/BulkOutputFormat, sstable's partitioner is not checked > even if you have Stats.db on same directory. BulkLoader tries to stream wrong > partitioned SSTables, and produces IO error. (I found this when I used > Murmur3partitioner for BOF while cluster was setup for RandomPartitioner. see > CASSANDRA-4813.) > It will be nice to validate partitioner when Stats.db is present to avoid > causing streaming error. -- 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
[2/6] git commit: Merge branch 'cassandra-1.2.0' into cassandra-1.2
Merge branch 'cassandra-1.2.0' into cassandra-1.2 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/4576ccba Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/4576ccba Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/4576ccba Branch: refs/heads/cassandra-1.2 Commit: 4576ccba6e83dd0b007c25f484c3d91ff95d609f Parents: a878a02 acda527 Author: Jonathan Ellis Authored: Tue Nov 13 16:48:31 2012 -0600 Committer: Jonathan Ellis Committed: Tue Nov 13 16:48:31 2012 -0600 -- .../org/apache/cassandra/cql3/QueryProcessor.java |3 --- 1 files changed, 0 insertions(+), 3 deletions(-) --
[6/6] git commit: reduce verbosity of QueryProcessor tracing
reduce verbosity of QueryProcessor tracing
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/acda5279
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/acda5279
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/acda5279
Branch: refs/heads/cassandra-1.2
Commit: acda52799297ab4676905577e3954df8e7a58ea5
Parents: 901a54a
Author: Jonathan Ellis
Authored: Tue Nov 13 16:48:18 2012 -0600
Committer: Jonathan Ellis
Committed: Tue Nov 13 16:48:24 2012 -0600
--
.../org/apache/cassandra/cql3/QueryProcessor.java |3 ---
1 files changed, 0 insertions(+), 3 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/cassandra/blob/acda5279/src/java/org/apache/cassandra/cql3/QueryProcessor.java
--
diff --git a/src/java/org/apache/cassandra/cql3/QueryProcessor.java
b/src/java/org/apache/cassandra/cql3/QueryProcessor.java
index 02b5edc..93990f6 100644
--- a/src/java/org/apache/cassandra/cql3/QueryProcessor.java
+++ b/src/java/org/apache/cassandra/cql3/QueryProcessor.java
@@ -127,11 +127,8 @@ public class QueryProcessor
throws RequestExecutionException, RequestValidationException
{
ClientState clientState = queryState.getClientState();
-Tracing.trace("Checking access");
statement.checkAccess(clientState);
-Tracing.trace("Validating statement");
statement.validate(clientState);
-Tracing.trace("Executing statement");
ResultMessage result = statement.execute(cl, queryState, variables);
return result == null ? new ResultMessage.Void() : result;
}
[4/6] git commit: reduce verbosity of QueryProcessor tracing
reduce verbosity of QueryProcessor tracing
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/acda5279
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/acda5279
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/acda5279
Branch: refs/heads/trunk
Commit: acda52799297ab4676905577e3954df8e7a58ea5
Parents: 901a54a
Author: Jonathan Ellis
Authored: Tue Nov 13 16:48:18 2012 -0600
Committer: Jonathan Ellis
Committed: Tue Nov 13 16:48:24 2012 -0600
--
.../org/apache/cassandra/cql3/QueryProcessor.java |3 ---
1 files changed, 0 insertions(+), 3 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/cassandra/blob/acda5279/src/java/org/apache/cassandra/cql3/QueryProcessor.java
--
diff --git a/src/java/org/apache/cassandra/cql3/QueryProcessor.java
b/src/java/org/apache/cassandra/cql3/QueryProcessor.java
index 02b5edc..93990f6 100644
--- a/src/java/org/apache/cassandra/cql3/QueryProcessor.java
+++ b/src/java/org/apache/cassandra/cql3/QueryProcessor.java
@@ -127,11 +127,8 @@ public class QueryProcessor
throws RequestExecutionException, RequestValidationException
{
ClientState clientState = queryState.getClientState();
-Tracing.trace("Checking access");
statement.checkAccess(clientState);
-Tracing.trace("Validating statement");
statement.validate(clientState);
-Tracing.trace("Executing statement");
ResultMessage result = statement.execute(cl, queryState, variables);
return result == null ? new ResultMessage.Void() : result;
}
[3/6] git commit: Merge branch 'cassandra-1.2.0' into cassandra-1.2
Merge branch 'cassandra-1.2.0' into cassandra-1.2 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/4576ccba Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/4576ccba Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/4576ccba Branch: refs/heads/trunk Commit: 4576ccba6e83dd0b007c25f484c3d91ff95d609f Parents: a878a02 acda527 Author: Jonathan Ellis Authored: Tue Nov 13 16:48:31 2012 -0600 Committer: Jonathan Ellis Committed: Tue Nov 13 16:48:31 2012 -0600 -- .../org/apache/cassandra/cql3/QueryProcessor.java |3 --- 1 files changed, 0 insertions(+), 3 deletions(-) --
[5/6] git commit: reduce verbosity of QueryProcessor tracing
reduce verbosity of QueryProcessor tracing
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/acda5279
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/acda5279
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/acda5279
Branch: refs/heads/cassandra-1.2.0
Commit: acda52799297ab4676905577e3954df8e7a58ea5
Parents: 901a54a
Author: Jonathan Ellis
Authored: Tue Nov 13 16:48:18 2012 -0600
Committer: Jonathan Ellis
Committed: Tue Nov 13 16:48:24 2012 -0600
--
.../org/apache/cassandra/cql3/QueryProcessor.java |3 ---
1 files changed, 0 insertions(+), 3 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/cassandra/blob/acda5279/src/java/org/apache/cassandra/cql3/QueryProcessor.java
--
diff --git a/src/java/org/apache/cassandra/cql3/QueryProcessor.java
b/src/java/org/apache/cassandra/cql3/QueryProcessor.java
index 02b5edc..93990f6 100644
--- a/src/java/org/apache/cassandra/cql3/QueryProcessor.java
+++ b/src/java/org/apache/cassandra/cql3/QueryProcessor.java
@@ -127,11 +127,8 @@ public class QueryProcessor
throws RequestExecutionException, RequestValidationException
{
ClientState clientState = queryState.getClientState();
-Tracing.trace("Checking access");
statement.checkAccess(clientState);
-Tracing.trace("Validating statement");
statement.validate(clientState);
-Tracing.trace("Executing statement");
ResultMessage result = statement.execute(cl, queryState, variables);
return result == null ? new ResultMessage.Void() : result;
}
[1/6] git commit: Merge branch 'cassandra-1.2' into trunk
Updated Branches: refs/heads/cassandra-1.2 a878a02fb -> 4576ccba6 refs/heads/cassandra-1.2.0 901a54a6d -> acda52799 refs/heads/trunk 49db94437 -> ac16a54a1 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/ac16a54a Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/ac16a54a Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/ac16a54a Branch: refs/heads/trunk Commit: ac16a54a163d27a09e5506dafa7a24062f962d0c Parents: 49db944 4576ccb Author: Jonathan Ellis Authored: Tue Nov 13 16:48:43 2012 -0600 Committer: Jonathan Ellis Committed: Tue Nov 13 16:48:43 2012 -0600 -- .../org/apache/cassandra/cql3/QueryProcessor.java |3 --- 1 files changed, 0 insertions(+), 3 deletions(-) --
[jira] [Created] (CASSANDRA-4957) When bulk loading, validate SSTable's partitioner as much as possible
Yuki Morishita created CASSANDRA-4957: - Summary: When bulk loading, validate SSTable's partitioner as much as possible Key: CASSANDRA-4957 URL: https://issues.apache.org/jira/browse/CASSANDRA-4957 Project: Cassandra Issue Type: Improvement Affects Versions: 1.1.0 Reporter: Yuki Morishita Priority: Minor When using BulkLoader/BulkOutputFormat, sstable's partitioner is not checked even if you have Stats.db on same directory. BulkLoader tries to stream wrong partitioned SSTables, and produces IO error. (I found this when I used Murmur3partitioner for BOF while cluster was setup for RandomPartitioner. see CASSANDRA-4813.) It will be nice to validate partitioner when Stats.db is present to avoid causing streaming error. -- 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
[4/6] git commit: change stream session ID from (host, counter) to TimeUUID; patch by yukim reviewed by Michael Kjellman for CASSANDRA-4813
change stream session ID from (host, counter) to TimeUUID; patch by yukim
reviewed by Michael Kjellman for CASSANDRA-4813
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/901a54a6
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/901a54a6
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/901a54a6
Branch: refs/heads/trunk
Commit: 901a54a6d6c7b6f7276088e67b45f95dcc7b57f7
Parents: 228d1cf
Author: Yuki Morishita
Authored: Tue Nov 13 16:18:07 2012 -0600
Committer: Yuki Morishita
Committed: Tue Nov 13 16:18:07 2012 -0600
--
CHANGES.txt|1 +
.../cassandra/net/OutboundTcpConnectionPool.java |2 +-
.../cassandra/streaming/AbstractStreamSession.java | 20 ++---
.../apache/cassandra/streaming/FileStreamTask.java |4 +-
.../cassandra/streaming/IncomingStreamReader.java |9 +-
.../apache/cassandra/streaming/StreamHeader.java | 54 +++
.../cassandra/streaming/StreamInSession.java | 70 +--
.../cassandra/streaming/StreamOutSession.java | 53 ---
.../apache/cassandra/streaming/StreamReply.java| 10 ++-
.../streaming/StreamReplyVerbHandler.java |2 +-
.../apache/cassandra/streaming/StreamRequest.java | 21 +++--
.../serialization/1.2/streaming.StreamHeader.bin | Bin 175902 -> 175917
bytes
.../serialization/1.2/streaming.StreamReply.bin| Bin 73 -> 89 bytes
.../1.2/streaming.StreamRequestMessage.bin | Bin 7167 -> 7215 bytes
.../cassandra/streaming/SerializationsTest.java| 27 +++---
.../cassandra/streaming/StreamingTransferTest.java |6 +-
16 files changed, 106 insertions(+), 173 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/cassandra/blob/901a54a6/CHANGES.txt
--
diff --git a/CHANGES.txt b/CHANGES.txt
index 518d3ec..4f54598 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -11,6 +11,7 @@
* Exclude gcable tombstones from merkle-tree computation (CASSANDRA-4905)
* Better printing of AbstractBounds for tracing (CASSANDRA-4931)
* Optimize mostRecentTomstone check in CC.collectAllData (CASSANDRA-4883)
+ * Change stream session ID to UUID to avoid collision from same node
(CASSANDRA-4813)
Merged from 1.1:
* reset getRangeSlice filter after finishing a row for get_paged_slice
(CASSANDRA-4919)
http://git-wip-us.apache.org/repos/asf/cassandra/blob/901a54a6/src/java/org/apache/cassandra/net/OutboundTcpConnectionPool.java
--
diff --git a/src/java/org/apache/cassandra/net/OutboundTcpConnectionPool.java
b/src/java/org/apache/cassandra/net/OutboundTcpConnectionPool.java
index 4d9ce63..237363d 100644
--- a/src/java/org/apache/cassandra/net/OutboundTcpConnectionPool.java
+++ b/src/java/org/apache/cassandra/net/OutboundTcpConnectionPool.java
@@ -124,7 +124,7 @@ public class OutboundTcpConnectionPool
else
{
Socket socket = SocketChannel.open(new
InetSocketAddress(endPoint(), DatabaseDescriptor.getStoragePort())).socket();
-if (Config.getOutboundBindAny())
+if (Config.getOutboundBindAny() && !socket.isBound())
socket.bind(new
InetSocketAddress(FBUtilities.getLocalAddress(), 0));
return socket;
}
http://git-wip-us.apache.org/repos/asf/cassandra/blob/901a54a6/src/java/org/apache/cassandra/streaming/AbstractStreamSession.java
--
diff --git a/src/java/org/apache/cassandra/streaming/AbstractStreamSession.java
b/src/java/org/apache/cassandra/streaming/AbstractStreamSession.java
index d190506..dd7d922 100644
--- a/src/java/org/apache/cassandra/streaming/AbstractStreamSession.java
+++ b/src/java/org/apache/cassandra/streaming/AbstractStreamSession.java
@@ -19,6 +19,7 @@
package org.apache.cassandra.streaming;
import java.net.InetAddress;
+import java.util.UUID;
import java.util.concurrent.atomic.AtomicBoolean;
import org.slf4j.LoggerFactory;
@@ -32,33 +33,30 @@ public abstract class AbstractStreamSession implements
IEndpointStateChangeSubsc
{
private static final Logger logger =
LoggerFactory.getLogger(AbstractStreamSession.class);
+protected final InetAddress host;
+protected final UUID sessionId;
protected String table;
-protected Pair context;
protected final IStreamCallback callback;
private final AtomicBoolean isClosed = new AtomicBoolean(false);
-protected AbstractStreamSession(String table, Pair
context, IStreamCallback callback)
+protected AbstractStreamSession(String table, InetAddress host, UUID
sessionId, IStreamCallback callback)
{
+this.host = host;
+
[5/6] git commit: change stream session ID from (host, counter) to TimeUUID; patch by yukim reviewed by Michael Kjellman for CASSANDRA-4813
change stream session ID from (host, counter) to TimeUUID; patch by yukim
reviewed by Michael Kjellman for CASSANDRA-4813
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/901a54a6
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/901a54a6
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/901a54a6
Branch: refs/heads/cassandra-1.2.0
Commit: 901a54a6d6c7b6f7276088e67b45f95dcc7b57f7
Parents: 228d1cf
Author: Yuki Morishita
Authored: Tue Nov 13 16:18:07 2012 -0600
Committer: Yuki Morishita
Committed: Tue Nov 13 16:18:07 2012 -0600
--
CHANGES.txt|1 +
.../cassandra/net/OutboundTcpConnectionPool.java |2 +-
.../cassandra/streaming/AbstractStreamSession.java | 20 ++---
.../apache/cassandra/streaming/FileStreamTask.java |4 +-
.../cassandra/streaming/IncomingStreamReader.java |9 +-
.../apache/cassandra/streaming/StreamHeader.java | 54 +++
.../cassandra/streaming/StreamInSession.java | 70 +--
.../cassandra/streaming/StreamOutSession.java | 53 ---
.../apache/cassandra/streaming/StreamReply.java| 10 ++-
.../streaming/StreamReplyVerbHandler.java |2 +-
.../apache/cassandra/streaming/StreamRequest.java | 21 +++--
.../serialization/1.2/streaming.StreamHeader.bin | Bin 175902 -> 175917
bytes
.../serialization/1.2/streaming.StreamReply.bin| Bin 73 -> 89 bytes
.../1.2/streaming.StreamRequestMessage.bin | Bin 7167 -> 7215 bytes
.../cassandra/streaming/SerializationsTest.java| 27 +++---
.../cassandra/streaming/StreamingTransferTest.java |6 +-
16 files changed, 106 insertions(+), 173 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/cassandra/blob/901a54a6/CHANGES.txt
--
diff --git a/CHANGES.txt b/CHANGES.txt
index 518d3ec..4f54598 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -11,6 +11,7 @@
* Exclude gcable tombstones from merkle-tree computation (CASSANDRA-4905)
* Better printing of AbstractBounds for tracing (CASSANDRA-4931)
* Optimize mostRecentTomstone check in CC.collectAllData (CASSANDRA-4883)
+ * Change stream session ID to UUID to avoid collision from same node
(CASSANDRA-4813)
Merged from 1.1:
* reset getRangeSlice filter after finishing a row for get_paged_slice
(CASSANDRA-4919)
http://git-wip-us.apache.org/repos/asf/cassandra/blob/901a54a6/src/java/org/apache/cassandra/net/OutboundTcpConnectionPool.java
--
diff --git a/src/java/org/apache/cassandra/net/OutboundTcpConnectionPool.java
b/src/java/org/apache/cassandra/net/OutboundTcpConnectionPool.java
index 4d9ce63..237363d 100644
--- a/src/java/org/apache/cassandra/net/OutboundTcpConnectionPool.java
+++ b/src/java/org/apache/cassandra/net/OutboundTcpConnectionPool.java
@@ -124,7 +124,7 @@ public class OutboundTcpConnectionPool
else
{
Socket socket = SocketChannel.open(new
InetSocketAddress(endPoint(), DatabaseDescriptor.getStoragePort())).socket();
-if (Config.getOutboundBindAny())
+if (Config.getOutboundBindAny() && !socket.isBound())
socket.bind(new
InetSocketAddress(FBUtilities.getLocalAddress(), 0));
return socket;
}
http://git-wip-us.apache.org/repos/asf/cassandra/blob/901a54a6/src/java/org/apache/cassandra/streaming/AbstractStreamSession.java
--
diff --git a/src/java/org/apache/cassandra/streaming/AbstractStreamSession.java
b/src/java/org/apache/cassandra/streaming/AbstractStreamSession.java
index d190506..dd7d922 100644
--- a/src/java/org/apache/cassandra/streaming/AbstractStreamSession.java
+++ b/src/java/org/apache/cassandra/streaming/AbstractStreamSession.java
@@ -19,6 +19,7 @@
package org.apache.cassandra.streaming;
import java.net.InetAddress;
+import java.util.UUID;
import java.util.concurrent.atomic.AtomicBoolean;
import org.slf4j.LoggerFactory;
@@ -32,33 +33,30 @@ public abstract class AbstractStreamSession implements
IEndpointStateChangeSubsc
{
private static final Logger logger =
LoggerFactory.getLogger(AbstractStreamSession.class);
+protected final InetAddress host;
+protected final UUID sessionId;
protected String table;
-protected Pair context;
protected final IStreamCallback callback;
private final AtomicBoolean isClosed = new AtomicBoolean(false);
-protected AbstractStreamSession(String table, Pair
context, IStreamCallback callback)
+protected AbstractStreamSession(String table, InetAddress host, UUID
sessionId, IStreamCallback callback)
{
+this.host = ho
[2/6] git commit: Merge branch 'cassandra-1.2.0' into cassandra-1.2
Merge branch 'cassandra-1.2.0' into cassandra-1.2 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/a878a02f Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/a878a02f Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/a878a02f Branch: refs/heads/cassandra-1.2 Commit: a878a02fb0c9d3abbcdd854039e5075793f861aa Parents: 90d2f8e 901a54a Author: Yuki Morishita Authored: Tue Nov 13 16:18:27 2012 -0600 Committer: Yuki Morishita Committed: Tue Nov 13 16:18:27 2012 -0600 -- CHANGES.txt|1 + .../cassandra/net/OutboundTcpConnectionPool.java |2 +- .../cassandra/streaming/AbstractStreamSession.java | 20 ++--- .../apache/cassandra/streaming/FileStreamTask.java |4 +- .../cassandra/streaming/IncomingStreamReader.java |9 +- .../apache/cassandra/streaming/StreamHeader.java | 54 +++ .../cassandra/streaming/StreamInSession.java | 70 +-- .../cassandra/streaming/StreamOutSession.java | 53 --- .../apache/cassandra/streaming/StreamReply.java| 10 ++- .../streaming/StreamReplyVerbHandler.java |2 +- .../apache/cassandra/streaming/StreamRequest.java | 21 +++-- .../serialization/1.2/streaming.StreamHeader.bin | Bin 175902 -> 175917 bytes .../serialization/1.2/streaming.StreamReply.bin| Bin 73 -> 89 bytes .../1.2/streaming.StreamRequestMessage.bin | Bin 7167 -> 7215 bytes .../cassandra/streaming/SerializationsTest.java| 27 +++--- .../cassandra/streaming/StreamingTransferTest.java |6 +- 16 files changed, 106 insertions(+), 173 deletions(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/a878a02f/CHANGES.txt --
[6/6] git commit: change stream session ID from (host, counter) to TimeUUID; patch by yukim reviewed by Michael Kjellman for CASSANDRA-4813
change stream session ID from (host, counter) to TimeUUID; patch by yukim
reviewed by Michael Kjellman for CASSANDRA-4813
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/901a54a6
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/901a54a6
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/901a54a6
Branch: refs/heads/cassandra-1.2
Commit: 901a54a6d6c7b6f7276088e67b45f95dcc7b57f7
Parents: 228d1cf
Author: Yuki Morishita
Authored: Tue Nov 13 16:18:07 2012 -0600
Committer: Yuki Morishita
Committed: Tue Nov 13 16:18:07 2012 -0600
--
CHANGES.txt|1 +
.../cassandra/net/OutboundTcpConnectionPool.java |2 +-
.../cassandra/streaming/AbstractStreamSession.java | 20 ++---
.../apache/cassandra/streaming/FileStreamTask.java |4 +-
.../cassandra/streaming/IncomingStreamReader.java |9 +-
.../apache/cassandra/streaming/StreamHeader.java | 54 +++
.../cassandra/streaming/StreamInSession.java | 70 +--
.../cassandra/streaming/StreamOutSession.java | 53 ---
.../apache/cassandra/streaming/StreamReply.java| 10 ++-
.../streaming/StreamReplyVerbHandler.java |2 +-
.../apache/cassandra/streaming/StreamRequest.java | 21 +++--
.../serialization/1.2/streaming.StreamHeader.bin | Bin 175902 -> 175917
bytes
.../serialization/1.2/streaming.StreamReply.bin| Bin 73 -> 89 bytes
.../1.2/streaming.StreamRequestMessage.bin | Bin 7167 -> 7215 bytes
.../cassandra/streaming/SerializationsTest.java| 27 +++---
.../cassandra/streaming/StreamingTransferTest.java |6 +-
16 files changed, 106 insertions(+), 173 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/cassandra/blob/901a54a6/CHANGES.txt
--
diff --git a/CHANGES.txt b/CHANGES.txt
index 518d3ec..4f54598 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -11,6 +11,7 @@
* Exclude gcable tombstones from merkle-tree computation (CASSANDRA-4905)
* Better printing of AbstractBounds for tracing (CASSANDRA-4931)
* Optimize mostRecentTomstone check in CC.collectAllData (CASSANDRA-4883)
+ * Change stream session ID to UUID to avoid collision from same node
(CASSANDRA-4813)
Merged from 1.1:
* reset getRangeSlice filter after finishing a row for get_paged_slice
(CASSANDRA-4919)
http://git-wip-us.apache.org/repos/asf/cassandra/blob/901a54a6/src/java/org/apache/cassandra/net/OutboundTcpConnectionPool.java
--
diff --git a/src/java/org/apache/cassandra/net/OutboundTcpConnectionPool.java
b/src/java/org/apache/cassandra/net/OutboundTcpConnectionPool.java
index 4d9ce63..237363d 100644
--- a/src/java/org/apache/cassandra/net/OutboundTcpConnectionPool.java
+++ b/src/java/org/apache/cassandra/net/OutboundTcpConnectionPool.java
@@ -124,7 +124,7 @@ public class OutboundTcpConnectionPool
else
{
Socket socket = SocketChannel.open(new
InetSocketAddress(endPoint(), DatabaseDescriptor.getStoragePort())).socket();
-if (Config.getOutboundBindAny())
+if (Config.getOutboundBindAny() && !socket.isBound())
socket.bind(new
InetSocketAddress(FBUtilities.getLocalAddress(), 0));
return socket;
}
http://git-wip-us.apache.org/repos/asf/cassandra/blob/901a54a6/src/java/org/apache/cassandra/streaming/AbstractStreamSession.java
--
diff --git a/src/java/org/apache/cassandra/streaming/AbstractStreamSession.java
b/src/java/org/apache/cassandra/streaming/AbstractStreamSession.java
index d190506..dd7d922 100644
--- a/src/java/org/apache/cassandra/streaming/AbstractStreamSession.java
+++ b/src/java/org/apache/cassandra/streaming/AbstractStreamSession.java
@@ -19,6 +19,7 @@
package org.apache.cassandra.streaming;
import java.net.InetAddress;
+import java.util.UUID;
import java.util.concurrent.atomic.AtomicBoolean;
import org.slf4j.LoggerFactory;
@@ -32,33 +33,30 @@ public abstract class AbstractStreamSession implements
IEndpointStateChangeSubsc
{
private static final Logger logger =
LoggerFactory.getLogger(AbstractStreamSession.class);
+protected final InetAddress host;
+protected final UUID sessionId;
protected String table;
-protected Pair context;
protected final IStreamCallback callback;
private final AtomicBoolean isClosed = new AtomicBoolean(false);
-protected AbstractStreamSession(String table, Pair
context, IStreamCallback callback)
+protected AbstractStreamSession(String table, InetAddress host, UUID
sessionId, IStreamCallback callback)
{
+this.host = host
[3/6] git commit: Merge branch 'cassandra-1.2.0' into cassandra-1.2
Merge branch 'cassandra-1.2.0' into cassandra-1.2 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/a878a02f Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/a878a02f Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/a878a02f Branch: refs/heads/trunk Commit: a878a02fb0c9d3abbcdd854039e5075793f861aa Parents: 90d2f8e 901a54a Author: Yuki Morishita Authored: Tue Nov 13 16:18:27 2012 -0600 Committer: Yuki Morishita Committed: Tue Nov 13 16:18:27 2012 -0600 -- CHANGES.txt|1 + .../cassandra/net/OutboundTcpConnectionPool.java |2 +- .../cassandra/streaming/AbstractStreamSession.java | 20 ++--- .../apache/cassandra/streaming/FileStreamTask.java |4 +- .../cassandra/streaming/IncomingStreamReader.java |9 +- .../apache/cassandra/streaming/StreamHeader.java | 54 +++ .../cassandra/streaming/StreamInSession.java | 70 +-- .../cassandra/streaming/StreamOutSession.java | 53 --- .../apache/cassandra/streaming/StreamReply.java| 10 ++- .../streaming/StreamReplyVerbHandler.java |2 +- .../apache/cassandra/streaming/StreamRequest.java | 21 +++-- .../serialization/1.2/streaming.StreamHeader.bin | Bin 175902 -> 175917 bytes .../serialization/1.2/streaming.StreamReply.bin| Bin 73 -> 89 bytes .../1.2/streaming.StreamRequestMessage.bin | Bin 7167 -> 7215 bytes .../cassandra/streaming/SerializationsTest.java| 27 +++--- .../cassandra/streaming/StreamingTransferTest.java |6 +- 16 files changed, 106 insertions(+), 173 deletions(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/a878a02f/CHANGES.txt --
[1/6] git commit: Merge branch 'cassandra-1.2' into trunk
Updated Branches: refs/heads/cassandra-1.2 90d2f8e8e -> a878a02fb refs/heads/cassandra-1.2.0 228d1cf6e -> 901a54a6d refs/heads/trunk 1650ae8f6 -> 49db94437 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/49db9443 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/49db9443 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/49db9443 Branch: refs/heads/trunk Commit: 49db94437005495367b3c28a5c98411f8fd19a9a Parents: 1650ae8 a878a02 Author: Yuki Morishita Authored: Tue Nov 13 16:18:58 2012 -0600 Committer: Yuki Morishita Committed: Tue Nov 13 16:18:58 2012 -0600 -- CHANGES.txt|1 + .../cassandra/net/OutboundTcpConnectionPool.java |2 +- .../cassandra/streaming/AbstractStreamSession.java | 20 ++--- .../apache/cassandra/streaming/FileStreamTask.java |4 +- .../cassandra/streaming/IncomingStreamReader.java |9 +- .../apache/cassandra/streaming/StreamHeader.java | 54 +++ .../cassandra/streaming/StreamInSession.java | 70 +-- .../cassandra/streaming/StreamOutSession.java | 53 --- .../apache/cassandra/streaming/StreamReply.java| 10 ++- .../streaming/StreamReplyVerbHandler.java |2 +- .../apache/cassandra/streaming/StreamRequest.java | 21 +++-- .../serialization/1.2/streaming.StreamHeader.bin | Bin 175902 -> 175917 bytes .../serialization/1.2/streaming.StreamReply.bin| Bin 73 -> 89 bytes .../1.2/streaming.StreamRequestMessage.bin | Bin 7167 -> 7215 bytes .../cassandra/streaming/SerializationsTest.java| 27 +++--- .../cassandra/streaming/StreamingTransferTest.java |6 +- 16 files changed, 106 insertions(+), 173 deletions(-) --
[jira] [Commented] (CASSANDRA-4837) IllegalStateException when upgrading schema
[
https://issues.apache.org/jira/browse/CASSANDRA-4837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13496601#comment-13496601
]
Wade Simmons commented on CASSANDRA-4837:
-
Same exception repeating. I'm going to see if I can make a patch to avoid this.
> IllegalStateException when upgrading schema
> ---
>
> Key: CASSANDRA-4837
> URL: https://issues.apache.org/jira/browse/CASSANDRA-4837
> Project: Cassandra
> Issue Type: Bug
> Components: Core
>Affects Versions: 1.1.6
> Environment: Linux
>Reporter: Wade Simmons
>Assignee: Pavel Yaskevich
> Attachments: CASSANDRA-4837.patch, schematables.tar.gz
>
>
> I am upgrading a cluster from 1.1.2 to 1.1.6. When restarting a node with new
> code, I am seeing this exception repeat in the logs:
> {code}
> ERROR [InternalResponseStage:21] 2012-10-19 00:41:26,794
> AbstractCassandraDaemon.java (line 135) Exception in thread
> Thread[InternalResponseStage:21,5,main]
> java.lang.IllegalStateException: One row required, 0 found
> at
> org.apache.cassandra.cql3.UntypedResultSet.one(UntypedResultSet.java:50)
> at
> org.apache.cassandra.config.KSMetaData.fromSchema(KSMetaData.java:258)
> at
> org.apache.cassandra.db.DefsTable.mergeKeyspaces(DefsTable.java:406)
> at org.apache.cassandra.db.DefsTable.mergeSchema(DefsTable.java:355)
> at
> org.apache.cassandra.db.DefsTable.mergeRemoteSchema(DefsTable.java:329)
> at
> org.apache.cassandra.service.MigrationManager$MigrationTask$1.response(MigrationManager.java:449)
> at
> org.apache.cassandra.net.ResponseVerbHandler.doVerb(ResponseVerbHandler.java:45)
> at
> org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:59)
> 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)
> {code}
> I added in some debugging logging to see what Row it was trying to load, and
> I see this:
> {code}
> Unable to load keyspace schema:
> Row(key=DecoratedKey(112573196966143652100562749464385838776,
> 5365676d656e7473496e746567726174696f6e54657374),
> cf=ColumnFamily(schema_keyspaces -deleted at 1350665377628000- []))
> {code}
> The hex key translates to a schema that exists in schema_keyspaces when I
> query on the rest of the cluster. I tried restarting one of the other nodes
> without upgrading the jar and it restarted without exceptions.
--
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-4912) BulkOutputFormat should support Hadoop MultipleOutput
[ https://issues.apache.org/jira/browse/CASSANDRA-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13496589#comment-13496589 ] Michael Kjellman commented on CASSANDRA-4912: - Okay, attached a script to load data (really simple but wanted you to see what kind of data I was using to test that the Example job runs) and App.java which will allow you to output to multiple column families with BOF. > BulkOutputFormat should support Hadoop MultipleOutput > - > > Key: CASSANDRA-4912 > URL: https://issues.apache.org/jira/browse/CASSANDRA-4912 > Project: Cassandra > Issue Type: New Feature > Components: Hadoop >Affects Versions: 1.2.0 beta 1, 1.2.0 beta 2 >Reporter: Michael Kjellman > Attachments: 4912.txt, App.java, loaddata.pl > > > Much like CASSANDRA-4208 BOF should support outputting to Multiple Column > Families. The current approach takken in the patch for COF results in only > one stream being sent. -- 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-4912) BulkOutputFormat should support Hadoop MultipleOutput
[ https://issues.apache.org/jira/browse/CASSANDRA-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Kjellman updated CASSANDRA-4912: Attachment: (was: Example.java) > BulkOutputFormat should support Hadoop MultipleOutput > - > > Key: CASSANDRA-4912 > URL: https://issues.apache.org/jira/browse/CASSANDRA-4912 > Project: Cassandra > Issue Type: New Feature > Components: Hadoop >Affects Versions: 1.2.0 beta 1, 1.2.0 beta 2 >Reporter: Michael Kjellman > Attachments: 4912.txt, App.java, loaddata.pl > > > Much like CASSANDRA-4208 BOF should support outputting to Multiple Column > Families. The current approach takken in the patch for COF results in only > one stream being sent. -- 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-4912) BulkOutputFormat should support Hadoop MultipleOutput
[ https://issues.apache.org/jira/browse/CASSANDRA-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Kjellman updated CASSANDRA-4912: Attachment: loaddata.pl > BulkOutputFormat should support Hadoop MultipleOutput > - > > Key: CASSANDRA-4912 > URL: https://issues.apache.org/jira/browse/CASSANDRA-4912 > Project: Cassandra > Issue Type: New Feature > Components: Hadoop >Affects Versions: 1.2.0 beta 1, 1.2.0 beta 2 >Reporter: Michael Kjellman > Attachments: 4912.txt, App.java, loaddata.pl > > > Much like CASSANDRA-4208 BOF should support outputting to Multiple Column > Families. The current approach takken in the patch for COF results in only > one stream being sent. -- 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-4912) BulkOutputFormat should support Hadoop MultipleOutput
[ https://issues.apache.org/jira/browse/CASSANDRA-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Kjellman updated CASSANDRA-4912: Attachment: App.java > BulkOutputFormat should support Hadoop MultipleOutput > - > > Key: CASSANDRA-4912 > URL: https://issues.apache.org/jira/browse/CASSANDRA-4912 > Project: Cassandra > Issue Type: New Feature > Components: Hadoop >Affects Versions: 1.2.0 beta 1, 1.2.0 beta 2 >Reporter: Michael Kjellman > Attachments: 4912.txt, App.java, loaddata.pl > > > Much like CASSANDRA-4208 BOF should support outputting to Multiple Column > Families. The current approach takken in the patch for COF results in only > one stream being sent. -- 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-4762) Support multiple OR clauses for CQL3 Compact storage
[
https://issues.apache.org/jira/browse/CASSANDRA-4762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
T Jake Luciani reassigned CASSANDRA-4762:
-
Assignee: T Jake Luciani
> Support multiple OR clauses for CQL3 Compact storage
>
>
> Key: CASSANDRA-4762
> URL: https://issues.apache.org/jira/browse/CASSANDRA-4762
> Project: Cassandra
> Issue Type: Improvement
> Components: Core
>Reporter: T Jake Luciani
>Assignee: T Jake Luciani
> Fix For: 1.2.1
>
>
> Given CASSANDRA-3885
> It seems it should be possible to store multiple ranges for many predicates
> even the inner parts of a composite column.
> They could be expressed as a expanded set of filter queries.
> example:
> {code}
> CREATE TABLE test (
>name text,
>tdate timestamp,
>tdate2 timestamp,
>tdate3 timestamp,
>num double,
>PRIMARY KEY(key,tdate,tdate2,tdate3)
> ) WITH COMPACT STORAGE;
> SELECT * FROM test WHERE
> name IN ('a','b') and
> tdate IN ('2010-01-01','2011-01-01') and
> tdate2 IN ('2010-01-01','2011-01-01') and
> tdate3 IN ('2010-01-01','2011-01-01') and
> num > 1.0
> {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
[jira] [Commented] (CASSANDRA-4813) Problem using BulkOutputFormat while streaming several SSTables simultaneously from a given node.
[ https://issues.apache.org/jira/browse/CASSANDRA-4813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13496587#comment-13496587 ] Michael Kjellman commented on CASSANDRA-4813: - Just tested a few more times. Looks good. Ship it! > Problem using BulkOutputFormat while streaming several SSTables > simultaneously from a given node. > - > > Key: CASSANDRA-4813 > URL: https://issues.apache.org/jira/browse/CASSANDRA-4813 > Project: Cassandra > Issue Type: Bug >Affects Versions: 1.1.0 > Environment: I am using SLES 10 SP3, Java 6, 4 Cassandra + Hadoop > nodes, 3 Hadoop only nodes (datanodes/tasktrackers), 1 namenode/jobtracker. > The machines used are Six-Core AMD Opteron(tm) Processor 8431, 24 cores and > 33 GB of RAM. I get the issue on both cassandra 1.1.3, 1.1.5 and I am using > Hadoop 0.20.2. >Reporter: Ralph Romanos >Assignee: Yuki Morishita >Priority: Minor > Labels: Bulkoutputformat, Hadoop, SSTables > Fix For: 1.2.0 rc1 > > Attachments: 4813.txt > > > The issue occurs when streaming simultaneously SSTables from the same node to > a cassandra cluster using SSTableloader. It seems to me that Cassandra cannot > handle receiving simultaneously SSTables from the same node. However, when it > receives simultaneously SSTables from two different nodes, everything works > fine. As a consequence, when using BulkOutputFormat to generate SSTables and > stream them to a cassandra cluster, I cannot use more than one reducer per > node otherwise I get a java.io.EOFException in the tasktracker's logs and a > java.io.IOException: Broken pipe in the Cassandra logs. -- 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-4885) Remove or rework per-row bloom filters
[ https://issues.apache.org/jira/browse/CASSANDRA-4885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Brown updated CASSANDRA-4885: --- Attachment: 0001-CASSANRDA-4885-Remove-per-row-bloom-filter.patch OK, so I've removed the bloom filter from the row header and the key index. For the row header, on reads we just skip over the BF section that's on disk (if the sstable is any version lesser than the new 'ja'), and never write it out when serializing. For the index, more or less the same solution. I think I've caught the places in the logic to make sure it does the right thing (don't misread existing files, never write out the BF in new files). However, I did run into a problem with one of the unit tests. ScrubTest.testScrubFile() expects a file that is corrupted so it can then attempt to fix it. The existing corrupt file (test/data/corrupt-sstables/Keyspace1-Super5-f-2-Data.db) has a corrupted BF that throws an exception the unit test is expecting. Now that we're skipping over the BF in the row header, however, the exception never gets thrown and the test fails because the file is 'no longer corrupt' :). I hacked up the code to trip a failure (by changing the columns count), but can somebody recommend a good way to create a corrupt file? > Remove or rework per-row bloom filters > -- > > Key: CASSANDRA-4885 > URL: https://issues.apache.org/jira/browse/CASSANDRA-4885 > Project: Cassandra > Issue Type: Improvement > Components: Core >Reporter: Jonathan Ellis >Assignee: Jason Brown > Fix For: 1.3 > > Attachments: 0001-CASSANRDA-4885-Remove-per-row-bloom-filter.patch > > > Per-row bloom filters may be a misfeature. > On small rows we don't create them. > On large rows we essentially only do slice queries that can't take advantage > of it. > And on very large rows if we ever did deserialize it, the performance hit of > doing so would outweigh the benefit of skipping the actual read. -- 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-4916) Starting Cassandra throws EOF while reading saved cache
[ https://issues.apache.org/jira/browse/CASSANDRA-4916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13496534#comment-13496534 ] Michael Kjellman commented on CASSANDRA-4916: - patch looks good. Ship it! > Starting Cassandra throws EOF while reading saved cache > --- > > Key: CASSANDRA-4916 > URL: https://issues.apache.org/jira/browse/CASSANDRA-4916 > Project: Cassandra > Issue Type: Bug > Components: Core >Reporter: Michael Kjellman >Assignee: Dave Brosius >Priority: Minor > Fix For: 1.2.1 > > Attachments: 4916.txt > > > Currently seeing nodes throw an EOF while reading a saved cache on the system > schema when starting cassandra > WARN 14:25:54,896 error reading saved cache > /ssd/saved_caches/system-schema_columns-KeyCache-b.db > java.io.EOFException > at java.io.DataInputStream.readInt(DataInputStream.java:392) > at > org.apache.cassandra.utils.ByteBufferUtil.readWithLength(ByteBufferUtil.java:349) > at > org.apache.cassandra.service.CacheService$KeyCacheSerializer.deserialize(CacheService.java:378) > at > org.apache.cassandra.cache.AutoSavingCache.loadSaved(AutoSavingCache.java:144) > at > org.apache.cassandra.db.ColumnFamilyStore.(ColumnFamilyStore.java:278) > at > org.apache.cassandra.db.ColumnFamilyStore.createColumnFamilyStore(ColumnFamilyStore.java:393) > at > org.apache.cassandra.db.ColumnFamilyStore.createColumnFamilyStore(ColumnFamilyStore.java:365) > at org.apache.cassandra.db.Table.initCf(Table.java:334) > at org.apache.cassandra.db.Table.(Table.java:272) > at org.apache.cassandra.db.Table.open(Table.java:102) > at org.apache.cassandra.db.Table.open(Table.java:80) > at org.apache.cassandra.db.SystemTable.checkHealth(SystemTable.java:320) > at > org.apache.cassandra.service.CassandraDaemon.setup(CassandraDaemon.java:203) > at > org.apache.cassandra.service.CassandraDaemon.activate(CassandraDaemon.java:395) > at > org.apache.cassandra.service.CassandraDaemon.main(CassandraDaemon.java:438) > to reproduce delete all data files, start a cluster, leave cluster up long > enough to build a cache. nodetool drain, kill cassandra process. start > cassandra process in foreground and note EOF thrown (see above for stack > trace) -- 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-4813) Problem using BulkOutputFormat while streaming several SSTables simultaneously from a given node.
[ https://issues.apache.org/jira/browse/CASSANDRA-4813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13496504#comment-13496504 ] Michael Kjellman commented on CASSANDRA-4813: - [~yukim] Looks like you are right. Was Murmur Partitioner and my job was configured for Random. On a first run looks like this patch is good to go. Sorry for the wild goose chase there. > Problem using BulkOutputFormat while streaming several SSTables > simultaneously from a given node. > - > > Key: CASSANDRA-4813 > URL: https://issues.apache.org/jira/browse/CASSANDRA-4813 > Project: Cassandra > Issue Type: Bug >Affects Versions: 1.1.0 > Environment: I am using SLES 10 SP3, Java 6, 4 Cassandra + Hadoop > nodes, 3 Hadoop only nodes (datanodes/tasktrackers), 1 namenode/jobtracker. > The machines used are Six-Core AMD Opteron(tm) Processor 8431, 24 cores and > 33 GB of RAM. I get the issue on both cassandra 1.1.3, 1.1.5 and I am using > Hadoop 0.20.2. >Reporter: Ralph Romanos >Assignee: Yuki Morishita >Priority: Minor > Labels: Bulkoutputformat, Hadoop, SSTables > Fix For: 1.2.0 rc1 > > Attachments: 4813.txt > > > The issue occurs when streaming simultaneously SSTables from the same node to > a cassandra cluster using SSTableloader. It seems to me that Cassandra cannot > handle receiving simultaneously SSTables from the same node. However, when it > receives simultaneously SSTables from two different nodes, everything works > fine. As a consequence, when using BulkOutputFormat to generate SSTables and > stream them to a cassandra cluster, I cannot use more than one reducer per > node otherwise I get a java.io.EOFException in the tasktracker's logs and a > java.io.IOException: Broken pipe in the Cassandra logs. -- 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
[2/4] git commit: Merge branch 'cassandra-1.2.0' into cassandra-1.2
Merge branch 'cassandra-1.2.0' into cassandra-1.2 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/90d2f8e8 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/90d2f8e8 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/90d2f8e8 Branch: refs/heads/trunk Commit: 90d2f8e8ec4a23b124760ebbf93926478bd76ae6 Parents: e6e846c 228d1cf Author: Sylvain Lebresne Authored: Tue Nov 13 20:13:13 2012 +0100 Committer: Sylvain Lebresne Committed: Tue Nov 13 20:13:13 2012 +0100 -- .../apache/cassandra/service/CassandraDaemon.java | 12 ++-- 1 files changed, 6 insertions(+), 6 deletions(-) --
[3/4] git commit: Merge branch 'cassandra-1.2.0' of https://git-wip-us.apache.org/repos/asf/cassandra into cassandra-1.2.0
Merge branch 'cassandra-1.2.0' of https://git-wip-us.apache.org/repos/asf/cassandra into cassandra-1.2.0 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/228d1cf6 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/228d1cf6 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/228d1cf6 Branch: refs/heads/trunk Commit: 228d1cf6ebdf6343121f1c95c862b2dfcc4e233a Parents: 91a10fa 94fa825 Author: Sylvain Lebresne Authored: Tue Nov 13 20:11:01 2012 +0100 Committer: Sylvain Lebresne Committed: Tue Nov 13 20:11:01 2012 +0100 -- .../cassandra/cache/ConcurrentLinkedHashCache.java |2 +- 1 files changed, 1 insertions(+), 1 deletions(-) --
[4/4] git commit: Start binary protocol server before thrift (as the later is too damn long to start)
Start binary protocol server before thrift (as the later is too damn long to
start)
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/91a10fa5
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/91a10fa5
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/91a10fa5
Branch: refs/heads/trunk
Commit: 91a10fa58e0218739e09498c2d90fa858cea85d6
Parents: 9c5e5dc
Author: Sylvain Lebresne
Authored: Tue Nov 13 20:10:50 2012 +0100
Committer: Sylvain Lebresne
Committed: Tue Nov 13 20:10:50 2012 +0100
--
.../apache/cassandra/service/CassandraDaemon.java | 12 ++--
1 files changed, 6 insertions(+), 6 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/cassandra/blob/91a10fa5/src/java/org/apache/cassandra/service/CassandraDaemon.java
--
diff --git a/src/java/org/apache/cassandra/service/CassandraDaemon.java
b/src/java/org/apache/cassandra/service/CassandraDaemon.java
index 03da7e3..687ddaa 100644
--- a/src/java/org/apache/cassandra/service/CassandraDaemon.java
+++ b/src/java/org/apache/cassandra/service/CassandraDaemon.java
@@ -346,17 +346,17 @@ public class CassandraDaemon
*/
public void start()
{
-String rpcFlag = System.getProperty("cassandra.start_rpc");
-if ((rpcFlag != null && Boolean.parseBoolean(rpcFlag)) || (rpcFlag ==
null && DatabaseDescriptor.startRpc()))
-thriftServer.start();
-else
-logger.info("Not starting RPC server as requested. Use JMX
(StorageService->startRPCServer()) to start it");
-
String nativeFlag =
System.getProperty("cassandra.start_native_transport");
if ((nativeFlag != null && Boolean.parseBoolean(nativeFlag)) ||
(nativeFlag == null && DatabaseDescriptor.startNativeTransport()))
nativeServer.start();
else
logger.info("Not starting native transport as requested. Use JMX
(StorageService->startNativeTransport()) to start it");
+
+String rpcFlag = System.getProperty("cassandra.start_rpc");
+if ((rpcFlag != null && Boolean.parseBoolean(rpcFlag)) || (rpcFlag ==
null && DatabaseDescriptor.startRpc()))
+thriftServer.start();
+else
+logger.info("Not starting RPC server as requested. Use JMX
(StorageService->startRPCServer()) to start it");
}
/**
[1/4] git commit: Merge branch 'cassandra-1.2' into trunk
Updated Branches: refs/heads/trunk 191c96f1d -> 1650ae8f6 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/1650ae8f Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/1650ae8f Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/1650ae8f Branch: refs/heads/trunk Commit: 1650ae8f6ff08ba89c2b0f8b523a87dc7bad06bf Parents: 191c96f 90d2f8e Author: Sylvain Lebresne Authored: Tue Nov 13 20:13:44 2012 +0100 Committer: Sylvain Lebresne Committed: Tue Nov 13 20:13:44 2012 +0100 -- .../apache/cassandra/service/CassandraDaemon.java | 12 ++-- 1 files changed, 6 insertions(+), 6 deletions(-) --
[1/3] git commit: Merge branch 'cassandra-1.2.0' into cassandra-1.2
Updated Branches: refs/heads/cassandra-1.2 e6e846c13 -> 90d2f8e8e Merge branch 'cassandra-1.2.0' into cassandra-1.2 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/90d2f8e8 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/90d2f8e8 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/90d2f8e8 Branch: refs/heads/cassandra-1.2 Commit: 90d2f8e8ec4a23b124760ebbf93926478bd76ae6 Parents: e6e846c 228d1cf Author: Sylvain Lebresne Authored: Tue Nov 13 20:13:13 2012 +0100 Committer: Sylvain Lebresne Committed: Tue Nov 13 20:13:13 2012 +0100 -- .../apache/cassandra/service/CassandraDaemon.java | 12 ++-- 1 files changed, 6 insertions(+), 6 deletions(-) --
[2/3] git commit: Merge branch 'cassandra-1.2.0' of https://git-wip-us.apache.org/repos/asf/cassandra into cassandra-1.2.0
Merge branch 'cassandra-1.2.0' of https://git-wip-us.apache.org/repos/asf/cassandra into cassandra-1.2.0 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/228d1cf6 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/228d1cf6 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/228d1cf6 Branch: refs/heads/cassandra-1.2 Commit: 228d1cf6ebdf6343121f1c95c862b2dfcc4e233a Parents: 91a10fa 94fa825 Author: Sylvain Lebresne Authored: Tue Nov 13 20:11:01 2012 +0100 Committer: Sylvain Lebresne Committed: Tue Nov 13 20:11:01 2012 +0100 -- .../cassandra/cache/ConcurrentLinkedHashCache.java |2 +- 1 files changed, 1 insertions(+), 1 deletions(-) --
[3/3] git commit: Start binary protocol server before thrift (as the later is too damn long to start)
Start binary protocol server before thrift (as the later is too damn long to
start)
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/91a10fa5
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/91a10fa5
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/91a10fa5
Branch: refs/heads/cassandra-1.2
Commit: 91a10fa58e0218739e09498c2d90fa858cea85d6
Parents: 9c5e5dc
Author: Sylvain Lebresne
Authored: Tue Nov 13 20:10:50 2012 +0100
Committer: Sylvain Lebresne
Committed: Tue Nov 13 20:10:50 2012 +0100
--
.../apache/cassandra/service/CassandraDaemon.java | 12 ++--
1 files changed, 6 insertions(+), 6 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/cassandra/blob/91a10fa5/src/java/org/apache/cassandra/service/CassandraDaemon.java
--
diff --git a/src/java/org/apache/cassandra/service/CassandraDaemon.java
b/src/java/org/apache/cassandra/service/CassandraDaemon.java
index 03da7e3..687ddaa 100644
--- a/src/java/org/apache/cassandra/service/CassandraDaemon.java
+++ b/src/java/org/apache/cassandra/service/CassandraDaemon.java
@@ -346,17 +346,17 @@ public class CassandraDaemon
*/
public void start()
{
-String rpcFlag = System.getProperty("cassandra.start_rpc");
-if ((rpcFlag != null && Boolean.parseBoolean(rpcFlag)) || (rpcFlag ==
null && DatabaseDescriptor.startRpc()))
-thriftServer.start();
-else
-logger.info("Not starting RPC server as requested. Use JMX
(StorageService->startRPCServer()) to start it");
-
String nativeFlag =
System.getProperty("cassandra.start_native_transport");
if ((nativeFlag != null && Boolean.parseBoolean(nativeFlag)) ||
(nativeFlag == null && DatabaseDescriptor.startNativeTransport()))
nativeServer.start();
else
logger.info("Not starting native transport as requested. Use JMX
(StorageService->startNativeTransport()) to start it");
+
+String rpcFlag = System.getProperty("cassandra.start_rpc");
+if ((rpcFlag != null && Boolean.parseBoolean(rpcFlag)) || (rpcFlag ==
null && DatabaseDescriptor.startRpc()))
+thriftServer.start();
+else
+logger.info("Not starting RPC server as requested. Use JMX
(StorageService->startRPCServer()) to start it");
}
/**
[2/2] git commit: Start binary protocol server before thrift (as the later is too damn long to start)
Start binary protocol server before thrift (as the later is too damn long to
start)
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/91a10fa5
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/91a10fa5
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/91a10fa5
Branch: refs/heads/cassandra-1.2.0
Commit: 91a10fa58e0218739e09498c2d90fa858cea85d6
Parents: 9c5e5dc
Author: Sylvain Lebresne
Authored: Tue Nov 13 20:10:50 2012 +0100
Committer: Sylvain Lebresne
Committed: Tue Nov 13 20:10:50 2012 +0100
--
.../apache/cassandra/service/CassandraDaemon.java | 12 ++--
1 files changed, 6 insertions(+), 6 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/cassandra/blob/91a10fa5/src/java/org/apache/cassandra/service/CassandraDaemon.java
--
diff --git a/src/java/org/apache/cassandra/service/CassandraDaemon.java
b/src/java/org/apache/cassandra/service/CassandraDaemon.java
index 03da7e3..687ddaa 100644
--- a/src/java/org/apache/cassandra/service/CassandraDaemon.java
+++ b/src/java/org/apache/cassandra/service/CassandraDaemon.java
@@ -346,17 +346,17 @@ public class CassandraDaemon
*/
public void start()
{
-String rpcFlag = System.getProperty("cassandra.start_rpc");
-if ((rpcFlag != null && Boolean.parseBoolean(rpcFlag)) || (rpcFlag ==
null && DatabaseDescriptor.startRpc()))
-thriftServer.start();
-else
-logger.info("Not starting RPC server as requested. Use JMX
(StorageService->startRPCServer()) to start it");
-
String nativeFlag =
System.getProperty("cassandra.start_native_transport");
if ((nativeFlag != null && Boolean.parseBoolean(nativeFlag)) ||
(nativeFlag == null && DatabaseDescriptor.startNativeTransport()))
nativeServer.start();
else
logger.info("Not starting native transport as requested. Use JMX
(StorageService->startNativeTransport()) to start it");
+
+String rpcFlag = System.getProperty("cassandra.start_rpc");
+if ((rpcFlag != null && Boolean.parseBoolean(rpcFlag)) || (rpcFlag ==
null && DatabaseDescriptor.startRpc()))
+thriftServer.start();
+else
+logger.info("Not starting RPC server as requested. Use JMX
(StorageService->startRPCServer()) to start it");
}
/**
[1/2] git commit: Merge branch 'cassandra-1.2.0' of https://git-wip-us.apache.org/repos/asf/cassandra into cassandra-1.2.0
Updated Branches: refs/heads/cassandra-1.2.0 94fa82558 -> 228d1cf6e Merge branch 'cassandra-1.2.0' of https://git-wip-us.apache.org/repos/asf/cassandra into cassandra-1.2.0 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/228d1cf6 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/228d1cf6 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/228d1cf6 Branch: refs/heads/cassandra-1.2.0 Commit: 228d1cf6ebdf6343121f1c95c862b2dfcc4e233a Parents: 91a10fa 94fa825 Author: Sylvain Lebresne Authored: Tue Nov 13 20:11:01 2012 +0100 Committer: Sylvain Lebresne Committed: Tue Nov 13 20:11:01 2012 +0100 -- .../cassandra/cache/ConcurrentLinkedHashCache.java |2 +- 1 files changed, 1 insertions(+), 1 deletions(-) --
[jira] [Updated] (CASSANDRA-4956) exclude system_traces from repair
[ https://issues.apache.org/jira/browse/CASSANDRA-4956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Ellis updated CASSANDRA-4956: -- Assignee: Yuki Morishita Can we generalize this to "don't bother doing validation compactions for RF=1?" > exclude system_traces from repair > - > > Key: CASSANDRA-4956 > URL: https://issues.apache.org/jira/browse/CASSANDRA-4956 > Project: Cassandra > Issue Type: Bug > Components: Core >Affects Versions: 1.2.0 beta 1 >Reporter: Brandon Williams >Assignee: Yuki Morishita >Priority: Trivial > Fix For: 1.2.1 > > > When a repair is issued, the system ks is skipped but not system_traces. -- 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-3974) Per-CF TTL
[
https://issues.apache.org/jira/browse/CASSANDRA-3974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13496414#comment-13496414
]
Kirk True commented on CASSANDRA-3974:
--
Jonathan, we want the ability for clients to explicitly *not* use the column
family default TTL?
> Per-CF TTL
> --
>
> Key: CASSANDRA-3974
> URL: https://issues.apache.org/jira/browse/CASSANDRA-3974
> Project: Cassandra
> Issue Type: New Feature
>Affects Versions: 1.2.0 beta 1
>Reporter: Jonathan Ellis
>Assignee: Kirk True
>Priority: Minor
> Fix For: 1.2.0 rc1
>
> Attachments: trunk-3974.txt, trunk-3974v2.txt, trunk-3974v3.txt,
> trunk-3974v4.txt, trunk-3974v5.txt, trunk-3974v6.txt, trunk-3974v7.txt
>
>
> Per-CF TTL would allow compaction optimizations ("drop an entire sstable's
> worth of expired data") that we can't do with per-column.
--
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-4774) IndexOutOfBoundsException in org.apache.cassandra.gms.Gossiper.sendGossip
[ https://issues.apache.org/jira/browse/CASSANDRA-4774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13496408#comment-13496408 ] Brandon Williams commented on CASSANDRA-4774: - Line 541 in 1.0.0 is in doGossipToSeed, are you certain about the version? I'm not sure what to look at. > IndexOutOfBoundsException in org.apache.cassandra.gms.Gossiper.sendGossip > - > > Key: CASSANDRA-4774 > URL: https://issues.apache.org/jira/browse/CASSANDRA-4774 > Project: Cassandra > Issue Type: Bug >Affects Versions: 1.0.0 > Environment: Saw this when looking through some logs in version 1.0.0 > system was under a lot of load. >Reporter: Benjamin Coverston >Assignee: Brandon Williams >Priority: Minor > > ERROR [GossipTasks:1] 2012-10-06 10:47:48,390 Gossiper.java (line 169) Gossip > error > java.lang.IndexOutOfBoundsException: Index: 13, Size: 5 > at java.util.ArrayList.RangeCheck(ArrayList.java:547) > at java.util.ArrayList.get(ArrayList.java:322) > at org.apache.cassandra.gms.Gossiper.sendGossip(Gossiper.java:541) > at > org.apache.cassandra.gms.Gossiper.doGossipToUnreachableMember(Gossiper.java:575) > at org.apache.cassandra.gms.Gossiper.access$300(Gossiper.java:59) > at org.apache.cassandra.gms.Gossiper$GossipTask.run(Gossiper.java:141) > at > org.apache.cassandra.concurrent.DebuggableScheduledThreadPoolExecutor$UncomplainingRunnable.run(DebuggableScheduledThreadPoolExecutor.java:79) > at > java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441) > at > java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:317) > at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:150) > at > java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$101(ScheduledThreadPoolExecutor.java:98) > at > java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(ScheduledThreadPoolExecutor.java:180) > at > java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:204) > 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 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
[2/3] git commit: Merge branch 'cassandra-1.2.0' into cassandra-1.2
Merge branch 'cassandra-1.2.0' into cassandra-1.2 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/e6e846c1 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/e6e846c1 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/e6e846c1 Branch: refs/heads/trunk Commit: e6e846c134da0740a5e6844c4933d131d43c36e3 Parents: 9a2ea9a 94fa825 Author: Vijay Parthasarathy Authored: Tue Nov 13 10:45:05 2012 -0800 Committer: Vijay Parthasarathy Committed: Tue Nov 13 10:45:05 2012 -0800 -- .../cassandra/cache/ConcurrentLinkedHashCache.java |2 +- 1 files changed, 1 insertions(+), 1 deletions(-) --
[3/3] git commit: update measure to measureDeep patch by vijay reviewed by jbellis for CASSANDRA-4860
update measure to measureDeep
patch by vijay reviewed by jbellis for CASSANDRA-4860
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/94fa8255
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/94fa8255
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/94fa8255
Branch: refs/heads/trunk
Commit: 94fa82558f198489e0eefb0c14392607d5d23224
Parents: 9c5e5dc
Author: Vijay Parthasarathy
Authored: Tue Nov 13 10:42:26 2012 -0800
Committer: Vijay Parthasarathy
Committed: Tue Nov 13 10:42:26 2012 -0800
--
.../cassandra/cache/ConcurrentLinkedHashCache.java |2 +-
1 files changed, 1 insertions(+), 1 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/cassandra/blob/94fa8255/src/java/org/apache/cassandra/cache/ConcurrentLinkedHashCache.java
--
diff --git a/src/java/org/apache/cassandra/cache/ConcurrentLinkedHashCache.java
b/src/java/org/apache/cassandra/cache/ConcurrentLinkedHashCache.java
index 375a7d0..0f992d3 100644
--- a/src/java/org/apache/cassandra/cache/ConcurrentLinkedHashCache.java
+++ b/src/java/org/apache/cassandra/cache/ConcurrentLinkedHashCache.java
@@ -57,7 +57,7 @@ public class ConcurrentLinkedHashCache implements
ICache
{
public int weightOf(K key, V value)
{
-long size = meter.measure(key) + meter.measure(value);
+long size = meter.measureDeep(key) + meter.measureDeep(value);
assert size < Integer.MAX_VALUE : "Serialized size cannot be
more than 2GB/Integer.MAX_VALUE";
return (int) size;
}
[1/3] git commit: Merge branch 'cassandra-1.2' into trunk
Updated Branches: refs/heads/trunk 2548ab590 -> 191c96f1d 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/191c96f1 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/191c96f1 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/191c96f1 Branch: refs/heads/trunk Commit: 191c96f1daef918ba17c3c35c14eed3cedc8ba17 Parents: 2548ab5 e6e846c Author: Vijay Parthasarathy Authored: Tue Nov 13 10:45:59 2012 -0800 Committer: Vijay Parthasarathy Committed: Tue Nov 13 10:45:59 2012 -0800 -- .../cassandra/cache/ConcurrentLinkedHashCache.java |2 +- 1 files changed, 1 insertions(+), 1 deletions(-) --
[jira] [Commented] (CASSANDRA-4813) Problem using BulkOutputFormat while streaming several SSTables simultaneously from a given node.
[ https://issues.apache.org/jira/browse/CASSANDRA-4813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13496406#comment-13496406 ] Yuki Morishita commented on CASSANDRA-4813: --- [~mkjellman] OK, I did test on distributed hadoop cluster with multiple reducers and job succeeded. At first I was getting the same error as yours (java.io.IOException: Broken pipe), but I figured out it was due to the mismatch in partitioner(My cluster was configured as RandomPartitioner and I used Murmur3Partitioner for BOF). Can you check that also? If that's not your case, can you upload Cassandra system.log? > Problem using BulkOutputFormat while streaming several SSTables > simultaneously from a given node. > - > > Key: CASSANDRA-4813 > URL: https://issues.apache.org/jira/browse/CASSANDRA-4813 > Project: Cassandra > Issue Type: Bug >Affects Versions: 1.1.0 > Environment: I am using SLES 10 SP3, Java 6, 4 Cassandra + Hadoop > nodes, 3 Hadoop only nodes (datanodes/tasktrackers), 1 namenode/jobtracker. > The machines used are Six-Core AMD Opteron(tm) Processor 8431, 24 cores and > 33 GB of RAM. I get the issue on both cassandra 1.1.3, 1.1.5 and I am using > Hadoop 0.20.2. >Reporter: Ralph Romanos >Assignee: Yuki Morishita >Priority: Minor > Labels: Bulkoutputformat, Hadoop, SSTables > Fix For: 1.2.0 rc1 > > Attachments: 4813.txt > > > The issue occurs when streaming simultaneously SSTables from the same node to > a cassandra cluster using SSTableloader. It seems to me that Cassandra cannot > handle receiving simultaneously SSTables from the same node. However, when it > receives simultaneously SSTables from two different nodes, everything works > fine. As a consequence, when using BulkOutputFormat to generate SSTables and > stream them to a cassandra cluster, I cannot use more than one reducer per > node otherwise I get a java.io.EOFException in the tasktracker's logs and a > java.io.IOException: Broken pipe in the Cassandra logs. -- 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
[2/2] git commit: update measure to measureDeep patch by vijay reviewed by jbellis for CASSANDRA-4860
update measure to measureDeep
patch by vijay reviewed by jbellis for CASSANDRA-4860
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/94fa8255
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/94fa8255
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/94fa8255
Branch: refs/heads/cassandra-1.2
Commit: 94fa82558f198489e0eefb0c14392607d5d23224
Parents: 9c5e5dc
Author: Vijay Parthasarathy
Authored: Tue Nov 13 10:42:26 2012 -0800
Committer: Vijay Parthasarathy
Committed: Tue Nov 13 10:42:26 2012 -0800
--
.../cassandra/cache/ConcurrentLinkedHashCache.java |2 +-
1 files changed, 1 insertions(+), 1 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/cassandra/blob/94fa8255/src/java/org/apache/cassandra/cache/ConcurrentLinkedHashCache.java
--
diff --git a/src/java/org/apache/cassandra/cache/ConcurrentLinkedHashCache.java
b/src/java/org/apache/cassandra/cache/ConcurrentLinkedHashCache.java
index 375a7d0..0f992d3 100644
--- a/src/java/org/apache/cassandra/cache/ConcurrentLinkedHashCache.java
+++ b/src/java/org/apache/cassandra/cache/ConcurrentLinkedHashCache.java
@@ -57,7 +57,7 @@ public class ConcurrentLinkedHashCache implements
ICache
{
public int weightOf(K key, V value)
{
-long size = meter.measure(key) + meter.measure(value);
+long size = meter.measureDeep(key) + meter.measureDeep(value);
assert size < Integer.MAX_VALUE : "Serialized size cannot be
more than 2GB/Integer.MAX_VALUE";
return (int) size;
}
[jira] [Updated] (CASSANDRA-4347) IP change of node requires assassinate to really remove old IP
[ https://issues.apache.org/jira/browse/CASSANDRA-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brandon Williams updated CASSANDRA-4347: Comment: was deleted (was: I am on vacation till 8/17. For ERP DBA related issues contact Neeren at 650 279-6155. For escalations contact Kevin Railsback. Thanks, Harpreet Kaur ) > IP change of node requires assassinate to really remove old IP > -- > > Key: CASSANDRA-4347 > URL: https://issues.apache.org/jira/browse/CASSANDRA-4347 > Project: Cassandra > Issue Type: Bug >Affects Versions: 1.0.10 > Environment: RHEL6, 64bit >Reporter: Karl Mueller >Assignee: Brandon Williams >Priority: Minor > Attachments: 4347.txt, dev-cass-post-assassinate-gossipinfo.txt, > kaos-cass00-gossipinfo-postmove.txt, kaos-cass03-gossipinfo-postmove.txt, > LocationInfo-hd-279-Data.db > > > In changing the IP addresses of nodes one-by-one, the node successfully moves > itself and its token. Everything works properly. > However, the node which had its IP changed (but NOT other nodes in the ring) > continues to have some type of state associated with the old IP and produces > log messages like this: > INFO [GossipStage:1] 2012-06-15 15:25:01,490 Gossiper.java (line 838) Node > /10.12.9.157 is now part of the cluster > INFO [GossipStage:1] 2012-06-15 15:25:01,490 Gossiper.java (line 804) > InetAddress /10.12.9.157 is now UP > INFO [GossipStage:1] 2012-06-15 15:25:01,491 StorageService.java (line 1017) > Nodes /10.12.9.157 and dev-cass01.sv.walmartlabs.com/10.93.15.11 have the > same token 113427455640312821154458202477256070484. Ignoring /10.12.9.157 > INFO [GossipTasks:1] 2012-06-15 15:25:11,373 Gossiper.java (line 818) > InetAddress /10.12.9.157 is now dead. > INFO [GossipTasks:1] 2012-06-15 15:25:32,380 Gossiper.java (line 632) > FatClient /10.12.9.157 has been silent for 3ms, removing from gossip > INFO [GossipStage:1] 2012-06-15 15:26:32,490 Gossiper.java (line 838) Node > /10.12.9.157 is now part of the cluster > INFO [GossipStage:1] 2012-06-15 15:26:32,491 Gossiper.java (line 804) > InetAddress /10.12.9.157 is now UP > INFO [GossipStage:1] 2012-06-15 15:26:32,491 StorageService.java (line 1017) > Nodes /10.12.9.157 and dev-cass01.sv.walmartlabs.com/10.93.15.11 have the > same token 113427455640312821154458202477256070484. Ignoring /10.12.9.157 > INFO [GossipTasks:1] 2012-06-15 15:26:42,402 Gossiper.java (line 818) > InetAddress /10.12.9.157 is now dead. > INFO [GossipTasks:1] 2012-06-15 15:27:03,410 Gossiper.java (line 632) > FatClient /10.12.9.157 has been silent for 3ms, removing from gossip > INFO [GossipStage:1] 2012-06-15 15:28:04,533 Gossiper.java (line 838) Node > /10.12.9.157 is now part of the cluster > Other nodes do NOT have the old IP showing up in logs. It's only the node > that moved. > The old IP doesn't show up in ring anywhere or in any other fashion. The > cluster seems to be fully operational, so I think it's just a cleanup issue. -- 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: update measure to measureDeep patch by vijay reviewed by jbellis for CASSANDRA-4860
Updated Branches:
refs/heads/cassandra-1.2.0 9c5e5dc0d -> 94fa82558
update measure to measureDeep
patch by vijay reviewed by jbellis for CASSANDRA-4860
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/94fa8255
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/94fa8255
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/94fa8255
Branch: refs/heads/cassandra-1.2.0
Commit: 94fa82558f198489e0eefb0c14392607d5d23224
Parents: 9c5e5dc
Author: Vijay Parthasarathy
Authored: Tue Nov 13 10:42:26 2012 -0800
Committer: Vijay Parthasarathy
Committed: Tue Nov 13 10:42:26 2012 -0800
--
.../cassandra/cache/ConcurrentLinkedHashCache.java |2 +-
1 files changed, 1 insertions(+), 1 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/cassandra/blob/94fa8255/src/java/org/apache/cassandra/cache/ConcurrentLinkedHashCache.java
--
diff --git a/src/java/org/apache/cassandra/cache/ConcurrentLinkedHashCache.java
b/src/java/org/apache/cassandra/cache/ConcurrentLinkedHashCache.java
index 375a7d0..0f992d3 100644
--- a/src/java/org/apache/cassandra/cache/ConcurrentLinkedHashCache.java
+++ b/src/java/org/apache/cassandra/cache/ConcurrentLinkedHashCache.java
@@ -57,7 +57,7 @@ public class ConcurrentLinkedHashCache implements
ICache
{
public int weightOf(K key, V value)
{
-long size = meter.measure(key) + meter.measure(value);
+long size = meter.measureDeep(key) + meter.measureDeep(value);
assert size < Integer.MAX_VALUE : "Serialized size cannot be
more than 2GB/Integer.MAX_VALUE";
return (int) size;
}
[jira] [Resolved] (CASSANDRA-4591) Pass -umask option to jsvc
[ https://issues.apache.org/jira/browse/CASSANDRA-4591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brandon Williams resolved CASSANDRA-4591. - Resolution: Later Maybe we can pick this back up when most platforms will have a compatible version. > Pass -umask option to jsvc > -- > > Key: CASSANDRA-4591 > URL: https://issues.apache.org/jira/browse/CASSANDRA-4591 > Project: Cassandra > Issue Type: Improvement > Components: Packaging >Affects Versions: 1.1.4 >Reporter: Nick Bailey >Assignee: Nick Bailey >Priority: Minor > Fix For: 1.1.7 > > > Currently jsvc defaults to a very restrictive umask. This makes it hard for > external tools to work with cassandra data files (snapshots). It would be > useful to pass in a -umask option to jsvc with slightly less restrictive > permissions (just adding group read permissions). > It should just be passing 'umask 0037' (u=rwx,g=r,o=), in the debian init > script. -- 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-4591) Pass -umask option to jsvc
[ https://issues.apache.org/jira/browse/CASSANDRA-4591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brandon Williams updated CASSANDRA-4591: Fix Version/s: (was: 1.1.7) > Pass -umask option to jsvc > -- > > Key: CASSANDRA-4591 > URL: https://issues.apache.org/jira/browse/CASSANDRA-4591 > Project: Cassandra > Issue Type: Improvement > Components: Packaging >Affects Versions: 1.1.4 >Reporter: Nick Bailey >Assignee: Nick Bailey >Priority: Minor > > Currently jsvc defaults to a very restrictive umask. This makes it hard for > external tools to work with cassandra data files (snapshots). It would be > useful to pass in a -umask option to jsvc with slightly less restrictive > permissions (just adding group read permissions). > It should just be passing 'umask 0037' (u=rwx,g=r,o=), in the debian init > script. -- 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: update measure to measureDeep patch by vijay reviewed by jbellis for CASSANDRA-4860
Updated Branches:
refs/heads/cassandra-1.1 a2ca30e79 -> 8d6e43f34
update measure to measureDeep
patch by vijay reviewed by jbellis for CASSANDRA-4860
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/8d6e43f3
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/8d6e43f3
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/8d6e43f3
Branch: refs/heads/cassandra-1.1
Commit: 8d6e43f34f4b2507fe294ec08e7a5dafe2a9928e
Parents: a2ca30e
Author: Vijay Parthasarathy
Authored: Tue Nov 13 10:28:50 2012 -0800
Committer: Vijay Parthasarathy
Committed: Tue Nov 13 10:28:50 2012 -0800
--
.../cache/ConcurrentLinkedHashCacheProvider.java |2 +-
1 files changed, 1 insertions(+), 1 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/cassandra/blob/8d6e43f3/src/java/org/apache/cassandra/cache/ConcurrentLinkedHashCacheProvider.java
--
diff --git
a/src/java/org/apache/cassandra/cache/ConcurrentLinkedHashCacheProvider.java
b/src/java/org/apache/cassandra/cache/ConcurrentLinkedHashCacheProvider.java
index cab3df5..691eab6 100644
--- a/src/java/org/apache/cassandra/cache/ConcurrentLinkedHashCacheProvider.java
+++ b/src/java/org/apache/cassandra/cache/ConcurrentLinkedHashCacheProvider.java
@@ -42,7 +42,7 @@ public class ConcurrentLinkedHashCacheProvider implements
IRowCacheProvider
public int weightOf(IRowCacheEntry value)
{
-return (int) Math.min(meter.measure(value), Integer.MAX_VALUE);
+return (int) Math.min(meter.measureDeep(value),
Integer.MAX_VALUE);
}
};
}
[jira] [Commented] (CASSANDRA-4912) BulkOutputFormat should support Hadoop MultipleOutput
[ https://issues.apache.org/jira/browse/CASSANDRA-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13496397#comment-13496397 ] Michael Kjellman commented on CASSANDRA-4912: - yeah sorry wasn't originally intended as a functional example. i'll create one that does something now. > BulkOutputFormat should support Hadoop MultipleOutput > - > > Key: CASSANDRA-4912 > URL: https://issues.apache.org/jira/browse/CASSANDRA-4912 > Project: Cassandra > Issue Type: New Feature > Components: Hadoop >Affects Versions: 1.2.0 beta 1, 1.2.0 beta 2 >Reporter: Michael Kjellman > Attachments: 4912.txt, Example.java > > > Much like CASSANDRA-4208 BOF should support outputting to Multiple Column > Families. The current approach takken in the patch for COF results in only > one stream being sent. -- 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-4912) BulkOutputFormat should support Hadoop MultipleOutput
[ https://issues.apache.org/jira/browse/CASSANDRA-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13496392#comment-13496392 ] Brandon Williams commented on CASSANDRA-4912: - I still get a slew of errors trying to compile this. An obvious one is in ReducerToCassandra.reduce where 'val' is never defined, but there are many others. > BulkOutputFormat should support Hadoop MultipleOutput > - > > Key: CASSANDRA-4912 > URL: https://issues.apache.org/jira/browse/CASSANDRA-4912 > Project: Cassandra > Issue Type: New Feature > Components: Hadoop >Affects Versions: 1.2.0 beta 1, 1.2.0 beta 2 >Reporter: Michael Kjellman > Attachments: 4912.txt, Example.java > > > Much like CASSANDRA-4208 BOF should support outputting to Multiple Column > Families. The current approach takken in the patch for COF results in only > one stream being sent. -- 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-4912) BulkOutputFormat should support Hadoop MultipleOutput
[ https://issues.apache.org/jira/browse/CASSANDRA-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Kjellman updated CASSANDRA-4912: Attachment: (was: Example.java) > BulkOutputFormat should support Hadoop MultipleOutput > - > > Key: CASSANDRA-4912 > URL: https://issues.apache.org/jira/browse/CASSANDRA-4912 > Project: Cassandra > Issue Type: New Feature > Components: Hadoop >Affects Versions: 1.2.0 beta 1, 1.2.0 beta 2 >Reporter: Michael Kjellman > Attachments: 4912.txt, Example.java > > > Much like CASSANDRA-4208 BOF should support outputting to Multiple Column > Families. The current approach takken in the patch for COF results in only > one stream being sent. -- 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-4912) BulkOutputFormat should support Hadoop MultipleOutput
[ https://issues.apache.org/jira/browse/CASSANDRA-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Kjellman updated CASSANDRA-4912: Attachment: Example.java > BulkOutputFormat should support Hadoop MultipleOutput > - > > Key: CASSANDRA-4912 > URL: https://issues.apache.org/jira/browse/CASSANDRA-4912 > Project: Cassandra > Issue Type: New Feature > Components: Hadoop >Affects Versions: 1.2.0 beta 1, 1.2.0 beta 2 >Reporter: Michael Kjellman > Attachments: 4912.txt, Example.java > > > Much like CASSANDRA-4208 BOF should support outputting to Multiple Column > Families. The current approach takken in the patch for COF results in only > one stream being sent. -- 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-4912) BulkOutputFormat should support Hadoop MultipleOutput
[ https://issues.apache.org/jira/browse/CASSANDRA-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13496382#comment-13496382 ] Michael Kjellman commented on CASSANDRA-4912: - Updated example with imports. > BulkOutputFormat should support Hadoop MultipleOutput > - > > Key: CASSANDRA-4912 > URL: https://issues.apache.org/jira/browse/CASSANDRA-4912 > Project: Cassandra > Issue Type: New Feature > Components: Hadoop >Affects Versions: 1.2.0 beta 1, 1.2.0 beta 2 >Reporter: Michael Kjellman > Attachments: 4912.txt, Example.java > > > Much like CASSANDRA-4208 BOF should support outputting to Multiple Column > Families. The current approach takken in the patch for COF results in only > one stream being sent. -- 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-4347) IP change of node requires assassinate to really remove old IP
[ https://issues.apache.org/jira/browse/CASSANDRA-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13496384#comment-13496384 ] Harpreet Kaur commented on CASSANDRA-4347: -- I am on vacation till 8/17. For ERP DBA related issues contact Neeren at 650 279-6155. For escalations contact Kevin Railsback. Thanks, Harpreet Kaur > IP change of node requires assassinate to really remove old IP > -- > > Key: CASSANDRA-4347 > URL: https://issues.apache.org/jira/browse/CASSANDRA-4347 > Project: Cassandra > Issue Type: Bug >Affects Versions: 1.0.10 > Environment: RHEL6, 64bit >Reporter: Karl Mueller >Assignee: Brandon Williams >Priority: Minor > Attachments: 4347.txt, dev-cass-post-assassinate-gossipinfo.txt, > kaos-cass00-gossipinfo-postmove.txt, kaos-cass03-gossipinfo-postmove.txt, > LocationInfo-hd-279-Data.db > > > In changing the IP addresses of nodes one-by-one, the node successfully moves > itself and its token. Everything works properly. > However, the node which had its IP changed (but NOT other nodes in the ring) > continues to have some type of state associated with the old IP and produces > log messages like this: > INFO [GossipStage:1] 2012-06-15 15:25:01,490 Gossiper.java (line 838) Node > /10.12.9.157 is now part of the cluster > INFO [GossipStage:1] 2012-06-15 15:25:01,490 Gossiper.java (line 804) > InetAddress /10.12.9.157 is now UP > INFO [GossipStage:1] 2012-06-15 15:25:01,491 StorageService.java (line 1017) > Nodes /10.12.9.157 and dev-cass01.sv.walmartlabs.com/10.93.15.11 have the > same token 113427455640312821154458202477256070484. Ignoring /10.12.9.157 > INFO [GossipTasks:1] 2012-06-15 15:25:11,373 Gossiper.java (line 818) > InetAddress /10.12.9.157 is now dead. > INFO [GossipTasks:1] 2012-06-15 15:25:32,380 Gossiper.java (line 632) > FatClient /10.12.9.157 has been silent for 3ms, removing from gossip > INFO [GossipStage:1] 2012-06-15 15:26:32,490 Gossiper.java (line 838) Node > /10.12.9.157 is now part of the cluster > INFO [GossipStage:1] 2012-06-15 15:26:32,491 Gossiper.java (line 804) > InetAddress /10.12.9.157 is now UP > INFO [GossipStage:1] 2012-06-15 15:26:32,491 StorageService.java (line 1017) > Nodes /10.12.9.157 and dev-cass01.sv.walmartlabs.com/10.93.15.11 have the > same token 113427455640312821154458202477256070484. Ignoring /10.12.9.157 > INFO [GossipTasks:1] 2012-06-15 15:26:42,402 Gossiper.java (line 818) > InetAddress /10.12.9.157 is now dead. > INFO [GossipTasks:1] 2012-06-15 15:27:03,410 Gossiper.java (line 632) > FatClient /10.12.9.157 has been silent for 3ms, removing from gossip > INFO [GossipStage:1] 2012-06-15 15:28:04,533 Gossiper.java (line 838) Node > /10.12.9.157 is now part of the cluster > Other nodes do NOT have the old IP showing up in logs. It's only the node > that moved. > The old IP doesn't show up in ring anywhere or in any other fashion. The > cluster seems to be fully operational, so I think it's just a cleanup issue. -- 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-4347) IP change of node requires assassinate to really remove old IP
[ https://issues.apache.org/jira/browse/CASSANDRA-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brandon Williams resolved CASSANDRA-4347. - Resolution: Won't Fix Closing since there isn't going to be a 1.0.13 release and this doesn't exist in 1.1+ > IP change of node requires assassinate to really remove old IP > -- > > Key: CASSANDRA-4347 > URL: https://issues.apache.org/jira/browse/CASSANDRA-4347 > Project: Cassandra > Issue Type: Bug >Affects Versions: 1.0.10 > Environment: RHEL6, 64bit >Reporter: Karl Mueller >Assignee: Brandon Williams >Priority: Minor > Attachments: 4347.txt, dev-cass-post-assassinate-gossipinfo.txt, > kaos-cass00-gossipinfo-postmove.txt, kaos-cass03-gossipinfo-postmove.txt, > LocationInfo-hd-279-Data.db > > > In changing the IP addresses of nodes one-by-one, the node successfully moves > itself and its token. Everything works properly. > However, the node which had its IP changed (but NOT other nodes in the ring) > continues to have some type of state associated with the old IP and produces > log messages like this: > INFO [GossipStage:1] 2012-06-15 15:25:01,490 Gossiper.java (line 838) Node > /10.12.9.157 is now part of the cluster > INFO [GossipStage:1] 2012-06-15 15:25:01,490 Gossiper.java (line 804) > InetAddress /10.12.9.157 is now UP > INFO [GossipStage:1] 2012-06-15 15:25:01,491 StorageService.java (line 1017) > Nodes /10.12.9.157 and dev-cass01.sv.walmartlabs.com/10.93.15.11 have the > same token 113427455640312821154458202477256070484. Ignoring /10.12.9.157 > INFO [GossipTasks:1] 2012-06-15 15:25:11,373 Gossiper.java (line 818) > InetAddress /10.12.9.157 is now dead. > INFO [GossipTasks:1] 2012-06-15 15:25:32,380 Gossiper.java (line 632) > FatClient /10.12.9.157 has been silent for 3ms, removing from gossip > INFO [GossipStage:1] 2012-06-15 15:26:32,490 Gossiper.java (line 838) Node > /10.12.9.157 is now part of the cluster > INFO [GossipStage:1] 2012-06-15 15:26:32,491 Gossiper.java (line 804) > InetAddress /10.12.9.157 is now UP > INFO [GossipStage:1] 2012-06-15 15:26:32,491 StorageService.java (line 1017) > Nodes /10.12.9.157 and dev-cass01.sv.walmartlabs.com/10.93.15.11 have the > same token 113427455640312821154458202477256070484. Ignoring /10.12.9.157 > INFO [GossipTasks:1] 2012-06-15 15:26:42,402 Gossiper.java (line 818) > InetAddress /10.12.9.157 is now dead. > INFO [GossipTasks:1] 2012-06-15 15:27:03,410 Gossiper.java (line 632) > FatClient /10.12.9.157 has been silent for 3ms, removing from gossip > INFO [GossipStage:1] 2012-06-15 15:28:04,533 Gossiper.java (line 838) Node > /10.12.9.157 is now part of the cluster > Other nodes do NOT have the old IP showing up in logs. It's only the node > that moved. > The old IP doesn't show up in ring anywhere or in any other fashion. The > cluster seems to be fully operational, so I think it's just a cleanup issue. -- 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-4912) BulkOutputFormat should support Hadoop MultipleOutput
[ https://issues.apache.org/jira/browse/CASSANDRA-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13496379#comment-13496379 ] Brandon Williams commented on CASSANDRA-4912: - Do you have an Example.java that contains all the imports? > BulkOutputFormat should support Hadoop MultipleOutput > - > > Key: CASSANDRA-4912 > URL: https://issues.apache.org/jira/browse/CASSANDRA-4912 > Project: Cassandra > Issue Type: New Feature > Components: Hadoop >Affects Versions: 1.2.0 beta 1, 1.2.0 beta 2 >Reporter: Michael Kjellman > Attachments: 4912.txt, Example.java > > > Much like CASSANDRA-4208 BOF should support outputting to Multiple Column > Families. The current approach takken in the patch for COF results in only > one stream being sent. -- 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-4733) Last written key >= current key exception when streaming
[
https://issues.apache.org/jira/browse/CASSANDRA-4733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Brandon Williams resolved CASSANDRA-4733.
-
Resolution: Cannot Reproduce
Fix Version/s: 1.2.0 beta 2
Not sure what this fixed this, but I can't repro any longer.
> Last written key >= current key exception when streaming
>
>
> Key: CASSANDRA-4733
> URL: https://issues.apache.org/jira/browse/CASSANDRA-4733
> Project: Cassandra
> Issue Type: Bug
> Components: Core
>Affects Versions: 1.2.0 beta 1
>Reporter: Brandon Williams
>Assignee: Yuki Morishita
> Fix For: 1.2.0 beta 2
>
>
> {noformat}
> ERROR 16:52:56,260 Exception in thread Thread[Streaming to
> /10.179.111.137:1,5,main]
> java.lang.RuntimeException: java.io.IOException: Connection reset by peer
> 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(ThreadPoolExecutor.java:886)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at java.lang.Thread.run(Thread.java:662)
> Caused by: java.io.IOException: Connection reset by peer
> at sun.nio.ch.FileDispatcher.write0(Native Method)
> at sun.nio.ch.SocketDispatcher.write(SocketDispatcher.java:29)
> at sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:72)
> at sun.nio.ch.IOUtil.write(IOUtil.java:43)
> at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:334)
> at java.nio.channels.Channels.writeFullyImpl(Channels.java:59)
> at java.nio.channels.Channels.writeFully(Channels.java:81)
> at java.nio.channels.Channels.access$000(Channels.java:47)
> at java.nio.channels.Channels$1.write(Channels.java:155)
> at
> com.ning.compress.lzf.ChunkEncoder.encodeAndWriteChunk(ChunkEncoder.java:133)
> at
> com.ning.compress.lzf.LZFOutputStream.writeCompressedBlock(LZFOutputStream.java:203)
> at
> com.ning.compress.lzf.LZFOutputStream.write(LZFOutputStream.java:97)
> at
> org.apache.cassandra.streaming.FileStreamTask.write(FileStreamTask.java:218)
> at
> org.apache.cassandra.streaming.FileStreamTask.stream(FileStreamTask.java:164)
> at
> org.apache.cassandra.streaming.FileStreamTask.runMayThrow(FileStreamTask.java:91)
> at
> org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:28)
> ... 3 more
> ERROR 16:53:03,951 Exception in thread Thread[Thread-11,5,main]
> java.lang.RuntimeException: Last written key
> DecoratedKey(113424593524874987650593774422007331058, 3036303936343535) >=
> current key DecoratedKey(59229538317742990547810678738983628664,
> 3036313133373139) writing into
> /var/lib/cassandra/data/Keyspace1-Standard1-tmp-ia-95-Data.db
> at
> org.apache.cassandra.io.sstable.SSTableWriter.beforeAppend(SSTableWriter.java:132)
> at
> org.apache.cassandra.io.sstable.SSTableWriter.appendFromStream(SSTableWriter.java:208)
> at
> org.apache.cassandra.streaming.IncomingStreamReader.streamIn(IncomingStreamReader.java:164)
> at
> org.apache.cassandra.streaming.IncomingStreamReader.read(IncomingStreamReader.java:107)
> at
> org.apache.cassandra.net.IncomingTcpConnection.stream(IncomingTcpConnection.java:220)
> at
> org.apache.cassandra.net.IncomingTcpConnection.handleStream(IncomingTcpConnection.java:165)
> at
> org.apache.cassandra.net.IncomingTcpConnection.run(IncomingTcpConnection.java:65)
> {noformat}
> I didn't do anything fancy here, just inserted about 6M keys at rf=2, then
> ran repair and got this.
--
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-4880) Endless loop flushing+compacting system/schema_keyspaces and system/schema_columnfamilies
[ https://issues.apache.org/jira/browse/CASSANDRA-4880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brandon Williams updated CASSANDRA-4880: Affects Version/s: 1.2.0 beta 1 > Endless loop flushing+compacting system/schema_keyspaces and > system/schema_columnfamilies > - > > Key: CASSANDRA-4880 > URL: https://issues.apache.org/jira/browse/CASSANDRA-4880 > Project: Cassandra > Issue Type: Bug > Components: Core >Affects Versions: 1.1.6, 1.2.0 beta 1 > Environment: Linux x86_64 3.4.9, sun-jdk 1.6.0_33 >Reporter: Mina Naguib >Assignee: Pavel Yaskevich > Fix For: 1.1.7, 1.2.0 rc1 > > > After upgrading a node from 1.1.2 to 1.1.6, the startup sequence entered a > loop as seen here: > http://mina.naguib.ca/misc/cassandra_116_startup_loop.txt > Stopping and starting the node entered the same loop. > Reverting back to 1.1.2 started successfully. -- 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-4880) Endless loop flushing+compacting system/schema_keyspaces and system/schema_columnfamilies
[ https://issues.apache.org/jira/browse/CASSANDRA-4880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brandon Williams updated CASSANDRA-4880: Fix Version/s: 1.2.0 rc1 1.1.7 > Endless loop flushing+compacting system/schema_keyspaces and > system/schema_columnfamilies > - > > Key: CASSANDRA-4880 > URL: https://issues.apache.org/jira/browse/CASSANDRA-4880 > Project: Cassandra > Issue Type: Bug > Components: Core >Affects Versions: 1.1.6, 1.2.0 beta 1 > Environment: Linux x86_64 3.4.9, sun-jdk 1.6.0_33 >Reporter: Mina Naguib >Assignee: Pavel Yaskevich > Fix For: 1.1.7, 1.2.0 rc1 > > > After upgrading a node from 1.1.2 to 1.1.6, the startup sequence entered a > loop as seen here: > http://mina.naguib.ca/misc/cassandra_116_startup_loop.txt > Stopping and starting the node entered the same loop. > Reverting back to 1.1.2 started successfully. -- 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-4956) exclude system_traces from repair
Brandon Williams created CASSANDRA-4956: --- Summary: exclude system_traces from repair Key: CASSANDRA-4956 URL: https://issues.apache.org/jira/browse/CASSANDRA-4956 Project: Cassandra Issue Type: Bug Components: Core Affects Versions: 1.2.0 beta 1 Reporter: Brandon Williams Priority: Trivial Fix For: 1.2.1 When a repair is issued, the system ks is skipped but not system_traces. -- 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
