You can run them both on the same machine, but it's always been the
case that multiple instances of StorageProxy need to be on different
IPs. So you'll have to override ListenAddress.
On Thu, Sep 16, 2010 at 4:20 PM, Asif Jan <asif....@gmail.com> wrote:
> 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....@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();
>>> }
>>>
>>>
>>>
>>>
>>>
>>>
>
>
--
Jonathan Ellis
Project Chair, Apache Cassandra
co-founder of Riptano, the source for professional Cassandra support
http://riptano.com
