mlowicki

INFO   [2015-12-18 10:01:21,207] [dw-1065 - POST /repair_run?clusterName=productioncluster&tables=user_device&cause=manual+spreaper+run&owner=mlowicki&keyspace=sync] c.s.r.r.RepairRunResource - add repair run called with: clusterName = Optional.of(productioncluster), keyspace = Optional.of(sync), tables = Optional.of(user_device), owner = Optional.of(mlowicki), cause = Optional.of(manual spreaper run), segmentCount = Optional.absent(), repairParallelism = Optional.absent(), intensity = Optional.absent(), incrementalRepair = Optional.absent()
INFO   [2015-12-18 10:01:21,443] [dw-1065 - POST /repair_run?clusterName=productioncluster&tables=user_device&cause=manual+spreaper+run&owner=mlowicki&keyspace=sync] c.s.r.r.CommonTools - create new repair unit for cluster 'productioncluster', keyspace 'sync', and column families: [user_device]
ERROR  [2015-12-18 10:01:21,459] [dw-1065 - POST /repair_run?clusterName=productioncluster&tables=user_device&cause=manual+spreaper+run&owner=mlowicki&keyspace=sync] i.d.j.e.Loggin

mlowicki

#!/bin/sh
### BEGIN INIT INFO
# Provides:          cassandra-reaper
# Required-Start:    $remote_fs $network
# Required-Stop:     $remote_fs $network
# Default-Start:     2 3 4 5
# Default-Stop:      0 1 6
# Short-Description: cassandra-reaper daemon
# Description:       This is a daemon that controls the cassandra-reaper
### END INIT INFO

mlowicki

segmentCount: 200 
repairParallelism: DATACENTER_AWARE
repairIntensity: 0.5 
repairRunThreadCount: 4
hangingRepairTimeoutMins: 30
storageType: database
enableCrossOrigin: true
incrementalRepair: false

logging:

mlowicki

class sync::database::reaper inherits sync::database::base {

  file { '/var/log/cassandra_reaper':
    ensure => directory
  }

  $postgres_reaper_db = 'cassandra_reaper'
  $postgres_reaper_user = 'cassandra_reaper'
  $postgres_reaper_password = 'XXX'

mlowicki

#!/bin/bash

set -o nounset
set -o errexit

version="$1"

echo "Uploading"

rsync -avz — progress "cassandra-reaper_${version}_amd64.deb" root@apt.services.ams.osa:/var/apt/debian/dists/wheezy/stable/binary-amd64

mlowicki

bash-3.2$ ./lua-5.3.1/src/lua code/soc.lua
./lua-5.3.1/src/lua: error loading module 'socket.core' from file '/usr/local/lib/lua/5.3/socket/core.so':
        dlopen(/usr/local/lib/lua/5.3/socket/core.so, 6): Symbol not found: _lua_getctx
  Referenced from: /usr/local/lib/lua/5.3/socket/core.so
  Expected in: dynamic lookup

stack traceback:
        [C]: in ?
        [C]: in function 'require'
        /usr/local/share/lua/5.3/socket.lua:12: in main chunk

mlowicki

cqlsh:test> desc table bucket;

CREATE TABLE test.bucket (
    user_id text,
    data_type_id int,
    spot timestamp,
    count int static,
    PRIMARY KEY ((user_id, data_type_id), spot)
) WITH CLUSTERING ORDER BY (spot ASC)
    AND bloom_filter_fp_chance = 0.01

mlowicki

    statement = ( 
        "UPDATE {db_name}.user_store USING TTL %s SET clear_pending = True"
        " WHERE user_id = %s IF EXISTS"
    ).format(db_name=settings.DATABASES['default']['NAME'])

    execute_statement(statement, (CLEAR_PENDING_TTL, user_id))
    
    ...
    
    def execute_statement(statement, params, **kw):

mlowicki

I0118 21:44:39.488481  2951 slave.cpp:1294] Got assigned task 0:dupa for framework 573d2e5f-6bf3-4bc9-80cb-916469eccebd-0019
I0118 21:44:39.489634  2951 slave.cpp:1410] Launching task 0:dupa for framework 573d2e5f-6bf3-4bc9-80cb-916469eccebd-0019
I0118 21:44:39.490368  2951 paths.cpp:436] Trying to chown '/tmp/mesos/slaves/a9b1b065-6442-45e2-b905-cebf82563c4a-S0/frameworks/573d2e5f-6bf3-4bc9-80cb-916469eccebd-0019/executors/default/runs/7d853343-c754-4b34-930a-23c3660073d0' to user 'debian'
I0118 21:44:39.495780  2951 slave.cpp:4999] Launching executor default of framework 573d2e5f-6bf3-4bc9-80cb-916469eccebd-0019 with resources  in work directory '/tmp/mesos/slaves/a9b1b065-6442-45e2-b905-cebf82563c4a-S0/frameworks/573d2e5f-6bf3-4bc9-80cb-916469eccebd-0019/executors/default/runs/7d853343-c754-4b34-930a-23c3660073d0'
I0118 21:44:39.496656  2953 containerizer.cpp:618] Starting container '7d853343-c754-4b34-930a-23c3660073d0' for executor 'default' of framework '573d2e5f-6bf3-4bc9-80cb-916469eccebd-0019'
I0118 

mlowicki

release unlocked lock
celery/app/trace.py in trace_task at line 240

R = retval = fun(*args, **kwargs)
celery/app/trace.py in __protected_call__ at line 438

return self.run(*args, **kwargs)
sync/tasks.py in wrapper at line 56

if not f(*args, **kwargs):