API tools faq
paste
Advertisement
Guest User

Untitled

a guest
Oct 21st, 2017
98
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 30.20 KB | None | 0 0
raw download clone embed print report
  1. [DEBUG] [10/21/2017 23:02:02.535] [on-spray-can-akka.actor.default-dispatcher-14] [akka://on-spray-can/user/IO-HTTP/listener-0/47] Dispatching GET request to http://172.17.0.68:8080/commands to handler Actor[akka://on-spray-can/system/IO-TCP/selectors/$a/50#691353160]
  2. [DEBUG] [10/21/2017 23:02:03.336] [default-akka.actor.default-dispatcher-10] [akka://default/user/IO-HTTP/group-0/89] Connection was PeerClosed, awaiting TcpConnection termination...
  3. [DEBUG] [10/21/2017 23:02:03.336] [default-akka.actor.default-dispatcher-10] [akka://default/user/IO-HTTP/group-0/89] TcpConnection terminated, stopping
  4. [DEBUG] [10/21/2017 23:02:21.167] [on-spray-can-akka.actor.default-dispatcher-11] [akka://on-spray-can/user/IO-HTTP/listener-0/47] Dispatching POST request to http://172.17.0.68:8080/ to handler Actor[akka://on-spray-can/system/IO-TCP/selectors/$a/50#691353160]
  5. [DEBUG] [10/21/2017 23:02:21.174] [on-spray-can-akka.actor.default-dispatcher-15] [akka://on-spray-can/user/data-receiver-service] POST request accepted : api-key = 31a19214e8063960392ff685bef193f5f56fcac93ce34ef85249049c , aggregator-id = myTestAggregator , file size = 674 , description = None
  6. [INFO] [10/21/2017 23:02:21.175] [on-spray-can-akka.actor.default-dispatcher-16] [akka://on-spray-can/user/data-receiver-service] File accepted for s3 upload, md5 = BEDAE8DCF51D3E703025BF59DBD76D17
  7. [DEBUG] [10/21/2017 23:02:21.175] [on-spray-can-akka.actor.default-dispatcher-16] [akka://on-spray-can/user/data-receiver-service/s3roundRouted/$g] Upload request received: S3UploadFile([B@7fea9f66,unparsed,myTestAggregator,5f1720a00bb0441b89b6f596f0202c59,no description,BEDAE8DCF51D3E703025BF59DBD76D17,171021230200,Actor[akka://on-spray-can/user/data-receiver-service/rabbitService#1654101991])
  8. [DEBUG] [10/21/2017 23:02:21.183] [on-spray-can-akka.actor.default-dispatcher-13] [akka://on-spray-can/user/data-receiver-service/userApiService] Connecting consul: http://172.17.0.36:8500/v1/catalog/service/aggregator-service [Retries remaining: 4]
  9. [DEBUG] [10/21/2017 23:02:21.188] [default-akka.actor.default-dispatcher-10] [akka://default/user/IO-HTTP/host-connector-0/0] Dispatching GET request to /v1/catalog/service/aggregator-service across connection Actor[akka://default/user/IO-HTTP/group-0/0#170907652]
  10. [DEBUG] [10/21/2017 23:02:21.193] [default-akka.actor.default-dispatcher-9] [akka://default/user/IO-HTTP/host-connector-0/0] Delivering 200 OK response for GET request to /v1/catalog/service/aggregator-service
  11. [DEBUG] [10/21/2017 23:02:21.196] [default-akka.actor.default-dispatcher-9] [akka://default/user/IO-HTTP/host-connector-4/11] Attempting new connection to 172.17.42.1:32799
  12. [DEBUG] [10/21/2017 23:02:21.196] [default-akka.actor.default-dispatcher-11] [akka://default/user/IO-HTTP/group-0/90] Attempting connection to /172.17.42.1:32799
  13. [DEBUG] [10/21/2017 23:02:21.198] [default-akka.actor.default-dispatcher-13] [akka://default/system/IO-TCP/selectors/$a/90] Attempting connection to [/172.17.42.1:32799]
  14. [DEBUG] [10/21/2017 23:02:21.204] [default-akka.actor.default-dispatcher-13] [akka://default/system/IO-TCP/selectors/$a/90] Connection established to [/172.17.42.1:32799]
  15. [DEBUG] [10/21/2017 23:02:21.204] [default-akka.actor.default-dispatcher-13] [akka://default/user/IO-HTTP/group-0/90] Connected to /172.17.42.1:32799
  16. [DEBUG] [10/21/2017 23:02:21.204] [default-akka.actor.default-dispatcher-13] [akka://default/user/IO-HTTP/host-connector-4/11] Connection to 172.17.42.1:32799 established, dispatching 1 pending requests
  17. [DEBUG] [10/21/2017 23:02:21.204] [default-akka.actor.default-dispatcher-13] [akka://default/user/IO-HTTP/host-connector-4/11] Dispatching GET request to /?clientId=5f1720a00bb0441b89b6f596f0202c59&uniqueId=myTestAggregator across connection Actor[akka://default/user/IO-HTTP/group-0/90#-1529276464]
  18. [DEBUG] [10/21/2017 23:02:21.196] [default-akka.actor.default-dispatcher-9] [akka://on-spray-can/user/data-receiver-service/userApiService] Sending get request to aggregator-service: http://172.17.42.1:32799/?clientId=5f1720a00bb0441b89b6f596f0202c59&uniqueId=myTestAggregator [Retries remaining: 4]
  19. [DEBUG] [10/21/2017 23:02:21.241] [default-akka.actor.default-dispatcher-10] [akka://default/user/IO-HTTP/host-connector-4/11] Delivering 200 OK response for GET request to /?clientId=5f1720a00bb0441b89b6f596f0202c59&uniqueId=myTestAggregator
  20. [DEBUG] [10/21/2017 23:02:21.245] [default-akka.actor.default-dispatcher-14] [akka://on-spray-can/user/data-receiver-service/userApiService] Aggregator-id exists:myTestAggregator, skipping.
  21. [DEBUG] [10/21/2017 23:02:22.508] [on-spray-can-akka.actor.default-dispatcher-13] [akka://on-spray-can/user/data-receiver-service/rabbitService] Failure Message sent to RabbitMQ: Failed upload {"url": "s3://sageaxcess-microservice-bucket-5f1720a00bb0441b89b6f596f0202c59/unparsed/20171021/drfile-myTestAggregator-171021230200-20171021230221aoPCKmxr.parquet", "dataType": "unparsed", "aggregatorId": "myTestAggregator", "clientId": "5f1720a00bb0441b89b6f596f0202c59", "md5": "BEDAE8DCF51D3E703025BF59DBD76D17", "time": "171021230200", "description": "no description"}, with exception Status Code: 400, AWS Service: Amazon S3, AWS Request ID: BD3120B6D30E9F0F, AWS Error Code: null, AWS Error Message: Bad Request
  22. [DEBUG] [10/21/2017 23:02:22.509] [default-akka.actor.default-dispatcher-71] [akka://default/user/rabbitmq/$a] in Connected received ChannelMessage(<function1>,false): received channel message resulted in ProcessSuccess(())
  23. [ERROR] [10/21/2017 23:02:22.509] [on-spray-can-akka.actor.default-dispatcher-16] [akka://on-spray-can/user/data-receiver-service/s3roundRouted/$g] Upload failed: {"url": "s3://sageaxcess-microservice-bucket-5f1720a00bb0441b89b6f596f0202c59/unparsed/20171021/drfile-myTestAggregator-171021230200-20171021230221aoPCKmxr.parquet", "dataType": "unparsed", "aggregatorId": "myTestAggregator", "clientId": "5f1720a00bb0441b89b6f596f0202c59", "md5": "BEDAE8DCF51D3E703025BF59DBD76D17", "time": "171021230200", "description": "no description"}
  24. com.amazonaws.services.s3.model.AmazonS3Exception: Status Code: 400, AWS Service: Amazon S3, AWS Request ID: BD3120B6D30E9F0F, AWS Error Code: null, AWS Error Message: Bad Request, S3 Extended Request ID: c6559lhwTY3aSJxcOAQjbbe4lz9jkDXy/f6BRGb7ynYe3dfhSzScYRcVpZkn5EkcYgLGs6cHbjc=
  25. at com.amazonaws.http.AmazonHttpClient.handleErrorResponse(AmazonHttpClient.java:798)
  26. at com.amazonaws.http.AmazonHttpClient.executeHelper(AmazonHttpClient.java:421)
  27. at com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:232)
  28. at com.amazonaws.services.s3.AmazonS3Client.invoke(AmazonS3Client.java:3528)
  29. at com.amazonaws.services.s3.AmazonS3Client.headBucket(AmazonS3Client.java:1031)
  30. at com.amazonaws.services.s3.AmazonS3Client.doesBucketExist(AmazonS3Client.java:994)
  31. at com.sageaxcess.handlers.S3UploaderActor.upload(S3UploaderActor.scala:50)
  32. at com.sageaxcess.handlers.S3UploaderActor$$anonfun$receive$1.applyOrElse(S3UploaderActor.scala:88)
  33. at akka.actor.Actor$class.aroundReceive(Actor.scala:484)
  34. at com.sageaxcess.handlers.S3UploaderActor.aroundReceive(S3UploaderActor.scala:27)
  35. at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
  36. at akka.actor.ActorCell.invoke(ActorCell.scala:495)
  37. at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
  38. at akka.dispatch.Mailbox.run(Mailbox.scala:224)
  39. at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
  40. at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
  41. at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
  42. at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
  43. at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
  44.  
  45. [DEBUG] [10/21/2017 23:02:23.420] [default-akka.actor.default-dispatcher-11] [akka://default/user/IO-HTTP/group-0/90] Connection was PeerClosed, awaiting TcpConnection termination...
  46. [DEBUG] [10/21/2017 23:02:23.420] [default-akka.actor.default-dispatcher-10] [akka://default/user/IO-HTTP/group-0/90] TcpConnection terminated, stopping
  47. [DEBUG] [10/21/2017 23:02:25.075] [on-spray-can-akka.actor.default-dispatcher-16] [akka://on-spray-can/system/IO-TCP/selectors/$a/49] Closing connection due to IO error java.io.IOException: Connection reset by peer
  48. [DEBUG] [10/21/2017 23:02:25.075] [on-spray-can-akka.actor.default-dispatcher-13] [akka://on-spray-can/user/IO-HTTP/listener-0/46] Connection was ErrorClosed(Connection reset by peer), awaiting TcpConnection termination...
  49. [DEBUG] [10/21/2017 23:02:25.076] [on-spray-can-akka.actor.default-dispatcher-13] [akka://on-spray-can/user/IO-HTTP/listener-0/46] TcpConnection terminated, stopping
  50. [DEBUG] [10/21/2017 23:02:53.429] [default-akka.actor.default-dispatcher-11] [akka://default/user/IO-HTTP/host-connector-4/11] Initiating idle shutdown
  51. [DEBUG] [10/21/2017 23:03:01.207] [on-spray-can-akka.actor.default-dispatcher-13] [akka://on-spray-can/system/IO-TCP/selectors/$a/0] New connection accepted
  52. [DEBUG] [10/21/2017 23:03:01.235] [on-spray-can-akka.actor.default-dispatcher-13] [akka://on-spray-can/user/IO-HTTP/listener-0/48] Dispatching POST request to http://172.17.0.68:8080/ to handler Actor[akka://on-spray-can/system/IO-TCP/selectors/$a/51#-1580928335]
  53. [DEBUG] [10/21/2017 23:03:01.273] [on-spray-can-akka.actor.default-dispatcher-14] [akka://on-spray-can/user/data-receiver-service] POST request accepted : api-key = 31a19214e8063960392ff685bef193f5f56fcac93ce34ef85249049c , aggregator-id = myTestAggregator , file size = 15696 , description = None
  54. [DEBUG] [10/21/2017 23:03:01.282] [default-akka.actor.default-dispatcher-11] [akka://default/user/IO-HTTP/host-connector-0/0] Dispatching GET request to /v1/catalog/service/aggregator-service across connection Actor[akka://default/user/IO-HTTP/group-0/0#170907652]
  55. [INFO] [10/21/2017 23:03:01.281] [on-spray-can-akka.actor.default-dispatcher-16] [akka://on-spray-can/user/data-receiver-service] File accepted for s3 upload, md5 = 3C1AF1592FD3B5886CCE7486255646A1
  56. [DEBUG] [10/21/2017 23:03:01.281] [on-spray-can-akka.actor.default-dispatcher-12] [akka://on-spray-can/user/data-receiver-service/s3roundRouted/$h] Upload request received: S3UploadFile([B@2d00fa31,GENERAL,myTestAggregator,5f1720a00bb0441b89b6f596f0202c59,no description,3C1AF1592FD3B5886CCE7486255646A1,171021230300,Actor[akka://on-spray-can/user/data-receiver-service/rabbitService#1654101991])
  57. [DEBUG] [10/21/2017 23:03:01.282] [on-spray-can-akka.actor.default-dispatcher-17] [akka://on-spray-can/user/data-receiver-service/userApiService] Connecting consul: http://172.17.0.36:8500/v1/catalog/service/aggregator-service [Retries remaining: 4]
  58. [DEBUG] [10/21/2017 23:03:01.290] [default-akka.actor.default-dispatcher-10] [akka://on-spray-can/user/data-receiver-service/userApiService] Sending get request to aggregator-service: http://172.17.42.1:32799/?clientId=5f1720a00bb0441b89b6f596f0202c59&uniqueId=myTestAggregator [Retries remaining: 4]
  59. [DEBUG] [10/21/2017 23:03:01.289] [default-akka.actor.default-dispatcher-11] [akka://default/user/IO-HTTP/host-connector-0/0] Delivering 200 OK response for GET request to /v1/catalog/service/aggregator-service
  60. [DEBUG] [10/21/2017 23:03:01.289] [default-akka.actor.default-dispatcher-5] [akka://default/user/IO-HTTP/host-connector-4/12] Attempting new connection to 172.17.42.1:32799
  61. [DEBUG] [10/21/2017 23:03:01.289] [default-akka.actor.default-dispatcher-5] [akka://default/user/IO-HTTP/group-0/91] Attempting connection to /172.17.42.1:32799
  62. [DEBUG] [10/21/2017 23:03:01.294] [default-akka.actor.default-dispatcher-10] [akka://default/system/IO-TCP/selectors/$a/91] Attempting connection to [/172.17.42.1:32799]
  63. [DEBUG] [10/21/2017 23:03:01.297] [default-akka.actor.default-dispatcher-10] [akka://default/system/IO-TCP/selectors/$a/91] Connection established to [/172.17.42.1:32799]
  64. [DEBUG] [10/21/2017 23:03:01.298] [default-akka.actor.default-dispatcher-10] [akka://default/user/IO-HTTP/group-0/91] Connected to /172.17.42.1:32799
  65. [DEBUG] [10/21/2017 23:03:01.298] [default-akka.actor.default-dispatcher-10] [akka://default/user/IO-HTTP/host-connector-4/12] Connection to 172.17.42.1:32799 established, dispatching 1 pending requests
  66. [DEBUG] [10/21/2017 23:03:01.298] [default-akka.actor.default-dispatcher-10] [akka://default/user/IO-HTTP/host-connector-4/12] Dispatching GET request to /?clientId=5f1720a00bb0441b89b6f596f0202c59&uniqueId=myTestAggregator across connection Actor[akka://default/user/IO-HTTP/group-0/91#362503819]
  67. [DEBUG] [10/21/2017 23:03:01.329] [default-akka.actor.default-dispatcher-10] [akka://default/user/IO-HTTP/host-connector-4/12] Delivering 200 OK response for GET request to /?clientId=5f1720a00bb0441b89b6f596f0202c59&uniqueId=myTestAggregator
  68. [DEBUG] [10/21/2017 23:03:01.331] [default-akka.actor.default-dispatcher-11] [akka://on-spray-can/user/data-receiver-service/userApiService] Aggregator-id exists:myTestAggregator, skipping.
  69. [DEBUG] [10/21/2017 23:03:02.076] [on-spray-can-akka.actor.default-dispatcher-14] [akka://on-spray-can/user/IO-HTTP/listener-0/48] Dispatching POST request to http://172.17.0.68:8080/ to handler Actor[akka://on-spray-can/system/IO-TCP/selectors/$a/51#-1580928335]
  70. [DEBUG] [10/21/2017 23:03:02.085] [on-spray-can-akka.actor.default-dispatcher-11] [akka://on-spray-can/user/data-receiver-service] POST request accepted : api-key = 31a19214e8063960392ff685bef193f5f56fcac93ce34ef85249049c , aggregator-id = myTestAggregator , file size = 12754 , description = None
  71. [INFO] [10/21/2017 23:03:02.085] [on-spray-can-akka.actor.default-dispatcher-14] [akka://on-spray-can/user/data-receiver-service] File accepted for s3 upload, md5 = 63EC28FEC9F529E022B4F7D526D3EA38
  72. [DEBUG] [10/21/2017 23:03:02.086] [on-spray-can-akka.actor.default-dispatcher-15] [akka://on-spray-can/user/data-receiver-service/s3roundRouted/$i] Upload request received: S3UploadFile([B@2129c6b3,HTTP,myTestAggregator,5f1720a00bb0441b89b6f596f0202c59,no description,63EC28FEC9F529E022B4F7D526D3EA38,171021230300,Actor[akka://on-spray-can/user/data-receiver-service/rabbitService#1654101991])
  73. [DEBUG] [10/21/2017 23:03:02.086] [on-spray-can-akka.actor.default-dispatcher-7] [akka://on-spray-can/user/data-receiver-service/userApiService] Connecting consul: http://172.17.0.36:8500/v1/catalog/service/aggregator-service [Retries remaining: 4]
  74. [DEBUG] [10/21/2017 23:03:02.096] [default-akka.actor.default-dispatcher-12] [akka://on-spray-can/user/data-receiver-service/userApiService] Sending get request to aggregator-service: http://172.17.42.1:32799/?clientId=5f1720a00bb0441b89b6f596f0202c59&uniqueId=myTestAggregator [Retries remaining: 4]
  75. [DEBUG] [10/21/2017 23:03:02.087] [default-akka.actor.default-dispatcher-9] [akka://default/user/IO-HTTP/host-connector-0/0] Dispatching GET request to /v1/catalog/service/aggregator-service across connection Actor[akka://default/user/IO-HTTP/group-0/0#170907652]
  76. [DEBUG] [10/21/2017 23:03:02.096] [default-akka.actor.default-dispatcher-12] [akka://default/user/IO-HTTP/host-connector-0/0] Delivering 200 OK response for GET request to /v1/catalog/service/aggregator-service
  77. [DEBUG] [10/21/2017 23:03:02.096] [default-akka.actor.default-dispatcher-12] [akka://default/user/IO-HTTP/host-connector-4/12] Dispatching GET request to /?clientId=5f1720a00bb0441b89b6f596f0202c59&uniqueId=myTestAggregator across connection Actor[akka://default/user/IO-HTTP/group-0/91#362503819]
  78. [DEBUG] [10/21/2017 23:03:02.130] [default-akka.actor.default-dispatcher-9] [akka://default/user/IO-HTTP/host-connector-4/12] Delivering 200 OK response for GET request to /?clientId=5f1720a00bb0441b89b6f596f0202c59&uniqueId=myTestAggregator
  79. [DEBUG] [10/21/2017 23:03:02.130] [default-akka.actor.default-dispatcher-12] [akka://on-spray-can/user/data-receiver-service/userApiService] Aggregator-id exists:myTestAggregator, skipping.
  80. [DEBUG] [10/21/2017 23:03:02.535] [on-spray-can-akka.actor.default-dispatcher-11] [akka://on-spray-can/user/IO-HTTP/listener-0/48] Dispatching GET request to http://172.17.0.68:8080/commands to handler Actor[akka://on-spray-can/system/IO-TCP/selectors/$a/51#-1580928335]
  81. [ERROR] [10/21/2017 23:03:02.632] [on-spray-can-akka.actor.default-dispatcher-12] [akka://on-spray-can/user/data-receiver-service/s3roundRouted/$h] Upload failed: {"url": "s3://sageaxcess-microservice-bucket-5f1720a00bb0441b89b6f596f0202c59/GENERAL/20171021/drfile-myTestAggregator-171021230300-20171021230301M3KJF25q.parquet", "dataType": "GENERAL", "aggregatorId": "myTestAggregator", "clientId": "5f1720a00bb0441b89b6f596f0202c59", "md5": "3C1AF1592FD3B5886CCE7486255646A1", "time": "171021230300", "description": "no description"}
  82. com.amazonaws.services.s3.model.AmazonS3Exception: Status Code: 400, AWS Service: Amazon S3, AWS Request ID: B5D0C067D5705F68, AWS Error Code: null, AWS Error Message: Bad Request, S3 Extended Request ID: IbrczBxb+aWqyJ6NfQWydHlFdrTi/2Aor8jTHl1ck32B4fc4JdiVTnrMDF5jRwrmAaqMBLk98tA=
  83. at com.amazonaws.http.AmazonHttpClient.handleErrorResponse(AmazonHttpClient.java:798)
  84. at com.amazonaws.http.AmazonHttpClient.executeHelper(AmazonHttpClient.java:421)
  85. at com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:232)
  86. at com.amazonaws.services.s3.AmazonS3Client.invoke(AmazonS3Client.java:3528)
  87. at com.amazonaws.services.s3.AmazonS3Client.headBucket(AmazonS3Client.java:1031)
  88. at com.amazonaws.services.s3.AmazonS3Client.doesBucketExist(AmazonS3Client.java:994)
  89. at com.sageaxcess.handlers.S3UploaderActor.upload(S3UploaderActor.scala:50)
  90. at com.sageaxcess.handlers.S3UploaderActor$$anonfun$receive$1.applyOrElse(S3UploaderActor.scala:88)
  91. at akka.actor.Actor$class.aroundReceive(Actor.scala:484)
  92. at com.sageaxcess.handlers.S3UploaderActor.aroundReceive(S3UploaderActor.scala:27)
  93. at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
  94. at akka.actor.ActorCell.invoke(ActorCell.scala:495)
  95. at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
  96. at akka.dispatch.Mailbox.run(Mailbox.scala:224)
  97. at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
  98. at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
  99. at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
  100. at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
  101. at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
  102.  
  103. [DEBUG] [10/21/2017 23:03:02.632] [on-spray-can-akka.actor.default-dispatcher-12] [akka://on-spray-can/user/data-receiver-service/rabbitService] Failure Message sent to RabbitMQ: Failed upload {"url": "s3://sageaxcess-microservice-bucket-5f1720a00bb0441b89b6f596f0202c59/GENERAL/20171021/drfile-myTestAggregator-171021230300-20171021230301M3KJF25q.parquet", "dataType": "GENERAL", "aggregatorId": "myTestAggregator", "clientId": "5f1720a00bb0441b89b6f596f0202c59", "md5": "3C1AF1592FD3B5886CCE7486255646A1", "time": "171021230300", "description": "no description"}, with exception Status Code: 400, AWS Service: Amazon S3, AWS Request ID: B5D0C067D5705F68, AWS Error Code: null, AWS Error Message: Bad Request
  104. [DEBUG] [10/21/2017 23:03:02.633] [default-akka.actor.default-dispatcher-71] [akka://default/user/rabbitmq/$a] in Connected received ChannelMessage(<function1>,false): received channel message resulted in ProcessSuccess(())
  105. [DEBUG] [10/21/2017 23:03:03.385] [on-spray-can-akka.actor.default-dispatcher-12] [akka://on-spray-can/user/data-receiver-service/rabbitService] Failure Message sent to RabbitMQ: Failed upload {"url": "s3://sageaxcess-microservice-bucket-5f1720a00bb0441b89b6f596f0202c59/HTTP/20171021/drfile-myTestAggregator-171021230300-2017102123030254E4cudx.parquet", "dataType": "HTTP", "aggregatorId": "myTestAggregator", "clientId": "5f1720a00bb0441b89b6f596f0202c59", "md5": "63EC28FEC9F529E022B4F7D526D3EA38", "time": "171021230300", "description": "no description"}, with exception Status Code: 400, AWS Service: Amazon S3, AWS Request ID: E994A90AAE56CED8, AWS Error Code: null, AWS Error Message: Bad Request
  106. [DEBUG] [10/21/2017 23:03:03.385] [default-akka.actor.default-dispatcher-90] [akka://default/user/rabbitmq/$a] in Connected received ChannelMessage(<function1>,false): received channel message resulted in ProcessSuccess(())
  107. [ERROR] [10/21/2017 23:03:03.386] [on-spray-can-akka.actor.default-dispatcher-15] [akka://on-spray-can/user/data-receiver-service/s3roundRouted/$i] Upload failed: {"url": "s3://sageaxcess-microservice-bucket-5f1720a00bb0441b89b6f596f0202c59/HTTP/20171021/drfile-myTestAggregator-171021230300-2017102123030254E4cudx.parquet", "dataType": "HTTP", "aggregatorId": "myTestAggregator", "clientId": "5f1720a00bb0441b89b6f596f0202c59", "md5": "63EC28FEC9F529E022B4F7D526D3EA38", "time": "171021230300", "description": "no description"}
  108. com.amazonaws.services.s3.model.AmazonS3Exception: Status Code: 400, AWS Service: Amazon S3, AWS Request ID: E994A90AAE56CED8, AWS Error Code: null, AWS Error Message: Bad Request, S3 Extended Request ID: La/HsP3SA8SNkTG7CWg85p6mG/Zp10ex1tLU5SDTn4U8RpJath4fKTY8KvxvGYCTQz+a4EOoKFA=
  109. at com.amazonaws.http.AmazonHttpClient.handleErrorResponse(AmazonHttpClient.java:798)
  110. at com.amazonaws.http.AmazonHttpClient.executeHelper(AmazonHttpClient.java:421)
  111. at com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:232)
  112. at com.amazonaws.services.s3.AmazonS3Client.invoke(AmazonS3Client.java:3528)
  113. at com.amazonaws.services.s3.AmazonS3Client.headBucket(AmazonS3Client.java:1031)
  114. at com.amazonaws.services.s3.AmazonS3Client.doesBucketExist(AmazonS3Client.java:994)
  115. at com.sageaxcess.handlers.S3UploaderActor.upload(S3UploaderActor.scala:50)
  116. at com.sageaxcess.handlers.S3UploaderActor$$anonfun$receive$1.applyOrElse(S3UploaderActor.scala:88)
  117. at akka.actor.Actor$class.aroundReceive(Actor.scala:484)
  118. at com.sageaxcess.handlers.S3UploaderActor.aroundReceive(S3UploaderActor.scala:27)
  119. at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
  120. at akka.actor.ActorCell.invoke(ActorCell.scala:495)
  121. at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
  122. at akka.dispatch.Mailbox.run(Mailbox.scala:224)
  123. at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
  124. at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
  125. at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
  126. at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
  127. at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
  128.  
  129. [DEBUG] [10/21/2017 23:03:04.303] [default-akka.actor.default-dispatcher-9] [akka://default/user/IO-HTTP/group-0/91] Connection was PeerClosed, awaiting TcpConnection termination...
  130. [DEBUG] [10/21/2017 23:03:04.303] [default-akka.actor.default-dispatcher-9] [akka://default/user/IO-HTTP/group-0/91] TcpConnection terminated, stopping
  131. [DEBUG] [10/21/2017 23:03:21.168] [on-spray-can-akka.actor.default-dispatcher-12] [akka://on-spray-can/user/IO-HTTP/listener-0/48] Dispatching POST request to http://172.17.0.68:8080/ to handler Actor[akka://on-spray-can/system/IO-TCP/selectors/$a/51#-1580928335]
  132. [DEBUG] [10/21/2017 23:03:21.178] [on-spray-can-akka.actor.default-dispatcher-7] [akka://on-spray-can/user/data-receiver-service] POST request accepted : api-key = 31a19214e8063960392ff685bef193f5f56fcac93ce34ef85249049c , aggregator-id = myTestAggregator , file size = 674 , description = None
  133. [INFO] [10/21/2017 23:03:21.179] [on-spray-can-akka.actor.default-dispatcher-13] [akka://on-spray-can/user/data-receiver-service] File accepted for s3 upload, md5 = 297F03AD29BDE33643A749763168CE4D
  134. [DEBUG] [10/21/2017 23:03:21.179] [on-spray-can-akka.actor.default-dispatcher-13] [akka://on-spray-can/user/data-receiver-service/s3roundRouted/$j] Upload request received: S3UploadFile([B@5271d7ee,unparsed,myTestAggregator,5f1720a00bb0441b89b6f596f0202c59,no description,297F03AD29BDE33643A749763168CE4D,171021230300,Actor[akka://on-spray-can/user/data-receiver-service/rabbitService#1654101991])
  135. [DEBUG] [10/21/2017 23:03:21.180] [on-spray-can-akka.actor.default-dispatcher-17] [akka://on-spray-can/user/data-receiver-service/userApiService] Connecting consul: http://172.17.0.36:8500/v1/catalog/service/aggregator-service [Retries remaining: 4]
  136. [DEBUG] [10/21/2017 23:03:21.187] [default-akka.actor.default-dispatcher-9] [akka://on-spray-can/user/data-receiver-service/userApiService] Sending get request to aggregator-service: http://172.17.42.1:32799/?clientId=5f1720a00bb0441b89b6f596f0202c59&uniqueId=myTestAggregator [Retries remaining: 4]
  137. [DEBUG] [10/21/2017 23:03:21.182] [default-akka.actor.default-dispatcher-12] [akka://default/user/IO-HTTP/host-connector-0/0] Dispatching GET request to /v1/catalog/service/aggregator-service across connection Actor[akka://default/user/IO-HTTP/group-0/0#170907652]
  138. [DEBUG] [10/21/2017 23:03:21.187] [default-akka.actor.default-dispatcher-9] [akka://default/user/IO-HTTP/host-connector-0/0] Delivering 200 OK response for GET request to /v1/catalog/service/aggregator-service
  139. [DEBUG] [10/21/2017 23:03:21.191] [default-akka.actor.default-dispatcher-9] [akka://default/user/IO-HTTP/host-connector-4/12] Attempting new connection to 172.17.42.1:32799
  140. [DEBUG] [10/21/2017 23:03:21.191] [default-akka.actor.default-dispatcher-10] [akka://default/user/IO-HTTP/group-0/92] Attempting connection to /172.17.42.1:32799
  141. [DEBUG] [10/21/2017 23:03:21.193] [default-akka.actor.default-dispatcher-10] [akka://default/system/IO-TCP/selectors/$a/92] Attempting connection to [/172.17.42.1:32799]
  142. [DEBUG] [10/21/2017 23:03:21.194] [default-akka.actor.default-dispatcher-10] [akka://default/system/IO-TCP/selectors/$a/92] Connection established to [/172.17.42.1:32799]
  143. [DEBUG] [10/21/2017 23:03:21.194] [default-akka.actor.default-dispatcher-10] [akka://default/user/IO-HTTP/group-0/92] Connected to /172.17.42.1:32799
  144. [DEBUG] [10/21/2017 23:03:21.194] [default-akka.actor.default-dispatcher-10] [akka://default/user/IO-HTTP/host-connector-4/12] Connection to 172.17.42.1:32799 established, dispatching 1 pending requests
  145. [DEBUG] [10/21/2017 23:03:21.194] [default-akka.actor.default-dispatcher-10] [akka://default/user/IO-HTTP/host-connector-4/12] Dispatching GET request to /?clientId=5f1720a00bb0441b89b6f596f0202c59&uniqueId=myTestAggregator across connection Actor[akka://default/user/IO-HTTP/group-0/92#2123666846]
  146. [DEBUG] [10/21/2017 23:03:21.260] [default-akka.actor.default-dispatcher-12] [akka://default/user/IO-HTTP/host-connector-4/12] Delivering 200 OK response for GET request to /?clientId=5f1720a00bb0441b89b6f596f0202c59&uniqueId=myTestAggregator
  147. [DEBUG] [10/21/2017 23:03:21.260] [default-akka.actor.default-dispatcher-10] [akka://on-spray-can/user/data-receiver-service/userApiService] Aggregator-id exists:myTestAggregator, skipping.
  148. [DEBUG] [10/21/2017 23:03:22.492] [on-spray-can-akka.actor.default-dispatcher-11] [akka://on-spray-can/user/data-receiver-service/rabbitService] Failure Message sent to RabbitMQ: Failed upload {"url": "s3://sageaxcess-microservice-bucket-5f1720a00bb0441b89b6f596f0202c59/unparsed/20171021/drfile-myTestAggregator-171021230300-20171021230321RaLoI4l5.parquet", "dataType": "unparsed", "aggregatorId": "myTestAggregator", "clientId": "5f1720a00bb0441b89b6f596f0202c59", "md5": "297F03AD29BDE33643A749763168CE4D", "time": "171021230300", "description": "no description"}, with exception Status Code: 400, AWS Service: Amazon S3, AWS Request ID: B91E950C5D4ABB6A, AWS Error Code: null, AWS Error Message: Bad Request
  149. [DEBUG] [10/21/2017 23:03:22.493] [default-akka.actor.default-dispatcher-71] [akka://default/user/rabbitmq/$a] in Connected received ChannelMessage(<function1>,false): received channel message resulted in ProcessSuccess(())
  150. [ERROR] [10/21/2017 23:03:22.493] [on-spray-can-akka.actor.default-dispatcher-13] [akka://on-spray-can/user/data-receiver-service/s3roundRouted/$j] Upload failed: {"url": "s3://sageaxcess-microservice-bucket-5f1720a00bb0441b89b6f596f0202c59/unparsed/20171021/drfile-myTestAggregator-171021230300-20171021230321RaLoI4l5.parquet", "dataType": "unparsed", "aggregatorId": "myTestAggregator", "clientId": "5f1720a00bb0441b89b6f596f0202c59", "md5": "297F03AD29BDE33643A749763168CE4D", "time": "171021230300", "description": "no description"}
  151. com.amazonaws.services.s3.model.AmazonS3Exception: Status Code: 400, AWS Service: Amazon S3, AWS Request ID: B91E950C5D4ABB6A, AWS Error Code: null, AWS Error Message: Bad Request, S3 Extended Request ID: QAREW0fpsTTwO0nYb5Bza1H1tFmuuBraCr4/evODg0eIf/YcrzZJnBQJx/5HLJ1zOcUxNeyjPHQ=
  152. at com.amazonaws.http.AmazonHttpClient.handleErrorResponse(AmazonHttpClient.java:798)
  153. at com.amazonaws.http.AmazonHttpClient.executeHelper(AmazonHttpClient.java:421)
  154. at com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:232)
  155. at com.amazonaws.services.s3.AmazonS3Client.invoke(AmazonS3Client.java:3528)
  156. at com.amazonaws.services.s3.AmazonS3Client.headBucket(AmazonS3Client.java:1031)
  157. at com.amazonaws.services.s3.AmazonS3Client.doesBucketExist(AmazonS3Client.java:994)
  158. at com.sageaxcess.handlers.S3UploaderActor.upload(S3UploaderActor.scala:50)
  159. at com.sageaxcess.handlers.S3UploaderActor$$anonfun$receive$1.applyOrElse(S3UploaderActor.scala:88)
  160. at akka.actor.Actor$class.aroundReceive(Actor.scala:484)
  161. at com.sageaxcess.handlers.S3UploaderActor.aroundReceive(S3UploaderActor.scala:27)
  162. at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
  163. at akka.actor.ActorCell.invoke(ActorCell.scala:495)
  164. at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
  165. at akka.dispatch.Mailbox.run(Mailbox.scala:224)
  166. at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
  167. at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
  168. at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
  169. at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
  170. at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
  171.  
  172. [DEBUG] [10/21/2017 23:03:22.714] [on-spray-can-akka.actor.default-dispatcher-13] [akka://on-spray-can/system/IO-TCP/selectors/$a/50] Closing connection due to IO error java.io.IOException: Connection reset by peer
  173. [DEBUG] [10/21/2017 23:03:22.715] [on-spray-can-akka.actor.default-dispatcher-11] [akka://on-spray-can/user/IO-HTTP/listener-0/47] Connection was ErrorClosed(Connection reset by peer), awaiting TcpConnection termination...
  174. [DEBUG] [10/21/2017 23:03:22.715] [on-spray-can-akka.actor.default-dispatcher-15] [akka://on-spray-can/user/IO-HTTP/listener-0/47] TcpConnection terminated, stopping
  175. [DEBUG] [10/21/2017 23:03:23.411] [default-akka.actor.default-dispatcher-12] [akka://default/user/IO-HTTP/group-0/92] Connection was PeerClosed, awaiting TcpConnection termination...
  176. [DEBUG] [10/21/2017 23:03:23.411] [default-akka.actor.default-dispatcher-12] [akka://default/user/IO-HTTP/group-0/92] TcpConnection terminated, stopping
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement
Public Pastes
Advertisement
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!