[2017-07-27 13:49:22,204] [ERROR] |Async loop died!|
com.amazonaws.services.kinesis.model.AmazonKinesisException: 1 validation error detected: Value null at 'shardIterator' failed to satisfy constraint: Member must not be null (Service: AmazonKinesis; Status Code: 400; Error Code: ValidationException; Request ID: e4edfcfe-d7d6-b123-b51e-0d8b03a06c87)
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.handleErrorResponse(AmazonHttpClient.java:1588) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeOneRequest(AmazonHttpClient.java:1258) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeHelper(AmazonHttpClient.java:1030) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.doExecute(AmazonHttpClient.java:742) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeWithTimer(AmazonHttpClient.java:716) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.execute(AmazonHttpClient.java:699) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.access$500(AmazonHttpClient.java:667) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutionBuilderImpl.execute(AmazonHttpClient.java:649) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:513) ~[stormjar.jar:?]
        at com.amazonaws.services.kinesis.AmazonKinesisClient.doInvoke(AmazonKinesisClient.java:1948) ~[stormjar.jar:?]
        at com.amazonaws.services.kinesis.AmazonKinesisClient.invoke(AmazonKinesisClient.java:1924) ~[stormjar.jar:?]
        at com.amazonaws.services.kinesis.AmazonKinesisClient.executeGetRecords(AmazonKinesisClient.java:969) ~[stormjar.jar:?]
        at com.amazonaws.services.kinesis.AmazonKinesisClient.getRecords(AmazonKinesisClient.java:945) ~[stormjar.jar:?]
        at org.apache.storm.kinesis.spout.KinesisConnection.fetchRecords(KinesisConnection.java:100) ~[dep-storm-kinesis-1.1.0-d3c97a19-a8f0-4c6d-8257-1c1a222a5a88.jar.1500090147000:1.1.0]
        at org.apache.storm.kinesis.spout.KinesisRecordsManager.fetchNewRecords(KinesisRecordsManager.java:303) ~[dep-storm-kinesis-1.1.0-d3c97a19-a8f0-4c6d-8257-1c1a222a5a88.jar.1500090147000:1.1.0]
        at org.apache.storm.kinesis.spout.KinesisRecordsManager.next(KinesisRecordsManager.java:130) ~[dep-storm-kinesis-1.1.0-d3c97a19-a8f0-4c6d-8257-1c1a222a5a88.jar.1500090147000:1.1.0]
        at org.apache.storm.kinesis.spout.KinesisSpout.nextTuple(KinesisSpout.java:82) ~[dep-storm-kinesis-1.1.0-d3c97a19-a8f0-4c6d-8257-1c1a222a5a88.jar.1500090147000:1.1.0]
        at org.apache.storm.daemon.executor$fn__4976$fn__4991$fn__5022.invoke(executor.clj:644) ~[storm-core-1.1.0.jar:1.1.0]
        at org.apache.storm.util$async_loop$fn__557.invoke(util.clj:484) [storm-core-1.1.0.jar:1.1.0]
        at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
        at java.lang.Thread.run(Thread.java:745) [?:1.8.0_111]
