spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Yasemin Kaya <godo...@gmail.com>
Subject Re: Cassandra Submit
Date Tue, 09 Jun 2015 11:36:54 GMT
I couldn't find any solution. I can write but I can't read from Cassandra.

2015-06-09 8:52 GMT+03:00 Yasemin Kaya <godot85@gmail.com>:

> Thanks alot Mohammed, Gerard and Yana.
> I can write to table, but exception returns me. It says "*Exception in
> thread "main" java.io.IOException: Failed to open thrift connection to
> Cassandra at 127.0.0.1:9160 <http://127.0.0.1:9160>*"
>
> In yaml file :
> rpc_address: localhost
> rpc_port: 9160
>
> And at project :
>
> .set("spark.cassandra.connection.host", "127.0.0.1")
> .set("spark.cassandra.connection.rpc.port", "9160");
>
> or
>
> .set("spark.cassandra.connection.host", "localhost")
> .set("spark.cassandra.connection.rpc.port", "9160");
>
> whatever I write setting,  I get same exception. Any help ??
>
>
> 2015-06-08 18:23 GMT+03:00 Yana Kadiyska <yana.kadiyska@gmail.com>:
>
>> yes, whatever you put for listen_address in cassandra.yaml. Also, you
>> should try to connect to your cassandra cluster via bin/cqlsh to make sure
>> you have connectivity before you try to make a a connection via spark.
>>
>> On Mon, Jun 8, 2015 at 4:43 AM, Yasemin Kaya <godot85@gmail.com> wrote:
>>
>>> Hi,
>>> I run my project on local. How can find ip address of my cassandra host
>>> ? From cassandra.yaml or ??
>>>
>>> yasemin
>>>
>>> 2015-06-08 11:27 GMT+03:00 Gerard Maas <gerard.maas@gmail.com>:
>>>
>>>> ????? = <ip address of your cassandra host>
>>>>
>>>> On Mon, Jun 8, 2015 at 10:12 AM, Yasemin Kaya <godot85@gmail.com>
>>>> wrote:
>>>>
>>>>> Hi ,
>>>>>
>>>>> How can I find spark.cassandra.connection.host? And what should I
>>>>> change ? Should I change cassandra.yaml ?
>>>>>
>>>>> Error says me *"Exception in thread "main" java.io.IOException:
>>>>> Failed to open native connection to Cassandra at {127.0.1.1}:9042"*
>>>>>
>>>>> What should I add *SparkConf sparkConf = new
>>>>> SparkConf().setAppName("JavaApiDemo").set(**"spark.driver.allowMultipleContexts",
>>>>> "true").set("spark.cassandra.connection.host", ?????);*
>>>>>
>>>>> Best
>>>>> yasemin
>>>>>
>>>>> 2015-06-06 3:04 GMT+03:00 Mohammed Guller <mohammed@glassbeam.com>:
>>>>>
>>>>>>  Check your spark.cassandra.connection.host setting. It should be
>>>>>> pointing to one of your Cassandra nodes.
>>>>>>
>>>>>>
>>>>>>
>>>>>> Mohammed
>>>>>>
>>>>>>
>>>>>>
>>>>>> *From:* Yasemin Kaya [mailto:godot85@gmail.com]
>>>>>> *Sent:* Friday, June 5, 2015 7:31 AM
>>>>>> *To:* user@spark.apache.org
>>>>>> *Subject:* Cassandra Submit
>>>>>>
>>>>>>
>>>>>>
>>>>>> Hi,
>>>>>>
>>>>>>
>>>>>>
>>>>>> I am using cassandraDB in my project. I had that error *Exception
in
>>>>>> thread "main" java.io.IOException: Failed to open native connection
to
>>>>>> Cassandra at {127.0.1.1}:9042*
>>>>>>
>>>>>>
>>>>>>
>>>>>> I think I have to modify the submit line. What should I add or remove
>>>>>> when I submit my project?
>>>>>>
>>>>>>
>>>>>>
>>>>>> Best,
>>>>>>
>>>>>> yasemin
>>>>>>
>>>>>>
>>>>>>
>>>>>>
>>>>>>
>>>>>> --
>>>>>>
>>>>>> hiç ender hiç
>>>>>>
>>>>>
>>>>>
>>>>>
>>>>> --
>>>>> hiç ender hiç
>>>>>
>>>>
>>>>
>>>
>>>
>>> --
>>> hiç ender hiç
>>>
>>
>>
>
>
> --
> hiç ender hiç
>



-- 
hiç ender hiç

Mime
View raw message