[1/3] git commit: fix build
Repository: cassandra Updated Branches: refs/heads/trunk ff88f2376 - 7879b2fe9 fix build Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/561f6ef5 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/561f6ef5 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/561f6ef5 Branch: refs/heads/trunk Commit: 561f6ef5cfb50878dff2ea3ceb182b48f400a23e Parents: e9d0214 Author: Jake Luciani j...@apache.org Authored: Fri Aug 15 15:15:09 2014 -0400 Committer: Jake Luciani j...@apache.org Committed: Fri Aug 15 15:15:09 2014 -0400 -- .../apache/cassandra/io/util/BufferedRandomAccessFileTest.java | 6 -- 1 file changed, 4 insertions(+), 2 deletions(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/561f6ef5/test/unit/org/apache/cassandra/io/util/BufferedRandomAccessFileTest.java -- diff --git a/test/unit/org/apache/cassandra/io/util/BufferedRandomAccessFileTest.java b/test/unit/org/apache/cassandra/io/util/BufferedRandomAccessFileTest.java index cfabf62..7dbbdc2 100644 --- a/test/unit/org/apache/cassandra/io/util/BufferedRandomAccessFileTest.java +++ b/test/unit/org/apache/cassandra/io/util/BufferedRandomAccessFileTest.java @@ -530,6 +530,8 @@ public class BufferedRandomAccessFileTest { //see https://issues.apache.org/jira/browse/CASSANDRA-7756 +final FileCacheService.CacheKey cacheKey = new FileCacheService.CacheKey(); + final int THREAD_COUNT = 40; ExecutorService executorService = Executors.newFixedThreadPool(THREAD_COUNT); @@ -550,8 +552,8 @@ public class BufferedRandomAccessFileTest RandomAccessReader r2 = RandomAccessReader.open(w2); -FileCacheService.instance.put(r1); -FileCacheService.instance.put(r2); +FileCacheService.instance.put(cacheKey, r1); +FileCacheService.instance.put(cacheKey, r2); final CountDownLatch finished = new CountDownLatch(THREAD_COUNT); final AtomicBoolean hadError = new AtomicBoolean(false);
[1/3] git commit: Fix build
Repository: cassandra Updated Branches: refs/heads/trunk bf4c76e47 - 277ca64c7 Fix build Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/9f1e9575 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/9f1e9575 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/9f1e9575 Branch: refs/heads/trunk Commit: 9f1e9575cb946cf2aa4efd403606474e070c3cc9 Parents: 2d21160 Author: Sylvain Lebresne sylv...@datastax.com Authored: Tue Aug 5 15:47:35 2014 +0200 Committer: Sylvain Lebresne sylv...@datastax.com Committed: Tue Aug 5 15:47:35 2014 +0200 -- src/java/org/apache/cassandra/hadoop/cql3/CqlConfigHelper.java | 5 + 1 file changed, 5 insertions(+) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/9f1e9575/src/java/org/apache/cassandra/hadoop/cql3/CqlConfigHelper.java -- diff --git a/src/java/org/apache/cassandra/hadoop/cql3/CqlConfigHelper.java b/src/java/org/apache/cassandra/hadoop/cql3/CqlConfigHelper.java index bd4598f..432cf9e 100644 --- a/src/java/org/apache/cassandra/hadoop/cql3/CqlConfigHelper.java +++ b/src/java/org/apache/cassandra/hadoop/cql3/CqlConfigHelper.java @@ -520,6 +520,11 @@ public class CqlConfigHelper } @Override +public void onSuspected(Host host) +{ +} + +@Override public HostDistance distance(Host host) { if (host.getAddress().getHostName().equals(stickHost))
[1/3] git commit: fix build
Repository: cassandra Updated Branches: refs/heads/cassandra-2.1 622ae5085 - 9faf90574 refs/heads/trunk efe57f230 - 26cd4408f fix build Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/9faf9057 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/9faf9057 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/9faf9057 Branch: refs/heads/cassandra-2.1 Commit: 9faf905743696264ef0fdf6f962378ce95829e50 Parents: 622ae50 Author: Brandon Williams brandonwilli...@apache.org Authored: Tue Aug 5 10:35:30 2014 -0500 Committer: Brandon Williams brandonwilli...@apache.org Committed: Tue Aug 5 10:35:30 2014 -0500 -- src/java/org/apache/cassandra/hadoop/cql3/CqlConfigHelper.java | 1 - 1 file changed, 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/9faf9057/src/java/org/apache/cassandra/hadoop/cql3/CqlConfigHelper.java -- diff --git a/src/java/org/apache/cassandra/hadoop/cql3/CqlConfigHelper.java b/src/java/org/apache/cassandra/hadoop/cql3/CqlConfigHelper.java index 7a5fd47..af6e99e 100644 --- a/src/java/org/apache/cassandra/hadoop/cql3/CqlConfigHelper.java +++ b/src/java/org/apache/cassandra/hadoop/cql3/CqlConfigHelper.java @@ -518,7 +518,6 @@ public class CqlConfigHelper liveRemoteHosts.add(host); } -@Override public void onSuspected(Host host) { }
[1/3] git commit: fix build, remove dead method again
Repository: cassandra Updated Branches: refs/heads/cassandra-2.1 7e71d01a0 - f75988150 refs/heads/trunk 7dd320c9e - 8625661d5 fix build, remove dead method again Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/f7598815 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/f7598815 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/f7598815 Branch: refs/heads/cassandra-2.1 Commit: f7598815059bad05b6c6a4af53c8f5f5c8800a04 Parents: 7e71d01 Author: Brandon Williams brandonwilli...@apache.org Authored: Tue Aug 5 14:05:21 2014 -0500 Committer: Brandon Williams brandonwilli...@apache.org Committed: Tue Aug 5 14:05:21 2014 -0500 -- src/java/org/apache/cassandra/hadoop/cql3/CqlConfigHelper.java | 5 - 1 file changed, 5 deletions(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/f7598815/src/java/org/apache/cassandra/hadoop/cql3/CqlConfigHelper.java -- diff --git a/src/java/org/apache/cassandra/hadoop/cql3/CqlConfigHelper.java b/src/java/org/apache/cassandra/hadoop/cql3/CqlConfigHelper.java index 7a5fd47..741f599 100644 --- a/src/java/org/apache/cassandra/hadoop/cql3/CqlConfigHelper.java +++ b/src/java/org/apache/cassandra/hadoop/cql3/CqlConfigHelper.java @@ -519,11 +519,6 @@ public class CqlConfigHelper } @Override -public void onSuspected(Host host) -{ -} - -@Override public HostDistance distance(Host host) { if (host.getAddress().getHostName().equals(stickHost))
[1/3] git commit: fix build
Updated Branches: refs/heads/cassandra-2.0 3a4d6beb4 - dc71d2200 refs/heads/trunk 2d6ab6fb5 - 82c0094a8 fix build Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/dc71d220 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/dc71d220 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/dc71d220 Branch: refs/heads/cassandra-2.0 Commit: dc71d2200339f9cf781346afc4b95b60dd3cd88f Parents: 3a4d6be Author: Brandon Williams brandonwilli...@apache.org Authored: Tue Nov 5 15:33:49 2013 -0600 Committer: Brandon Williams brandonwilli...@apache.org Committed: Tue Nov 5 15:33:49 2013 -0600 -- .../cassandra/hadoop/AbstractColumnFamilyInputFormat.java | 9 ++--- 1 file changed, 6 insertions(+), 3 deletions(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/dc71d220/src/java/org/apache/cassandra/hadoop/AbstractColumnFamilyInputFormat.java -- diff --git a/src/java/org/apache/cassandra/hadoop/AbstractColumnFamilyInputFormat.java b/src/java/org/apache/cassandra/hadoop/AbstractColumnFamilyInputFormat.java index 274e43f..7876b62 100644 --- a/src/java/org/apache/cassandra/hadoop/AbstractColumnFamilyInputFormat.java +++ b/src/java/org/apache/cassandra/hadoop/AbstractColumnFamilyInputFormat.java @@ -95,9 +95,12 @@ public abstract class AbstractColumnFamilyInputFormatK, Y extends InputFormat { logger.debug(Creating authenticated client for CF input format); TTransport transport; -try { -transport = ConfigHelper.getClientTransportFactory(conf).openTransport(location, port, conf); -} catch (Exception e) { +try +{ +transport = ConfigHelper.getClientTransportFactory(conf).openTransport(location, port); +} +catch (Exception e) +{ throw new TTransportException(Failed to open a transport to + location + : + port + ., e); } TProtocol binaryProtocol = new TBinaryProtocol(transport, true, true);
[1/3] git commit: fix build
Updated Branches: refs/heads/cassandra-1.2 241c70a37 - 102c3c123 refs/heads/cassandra-2.0 21ab8f81a - b557f7e37 fix build Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/102c3c12 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/102c3c12 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/102c3c12 Branch: refs/heads/cassandra-1.2 Commit: 102c3c123ed52bff6d2e2418bb393b9fdc427f7e Parents: 241c70a Author: Jonathan Ellis jbel...@apache.org Authored: Tue Oct 8 12:04:34 2013 -0500 Committer: Jonathan Ellis jbel...@apache.org Committed: Tue Oct 8 12:04:34 2013 -0500 -- .../apache/cassandra/db/index/composites/CompositesSearcher.java | 2 +- src/java/org/apache/cassandra/db/index/keys/KeysSearcher.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/102c3c12/src/java/org/apache/cassandra/db/index/composites/CompositesSearcher.java -- diff --git a/src/java/org/apache/cassandra/db/index/composites/CompositesSearcher.java b/src/java/org/apache/cassandra/db/index/composites/CompositesSearcher.java index 82e227f..5ab1df6 100644 --- a/src/java/org/apache/cassandra/db/index/composites/CompositesSearcher.java +++ b/src/java/org/apache/cassandra/db/index/composites/CompositesSearcher.java @@ -56,7 +56,7 @@ public class CompositesSearcher extends SecondaryIndexSearcher { IndexExpression best = null; int bestMeanCount = Integer.MAX_VALUE; -MapSecondaryIndex, Integer candidates = new HashMap(); +MapSecondaryIndex, Integer candidates = new HashMapSecondaryIndex, Integer(); for (IndexExpression expression : clause) { http://git-wip-us.apache.org/repos/asf/cassandra/blob/102c3c12/src/java/org/apache/cassandra/db/index/keys/KeysSearcher.java -- diff --git a/src/java/org/apache/cassandra/db/index/keys/KeysSearcher.java b/src/java/org/apache/cassandra/db/index/keys/KeysSearcher.java index 7d23e6c..bed6104 100644 --- a/src/java/org/apache/cassandra/db/index/keys/KeysSearcher.java +++ b/src/java/org/apache/cassandra/db/index/keys/KeysSearcher.java @@ -52,7 +52,7 @@ public class KeysSearcher extends SecondaryIndexSearcher { IndexExpression best = null; int bestMeanCount = Integer.MAX_VALUE; -MapSecondaryIndex, Integer candidates = new HashMap(); +MapSecondaryIndex, Integer candidates = new HashMapSecondaryIndex, Integer(); for (IndexExpression expression : clause) {
[1/3] git commit: fix build
Updated Branches: refs/heads/cassandra-1.2 76ad645a3 - 373c0336e refs/heads/trunk ee85c8ea9 - f6fd5bab7 fix build Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/373c0336 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/373c0336 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/373c0336 Branch: refs/heads/cassandra-1.2 Commit: 373c0336e3e902d2332765ce712546a9e1bef837 Parents: 76ad645 Author: Brandon Williams brandonwilli...@apache.org Authored: Thu Jul 18 18:46:12 2013 -0500 Committer: Brandon Williams brandonwilli...@apache.org Committed: Thu Jul 18 18:46:12 2013 -0500 -- src/java/org/apache/cassandra/service/StorageService.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/373c0336/src/java/org/apache/cassandra/service/StorageService.java -- diff --git a/src/java/org/apache/cassandra/service/StorageService.java b/src/java/org/apache/cassandra/service/StorageService.java index c4ceee5..d166553 100644 --- a/src/java/org/apache/cassandra/service/StorageService.java +++ b/src/java/org/apache/cassandra/service/StorageService.java @@ -944,7 +944,7 @@ public class StorageService extends NotificationBroadcasterSupport implements IE } Tracing.instance(); if (!Gossiper.instance.seenAnySeed()) -throw new IllegalStateException(Unable to contact any seeds!) +throw new IllegalStateException(Unable to contact any seeds!); setMode(Mode.JOINING, Starting to bootstrap..., true); new BootStrapper(FBUtilities.getBroadcastAddress(), tokens, tokenMetadata).bootstrap(); // handles token update logger.info(Bootstrap completed! for the tokens {}, tokens);
[1/3] git commit: fix build
Updated Branches: refs/heads/cassandra-1.2 ba6396a20 - d6145668c refs/heads/trunk 280284961 - 11928f7d8 fix build Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/d6145668 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/d6145668 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/d6145668 Branch: refs/heads/cassandra-1.2 Commit: d6145668c6cee8e30246f912ee58e8cd2ffdb9ba Parents: ba6396a Author: Brandon Williams brandonwilli...@apache.org Authored: Mon Jul 15 16:10:23 2013 -0500 Committer: Brandon Williams brandonwilli...@apache.org Committed: Mon Jul 15 16:10:23 2013 -0500 -- src/java/org/apache/cassandra/config/DatabaseDescriptor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/cassandra/blob/d6145668/src/java/org/apache/cassandra/config/DatabaseDescriptor.java -- diff --git a/src/java/org/apache/cassandra/config/DatabaseDescriptor.java b/src/java/org/apache/cassandra/config/DatabaseDescriptor.java index 91ae675..55d78b8 100644 --- a/src/java/org/apache/cassandra/config/DatabaseDescriptor.java +++ b/src/java/org/apache/cassandra/config/DatabaseDescriptor.java @@ -728,7 +728,7 @@ public class DatabaseDescriptor public static boolean isReplacing() { -return 0 != getReplaceTokens().size() || getReplaceNode() != null +return 0 != getReplaceTokens().size() || getReplaceNode() != null; } public static String getClusterName()