[2017-07-27 13:49:22,212] [ERROR] ||
com.amazonaws.services.kinesis.model.AmazonKinesisException: 1 validation error detected: Value null at 'shardIterator' failed to satisfy constraint: Member must not be null (Service: AmazonKinesis; Status Code: 400; Error Code: ValidationException; Request ID: e4edfcfe-d7d6-b123-b51e-0d8b03a06c87)
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.handleErrorResponse(AmazonHttpClient.java:1588) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeOneRequest(AmazonHttpClient.java:1258) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeHelper(AmazonHttpClient.java:1030) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.doExecute(AmazonHttpClient.java:742) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeWithTimer(AmazonHttpClient.java:716) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.execute(AmazonHttpClient.java:699) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.access$500(AmazonHttpClient.java:667) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutionBuilderImpl.execute(AmazonHttpClient.java:649) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:513) ~[stormjar.jar:?]
        at com.amazonaws.services.kinesis.AmazonKinesisClient.doInvoke(AmazonKinesisClient.java:1948) ~[stormjar.jar:?]
        at com.amazonaws.services.kinesis.AmazonKinesisClient.invoke(AmazonKinesisClient.java:1924) ~[stormjar.jar:?]
        at com.amazonaws.services.kinesis.AmazonKinesisClient.executeGetRecords(AmazonKinesisClient.java:969) ~[stormjar.jar:?]
        at com.amazonaws.services.kinesis.AmazonKinesisClient.getRecords(AmazonKinesisClient.java:945) ~[stormjar.jar:?]
        at org.apache.storm.kinesis.spout.KinesisConnection.fetchRecords(KinesisConnection.java:100) ~[dep-storm-kinesis-1.1.0-d3c97a19-a8f0-4c6d-8257-1c1a222a5a88.jar.1500090147000:1.1.0]
        at org.apache.storm.kinesis.spout.KinesisRecordsManager.fetchNewRecords(KinesisRecordsManager.java:303) ~[dep-storm-kinesis-1.1.0-d3c97a19-a8f0-4c6d-8257-1c1a222a5a88.jar.1500090147000:1.1.0]
        at org.apache.storm.kinesis.spout.KinesisRecordsManager.next(KinesisRecordsManager.java:130) ~[dep-storm-kinesis-1.1.0-d3c97a19-a8f0-4c6d-8257-1c1a222a5a88.jar.1500090147000:1.1.0]
        at org.apache.storm.kinesis.spout.KinesisSpout.nextTuple(KinesisSpout.java:82) ~[dep-storm-kinesis-1.1.0-d3c97a19-a8f0-4c6d-8257-1c1a222a5a88.jar.1500090147000:1.1.0]
        at org.apache.storm.daemon.executor$fn__4976$fn__4991$fn__5022.invoke(executor.clj:644) ~[storm-core-1.1.0.jar:1.1.0]
        at org.apache.storm.util$async_loop$fn__557.invoke(util.clj:484) [storm-core-1.1.0.jar:1.1.0]
        at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
        at java.lang.Thread.run(Thread.java:745) [?:1.8.0_111]
[2017-07-27 13:49:22,237] [ERROR] |Halting process: ("Worker died")|
java.lang.RuntimeException: ("Worker died")
        at org.apache.storm.util$exit_process_BANG_.doInvoke(util.clj:341) [storm-core-1.1.0.jar:1.1.0]
        at clojure.lang.RestFn.invoke(RestFn.java:423) [clojure-1.7.0.jar:?]
        at org.apache.storm.daemon.worker$fn__5646$fn__5647.invoke(worker.clj:763) [storm-core-1.1.0.jar:1.1.0]
        at org.apache.storm.daemon.executor$mk_executor_data$fn__4863$fn__4864.invoke(executor.clj:274) [storm-core-1.1.0.jar:1.1.0]
        at org.apache.storm.util$async_loop$fn__557.invoke(util.clj:494) [storm-core-1.1.0.jar:1.1.0]
        at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
        at java.lang.Thread.run(Thread.java:745) [?:1.8.0_111]
