Skip to content

Instantly share code, notes, and snippets.

@nezihyigitbasi
nezihyigitbasi / presto-rest.md
Last active September 14, 2021 11:54
Presto REST Services

/v1/node
/v1/node/failed
/v1/execute
/v1/statement
/v1/query
/v1/query/{query_id}
/v1/thread
/ui/thread
/v1/task
/v1/task/{task_id}

@nezihyigitbasi
nezihyigitbasi / stuck-task-01
Last active August 29, 2015 14:08
Presto 0.76 stuck task
{
"taskId": "20141031_202656_00949_bk886.1.2",
"version": 116802,
"state": "RUNNING",
"self": "http://10.45.171.15:8080/v1/task/20141031_202656_00949_bk886.1.2",
"lastHeartbeat": "2014-10-31T22:34:25.813Z",
"outputBuffers": {
"state": "NO_MORE_BUFFERS",
"masterSequenceId": 0,
"pagesAdded": 0,
@nezihyigitbasi
nezihyigitbasi / stuck-task-02
Created October 31, 2014 23:03
Presto 0.76 stuck task 2
{
"taskId": "20141031_202656_00949_bk886.0.0",
"version": 108571,
"state": "RUNNING",
"self": "http://10.171.11.76:8080/v1/task/20141031_202656_00949_bk886.0.0",
"lastHeartbeat": "2014-10-31T22:24:42.900Z",
"outputBuffers": {
"state": "NO_MORE_BUFFERS",
"masterSequenceId": 0,
"pagesAdded": 0,
@nezihyigitbasi
nezihyigitbasi / query.md
Last active August 29, 2015 14:13
failed query
SELECT 
    a,
    b,
    c,
    SUM(d);
    COUNT(DISTINCT e)
FROM t1
    INNER JOIN t2
 ON t1.a=t2.a
@nezihyigitbasi
nezihyigitbasi / fs.md
Created January 16, 2015 18:59
failing stage
"tasks" : [ {
            "taskId" : "20150116_185256_01316_dzhr7.4.0",
            "version" : 9223372036854775807,
            "state" : "FAILED",
            "self" : "http://10.232.19.66:8080/v1/task/20150116_185256_01316_dzhr7.4.0",
            "lastHeartbeat" : "2015-01-16T18:53:02.172Z",
            "outputBuffers" : {
              "state" : "NO_MORE_BUFFERS",
              "masterSequenceId" : 0,
{
            "taskId" : "20150703_221751_01346_wvjsd.3.200",
            "nodeInstanceId" : "3e1bc3c2-eb5d-4044-9a55-9f82a4f41dba",
            "version" : 1670,
            "state" : "FINISHED",
            "self" : "http://10.111.200.68:8080/v1/task/20150703_221751_01346_wvjsd.3.200",
            "lastHeartbeat" : "2015-07-03T22:19:35.400Z",
            "outputBuffers" : {
              "state" : "FINISHED",
diff --git a/presto-client/src/main/java/com/facebook/presto/client/StatementClient.java b/presto-client/src/main/java/com/facebook/presto/client/StatementClient.java
index 8fdb9b9..09e1699 100644
--- a/presto-client/src/main/java/com/facebook/presto/client/StatementClient.java
+++ b/presto-client/src/main/java/com/facebook/presto/client/StatementClient.java
@@ -29,6 +29,7 @@ import io.airlift.units.Duration;
 import javax.annotation.concurrent.ThreadSafe;

 import java.io.Closeable;
+import java.io.InterruptedIOException;
@nezihyigitbasi
nezihyigitbasi / presto-kafka-issue.md
Created September 15, 2016 16:17
presto kafka issue
java.lang.NoClassDefFoundError: org/apache/log4j/Logger
        at kafka.utils.Logging$class.logger(Logging.scala:24)
        at kafka.consumer.SimpleConsumer.logger$lzycompute(SimpleConsumer.scala:30)
        at kafka.consumer.SimpleConsumer.logger(SimpleConsumer.scala:30)
        at kafka.utils.Logging$class.info(Logging.scala:67)
        at kafka.consumer.SimpleConsumer.info(SimpleConsumer.scala:30)
        at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:74)
        at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:68)
        at kafka.consumer.SimpleConsumer.send(SimpleConsumer.scala:91)
2017-04-26T03:05:48.473-0700: 78441.557: Total time for which application threads were stopped: 1.6807240 seconds, Stopping threads took: 0.0016528 seconds
2017-04-26T03:05:50.417-0700: 78443.501: Application time: 1.9435166 seconds
2017-04-26T03:05:50.452-0700: 78443.536: [GC pause (G1 Evacuation Pause) (young) 78443.537: [G1Ergonomics (CSet Construction) start choosing CSet, _pending_cards: 122436, predicted base time: 76.76 ms, remaining time: 123.24 ms, target pause time: 200.00 ms]
 78443.537: [G1Ergonomics (CSet Construction) add young regions to CSet, eden: 225 regions, survivors: 31 regions, predicted young region time: 241.18 ms]
 78443.537: [G1Ergonomics (CSet Construction) finish choosing CSet, eden: 225 regions, survivors: 31 regions, old: 0 regions, predicted pause time: 317.94 ms, target pause time: 200.00 ms]
2017-04-26T03:05:50.751-0700: 78443.835: [SoftReference, 0 refs, 0.0000357 secs]2017-04-26T03:05:50.751-0700: 78443.835: [WeakReference, 63 refs, 0.0000269 secs]2017-04-26T03:05:50.751
-server
-Xss2048k
-XX:MaxMetaspaceSize=4G
-XX:+PreserveFramePointer
-XX:-UseBiasedLocking
-XX:+PrintGCApplicationConcurrentTime
-XX:+PrintGCApplicationStoppedTime
-XX:+UnlockExperimentalVMOptions
-XX:+UseG1GC