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();
> }
>
>
>
>
>
>