[2017-07-27 13:49:56,776] [ERROR] |connection to Netty-Client-ip-20-0-3-51/20.0.3.51:6705 is unavailable|
[2017-07-27 13:49:56,786] [ERROR] |connection attempt 2 to Netty-Client-ip-20-0-3-51/20.0.3.51:6705 failed: java.net.ConnectException: Connection refused: ip-20-0-3-51/20.0.3.51:6705|
[2017-07-27 13:49:56,983] [ERROR] |connection attempt 3 to Netty-Client-ip-20-0-3-51/20.0.3.51:6705 failed: java.net.ConnectException: Connection refused: ip-20-0-3-51/20.0.3.51:6705|
[2017-07-27 13:49:57,182] [ERROR] |connection attempt 4 to Netty-Client-ip-20-0-3-51/20.0.3.51:6705 failed: java.net.ConnectException: Connection refused: ip-20-0-3-51/20.0.3.51:6705|
[2017-07-27 13:49:57,382] [ERROR] |connection attempt 5 to Netty-Client-ip-20-0-3-51/20.0.3.51:6705 failed: java.net.ConnectException: Connection refused: ip-20-0-3-51/20.0.3.51:6705|
[2017-07-27 13:49:57,586] [ERROR] |connection attempt 6 to Netty-Client-ip-20-0-3-51/20.0.3.51:6705 failed: java.net.ConnectException: Connection refused: ip-20-0-3-51/20.0.3.51:6705|
[2017-07-27 13:49:57,882] [ERROR] |connection attempt 7 to Netty-Client-ip-20-0-3-51/20.0.3.51:6705 failed: java.net.ConnectException: Connection refused: ip-20-0-3-51/20.0.3.51:6705|
[2017-07-27 13:49:58,183] [ERROR] |connection attempt 8 to Netty-Client-ip-20-0-3-51/20.0.3.51:6705 failed: java.net.ConnectException: Connection refused: ip-20-0-3-51/20.0.3.51:6705|
[2017-07-27 13:49:58,582] [ERROR] |connection attempt 9 to Netty-Client-ip-20-0-3-51/20.0.3.51:6705 failed: java.net.ConnectException: Connection refused: ip-20-0-3-51/20.0.3.51:6705|
[2017-07-27 13:49:58,984] [ERROR] |connection attempt 10 to Netty-Client-ip-20-0-3-51/20.0.3.51:6705 failed: java.net.ConnectException: Connection refused: ip-20-0-3-51/20.0.3.51:6705|
[2017-07-27 13:49:59,382] [ERROR] |connection attempt 11 to Netty-Client-ip-20-0-3-51/20.0.3.51:6705 failed: java.net.ConnectException: Connection refused: ip-20-0-3-51/20.0.3.51:6705|
[2017-07-27 13:49:59,782] [ERROR] |connection attempt 12 to Netty-Client-ip-20-0-3-51/20.0.3.51:6705 failed: java.net.ConnectException: Connection refused: ip-20-0-3-51/20.0.3.51:6705|
[2017-07-27 13:50:00,184] [ERROR] |connection attempt 13 to Netty-Client-ip-20-0-3-51/20.0.3.51:6705 failed: java.net.ConnectException: Connection refused: ip-20-0-3-51/20.0.3.51:6705|
[2017-07-27 13:50:00,582] [ERROR] |connection attempt 14 to Netty-Client-ip-20-0-3-51/20.0.3.51:6705 failed: java.net.ConnectException: Connection refused: ip-20-0-3-51/20.0.3.51:6705|
[2017-07-27 13:50:00,982] [ERROR] |connection attempt 15 to Netty-Client-ip-20-0-3-51/20.0.3.51:6705 failed: java.net.ConnectException: Connection refused: ip-20-0-3-51/20.0.3.51:6705|
[2017-07-27 13:50:01,382] [ERROR] |connection attempt 16 to Netty-Client-ip-20-0-3-51/20.0.3.51:6705 failed: java.net.ConnectException: Connection refused: ip-20-0-3-51/20.0.3.51:6705|
[2017-07-27 13:50:01,783] [ERROR] |connection attempt 17 to Netty-Client-ip-20-0-3-51/20.0.3.51:6705 failed: java.net.ConnectException: Connection refused: ip-20-0-3-51/20.0.3.51:6705|
[2017-07-27 13:50:02,182] [ERROR] |connection attempt 18 to Netty-Client-ip-20-0-3-51/20.0.3.51:6705 failed: java.net.ConnectException: Connection refused: ip-20-0-3-51/20.0.3.51:6705|
[2017-07-27 13:53:51,575] [ERROR] |Async loop died!|
com.amazonaws.services.kinesis.model.AmazonKinesisException: null (Service: AmazonKinesis; Status Code: 500; Error Code: InternalFailure; Request ID: c89091de-945b-0af8-9963-635da427cc91)
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.handleErrorResponse(AmazonHttpClient.java:1588) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeOneRequest(AmazonHttpClient.java:1258) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeHelper(AmazonHttpClient.java:1030) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.doExecute(AmazonHttpClient.java:742) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeWithTimer(AmazonHttpClient.java:716) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.execute(AmazonHttpClient.java:699) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.access$500(AmazonHttpClient.java:667) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutionBuilderImpl.execute(AmazonHttpClient.java:649) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:513) ~[stormjar.jar:?]
        at com.amazonaws.services.kinesis.AmazonKinesisClient.doInvoke(AmazonKinesisClient.java:1948) ~[stormjar.jar:?]
        at com.amazonaws.services.kinesis.AmazonKinesisClient.invoke(AmazonKinesisClient.java:1924) ~[stormjar.jar:?]
        at com.amazonaws.services.kinesis.AmazonKinesisClient.executeGetRecords(AmazonKinesisClient.java:969) ~[stormjar.jar:?]
        at com.amazonaws.services.kinesis.AmazonKinesisClient.getRecords(AmazonKinesisClient.java:945) ~[stormjar.jar:?]
        at org.apache.storm.kinesis.spout.KinesisConnection.fetchRecords(KinesisConnection.java:100) ~[dep-storm-kinesis-1.1.0-d3c97a19-a8f0-4c6d-8257-1c1a222a5a88.jar.1500090147000:1.1.0]
        at org.apache.storm.kinesis.spout.KinesisRecordsManager.fetchNewRecords(KinesisRecordsManager.java:303) ~[dep-storm-kinesis-1.1.0-d3c97a19-a8f0-4c6d-8257-1c1a222a5a88.jar.1500090147000:1.1.0]
        at org.apache.storm.kinesis.spout.KinesisRecordsManager.next(KinesisRecordsManager.java:130) ~[dep-storm-kinesis-1.1.0-d3c97a19-a8f0-4c6d-8257-1c1a222a5a88.jar.1500090147000:1.1.0]
        at org.apache.storm.kinesis.spout.KinesisSpout.nextTuple(KinesisSpout.java:82) ~[dep-storm-kinesis-1.1.0-d3c97a19-a8f0-4c6d-8257-1c1a222a5a88.jar.1500090147000:1.1.0]
        at org.apache.storm.daemon.executor$fn__4976$fn__4991$fn__5022.invoke(executor.clj:644) ~[storm-core-1.1.0.jar:1.1.0]
        at org.apache.storm.util$async_loop$fn__557.invoke(util.clj:484) [storm-core-1.1.0.jar:1.1.0]
        at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
        at java.lang.Thread.run(Thread.java:745) [?:1.8.0_111]
