diff --git a/src/java/org/apache/cassandra/client/RingCache.java b/src/java/org/apache/cassandra/client/RingCache.java index 4db4a0d8c3..3308471a2a 100644 --- a/src/java/org/apache/cassandra/client/RingCache.java +++ b/src/java/org/apache/cassandra/client/RingCache.java @@ -52,7 +52,7 @@ public class RingCache private Multimap, InetAddress> rangeMap; - public RingCache(Configuration conf) throws IOException + public RingCache(Configuration conf) { this.conf = conf; this.partitioner = ConfigHelper.getOutputPartitioner(conf); diff --git a/src/java/org/apache/cassandra/hadoop/ColumnFamilyOutputFormat.java b/src/java/org/apache/cassandra/hadoop/ColumnFamilyOutputFormat.java index 7b6cb0b3be..962c2e97c8 100644 --- a/src/java/org/apache/cassandra/hadoop/ColumnFamilyOutputFormat.java +++ b/src/java/org/apache/cassandra/hadoop/ColumnFamilyOutputFormat.java @@ -114,7 +114,7 @@ public class ColumnFamilyOutputFormat extends OutputFormat> * mutations, and the ring cache for the given keyspace. * * @param context the task attempt context - * @throws IOException */ - ColumnFamilyRecordWriter(TaskAttemptContext context) throws IOException + ColumnFamilyRecordWriter(TaskAttemptContext context) { this(context.getConfiguration()); this.progressable = new Progressable(context); } - ColumnFamilyRecordWriter(Configuration conf, Progressable progressable) throws IOException + ColumnFamilyRecordWriter(Configuration conf, Progressable progressable) { this(conf); this.progressable = progressable; } - ColumnFamilyRecordWriter(Configuration conf) throws IOException + ColumnFamilyRecordWriter(Configuration conf) { this.conf = conf; this.ringCache = new RingCache(conf); diff --git a/test/unit/org/apache/cassandra/client/TestRingCache.java b/test/unit/org/apache/cassandra/client/TestRingCache.java index c16e336620..51a88f8e48 100644 --- a/test/unit/org/apache/cassandra/client/TestRingCache.java +++ b/test/unit/org/apache/cassandra/client/TestRingCache.java @@ -17,7 +17,6 @@ */ package org.apache.cassandra.client; -import java.io.IOException; import java.net.InetAddress; import java.nio.ByteBuffer; import java.util.Collection; @@ -46,7 +45,7 @@ public class TestRingCache private Cassandra.Client thriftClient; private Configuration conf; - public TestRingCache(String keyspace) throws IOException + public TestRingCache(String keyspace) { ConfigHelper.setOutputColumnFamily(conf, keyspace, "Standard1"); ringCache = new RingCache(conf);