stevenschlansker

package hack;

import java.time.Duration;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.BeanFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;

stevenschlansker

import java.lang.reflect.Type;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;
import java.util.Optional;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.CopyOnWriteArrayList;
import java.util.function.Supplier;
import java.util.stream.Stream;

stevenschlansker

2016-04-07T02:32:36.223Z ERROR <> [worker-0] com.opentable.logging.KafkaPipeline - [default] pipeline dying due to exception
java.lang.IllegalStateException: Memory records is not writable
at org.apache.kafka.common.record.MemoryRecords.append(MemoryRecords.java:93)
at org.apache.kafka.clients.producer.internals.RecordBatch.tryAppend(RecordBatch.java:69)
at org.apache.kafka.clients.producer.internals.RecordAccumulator.append(RecordAccumulator.java:168)
at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:435)
at com.opentable.logging.KafkaPipeline.writeOut(KafkaPipeline.java:216)
at com.opentable.logging.KafkaPipeline.processMessage(KafkaPipeline.java:186)
at java.lang.Iterable.forEach(Iterable.java:75)
at com.opentable.logging.KafkaPipeline.copyQueue(KafkaPipeline.java:145)

stevenschlansker

2016-04-06T04:30:56.117Z INFO <> [worker-2] com.opentable.logging.KafkaPipeline - STATS -> INPUT:896.78 OUT:24.66 ACK:24.66 DLQ:0.00 DROP:872.12 (messages/sec) processing time 75%:16.10 95%:36.14 99%:66.76 µs/msg)
2016-04-06T04:30:57.588Z INFO <> [ProducerSendThread-pp-buzzsaw-2-mesos-slave3-qa-sf.qasql.opentable.com] kafka.client.ClientUtils$ - Fetching metadata from broker id:0,host:logging-kafka-qa-sf-1.otenv.com,port:9092 with correlation id 8552 for 1 topic(s) Set(logstash)
2016-04-06T04:30:57.590Z INFO <> [ProducerSendThread-pp-buzzsaw-2-mesos-slave3-qa-sf.qasql.opentable.com] kafka.producer.SyncProducer - Connected to logging-kafka-qa-sf-1.otenv.com:9092 for producing
2016-04-06T04:30:57.592Z INFO <> [ProducerSendThread-pp-buzzsaw-2-mesos-slave3-qa-sf.qasql.opentable.com] kafka.producer.SyncProducer - Disconnecting from logging-kafka-qa-sf-1.otenv.com:9092
2016-04-06T04:30:57.592Z INFO <> [ProducerSendThread-pp-buzzsaw-2-mesos-slave3-qa-sf.qasql.opentable.com] kafka.producer.SyncProducer - Disconnectin

stevenschlansker

2016-04-05T22:42:00.528Z INFO <> [ProducerSendThread-pp-buzzsaw-1-mesos-slave6-qa-sf.qasql.opentable.com] kafka.client.ClientUtils$ - Fetching metadata from broker id:2,host:logging-kafka-qa-sf-3.otenv.com,port:9092 with correlation id 6677 for 1 topic(s) Set(logstash)
2016-04-05T22:42:00.532Z INFO <> [ProducerSendThread-pp-buzzsaw-1-mesos-slave6-qa-sf.qasql.opentable.com] kafka.producer.SyncProducer - Connected to logging-kafka-qa-sf-3.otenv.com:9092 for producing
2016-04-05T22:42:00.534Z INFO <> [ProducerSendThread-pp-buzzsaw-1-mesos-slave6-qa-sf.qasql.opentable.com] kafka.producer.SyncProducer - Disconnecting from logging-kafka-qa-sf-3.otenv.com:9092
2016-04-05T22:42:00.534Z INFO <> [ProducerSendThread-pp-buzzsaw-1-mesos-slave6-qa-sf.qasql.opentable.com] kafka.producer.SyncProducer - Disconnecting from qa-sf-logkafka-10.qasql.opentable.com:9092
2016-04-05T22:42:00.538Z INFO <> [ProducerSendThread-pp-buzzsaw-1-mesos-slave6-qa-sf.qasql.opentable.com] kafka.producer.SyncProducer - Connected to qa-sf-logkafka-