[2017-07-27 13:53:51,579] [ERROR] ||
com.amazonaws.services.kinesis.model.AmazonKinesisException: null (Service: AmazonKinesis; Status Code: 500; Error Code: InternalFailure; Request ID: c89091de-945b-0af8-9963-635da427cc91)
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.handleErrorResponse(AmazonHttpClient.java:1588) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeOneRequest(AmazonHttpClient.java:1258) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeHelper(AmazonHttpClient.java:1030) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.doExecute(AmazonHttpClient.java:742) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeWithTimer(AmazonHttpClient.java:716) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.execute(AmazonHttpClient.java:699) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.access$500(AmazonHttpClient.java:667) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutionBuilderImpl.execute(AmazonHttpClient.java:649) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:513) ~[stormjar.jar:?]
        at com.amazonaws.services.kinesis.AmazonKinesisClient.doInvoke(AmazonKinesisClient.java:1948) ~[stormjar.jar:?]
        at com.amazonaws.services.kinesis.AmazonKinesisClient.invoke(AmazonKinesisClient.java:1924) ~[stormjar.jar:?]
        at com.amazonaws.services.kinesis.AmazonKinesisClient.executeGetRecords(AmazonKinesisClient.java:969) ~[stormjar.jar:?]
        at com.amazonaws.services.kinesis.AmazonKinesisClient.getRecords(AmazonKinesisClient.java:945) ~[stormjar.jar:?]
        at org.apache.storm.kinesis.spout.KinesisConnection.fetchRecords(KinesisConnection.java:100) ~[dep-storm-kinesis-1.1.0-d3c97a19-a8f0-4c6d-8257-1c1a222a5a88.jar.1500090147000:1.1.0]
        at org.apache.storm.kinesis.spout.KinesisRecordsManager.fetchNewRecords(KinesisRecordsManager.java:303) ~[dep-storm-kinesis-1.1.0-d3c97a19-a8f0-4c6d-8257-1c1a222a5a88.jar.1500090147000:1.1.0]
        at org.apache.storm.kinesis.spout.KinesisRecordsManager.next(KinesisRecordsManager.java:130) ~[dep-storm-kinesis-1.1.0-d3c97a19-a8f0-4c6d-8257-1c1a222a5a88.jar.1500090147000:1.1.0]
        at org.apache.storm.kinesis.spout.KinesisSpout.nextTuple(KinesisSpout.java:82) ~[dep-storm-kinesis-1.1.0-d3c97a19-a8f0-4c6d-8257-1c1a222a5a88.jar.1500090147000:1.1.0]
        at org.apache.storm.daemon.executor$fn__4976$fn__4991$fn__5022.invoke(executor.clj:644) ~[storm-core-1.1.0.jar:1.1.0]
        at org.apache.storm.util$async_loop$fn__557.invoke(util.clj:484) [storm-core-1.1.0.jar:1.1.0]
        at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
        at java.lang.Thread.run(Thread.java:745) [?:1.8.0_111]
