IBMStreams / streamsx.dps

The IBMStreams/streamsx.dps GitHub repository is home to the Streams toolkit named DPS (Distributed Process Store)
http://ibmstreams.github.io/streamsx.dps
Other
4 stars 9 forks source link

Can't connect to Cassandra 3.11.3 #86

Closed vitalizoubov closed 4 years ago

vitalizoubov commented 5 years ago

I am trying to connect to Cassandra (ReleaseVersion: 3.11.3) from SPL and getting the following error:

[streamsadmin@streams bin]$ ./standalone

before dpsGetNoSqlDbProductName() 01 Feb 2019 12:04:52.736 [31236] ERROR #splapptrc,J[0],P[0],Sink1.NextBeat,DistributedProcessStore M[DistributedProcessStore.cpp:fetchDBConnectionParameters:111] - Going to read the DPS configuration details from the DPS config file '/tmp/6476337534352895776/Distributed/toolkits/04_all_dps_apis_at_work_in_spl/etc/no-sql-kv-store-servers.cfg'. 01 Feb 2019 12:04:52.737 [31236] ERROR #splapptrc,J[0],P[0],Sink1.NextBeat,DistributedProcessStore M[DistributedProcessStore.cpp:fetchDBConnectionParameters:228] - Completed reading the DPS configuration details. 1549040692.789 [ERROR] (src/connection.cpp:675:void cass::Connection::notify_error(const string&)): Host 192.168.1.17 had the following error on startup: 'Error response: 'Invalid or unsupported protocol version (2); supported versions are (3/v3, 4/v4, 5/v5-beta)' (0x0200000A)' 1549040692.790 [WARN] (src/control_connection.cpp:208:void cass::ControlConnection::on_connection_closed(cass::Connection)): Lost connection on host 192.168.1.17 1549040692.799 [ERROR] (src/connection.cpp:675:void cass::Connection::notify_error(const string&)): Host 192.168.1.17 had the following error on startup: 'Error response: 'Invalid or unsupported protocol version (1); supported versions are (3/v3, 4/v4, 5/v5-beta)' (0x0200000A)' 1549040692.799 [WARN] (src/control_connection.cpp:208:void cass::ControlConnection::on_connection_closed(cass::Connection)): Lost connection on host 192.168.1.17 1549040692.799 [ERROR] (src/control_connection.cpp:218:void cass::ControlConnection::on_connection_closed(cass::Connection*)): Host 192.168.1.17 does not support any valid protocol version 01 Feb 2019 12:04:52.808 [31236] ERROR #splapptrc,J[0],P[0],Sink1.NextBeat,DistributedProcessStore M[DistributedProcessStore.cpp:connectToDatabase:430] - Cannot connect to database. Details: 'Unable to connect a Cassandra session with a Cassandra cluster.'. 01 Feb 2019 12:04:52.812 [31236] ERROR #splapplog,J[0],P[0],Sink1.NextBeat,spl_pe M[PEImpl.cpp:logTerminatingException:1988] - CDISR5033E: An exception occurred during the execution of the Sink1.NextBeat operator. Processing element number 0 is terminating. 01 Feb 2019 12:04:52.812 [31236] ERROR #splapptrc,J[0],P[0],Sink1.NextBeat,#splapptrc,J[0],P[0],Sink1.NextBeat,spl_operator M[PEImpl.cpp:handleOperatorFailure:596] - CDISR5030E: An exception occurred during the execution of the Sink1.NextBeat operator. The exception is: Cannot connect to database. Details: 'Unable to connect a Cassandra session with a Cassandra cluster.'.

OS and Streams versions: Version=4.2.1.1 ProductName=IBM Streams Build=20170410181410 Architecture=x86_64 OS=Red Hat Enterprise Linux Server release 7.0 (Maipo) OS.VERSION=7 OS.PATCH=0 Edition=Developer EditionName=IBM Streams Developer Edition

nysenthil commented 5 years ago

Hi Vitali, The last change I made in the DPS toolkit specifically for Cassandra was in the Fall of 2015 to support the Cassandra version 2.1.4 along with the important requirement of the Cassandra C++ driver version 1.0.3. Your observation is correct that it will not work on Cassandra 3. There is a bank that asked me to add support for Cassandra 3 in the DPS toolkit. It will take a couple of months to add that support, test and commit it in GitHub.I will update in the next two to three months after we finish our testing at that bank.

vitalizoubov commented 5 years ago

Hi Senthil,

Thank you.

Vitali

On Sat, Feb 2, 2019 at 8:25 PM Senthil Nathan notifications@github.com wrote:

Hi Vitali, The last change I made in the DPS toolkit specifically for Cassandra was in the Fall of 2015 to support the Cassandra version 2.1.4 along with the important requirement of the Cassandra C++ driver version 1.0.3. Your observation is correct that it will not work on Cassandra 3. There is a bank that asked me to add support for Cassandra 3 in the DPS toolkit. It will take a couple of months to add that support, test and commit it in GitHub.I will update in the next two to three months after we finish our testing at that bank.

— You are receiving this because you authored the thread. Reply to this email directly, view it on GitHub https://github.com/IBMStreams/streamsx.dps/issues/86#issuecomment-460014407, or mute the thread https://github.com/notifications/unsubscribe-auth/AWUnig4iQOnpfAz0OSfLpQWGec1GJddhks5vJjqBgaJpZM4aeuqd .

-- Vitali Zoubov vitali.zoubov@gmail.com 774-262-9034

vitalizoubov commented 5 years ago

Thank you Senthil,

Vitali

On Sat, Feb 2, 2019 at 8:25 PM Senthil Nathan notifications@github.com wrote:

Hi Vitali, The last change I made in the DPS toolkit specifically for Cassandra was in the Fall of 2015 to support the Cassandra version 2.1.4 along with the important requirement of the Cassandra C++ driver version 1.0.3. Your observation is correct that it will not work on Cassandra 3. There is a bank that asked me to add support for Cassandra 3 in the DPS toolkit. It will take a couple of months to add that support, test and commit it in GitHub.I will update in the next two to three months after we finish our testing at that bank.

— You are receiving this because you authored the thread. Reply to this email directly, view it on GitHub https://github.com/IBMStreams/streamsx.dps/issues/86#issuecomment-460014407, or mute the thread https://github.com/notifications/unsubscribe-auth/AWUnig4iQOnpfAz0OSfLpQWGec1GJddhks5vJjqBgaJpZM4aeuqd .

-- Vitali Zoubov vitali.zoubov@gmail.com 774-262-9034

anouri commented 4 years ago

corrected