Skip to content

Instantly share code, notes, and snippets.

@mlowicki
Created October 6, 2015 19:54
Show Gist options
  • Select an option

  • Save mlowicki/96946cd3a67e275c2ff2 to your computer and use it in GitHub Desktop.

Select an option

Save mlowicki/96946cd3a67e275c2ff2 to your computer and use it in GitHub Desktop.
loop # 5 now = 2015-10-06 19:53:17.199042
DEBUG:cassandra.cqlengine.connection:
SELECT writetime(version), version FROM sync.entity_by_id2 WHERE user_id=%s AND data_type_id=%s
DEBUG:cassandra.protocol:query:
SELECT writetime(version), version FROM sync.entity_by_id2 WHERE user_id='consistency_stress_tester_new_driver_7' AND data_type_id=666
DEBUG:cassandra.connection:response: <ResultMessage(paging_state=None, stream_id=2, kind=2, results=([u'writetime(version)', u'version'], [(1444161187029000, 4)]), trace_id
=None)>
old entity_by_id.version = 4 writetime = 2015-10-06 19:53:07
DEBUG:cassandra.cqlengine.connection:
INSERT INTO sync.entity_by_id2 (user_id, data_type_id, version, id) VALUES (%s, %s, %s, %s)
DEBUG:cassandra.protocol:query:
INSERT INTO sync.entity_by_id2 (user_id, data_type_id, version, id) VALUES ('consistency_stress_tester_new_driver_7', 666, 5, 's1')
DEBUG:cassandra.connection:response: <ResultMessage(paging_state=None, stream_id=2, kind=1, results=None, trace_id=None)>
DEBUG:cassandra.connection:Sending options message heartbeat on idle connection (36047760) 10.210.3.221
DEBUG:cassandra.connection:Sending options message heartbeat on idle connection (36114000) 10.210.3.117
DEBUG:cassandra.connection:Sending options message heartbeat on idle connection (36114320) 10.210.3.224
DEBUG:cassandra.connection:Sending options message heartbeat on idle connection (36190096) 10.210.3.160
DEBUG:cassandra.connection:response: <SupportedMessage(stream_id=1, cql_versions=[u'3.2.0'], options={u'COMPRESSION': [u'snappy', u'lz4']}, trace_id=None)>
DEBUG:cassandra.connection:Sending options message heartbeat on idle connection (36189520) 10.210.3.161
DEBUG:cassandra.connection:Received options response on connection (36047760) from 10.210.3.221
DEBUG:cassandra.connection:Sending options message heartbeat on idle connection (36191568) 10.210.3.162
DEBUG:cassandra.connection:Sending options message heartbeat on idle connection (36190992) 10.210.3.230
DEBUG:cassandra.connection:response: <SupportedMessage(stream_id=1, cql_versions=[u'3.2.0'], options={u'COMPRESSION': [u'snappy', u'lz4']}, trace_id=None)>
DEBUG:cassandra.connection:Sending options message heartbeat on idle connection (36191632) 10.210.3.230
DEBUG:cassandra.connection:Received options response on connection (36114000) from 10.210.3.117
DEBUG:cassandra.connection:Sending options message heartbeat on idle connection (32695376) 10.210.3.161
DEBUG:cassandra.connection:response: <SupportedMessage(stream_id=1, cql_versions=[u'3.2.0'], options={u'COMPRESSION': [u'snappy', u'lz4']}, trace_id=None)>
DEBUG:cassandra.connection:Received options response on connection (36189520) from 10.210.3.161
DEBUG:cassandra.connection:response: <SupportedMessage(stream_id=9, cql_versions=[u'3.2.0'], options={u'COMPRESSION': [u'snappy', u'lz4']}, trace_id=None)>
DEBUG:cassandra.connection:Received options response on connection (32695376) from 10.210.3.161
DEBUG:cassandra.connection:response: <SupportedMessage(stream_id=1, cql_versions=[u'3.2.0'], options={u'COMPRESSION': [u'snappy', u'lz4']}, trace_id=None)>
DEBUG:cassandra.connection:Received options response on connection (36190096) from 10.210.3.160
DEBUG:cassandra.connection:response: <SupportedMessage(stream_id=1, cql_versions=[u'3.2.0'], options={u'COMPRESSION': [u'snappy', u'lz4']}, trace_id=None)>
DEBUG:cassandra.connection:Received options response on connection (36191568) from 10.210.3.162
DEBUG:cassandra.connection:response: <SupportedMessage(stream_id=2, cql_versions=[u'3.2.0'], options={u'COMPRESSION': [u'snappy', u'lz4']}, trace_id=None)>
DEBUG:cassandra.connection:Received options response on connection (36190992) from 10.210.3.230
DEBUG:cassandra.connection:response: <SupportedMessage(stream_id=1, cql_versions=[u'3.2.0'], options={u'COMPRESSION': [u'snappy', u'lz4']}, trace_id=None)>
DEBUG:cassandra.connection:Received options response on connection (36191632) from 10.210.3.230
DEBUG:cassandra.connection:response: <SupportedMessage(stream_id=1, cql_versions=[u'3.2.0'], options={u'COMPRESSION': [u'snappy', u'lz4']}, trace_id=None)>
DEBUG:cassandra.connection:Received options response on connection (36114320) from 10.210.3.224
loop # 6 now = 2015-10-06 19:53:27.216633
DEBUG:cassandra.cqlengine.connection:
SELECT writetime(version), version FROM sync.entity_by_id2 WHERE user_id=%s AND data_type_id=%s
DEBUG:cassandra.protocol:query:
SELECT writetime(version), version FROM sync.entity_by_id2 WHERE user_id='consistency_stress_tester_new_driver_7' AND data_type_id=666
DEBUG:cassandra.connection:response: <ResultMessage(paging_state=None, stream_id=3, kind=2, results=([u'writetime(version)', u'version'], [(1444161213504000, 5)]), trace_id=None)>
old entity_by_id.version = 5 writetime = 2015-10-06 19:53:33
DEBUG:cassandra.cqlengine.connection:
INSERT INTO sync.entity_by_id2 (user_id, data_type_id, version, id) VALUES (%s, %s, %s, %s)
DEBUG:cassandra.protocol:query:
INSERT INTO sync.entity_by_id2 (user_id, data_type_id, version, id) VALUES ('consistency_stress_tester_new_driver_7', 666, 6, 's1')
DEBUG:cassandra.connection:response: <ResultMessage(paging_state=None, stream_id=2, kind=1, results=None, trace_id=None)>
loop # 7 now = 2015-10-06 19:53:37.230865
DEBUG:cassandra.cqlengine.connection:
SELECT writetime(version), version FROM sync.entity_by_id2 WHERE user_id=%s AND data_type_id=%s
DEBUG:cassandra.protocol:query:
SELECT writetime(version), version FROM sync.entity_by_id2 WHERE user_id='consistency_stress_tester_new_driver_7' AND data_type_id=666
DEBUG:cassandra.connection:response: <ResultMessage(paging_state=None, stream_id=3, kind=2, results=([u'writetime(version)', u'version'], [(1444161213504000, 5)]), trace_id=None)>
old entity_by_id.version = 5 writetime = 2015-10-06 19:53:33
DEBUG:cassandra.cqlengine.connection:
INSERT INTO sync.entity_by_id2 (user_id, data_type_id, version, id) VALUES (%s, %s, %s, %s)
DEBUG:cassandra.protocol:query:
INSERT INTO sync.entity_by_id2 (user_id, data_type_id, version, id) VALUES ('consistency_stress_tester_new_driver_7', 666, 7, 's1')
DEBUG:cassandra.connection:response: <ResultMessage(paging_state=None, stream_id=3, kind=1, results=None, trace_id=None)>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment