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 05:52:27 GMT
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ç

Mime
View raw message