stevenschlansker

root@mesos1-prod-uswest2:~# grep 'prod-abaggregator-shadow-aux-cpennello.2016.03.24T15.36.06-1458850' /var/log/upstart/singularity.log
INFO  [2016-03-24 20:11:41,426] com.hubspot.singularity.mesos.SingularityMesosScheduler: Launching task prod-abaggregator-shadow-aux-cpennello.2016.03.24T15.36.06-1458850301426-1-mesos_slave12_prod_uswest2.otsql.opentable.com-us_west_2a slot on slave 12e39206-7831-4a78-9ed4-af58e7c3683a-S8 (mesos-slave12-prod-uswest2.otsql.opentable.com)
INFO  [2016-03-24 20:11:42,132] com.hubspot.singularity.mesos.SingularityMesosScheduler: 25 tasks ([prod-onboarding-service-teamcity.2016.03.21T19.49.33-1458850301251-1-mesos_slave12_prod_uswest2.otsql.opentable.com-us_west_2a, prod-abtest-shadow-stryker.2016.03.22T17.39.44-1458850301288-1-mesos_slave12_prod_uswest2.otsql.opentable.com-us_west_2a, prod-oti-connect-support-teamcity.2016.03.11T23.23.02-1458850301324-1-mesos_slave12_prod_uswest2.otsql.opentable.com-us_west_2a, prod-gcwebdiagnostics-teamcity.2015.07.08T23.09.27-1458850301360-1-mes

stevenschlansker

### Keybase proof

I hereby claim:

  * I am stevenschlansker on github.
  * I am sugis (https://keybase.io/sugis) on keybase.
  * I have a public key ASC5XXFIYYPg3iefWLsNba_DXKhA8ju3XxtPpfQQTwou1go

To claim this, I am signing this object:

stevenschlansker

Process:         palemoon [94718]
Path:            /Applications/NewMoon.app/Contents/MacOS/palemoon
Identifier:      org.mozilla.newmoon
Version:         26.0.0 (2616.1.21)
Code Type:       X86-64 (Native)
Parent Process:  launchd [328]
Responsible:     palemoon [94718]
User ID:         501

Date/Time:       2016-01-27 13:44:52.901 -0800

stevenschlansker

sqlite> CREATE VIRTUAL TABLE tokens1 USING fts3tokenize(simple,en_US);
sqlite> SELECT * FROM tokens1 WHERE input='song_0';
input|token|start|end|position
song_0|song|0|4|0
song_0|0|5|6|1

stevenschlansker

2015-10-05T17:36:44.289Z INFO <> [Server Shutdown Thread] o.e.j.server.handler.ContextHandler - Stopped o.e.j.s.ServletContextHandler@6993c8df{/,null,UNAVAILABLE}
2015-10-05T17:36:59.300Z WARN <> [qtp671959170-3241] o.e.j.util.SharedBlockingCallback - Blocker not complete Blocker@44027995{null}
2015-10-05T17:36:59.301Z WARN <> [qtp671959170-1624] o.e.j.util.thread.QueuedThreadPool - qtp671959170{STOPPING,10<=40<=40,i=0,q=41621} rejected org.eclipse.jetty.io.ManagedSelector$2@18d3108
2015-10-05T17:36:59.302Z WARN <> [qtp671959170-1624] o.e.j.util.thread.QueuedThreadPool -
java.util.concurrent.RejectedExecutionException: org.eclipse.jetty.io.ManagedSelector$2@18d3108
at org.eclipse.jetty.util.thread.QueuedThreadPool.execute(QueuedThreadPool.java:377) ~[discovery-server-0.11.3-jar-with-dependencies.jar:0.11.3]
at org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume.execute(ProduceExecuteConsume.java:58) ~[discovery-server-0.11.3-jar-with-dependencies.jar:0.11.3]
at org.eclipse.jetty.util.thread.strategy.