Skip to content

Instantly share code, notes, and snippets.

View nemosupremo's full-sized avatar

nemosupremo nemosupremo

52 followers · 26 following
View GitHub Profile
@nemosupremo
nemosupremo / gist:030637d7637ab72975d0
Created April 1, 2015 21:16
func (h *NumericHistogram) Quantile(q float64) float64 {
count := q * float64(h.total)
for i := range h.bins {
count -= float64(h.bins[i].count)
if count <= 0 {
return h.bins[i].value
}
}
@nemosupremo
nemosupremo / presto thread dump
Created June 14, 2015 21:55
Full thread dump Java HotSpot(TM) 64-Bit Server VM (25.45-b02 mixed mode):
"http-client-shared-209" #209 daemon prio=5 os_prio=0 tid=0x00007fd8740b6000 nid=0x67b9 waiting on condition [0x00007fd7c4d27000]
java.lang.Thread.State: TIMED_WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for <0x00000000a9b62170> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
at org.eclipse.jetty.util.BlockingArrayQueue.poll(BlockingArrayQueue.java:389)
at org.eclipse.jetty.util.thread.QueuedThreadPool.idleJobPoll(QueuedThreadPool.java:531)
@nemosupremo
nemosupremo / gist:eb0c54883b1ccc10b745
Created June 16, 2015 22:40
@ScalarFunction("msgpack_extract_map_i")
@SqlType(StandardTypes.BIGINT)
public static long intMsgpackExtract(@SqlType(StandardTypes.VARCHAR) Slice msg, @SqlType(StandardTypes.VARCHAR) Slice key)
{
try {
io.airlift.slice.BasicSliceInput in = msg.getInput();
System.out.println(bytesToHexString(in.slice().toByteBuffer().array())); // this returns 0x30783836613137356564613137366, expecting 0x86a175eda176...
TypeReference<Map<String, Object>> typeReference = new TypeReference<Map<String, Object>>(){};
Map<String, Object> xs = MSGPACK_FACTORY.readValue(msg.getInput(), typeReference);
@nemosupremo
nemosupremo / gist:0ef1d7c1d624e689cfce
Last active August 29, 2015 14:23
@nemosupremo
nemosupremo / gist:61ba7c994cc5a3d284bf
Created October 9, 2015 19:12
Oct 9 16:06:42 master-01 marathon[20175]: [INFO] [10/09/2015 16:06:42.312] [marathon-akka.actor.default-dispatcher-8] [akka://marathon/user/$Me] Received health result: [Healthy(geard.b5b916ae-6df1-11e5-8632-00163e105035,2015-10-08T19:21:00.379Z,2015-10-09T16:06:42.312Z)]
Oct 9 16:06:51 master-01 mesos-master[11603]: 2015-10-09 16:06:51,508:11603(0x7f520d069700):ZOO_ERROR@handle_socket_error_msg@1643: Socket [10.129.196.11:2181] zk retcode=-7, errno=110(Connection timed out): connection to 10.129.196.11:2181 timed out (exceeded timeout by 3ms)
Oct 9 16:06:51 master-01 mesos-master[11603]: 2015-10-09 16:06:51,508:11603(0x7f520d069700):ZOO_INFO@check_events@1703: initiated connection to server [10.129.196.49:2181]
Oct 9 16:06:51 master-01 mesos-master[11603]: 2015-10-09 16:06:51,508:11603(0x7f520e06b700):ZOO_ERROR@handle_socket_error_msg@1643: Socket [10.129.196.11:2181] zk retcode=-7, errno=110(Connection timed out): connection to 10.129.196.11:2181 timed out (exceeded timeout by 4ms)
Oct 9 16:06:51 maste
@nemosupremo
nemosupremo / mesos01
Created October 13, 2015 18:15
This file has been truncated, but you can view the full file.
Oct 13 17:38:23 master-01 marathon[16383]: [2015-10-13 17:38:23,677] INFO Already running 1 instances of /elasticsearch. Not scaling. (mesosphere.marathon.SchedulerActions:538)
Oct 13 17:38:23 master-01 marathon[16383]: [2015-10-13 17:38:23,677] INFO Already running 1 instances of /jenkins. Not scaling. (mesosphere.marathon.SchedulerActions:538)
Oct 13 17:38:23 master-01 marathon[16383]: [2015-10-13 17:38:23,677] INFO Already running 1 instances of /mongo-mms-agent. Not scaling. (mesosphere.marathon.SchedulerActions:538)
Oct 13 17:38:23 master-01 marathon[16383]: [2015-10-13 17:38:23,677] INFO Already running 0 instances of /redis. Not scaling. (mesosphere.marathon.SchedulerActions:538)
Oct 13 17:38:23 master-01 marathon[16383]: [2015-10-13 17:38:23,678] INFO Already running 1 instances of /docker. Not scaling. (mesosphere.marathon.SchedulerActions:538)
Oct 13 17:38:23 master-01 marathon[16383]: [2015-10-13 17:38:23,679] INFO Already running 0 instances of /nginx. Not scaling. (mesosphere.marathon.SchedulerAc
@nemosupremo
nemosupremo / mesos02
Created October 13, 2015 18:17
This file has been truncated, but you can view the full file.
Oct 13 16:10:24 master-02 mesos-master[25272]: I1013 16:10:24.559458 25293 hierarchical.hpp:648] Recovered ports(*):[1-3332, 3334-7945, 7947-65535]; cpus(*):0.5; mem(*):117; disk(*):17699 (total allocatable: ports(*):[1-3332, 3334-7945, 7947-65535]; cpus(*):0.5; mem(*):117; disk(*):17699) on slave 20151003-015036-935624970-5050-22288-S1 from framework 20151005-201909-834961674-5050-7935-0001
Oct 13 16:10:24 master-02 mesos-master[25272]: I1013 16:10:24.559607 25293 hierarchical.hpp:648] Recovered mem(*):1792; ports(*):[2048-65535]; cpus(*):2; disk(*):42899 (total allocatable: mem(*):1792; ports(*):[2048-65535]; cpus(*):2; disk(*):42899) on slave 20151003-015036-935624970-5050-22288-S16 from framework 20151005-201909-834961674-5050-7935-0001
Oct 13 16:10:25 master-02 mesos-master[25272]: I1013 16:10:25.558974 25294 master.cpp:3760] Sending 7 offers to framework 20151005-201909-834961674-5050-7935-0001 (Jenkins Scheduler) at scheduler-3ed87769-8c90-4784-abe2-079c5193fab9@10.129.196.26:40706
Oct 13 16:10:25 mast
@nemosupremo
nemosupremo / mesos03
Created October 13, 2015 18:17
This file has been truncated, but you can view the full file.
Oct 13 18:00:52 master-03 mesos-master[30754]: I1013 18:00:52.529577 30773 hierarchical.hpp:648] Recovered ports(*):[1-3332, 3334-7945, 7947-65535]; cpus(*):0.5; mem(*):117; disk(*):17699 (total allocatable: ports(*):[1-3332, 3334-7945, 7947-65535]; cpus(*):0.5; mem(*):117; disk(*):17699) on slave 20151003-015036-935624970-5050-22288-S12 from framework 20150604-223829-834961674-5050-11626-0001
Oct 13 18:00:52 master-03 mesos-master[30754]: I1013 18:00:52.529817 30774 master.cpp:2273] Processing ACCEPT call for offers: [ 20151013-164927-935624970-5050-30754-O41082 ] on slave 20151003-015036-935624970-5050-22288-S0 at slave(1)@10.129.196.45:5051 (10.129.196.45) for framework 20150604-223829-834961674-5050-11626-0001 (chronos-2.3.4) at scheduler-bf56baae-3f0e-4a41-82e5-3a095e256a57@10.129.196.26:46411
Oct 13 18:00:52 master-03 mesos-master[30754]: I1013 18:00:52.529906 30774 hierarchical.hpp:648] Recovered ports(*):[1-3332, 3334-7945, 7947-65535]; cpus(*):0.5; mem(*):117; disk(*):17699 (total allocatable: ports(
@nemosupremo
nemosupremo / gist:d85d954e1dfd297056aa
Created October 21, 2015 20:20
ERROR [SharedPool-Worker-1] 2015-10-21 13:14:28,660 ErrorMessage.java:251 - Unexpected exception during request
java.lang.NullPointerException: null
at org.apache.cassandra.service.pager.RangeSliceQueryPager.containsPreviousLast(RangeSliceQueryPager.java:100) ~[apache-cassandra-2.1.6.jar:2.1.6]
at org.apache.cassandra.service.pager.AbstractQueryPager.fetchPage(AbstractQueryPager.java:119) ~[apache-cassandra-2.1.6.jar:2.1.6]
at org.apache.cassandra.service.pager.RangeSliceQueryPager.fetchPage(RangeSliceQueryPager.java:37) ~[apache-cassandra-2.1.6.jar:2.1.6]
at org.apache.cassandra.cql3.statements.SelectStatement.execute(SelectStatement.java:222) ~[apache-cassandra-2.1.6.jar:2.1.6]
at org.apache.cassandra.cql3.statements.SelectStatement.execute(SelectStatement.java:63) ~[apache-cassandra-2.1.6.jar:2.1.6]
at org.apache.cassandra.cql3.QueryProcessor.processStatement(QueryProcessor.java:238) ~[apache-cassandra-2.1.6.jar:2.1.6]
at org.apache.cassandra.cql3.QueryProcessor.process(QueryProcessor.java:260) ~[ap
@nemosupremo
nemosupremo / gist:e13fe389fee9bf04c1b6
Created November 4, 2015 05:41
Nov 4 05:26:35 master-01 marathon[26260]: [INFO] [11/04/2015 05:26:35.940] [marathon-akka.actor.default-dispatcher-21] [akka://marathon/user/$5z] Received health result: [Healthy(web-staging.675da6ba-82aa-11e5-8983-00163e105035,2015-11-04T01:24:53.013Z,2015-11-04T05:26:35.940Z)]
Nov 4 05:26:36 master-01 marathon[26260]: [2015-11-04 05:26:36,237] INFO Opening socket connection to server master-02.channelmeter.com/10.129.196.11:2181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn:975)
Nov 4 05:26:36 master-01 marathon[26260]: [2015-11-04 05:26:36,238] INFO Socket connection established to master-02.channelmeter.com/10.129.196.11:2181, initiating session (org.apache.zookeeper.ClientCnxn:852)
Nov 4 05:26:36 master-01 marathon[26260]: [2015-11-04 05:26:36,240] INFO Unable to reconnect to ZooKeeper service, session 0x250d0a1a0b50000 has expired, closing socket connection (org.apache.zookeeper.ClientCnxn:1094)
Nov 4 05:26:36 master-01 marathon[26260]: [2015-11-04 05