[2017-07-27 13:53:51,607] [ERROR] |Halting process: ("Worker died")|
java.lang.RuntimeException: ("Worker died")
        at org.apache.storm.util$exit_process_BANG_.doInvoke(util.clj:341) [storm-core-1.1.0.jar:1.1.0]
        at clojure.lang.RestFn.invoke(RestFn.java:423) [clojure-1.7.0.jar:?]
        at org.apache.storm.daemon.worker$fn__5646$fn__5647.invoke(worker.clj:763) [storm-core-1.1.0.jar:1.1.0]
        at org.apache.storm.daemon.executor$mk_executor_data$fn__4863$fn__4864.invoke(executor.clj:274) [storm-core-1.1.0.jar:1.1.0]
        at org.apache.storm.util$async_loop$fn__557.invoke(util.clj:494) [storm-core-1.1.0.jar:1.1.0]
        at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
        at java.lang.Thread.run(Thread.java:745) [?:1.8.0_111]
[2017-07-27 14:00:19,235] [ERROR] |Async loop died!|
com.amazonaws.services.kinesis.model.AmazonKinesisException: null (Service: AmazonKinesis; Status Code: 500; Error Code: InternalFailure; Request ID: f9f97cd8-577c-9ea5-a80a-88ded4d86c0e)
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.handleErrorResponse(AmazonHttpClient.java:1588) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeOneRequest(AmazonHttpClient.java:1258) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeHelper(AmazonHttpClient.java:1030) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.doExecute(AmazonHttpClient.java:742) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeWithTimer(AmazonHttpClient.java:716) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.execute(AmazonHttpClient.java:699) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.access$500(AmazonHttpClient.java:667) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutionBuilderImpl.execute(AmazonHttpClient.java:649) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:513) ~[stormjar.jar:?]
        at com.amazonaws.services.kinesis.AmazonKinesisClient.doInvoke(AmazonKinesisClient.java:1948) ~[stormjar.jar:?]
        at com.amazonaws.services.kinesis.AmazonKinesisClient.invoke(AmazonKinesisClient.java:1924) ~[stormjar.jar:?]
        at com.amazonaws.services.kinesis.AmazonKinesisClient.executeGetRecords(AmazonKinesisClient.java:969) ~[stormjar.jar:?]
        at com.amazonaws.services.kinesis.AmazonKinesisClient.getRecords(AmazonKinesisClient.java:945) ~[stormjar.jar:?]
        at org.apache.storm.kinesis.spout.KinesisConnection.fetchRecords(KinesisConnection.java:100) ~[dep-storm-kinesis-1.1.0-d3c97a19-a8f0-4c6d-8257-1c1a222a5a88.jar.1500090147000:1.1.0]
        at org.apache.storm.kinesis.spout.KinesisRecordsManager.fetchNewRecords(KinesisRecordsManager.java:303) ~[dep-storm-kinesis-1.1.0-d3c97a19-a8f0-4c6d-8257-1c1a222a5a88.jar.1500090147000:1.1.0]
        at org.apache.storm.kinesis.spout.KinesisRecordsManager.next(KinesisRecordsManager.java:130) ~[dep-storm-kinesis-1.1.0-d3c97a19-a8f0-4c6d-8257-1c1a222a5a88.jar.1500090147000:1.1.0]
        at org.apache.storm.kinesis.spout.KinesisSpout.nextTuple(KinesisSpout.java:82) ~[dep-storm-kinesis-1.1.0-d3c97a19-a8f0-4c6d-8257-1c1a222a5a88.jar.1500090147000:1.1.0]
        at org.apache.storm.daemon.executor$fn__4976$fn__4991$fn__5022.invoke(executor.clj:644) ~[storm-core-1.1.0.jar:1.1.0]
        at org.apache.storm.util$async_loop$fn__557.invoke(util.clj:484) [storm-core-1.1.0.jar:1.1.0]
        at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
        at java.lang.Thread.run(Thread.java:745) [?:1.8.0_111]
