cassandra-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Asif Jan <asif....@gmail.com>
Subject Re: Getting client only example to work
Date Thu, 16 Sep 2010 21:20:06 GMT
ok, did something about the message service changed in the initClient  
method; essentially now one can not call initClient when a cassandra  
instance is running on the same machine.

thanks
On Sep 16, 2010, at 3:48 PM, Gary Dusbabek wrote:

> I discovered some problems with the fat client earlier this week when
> I tried using it.  It needs some fixes to keep up with all the 0.7
> changes.
>
> Gary.
>
> On Thu, Sep 16, 2010 at 05:48, Asif Jan <asif.jan@gmail.com> wrote:
>>
>> Hi
>> I am using 0.7.0-beta1 , and trying to get the contrib/client_only  
>> example
>> to work.
>> I am running cassandra on host1, and trying to access it from host2.
>> When using thirft (via cassandra-cli) and in my application; I am  
>> able to
>> connect and do all operations as expected.
>> But I am not able to connect to cassandra when using the code in  
>> client_only
>>  (or far that matter using contrib/bmt_example). Since my test  
>> requires to
>> do bulk insertion of about 1.4 TB of data, so I need to use a non- 
>> thirft
>> interface.
>> The error that I am getting is follows (the keyspace and the column  
>> family
>> exist and can be used via Thirft) :
>> 10/09/16 12:35:31 INFO config.DatabaseDescriptor: DiskAccessMode  
>> 'auto'
>> determined to be mmap, indexAccessMode is mmap
>> 10/09/16 12:35:31 INFO service.StorageService: Starting up client  
>> gossip
>> Exception in thread "main" java.lang.IllegalArgumentException:  
>> Unknown
>> ColumnFamily Standard1 in keyspace Keyspace1
>> at
>> org 
>> .apache 
>> .cassandra 
>> .config.DatabaseDescriptor.getComparator(DatabaseDescriptor.java: 
>> 1009)
>> at
>> org 
>> .apache 
>> .cassandra.db.ColumnFamily.getComparatorFor(ColumnFamily.java:418)
>> at gaia.cu7.cassandra.input.Ingestor.testWriting(Ingestor.java:103)
>> at gaia.cu7.cassandra.input.Ingestor.main(Ingestor.java:187)
>> I am using the following code (from client_only example) (also  
>> passing JVM
>> parameter -Dstorage-config=path_2_cassandra.yaml)
>>
>>
>> public static void main(String[] args) throws Exception {
>> System.setProperty("storage-config","cassandra.yaml");
>>         testWriting();
>> }
>>
>> // from client_only example
>>  private static void testWriting() throws Exception
>>     {
>>         StorageService.instance.initClient();
>>         // sleep for a bit so that gossip can do its thing.
>>         try
>>         {
>>             Thread.sleep(10000L);
>>         }
>>         catch (Exception ex)
>>         {
>>             throw new AssertionError(ex);
>>         }
>>         // do some writing.
>>         final AbstractType comp =  
>> ColumnFamily.getComparatorFor("Keyspace1",
>> "Standard1", null);
>>         for (int i = 0; i < 100; i++)
>>         {
>>             RowMutation change = new RowMutation("Keyspace1",  
>> ("key" +
>> i).getBytes());
>>             ColumnPath cp = new
>> ColumnPath("Standard1").setColumn(("colb").getBytes());
>>             change.add(new QueryPath(cp), ("value" + i).getBytes(),  
>> new
>> TimestampClock(0));
>>             // don't call change.apply().  The reason is that is  
>> makes a
>> static call into Table, which will perform
>>             // local storage initialization, which creates local
>> directories.
>>             // change.apply();
>>             StorageProxy.mutate(Arrays.asList(change));
>>             System.out.println("wrote key" + i);
>>         }
>>         System.out.println("Done writing.");
>>         StorageService.instance.stopClient();
>>     }
>>
>>
>>
>>
>>
>>


Mime
View raw message