API tools faq
paste
Advertisement
Guest User

flume-error1

a guest
Nov 21st, 2011
122
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 6.63 KB | None | 0 0
raw download clone embed print report
  1. 2011-11-21 19:38:46,318 WARN org.jets3t.service.impl.rest.httpclient.RestS3Service: Response '/flume%2F2011%2F11%2F20%2F03%2Fsyslog20111121-193628975-0500.2960659853113025.00000025_%24folder%24' - Unexpected response code 404, expected 200
  2. 2011-11-21 19:38:46,371 WARN org.jets3t.service.impl.rest.httpclient.RestS3Service: Response '/flume%2F2011%2F11%2F20%2F03' - Unexpected response code 404, expected 200
  3. 2011-11-21 19:38:46,394 WARN org.jets3t.service.impl.rest.httpclient.RestS3Service: Response '/flume%2F2011%2F11%2F20%2F03_%24folder%24' - Unexpected response code 404, expected 200
  4. 2011-11-21 19:38:46,779 INFO com.cloudera.flume.handlers.hdfs.EscapedCustomDfsSink: Closing s3n://hooklogic-data-east/flume/2011/11/21/16/syslog20111121-193628975-0500.2960659853113025.00000025
  5. 2011-11-21 19:38:46,779 INFO com.cloudera.flume.handlers.hdfs.CustomDfsSink: Closing HDFS file: s3n://hooklogic-data-east/flume/2011/11/21/16/syslog20111121-193628975-0500.2960659853113025.00000025.tmp
  6. 2011-11-21 19:38:46,779 INFO com.cloudera.flume.handlers.hdfs.CustomDfsSink: done writing raw file to hdfs
  7. 2011-11-21 19:38:46,779 INFO org.apache.hadoop.fs.s3native.NativeS3FileSystem: OutputStream for key 'flume/2011/11/21/16/syslog20111121-193628975-0500.2960659853113025.00000025.tmp' closed. Now beginning upload
  8. 2011-11-21 19:38:46,909 INFO org.apache.hadoop.fs.s3native.NativeS3FileSystem: OutputStream for key 'flume/2011/11/21/16/syslog20111121-193628975-0500.2960659853113025.00000025.tmp' upload complete
  9. 2011-11-21 19:38:46,935 WARN org.jets3t.service.impl.rest.httpclient.RestS3Service: Response '/flume%2F2011%2F11%2F21%2F16%2Fsyslog20111121-193628975-0500.2960659853113025.00000025' - Unexpected response code 404, expected 200
  10. 2011-11-21 19:38:46,952 WARN org.jets3t.service.impl.rest.httpclient.RestS3Service: Response '/flume%2F2011%2F11%2F21%2F16%2Fsyslog20111121-193628975-0500.2960659853113025.00000025_%24folder%24' - Unexpected response code 404, expected 200
  11. 2011-11-21 19:38:47,006 WARN org.jets3t.service.impl.rest.httpclient.RestS3Service: Response '/flume%2F2011%2F11%2F21%2F16' - Unexpected response code 404, expected 200
  12. 2011-11-21 19:38:47,042 WARN org.jets3t.service.impl.rest.httpclient.RestS3Service: Response '/flume%2F2011%2F11%2F21%2F16_%24folder%24' - Unexpected response code 404, expected 200
  13. 2011-11-21 19:38:47,233 ERROR com.cloudera.flume.handlers.endtoend.CollectorAckListener: acknowledge failed
  14. java.io.IOException: java.lang.InterruptedException: sleep interrupted
  15. at com.cloudera.flume.agent.MultiMasterRPC.acknowledge(MultiMasterRPC.java:316)
  16. at com.cloudera.flume.handlers.endtoend.CollectorAckListener.end(CollectorAckListener.java:43)
  17. at com.cloudera.flume.collector.CollectorSink$RollDetectDeco.flushRollAcks(CollectorSink.java:186)
  18. at com.cloudera.flume.collector.CollectorSink$RollDetectDeco.close(CollectorSink.java:172)
  19. at com.cloudera.flume.handlers.rolling.RollSink.synchronousRotate(RollSink.java:253)
  20. at com.cloudera.flume.handlers.rolling.RollSink.rotate(RollSink.java:277)
  21. at com.cloudera.flume.handlers.rolling.RollSink.synchronousAppend(RollSink.java:226)
  22. at com.cloudera.flume.handlers.rolling.RollSink$1.call(RollSink.java:183)
  23. at com.cloudera.flume.handlers.rolling.RollSink$1.call(RollSink.java:181)
  24. at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
  25. at java.util.concurrent.FutureTask.run(FutureTask.java:138)
  26. at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
  27. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
  28. at java.lang.Thread.run(Thread.java:662)
  29. Caused by: java.lang.InterruptedException: sleep interrupted
  30. at java.lang.Thread.sleep(Native Method)
  31. at com.cloudera.util.ExponentialBackoff.waitUntilRetryOk(ExponentialBackoff.java:122)
  32. at com.cloudera.util.RetryHarness.attempt(RetryHarness.java:61)
  33. at com.cloudera.flume.agent.MultiMasterRPC.acknowledge(MultiMasterRPC.java:314)
  34. ... 13 more
  35. 2011-11-21 19:38:47,234 WARN com.cloudera.flume.handlers.rolling.RollSink: IOException when closing subsink
  36. java.io.IOException: java.io.IOException: java.lang.InterruptedException: sleep interrupted
  37. at com.cloudera.flume.handlers.endtoend.CollectorAckListener.end(CollectorAckListener.java:47)
  38. at com.cloudera.flume.collector.CollectorSink$RollDetectDeco.flushRollAcks(CollectorSink.java:186)
  39. at com.cloudera.flume.collector.CollectorSink$RollDetectDeco.close(CollectorSink.java:172)
  40. at com.cloudera.flume.handlers.rolling.RollSink.synchronousRotate(RollSink.java:253)
  41. at com.cloudera.flume.handlers.rolling.RollSink.rotate(RollSink.java:277)
  42. at com.cloudera.flume.handlers.rolling.RollSink.synchronousAppend(RollSink.java:226)
  43. at com.cloudera.flume.handlers.rolling.RollSink$1.call(RollSink.java:183)
  44. at com.cloudera.flume.handlers.rolling.RollSink$1.call(RollSink.java:181)
  45. at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
  46. at java.util.concurrent.FutureTask.run(FutureTask.java:138)
  47. at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
  48. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
  49. at java.lang.Thread.run(Thread.java:662)
  50. Caused by: java.io.IOException: java.lang.InterruptedException: sleep interrupted
  51. at com.cloudera.flume.agent.MultiMasterRPC.acknowledge(MultiMasterRPC.java:316)
  52. at com.cloudera.flume.handlers.endtoend.CollectorAckListener.end(CollectorAckListener.java:43)
  53. ... 12 more
  54. Caused by: java.lang.InterruptedException: sleep interrupted
  55. at java.lang.Thread.sleep(Native Method)
  56. at com.cloudera.util.ExponentialBackoff.waitUntilRetryOk(ExponentialBackoff.java:122)
  57. at com.cloudera.util.RetryHarness.attempt(RetryHarness.java:61)
  58. at com.cloudera.flume.agent.MultiMasterRPC.acknowledge(MultiMasterRPC.java:314)
  59. ... 13 more
  60. 2011-11-21 19:38:47,234 WARN com.cloudera.flume.conf.FlumeBuilder: Deprecated syntax: Expected a format spec but instead had a (String) raw
  61. 2011-11-21 19:38:47,235 WARN com.cloudera.flume.conf.FlumeBuilder: Deprecated syntax: Expected a format spec but instead had a (String) raw
  62. 2011-11-21 19:38:47,236 WARN com.cloudera.flume.handlers.endtoend.AckChecksumChecker: partial acks abandoned: {20111117-141438565-0500.3224326962170586.00000028=1321608546730}
  63. 2011-11-21 19:38:47,236 ERROR com.cloudera.flume.core.connector.DirectDriver: Exiting driver logicalNode beacon_flume01use-22 in error state ThriftEventSource | Fanout because null
  64.  
  65.  
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!