[2017-07-27 14:00:19,244] [ERROR] ||
com.amazonaws.services.kinesis.model.AmazonKinesisException: null (Service: AmazonKinesis; Status Code: 500; Error Code: InternalFailure; Request ID: f9f97cd8-577c-9ea5-a80a-88ded4d86c0e)
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.handleErrorResponse(AmazonHttpClient.java:1588) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeOneRequest(AmazonHttpClient.java:1258) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeHelper(AmazonHttpClient.java:1030) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.doExecute(AmazonHttpClient.java:742) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeWithTimer(AmazonHttpClient.java:716) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.execute(AmazonHttpClient.java:699) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutor.access$500(AmazonHttpClient.java:667) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient$RequestExecutionBuilderImpl.execute(AmazonHttpClient.java:649) ~[stormjar.jar:?]
        at com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:513) ~[stormjar.jar:?]
        at com.amazonaws.services.kinesis.AmazonKinesisClient.doInvoke(AmazonKinesisClient.java:1948) ~[stormjar.jar:?]
        at com.amazonaws.services.kinesis.AmazonKinesisClient.invoke(AmazonKinesisClient.java:1924) ~[stormjar.jar:?]
        at com.amazonaws.services.kinesis.AmazonKinesisClient.executeGetRecords(AmazonKinesisClient.java:969) ~[stormjar.jar:?]
        at com.amazonaws.services.kinesis.AmazonKinesisClient.getRecords(AmazonKinesisClient.java:945) ~[stormjar.jar:?]
        at org.apache.storm.kinesis.spout.KinesisConnection.fetchRecords(KinesisConnection.java:100) ~[dep-storm-kinesis-1.1.0-d3c97a19-a8f0-4c6d-8257-1c1a222a5a88.jar.1500090147000:1.1.0]
        at org.apache.storm.kinesis.spout.KinesisRecordsManager.fetchNewRecords(KinesisRecordsManager.java:303) ~[dep-storm-kinesis-1.1.0-d3c97a19-a8f0-4c6d-8257-1c1a222a5a88.jar.1500090147000:1.1.0]
        at org.apache.storm.kinesis.spout.KinesisRecordsManager.next(KinesisRecordsManager.java:130) ~[dep-storm-kinesis-1.1.0-d3c97a19-a8f0-4c6d-8257-1c1a222a5a88.jar.1500090147000:1.1.0]
        at org.apache.storm.kinesis.spout.KinesisSpout.nextTuple(KinesisSpout.java:82) ~[dep-storm-kinesis-1.1.0-d3c97a19-a8f0-4c6d-8257-1c1a222a5a88.jar.1500090147000:1.1.0]
        at org.apache.storm.daemon.executor$fn__4976$fn__4991$fn__5022.invoke(executor.clj:644) ~[storm-core-1.1.0.jar:1.1.0]
        at org.apache.storm.util$async_loop$fn__557.invoke(util.clj:484) [storm-core-1.1.0.jar:1.1.0]
        at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
        at java.lang.Thread.run(Thread.java:745) [?:1.8.0_111]
[2017-07-27 14:00:19,266] [ERROR] |Halting process: ("Worker died")|
java.lang.RuntimeException: ("Worker died")
        at org.apache.storm.util$exit_process_BANG_.doInvoke(util.clj:341) [storm-core-1.1.0.jar:1.1.0]
        at clojure.lang.RestFn.invoke(RestFn.java:423) [clojure-1.7.0.jar:?]
        at org.apache.storm.daemon.worker$fn__5646$fn__5647.invoke(worker.clj:763) [storm-core-1.1.0.jar:1.1.0]
        at org.apache.storm.daemon.executor$mk_executor_data$fn__4863$fn__4864.invoke(executor.clj:274) [storm-core-1.1.0.jar:1.1.0]
        at org.apache.storm.util$async_loop$fn__557.invoke(util.clj:494) [storm-core-1.1.0.jar:1.1.0]
        at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
        at java.lang.Thread.run(Thread.java:745) [?:1.8.0_111]
~