Guest User

Untitled

a guest
Jul 1st, 2019
127
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 35.93 KB | None | 0 0
  1. [Stage 2:> (0 + 1) / 1]19/07/01 09:41:40 WARN TaskSetManager: Lost task 0.0 in stage 2.0 (TID 4, ip-172-16-1-13.ap-south-1.compute.internal, executor 2): java.sql.SQLException: Error executing query
  2. at com.facebook.presto.jdbc.PrestoStatement.internalExecute(PrestoStatement.java:279)
  3. at com.facebook.presto.jdbc.PrestoStatement.execute(PrestoStatement.java:228)
  4. at com.facebook.presto.jdbc.PrestoPreparedStatement.<init>(PrestoPreparedStatement.java:80)
  5. at com.facebook.presto.jdbc.PrestoConnection.prepareStatement(PrestoConnection.java:128)
  6. at com.facebook.presto.jdbc.PrestoConnection.prepareStatement(PrestoConnection.java:298)
  7. at org.apache.spark.sql.execution.datasources.jdbc.JDBCRDD.compute(JDBCRDD.scala:300)
  8. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:324)
  9. at org.apache.spark.rdd.RDD.iterator(RDD.scala:288)
  10. at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52)
  11. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:324)
  12. at org.apache.spark.rdd.RDD.iterator(RDD.scala:288)
  13. at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52)
  14. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:324)
  15. at org.apache.spark.rdd.RDD.iterator(RDD.scala:288)
  16. at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52)
  17. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:324)
  18. at org.apache.spark.rdd.RDD.iterator(RDD.scala:288)
  19. at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:90)
  20. at org.apache.spark.scheduler.Task.run(Task.scala:121)
  21. at org.apache.spark.executor.Executor$TaskRunner$$anonfun$10.apply(Executor.scala:408)
  22. at org.apache.spark.util.Utils$.tryWithSafeFinally(Utils.scala:1360)
  23. at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:414)
  24. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
  25. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
  26. at java.lang.Thread.run(Thread.java:748)
  27. Caused by: java.io.UncheckedIOException: java.net.SocketTimeoutException
  28. at com.facebook.presto.jdbc.internal.client.JsonResponse.execute(JsonResponse.java:154)
  29. at com.facebook.presto.jdbc.internal.client.StatementClientV1.<init>(StatementClientV1.java:132)
  30. at com.facebook.presto.jdbc.internal.client.StatementClientFactory.newStatementClient(StatementClientFactory.java:24)
  31. at com.facebook.presto.jdbc.QueryExecutor.startQuery(QueryExecutor.java:46)
  32. at com.facebook.presto.jdbc.PrestoConnection.startQuery(PrestoConnection.java:701)
  33. at com.facebook.presto.jdbc.PrestoStatement.internalExecute(PrestoStatement.java:240)
  34. ... 24 more
  35. Caused by: java.net.SocketTimeoutException
  36. at sun.nio.ch.SocketAdaptor.connect(SocketAdaptor.java:118)
  37. at com.facebook.presto.jdbc.internal.okhttp3.internal.platform.Platform.connectSocket(Platform.java:125)
  38. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.RealConnection.connectSocket(RealConnection.java:238)
  39. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.RealConnection.connect(RealConnection.java:158)
  40. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.StreamAllocation.findConnection(StreamAllocation.java:256)
  41. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.StreamAllocation.findHealthyConnection(StreamAllocation.java:134)
  42. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.StreamAllocation.newStream(StreamAllocation.java:113)
  43. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.ConnectInterceptor.intercept(ConnectInterceptor.java:42)
  44. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
  45. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
  46. at com.facebook.presto.jdbc.internal.okhttp3.internal.cache.CacheInterceptor.intercept(CacheInterceptor.java:93)
  47. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
  48. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
  49. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.BridgeInterceptor.intercept(BridgeInterceptor.java:93)
  50. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
  51. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RetryAndFollowUpInterceptor.intercept(RetryAndFollowUpInterceptor.java:125)
  52. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
  53. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
  54. at com.facebook.presto.jdbc.internal.client.OkHttpUtil.lambda$userAgent$0(OkHttpUtil.java:77)
  55. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
  56. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
  57. at com.facebook.presto.jdbc.internal.okhttp3.RealCall.getResponseWithInterceptorChain(RealCall.java:200)
  58. at com.facebook.presto.jdbc.internal.okhttp3.RealCall.execute(RealCall.java:77)
  59. at com.facebook.presto.jdbc.internal.client.JsonResponse.execute(JsonResponse.java:131)
  60. ... 29 more
  61.  
  62. 19/07/01 09:41:50 WARN TaskSetManager: Lost task 0.1 in stage 2.0 (TID 5, ip-172-16-1-13.ap-south-1.compute.internal, executor 2): java.sql.SQLException: Error executing query
  63. at com.facebook.presto.jdbc.PrestoStatement.internalExecute(PrestoStatement.java:279)
  64. at com.facebook.presto.jdbc.PrestoStatement.execute(PrestoStatement.java:228)
  65. at com.facebook.presto.jdbc.PrestoPreparedStatement.<init>(PrestoPreparedStatement.java:80)
  66. at com.facebook.presto.jdbc.PrestoConnection.prepareStatement(PrestoConnection.java:128)
  67. at com.facebook.presto.jdbc.PrestoConnection.prepareStatement(PrestoConnection.java:298)
  68. at org.apache.spark.sql.execution.datasources.jdbc.JDBCRDD.compute(JDBCRDD.scala:300)
  69. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:324)
  70. at org.apache.spark.rdd.RDD.iterator(RDD.scala:288)
  71. at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52)
  72. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:324)
  73. at org.apache.spark.rdd.RDD.iterator(RDD.scala:288)
  74. at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52)
  75. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:324)
  76. at org.apache.spark.rdd.RDD.iterator(RDD.scala:288)
  77. at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52)
  78. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:324)
  79. at org.apache.spark.rdd.RDD.iterator(RDD.scala:288)
  80. at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:90)
  81. at org.apache.spark.scheduler.Task.run(Task.scala:121)
  82. at org.apache.spark.executor.Executor$TaskRunner$$anonfun$10.apply(Executor.scala:408)
  83. at org.apache.spark.util.Utils$.tryWithSafeFinally(Utils.scala:1360)
  84. at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:414)
  85. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
  86. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
  87. at java.lang.Thread.run(Thread.java:748)
  88. Caused by: java.io.UncheckedIOException: java.net.SocketTimeoutException
  89. at com.facebook.presto.jdbc.internal.client.JsonResponse.execute(JsonResponse.java:154)
  90. at com.facebook.presto.jdbc.internal.client.StatementClientV1.<init>(StatementClientV1.java:132)
  91. at com.facebook.presto.jdbc.internal.client.StatementClientFactory.newStatementClient(StatementClientFactory.java:24)
  92. at com.facebook.presto.jdbc.QueryExecutor.startQuery(QueryExecutor.java:46)
  93. at com.facebook.presto.jdbc.PrestoConnection.startQuery(PrestoConnection.java:701)
  94. at com.facebook.presto.jdbc.PrestoStatement.internalExecute(PrestoStatement.java:240)
  95. ... 24 more
  96. Caused by: java.net.SocketTimeoutException
  97. at sun.nio.ch.SocketAdaptor.connect(SocketAdaptor.java:118)
  98. at com.facebook.presto.jdbc.internal.okhttp3.internal.platform.Platform.connectSocket(Platform.java:125)
  99. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.RealConnection.connectSocket(RealConnection.java:238)
  100. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.RealConnection.connect(RealConnection.java:158)
  101. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.StreamAllocation.findConnection(StreamAllocation.java:256)
  102. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.StreamAllocation.findHealthyConnection(StreamAllocation.java:134)
  103. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.StreamAllocation.newStream(StreamAllocation.java:113)
  104. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.ConnectInterceptor.intercept(ConnectInterceptor.java:42)
  105. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
  106. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
  107. at com.facebook.presto.jdbc.internal.okhttp3.internal.cache.CacheInterceptor.intercept(CacheInterceptor.java:93)
  108. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
  109. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
  110. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.BridgeInterceptor.intercept(BridgeInterceptor.java:93)
  111. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
  112. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RetryAndFollowUpInterceptor.intercept(RetryAndFollowUpInterceptor.java:125)
  113. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
  114. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
  115. at com.facebook.presto.jdbc.internal.client.OkHttpUtil.lambda$userAgent$0(OkHttpUtil.java:77)
  116. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
  117. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
  118. at com.facebook.presto.jdbc.internal.okhttp3.RealCall.getResponseWithInterceptorChain(RealCall.java:200)
  119. at com.facebook.presto.jdbc.internal.okhttp3.RealCall.execute(RealCall.java:77)
  120. at com.facebook.presto.jdbc.internal.client.JsonResponse.execute(JsonResponse.java:131)
  121. ... 29 more
  122.  
  123. 19/07/01 09:42:00 WARN TaskSetManager: Lost task 0.2 in stage 2.0 (TID 6, ip-172-16-1-13.ap-south-1.compute.internal, executor 2): java.sql.SQLException: Error executing query
  124. at com.facebook.presto.jdbc.PrestoStatement.internalExecute(PrestoStatement.java:279)
  125. at com.facebook.presto.jdbc.PrestoStatement.execute(PrestoStatement.java:228)
  126. at com.facebook.presto.jdbc.PrestoPreparedStatement.<init>(PrestoPreparedStatement.java:80)
  127. at com.facebook.presto.jdbc.PrestoConnection.prepareStatement(PrestoConnection.java:128)
  128. at com.facebook.presto.jdbc.PrestoConnection.prepareStatement(PrestoConnection.java:298)
  129. at org.apache.spark.sql.execution.datasources.jdbc.JDBCRDD.compute(JDBCRDD.scala:300)
  130. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:324)
  131. at org.apache.spark.rdd.RDD.iterator(RDD.scala:288)
  132. at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52)
  133. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:324)
  134. at org.apache.spark.rdd.RDD.iterator(RDD.scala:288)
  135. at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52)
  136. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:324)
  137. at org.apache.spark.rdd.RDD.iterator(RDD.scala:288)
  138. at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52)
  139. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:324)
  140. at org.apache.spark.rdd.RDD.iterator(RDD.scala:288)
  141. at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:90)
  142. at org.apache.spark.scheduler.Task.run(Task.scala:121)
  143. at org.apache.spark.executor.Executor$TaskRunner$$anonfun$10.apply(Executor.scala:408)
  144. at org.apache.spark.util.Utils$.tryWithSafeFinally(Utils.scala:1360)
  145. at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:414)
  146. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
  147. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
  148. at java.lang.Thread.run(Thread.java:748)
  149. Caused by: java.io.UncheckedIOException: java.net.SocketTimeoutException
  150. at com.facebook.presto.jdbc.internal.client.JsonResponse.execute(JsonResponse.java:154)
  151. at com.facebook.presto.jdbc.internal.client.StatementClientV1.<init>(StatementClientV1.java:132)
  152. at com.facebook.presto.jdbc.internal.client.StatementClientFactory.newStatementClient(StatementClientFactory.java:24)
  153. at com.facebook.presto.jdbc.QueryExecutor.startQuery(QueryExecutor.java:46)
  154. at com.facebook.presto.jdbc.PrestoConnection.startQuery(PrestoConnection.java:701)
  155. at com.facebook.presto.jdbc.PrestoStatement.internalExecute(PrestoStatement.java:240)
  156. ... 24 more
  157. Caused by: java.net.SocketTimeoutException
  158. at sun.nio.ch.SocketAdaptor.connect(SocketAdaptor.java:118)
  159. at com.facebook.presto.jdbc.internal.okhttp3.internal.platform.Platform.connectSocket(Platform.java:125)
  160. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.RealConnection.connectSocket(RealConnection.java:238)
  161. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.RealConnection.connect(RealConnection.java:158)
  162. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.StreamAllocation.findConnection(StreamAllocation.java:256)
  163. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.StreamAllocation.findHealthyConnection(StreamAllocation.java:134)
  164. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.StreamAllocation.newStream(StreamAllocation.java:113)
  165. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.ConnectInterceptor.intercept(ConnectInterceptor.java:42)
  166. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
  167. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
  168. at com.facebook.presto.jdbc.internal.okhttp3.internal.cache.CacheInterceptor.intercept(CacheInterceptor.java:93)
  169. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
  170. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
  171. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.BridgeInterceptor.intercept(BridgeInterceptor.java:93)
  172. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
  173. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RetryAndFollowUpInterceptor.intercept(RetryAndFollowUpInterceptor.java:125)
  174. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
  175. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
  176. at com.facebook.presto.jdbc.internal.client.OkHttpUtil.lambda$userAgent$0(OkHttpUtil.java:77)
  177. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
  178. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
  179. at com.facebook.presto.jdbc.internal.okhttp3.RealCall.getResponseWithInterceptorChain(RealCall.java:200)
  180. at com.facebook.presto.jdbc.internal.okhttp3.RealCall.execute(RealCall.java:77)
  181. at com.facebook.presto.jdbc.internal.client.JsonResponse.execute(JsonResponse.java:131)
  182. ... 29 more
  183.  
  184. 19/07/01 09:42:10 WARN TaskSetManager: Lost task 0.3 in stage 2.0 (TID 7, ip-172-16-1-13.ap-south-1.compute.internal, executor 2): java.sql.SQLException: Error executing query
  185. at com.facebook.presto.jdbc.PrestoStatement.internalExecute(PrestoStatement.java:279)
  186. at com.facebook.presto.jdbc.PrestoStatement.execute(PrestoStatement.java:228)
  187. at com.facebook.presto.jdbc.PrestoPreparedStatement.<init>(PrestoPreparedStatement.java:80)
  188. at com.facebook.presto.jdbc.PrestoConnection.prepareStatement(PrestoConnection.java:128)
  189. at com.facebook.presto.jdbc.PrestoConnection.prepareStatement(PrestoConnection.java:298)
  190. at org.apache.spark.sql.execution.datasources.jdbc.JDBCRDD.compute(JDBCRDD.scala:300)
  191. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:324)
  192. at org.apache.spark.rdd.RDD.iterator(RDD.scala:288)
  193. at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52)
  194. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:324)
  195. at org.apache.spark.rdd.RDD.iterator(RDD.scala:288)
  196. at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52)
  197. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:324)
  198. at org.apache.spark.rdd.RDD.iterator(RDD.scala:288)
  199. at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52)
  200. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:324)
  201. at org.apache.spark.rdd.RDD.iterator(RDD.scala:288)
  202. at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:90)
  203. at org.apache.spark.scheduler.Task.run(Task.scala:121)
  204. at org.apache.spark.executor.Executor$TaskRunner$$anonfun$10.apply(Executor.scala:408)
  205. at org.apache.spark.util.Utils$.tryWithSafeFinally(Utils.scala:1360)
  206. at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:414)
  207. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
  208. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
  209. at java.lang.Thread.run(Thread.java:748)
  210. Caused by: java.io.UncheckedIOException: java.net.SocketTimeoutException
  211. at com.facebook.presto.jdbc.internal.client.JsonResponse.execute(JsonResponse.java:154)
  212. at com.facebook.presto.jdbc.internal.client.StatementClientV1.<init>(StatementClientV1.java:132)
  213. at com.facebook.presto.jdbc.internal.client.StatementClientFactory.newStatementClient(StatementClientFactory.java:24)
  214. at com.facebook.presto.jdbc.QueryExecutor.startQuery(QueryExecutor.java:46)
  215. at com.facebook.presto.jdbc.PrestoConnection.startQuery(PrestoConnection.java:701)
  216. at com.facebook.presto.jdbc.PrestoStatement.internalExecute(PrestoStatement.java:240)
  217. ... 24 more
  218. Caused by: java.net.SocketTimeoutException
  219. at sun.nio.ch.SocketAdaptor.connect(SocketAdaptor.java:118)
  220. at com.facebook.presto.jdbc.internal.okhttp3.internal.platform.Platform.connectSocket(Platform.java:125)
  221. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.RealConnection.connectSocket(RealConnection.java:238)
  222. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.RealConnection.connect(RealConnection.java:158)
  223. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.StreamAllocation.findConnection(StreamAllocation.java:256)
  224. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.StreamAllocation.findHealthyConnection(StreamAllocation.java:134)
  225. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.StreamAllocation.newStream(StreamAllocation.java:113)
  226. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.ConnectInterceptor.intercept(ConnectInterceptor.java:42)
  227. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
  228. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
  229. at com.facebook.presto.jdbc.internal.okhttp3.internal.cache.CacheInterceptor.intercept(CacheInterceptor.java:93)
  230. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
  231. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
  232. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.BridgeInterceptor.intercept(BridgeInterceptor.java:93)
  233. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
  234. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RetryAndFollowUpInterceptor.intercept(RetryAndFollowUpInterceptor.java:125)
  235. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
  236. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
  237. at com.facebook.presto.jdbc.internal.client.OkHttpUtil.lambda$userAgent$0(OkHttpUtil.java:77)
  238. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
  239. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
  240. at com.facebook.presto.jdbc.internal.okhttp3.RealCall.getResponseWithInterceptorChain(RealCall.java:200)
  241. at com.facebook.presto.jdbc.internal.okhttp3.RealCall.execute(RealCall.java:77)
  242. at com.facebook.presto.jdbc.internal.client.JsonResponse.execute(JsonResponse.java:131)
  243. ... 29 more
  244.  
  245. 19/07/01 09:42:10 ERROR TaskSetManager: Task 0 in stage 2.0 failed 4 times; aborting job
  246. Traceback (most recent call last):
  247. File "<stdin>", line 1, in <module>
  248. File "/usr/lib/spark/python/pyspark/sql/dataframe.py", line 1252, in head
  249. return self.take(n)
  250. File "/usr/lib/spark/python/pyspark/sql/dataframe.py", line 571, in take
  251. return self.limit(num).collect()
  252. File "/usr/lib/spark/python/pyspark/sql/dataframe.py", line 533, in collect
  253. sock_info = self._jdf.collectToPython()
  254. File "/usr/lib/spark/python/lib/py4j-0.10.7-src.zip/py4j/java_gateway.py", line 1257, in __call__
  255. File "/usr/lib/spark/python/pyspark/sql/utils.py", line 63, in deco
  256. return f(*a, **kw)
  257. File "/usr/lib/spark/python/lib/py4j-0.10.7-src.zip/py4j/protocol.py", line 328, in get_return_value
  258. py4j.protocol.Py4JJavaError: An error occurred while calling o120.collectToPython.
  259. : org.apache.spark.SparkException: Job aborted due to stage failure: Task 0 in stage 2.0 failed 4 times, most recent failure: Lost task 0.3 in stage 2.0 (TID 7, ip-172-16-1-13.ap-south-1.compute.internal, executor 2): java.sql.SQLException: Error executing query
  260. at com.facebook.presto.jdbc.PrestoStatement.internalExecute(PrestoStatement.java:279)
  261. at com.facebook.presto.jdbc.PrestoStatement.execute(PrestoStatement.java:228)
  262. at com.facebook.presto.jdbc.PrestoPreparedStatement.<init>(PrestoPreparedStatement.java:80)
  263. at com.facebook.presto.jdbc.PrestoConnection.prepareStatement(PrestoConnection.java:128)
  264. at com.facebook.presto.jdbc.PrestoConnection.prepareStatement(PrestoConnection.java:298)
  265. at org.apache.spark.sql.execution.datasources.jdbc.JDBCRDD.compute(JDBCRDD.scala:300)
  266. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:324)
  267. at org.apache.spark.rdd.RDD.iterator(RDD.scala:288)
  268. at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52)
  269. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:324)
  270. at org.apache.spark.rdd.RDD.iterator(RDD.scala:288)
  271. at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52)
  272. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:324)
  273. at org.apache.spark.rdd.RDD.iterator(RDD.scala:288)
  274. at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52)
  275. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:324)
  276. at org.apache.spark.rdd.RDD.iterator(RDD.scala:288)
  277. at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:90)
  278. at org.apache.spark.scheduler.Task.run(Task.scala:121)
  279. at org.apache.spark.executor.Executor$TaskRunner$$anonfun$10.apply(Executor.scala:408)
  280. at org.apache.spark.util.Utils$.tryWithSafeFinally(Utils.scala:1360)
  281. at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:414)
  282. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
  283. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
  284. at java.lang.Thread.run(Thread.java:748)
  285. Caused by: java.io.UncheckedIOException: java.net.SocketTimeoutException
  286. at com.facebook.presto.jdbc.internal.client.JsonResponse.execute(JsonResponse.java:154)
  287. at com.facebook.presto.jdbc.internal.client.StatementClientV1.<init>(StatementClientV1.java:132)
  288. at com.facebook.presto.jdbc.internal.client.StatementClientFactory.newStatementClient(StatementClientFactory.java:24)
  289. at com.facebook.presto.jdbc.QueryExecutor.startQuery(QueryExecutor.java:46)
  290. at com.facebook.presto.jdbc.PrestoConnection.startQuery(PrestoConnection.java:701)
  291. at com.facebook.presto.jdbc.PrestoStatement.internalExecute(PrestoStatement.java:240)
  292. ... 24 more
  293. Caused by: java.net.SocketTimeoutException
  294. at sun.nio.ch.SocketAdaptor.connect(SocketAdaptor.java:118)
  295. at com.facebook.presto.jdbc.internal.okhttp3.internal.platform.Platform.connectSocket(Platform.java:125)
  296. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.RealConnection.connectSocket(RealConnection.java:238)
  297. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.RealConnection.connect(RealConnection.java:158)
  298. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.StreamAllocation.findConnection(StreamAllocation.java:256)
  299. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.StreamAllocation.findHealthyConnection(StreamAllocation.java:134)
  300. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.StreamAllocation.newStream(StreamAllocation.java:113)
  301. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.ConnectInterceptor.intercept(ConnectInterceptor.java:42)
  302. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
  303. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
  304. at com.facebook.presto.jdbc.internal.okhttp3.internal.cache.CacheInterceptor.intercept(CacheInterceptor.java:93)
  305. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
  306. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
  307. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.BridgeInterceptor.intercept(BridgeInterceptor.java:93)
  308. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
  309. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RetryAndFollowUpInterceptor.intercept(RetryAndFollowUpInterceptor.java:125)
  310. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
  311. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
  312. at com.facebook.presto.jdbc.internal.client.OkHttpUtil.lambda$userAgent$0(OkHttpUtil.java:77)
  313. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
  314. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
  315. at com.facebook.presto.jdbc.internal.okhttp3.RealCall.getResponseWithInterceptorChain(RealCall.java:200)
  316. at com.facebook.presto.jdbc.internal.okhttp3.RealCall.execute(RealCall.java:77)
  317. at com.facebook.presto.jdbc.internal.client.JsonResponse.execute(JsonResponse.java:131)
  318. ... 29 more
  319.  
  320. Driver stacktrace:
  321. at org.apache.spark.scheduler.DAGScheduler.org$apache$spark$scheduler$DAGScheduler$$failJobAndIndependentStages(DAGScheduler.scala:2041)
  322. at org.apache.spark.scheduler.DAGScheduler$$anonfun$abortStage$1.apply(DAGScheduler.scala:2029)
  323. at org.apache.spark.scheduler.DAGScheduler$$anonfun$abortStage$1.apply(DAGScheduler.scala:2028)
  324. at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)
  325. at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:48)
  326. at org.apache.spark.scheduler.DAGScheduler.abortStage(DAGScheduler.scala:2028)
  327. at org.apache.spark.scheduler.DAGScheduler$$anonfun$handleTaskSetFailed$1.apply(DAGScheduler.scala:966)
  328. at org.apache.spark.scheduler.DAGScheduler$$anonfun$handleTaskSetFailed$1.apply(DAGScheduler.scala:966)
  329. at scala.Option.foreach(Option.scala:257)
  330. at org.apache.spark.scheduler.DAGScheduler.handleTaskSetFailed(DAGScheduler.scala:966)
  331. at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.doOnReceive(DAGScheduler.scala:2262)
  332. at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.onReceive(DAGScheduler.scala:2211)
  333. at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.onReceive(DAGScheduler.scala:2200)
  334. at org.apache.spark.util.EventLoop$$anon$1.run(EventLoop.scala:49)
  335. at org.apache.spark.scheduler.DAGScheduler.runJob(DAGScheduler.scala:777)
  336. at org.apache.spark.SparkContext.runJob(SparkContext.scala:2061)
  337. at org.apache.spark.SparkContext.runJob(SparkContext.scala:2082)
  338. at org.apache.spark.SparkContext.runJob(SparkContext.scala:2101)
  339. at org.apache.spark.sql.execution.SparkPlan.executeTake(SparkPlan.scala:365)
  340. at org.apache.spark.sql.execution.CollectLimitExec.executeCollect(limit.scala:38)
  341. at org.apache.spark.sql.Dataset$$anonfun$collectToPython$1.apply(Dataset.scala:3257)
  342. at org.apache.spark.sql.Dataset$$anonfun$collectToPython$1.apply(Dataset.scala:3254)
  343. at org.apache.spark.sql.Dataset$$anonfun$53.apply(Dataset.scala:3364)
  344. at org.apache.spark.sql.execution.SQLExecution$$anonfun$withNewExecutionId$1.apply(SQLExecution.scala:78)
  345. at org.apache.spark.sql.execution.SQLExecution$.withSQLConfPropagated(SQLExecution.scala:125)
  346. at org.apache.spark.sql.execution.SQLExecution$.withNewExecutionId(SQLExecution.scala:73)
  347. at org.apache.spark.sql.Dataset.withAction(Dataset.scala:3363)
  348. at org.apache.spark.sql.Dataset.collectToPython(Dataset.scala:3254)
  349. at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  350. at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  351. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  352. at java.lang.reflect.Method.invoke(Method.java:498)
  353. at py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
  354. at py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
  355. at py4j.Gateway.invoke(Gateway.java:282)
  356. at py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
  357. at py4j.commands.CallCommand.execute(CallCommand.java:79)
  358. at py4j.GatewayConnection.run(GatewayConnection.java:238)
  359. at java.lang.Thread.run(Thread.java:748)
  360. Caused by: java.sql.SQLException: Error executing query
  361. at com.facebook.presto.jdbc.PrestoStatement.internalExecute(PrestoStatement.java:279)
  362. at com.facebook.presto.jdbc.PrestoStatement.execute(PrestoStatement.java:228)
  363. at com.facebook.presto.jdbc.PrestoPreparedStatement.<init>(PrestoPreparedStatement.java:80)
  364. at com.facebook.presto.jdbc.PrestoConnection.prepareStatement(PrestoConnection.java:128)
  365. at com.facebook.presto.jdbc.PrestoConnection.prepareStatement(PrestoConnection.java:298)
  366. at org.apache.spark.sql.execution.datasources.jdbc.JDBCRDD.compute(JDBCRDD.scala:300)
  367. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:324)
  368. at org.apache.spark.rdd.RDD.iterator(RDD.scala:288)
  369. at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52)
  370. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:324)
  371. at org.apache.spark.rdd.RDD.iterator(RDD.scala:288)
  372. at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52)
  373. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:324)
  374. at org.apache.spark.rdd.RDD.iterator(RDD.scala:288)
  375. at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52)
  376. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:324)
  377. at org.apache.spark.rdd.RDD.iterator(RDD.scala:288)
  378. at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:90)
  379. at org.apache.spark.scheduler.Task.run(Task.scala:121)
  380. at org.apache.spark.executor.Executor$TaskRunner$$anonfun$10.apply(Executor.scala:408)
  381. at org.apache.spark.util.Utils$.tryWithSafeFinally(Utils.scala:1360)
  382. at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:414)
  383. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
  384. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
  385. ... 1 more
  386. Caused by: java.io.UncheckedIOException: java.net.SocketTimeoutException
  387. at com.facebook.presto.jdbc.internal.client.JsonResponse.execute(JsonResponse.java:154)
  388. at com.facebook.presto.jdbc.internal.client.StatementClientV1.<init>(StatementClientV1.java:132)
  389. at com.facebook.presto.jdbc.internal.client.StatementClientFactory.newStatementClient(StatementClientFactory.java:24)
  390. at com.facebook.presto.jdbc.QueryExecutor.startQuery(QueryExecutor.java:46)
  391. at com.facebook.presto.jdbc.PrestoConnection.startQuery(PrestoConnection.java:701)
  392. at com.facebook.presto.jdbc.PrestoStatement.internalExecute(PrestoStatement.java:240)
  393. ... 24 more
  394. Caused by: java.net.SocketTimeoutException
  395. at sun.nio.ch.SocketAdaptor.connect(SocketAdaptor.java:118)
  396. at com.facebook.presto.jdbc.internal.okhttp3.internal.platform.Platform.connectSocket(Platform.java:125)
  397. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.RealConnection.connectSocket(RealConnection.java:238)
  398. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.RealConnection.connect(RealConnection.java:158)
  399. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.StreamAllocation.findConnection(StreamAllocation.java:256)
  400. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.StreamAllocation.findHealthyConnection(StreamAllocation.java:134)
  401. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.StreamAllocation.newStream(StreamAllocation.java:113)
  402. at com.facebook.presto.jdbc.internal.okhttp3.internal.connection.ConnectInterceptor.intercept(ConnectInterceptor.java:42)
  403. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
  404. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
  405. at com.facebook.presto.jdbc.internal.okhttp3.internal.cache.CacheInterceptor.intercept(CacheInterceptor.java:93)
  406. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
  407. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
  408. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.BridgeInterceptor.intercept(BridgeInterceptor.java:93)
  409. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
  410. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RetryAndFollowUpInterceptor.intercept(RetryAndFollowUpInterceptor.java:125)
  411. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
  412. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
  413. at com.facebook.presto.jdbc.internal.client.OkHttpUtil.lambda$userAgent$0(OkHttpUtil.java:77)
  414. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
  415. at com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
  416. at com.facebook.presto.jdbc.internal.okhttp3.RealCall.getResponseWithInterceptorChain(RealCall.java:200)
  417. at com.facebook.presto.jdbc.internal.okhttp3.RealCall.execute(RealCall.java:77)
  418. at com.facebook.presto.jdbc.internal.client.JsonResponse.execute(JsonResponse.java:131)
  419. ... 29 more
Add Comment
Please, Sign In to add comment