API tools faq
paste
Advertisement
Guest User

Untitled

a guest
May 14th, 2015
435
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 8.66 KB | None | 0 0
raw download clone embed print report
  1. 2015-05-14 04:49:42 ClientUtils$ [INFO] Fetching metadata from broker id:1,host:sprdargas403,port:6667 with correlation id 7160 for 1 topic(s) Set(__samza_checkpoint_ver_1_for_Argos_1)
  2. 2015-05-14 04:49:42 SyncProducer [INFO] Connected to sprdargas403:6667 for producing
  3. 2015-05-14 04:49:42 SyncProducer [INFO] Disconnecting from sprdargas403:6667
  4. 2015-05-14 04:49:42 BrokerPartitionInfo [WARN] Error while fetching metadata partition 0 leader: none replicas: 1018019532 (sprdargas402:6667) isr: isUnderReplicated: true for topic partition [__samza_checkpoint_ver_1_for_Argos_1,0]: [class kafka.common.LeaderNotAvailableException]
  5. 2015-05-14 04:49:42 DefaultEventHandler [WARN] Failed to send data since partitions [__samza_checkpoint_ver_1_for_Argos_1,0] don't have a leader
  6. 2015-05-14 04:49:42 DefaultEventHandler [INFO] Back off for 100 ms before retrying send. Remaining retries = 2147480095
  7. 2015-05-14 04:49:42 ClientUtils$ [INFO] Fetching metadata from broker id:0,host:sprdargas402,port:6667 with correlation id 7162 for 1 topic(s) Set(__samza_checkpoint_ver_1_for_Argos_1)
  8. 2015-05-14 04:49:42 SyncProducer [ERROR] Producer connection to sprdargas402:6667 unsuccessful
  9. java.net.ConnectException: Connection refused
  10. at sun.nio.ch.Net.connect0(Native Method)
  11. at sun.nio.ch.Net.connect(Net.java:465)
  12. at sun.nio.ch.Net.connect(Net.java:457)
  13. at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:670)
  14. at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
  15. at kafka.producer.SyncProducer.connect(SyncProducer.scala:141)
  16. at kafka.producer.SyncProducer.getOrMakeConnection(SyncProducer.scala:156)
  17. at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:68)
  18. at kafka.producer.SyncProducer.send(SyncProducer.scala:112)
  19. at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:53)
  20. at kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82)
  21. at kafka.producer.async.DefaultEventHandler$$anonfun$handle$2.apply$mcV$sp(DefaultEventHandler.scala:78)
  22. at kafka.utils.Utils$.swallow(Utils.scala:167)
  23. at kafka.utils.Logging$class.swallowError(Logging.scala:106)
  24. at kafka.utils.Utils$.swallowError(Utils.scala:46)
  25. at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:78)
  26. at kafka.producer.Producer.send(Producer.scala:76)
  27. at org.apache.samza.checkpoint.kafka.KafkaCheckpointManager$$anonfun$writeLog$1.apply(KafkaCheckpointManager.scala:124)
  28. at org.apache.samza.checkpoint.kafka.KafkaCheckpointManager$$anonfun$writeLog$1.apply(KafkaCheckpointManager.scala:119)
  29. at org.apache.samza.util.ExponentialSleepStrategy.run(ExponentialSleepStrategy.scala:82)
  30. at org.apache.samza.checkpoint.kafka.KafkaCheckpointManager.writeLog(KafkaCheckpointManager.scala:118)
  31. at org.apache.samza.checkpoint.kafka.KafkaCheckpointManager.writeCheckpoint(KafkaCheckpointManager.scala:94)
  32. at org.apache.samza.checkpoint.OffsetManager.checkpoint(OffsetManager.scala:206)
  33. at org.apache.samza.container.TaskInstance.commit(TaskInstance.scala:172)
  34. at org.apache.samza.container.RunLoop$$anonfun$commit$1$$anonfun$apply$mcV$sp$4.apply(RunLoop.scala:131)
  35. at org.apache.samza.container.RunLoop$$anonfun$commit$1$$anonfun$apply$mcV$sp$4.apply(RunLoop.scala:131)
  36. at scala.collection.Iterator$class.foreach(Iterator.scala:727)
  37. at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
  38. at scala.collection.MapLike$DefaultValuesIterable.foreach(MapLike.scala:206)
  39. at org.apache.samza.container.RunLoop$$anonfun$commit$1.apply$mcV$sp(RunLoop.scala:131)
  40. at org.apache.samza.container.RunLoop$$anonfun$commit$1.apply(RunLoop.scala:126)
  41. at org.apache.samza.container.RunLoop$$anonfun$commit$1.apply(RunLoop.scala:126)
  42. at org.apache.samza.util.TimerUtils$class.updateTimer(TimerUtils.scala:37)
  43. at org.apache.samza.container.RunLoop.updateTimer(RunLoop.scala:36)
  44. at org.apache.samza.container.RunLoop.commit(RunLoop.scala:126)
  45. at org.apache.samza.container.RunLoop.run(RunLoop.scala:67)
  46. at org.apache.samza.container.SamzaContainer.run(SamzaContainer.scala:556)
  47. at org.apache.samza.container.SamzaContainer$.safeMain(SamzaContainer.scala:108)
  48. at org.apache.samza.container.SamzaContainer$.main(SamzaContainer.scala:87)
  49. at org.apache.samza.container.SamzaContainer.main(SamzaContainer.scala)
  50. 2015-05-14 04:49:42 ClientUtils$ [WARN] Fetching topic metadata with correlation id 7162 for topics [Set(__samza_checkpoint_ver_1_for_Argos_1)] from broker [id:0,host:sprdargas402,port:6667] failed
  51. java.net.ConnectException: Connection refused
  52. at sun.nio.ch.Net.connect0(Native Method)
  53. at sun.nio.ch.Net.connect(Net.java:465)
  54. at sun.nio.ch.Net.connect(Net.java:457)
  55. at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:670)
  56. at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
  57. at kafka.producer.SyncProducer.connect(SyncProducer.scala:141)
  58. at kafka.producer.SyncProducer.getOrMakeConnection(SyncProducer.scala:156)
  59. at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:68)
  60. at kafka.producer.SyncProducer.send(SyncProducer.scala:112)
  61. at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:53)
  62. at kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82)
  63. at kafka.producer.async.DefaultEventHandler$$anonfun$handle$2.apply$mcV$sp(DefaultEventHandler.scala:78)
  64. at kafka.utils.Utils$.swallow(Utils.scala:167)
  65. at kafka.utils.Logging$class.swallowError(Logging.scala:106)
  66. at kafka.utils.Utils$.swallowError(Utils.scala:46)
  67. at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:78)
  68. at kafka.producer.Producer.send(Producer.scala:76)
  69. at org.apache.samza.checkpoint.kafka.KafkaCheckpointManager$$anonfun$writeLog$1.apply(KafkaCheckpointManager.scala:124)
  70. at org.apache.samza.checkpoint.kafka.KafkaCheckpointManager$$anonfun$writeLog$1.apply(KafkaCheckpointManager.scala:119)
  71. at org.apache.samza.util.ExponentialSleepStrategy.run(ExponentialSleepStrategy.scala:82)
  72. at org.apache.samza.checkpoint.kafka.KafkaCheckpointManager.writeLog(KafkaCheckpointManager.scala:118)
  73. at org.apache.samza.checkpoint.kafka.KafkaCheckpointManager.writeCheckpoint(KafkaCheckpointManager.scala:94)
  74. at org.apache.samza.checkpoint.OffsetManager.checkpoint(OffsetManager.scala:206)
  75. at org.apache.samza.container.TaskInstance.commit(TaskInstance.scala:172)
  76. at org.apache.samza.container.RunLoop$$anonfun$commit$1$$anonfun$apply$mcV$sp$4.apply(RunLoop.scala:131)
  77. at org.apache.samza.container.RunLoop$$anonfun$commit$1$$anonfun$apply$mcV$sp$4.apply(RunLoop.scala:131)
  78. at scala.collection.Iterator$class.foreach(Iterator.scala:727)
  79. at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
  80. at scala.collection.MapLike$DefaultValuesIterable.foreach(MapLike.scala:206)
  81. at org.apache.samza.container.RunLoop$$anonfun$commit$1.apply$mcV$sp(RunLoop.scala:131)
  82. at org.apache.samza.container.RunLoop$$anonfun$commit$1.apply(RunLoop.scala:126)
  83. at org.apache.samza.container.RunLoop$$anonfun$commit$1.apply(RunLoop.scala:126)
  84. at org.apache.samza.util.TimerUtils$class.updateTimer(TimerUtils.scala:37)
  85. at org.apache.samza.container.RunLoop.updateTimer(RunLoop.scala:36)
  86. at org.apache.samza.container.RunLoop.commit(RunLoop.scala:126)
  87. at org.apache.samza.container.RunLoop.run(RunLoop.scala:67)
  88. at org.apache.samza.container.SamzaContainer.run(SamzaContainer.scala:556)
  89. at org.apache.samza.container.SamzaContainer$.safeMain(SamzaContainer.scala:108)
  90. at org.apache.samza.container.SamzaContainer$.main(SamzaContainer.scala:87)
  91. at org.apache.samza.container.SamzaContainer.main(SamzaContainer.scala)
  92. 2015-05-14 04:49:42 ClientUtils$ [INFO] Fetching metadata from broker id:1,host:sprdargas403,port:6667 with correlation id 7162 for 1 topic(s) Set(__samza_checkpoint_ver_1_for_Argos_1)
  93. 2015-05-14 04:49:42 SyncProducer [INFO] Connected to sprdargas403:6667 for producing
  94. 2015-05-14 04:49:42 SyncProducer [INFO] Disconnecting from sprdargas403:6667
  95. 2015-05-14 04:49:42 BrokerPartitionInfo [WARN] Error while fetching metadata partition 0 leader: none replicas: 1018019532 (sprdargas402:6667) isr: isUnderReplicated: true for topic partition [__samza_checkpoint_ver_1_for_Argos_1,0]: [class kafka.common.LeaderNotAvailableException]
  96. 2015-05-14 04:49:42 DefaultEventHandler [WARN] Failed to send data since partitions [__samza_checkpoint_ver_1_for_Argos_1,0] don't have a leader
  97. 2015-05-14 04:49:42 DefaultEventHandler [INFO] Back off for 100 ms before retrying send. Remaining retries = 2147480094
  98. 2015-05-14 04:49:42 ClientUtils$ [INFO] Fetching metadata from broker id:0,host:sprdargas402,port:6667 with correlation id 7164 for 1 topic(s) Set(__samza_checkpoint_ver_1_for_Argos_1)
  99. 2015-05-14 04:49:42 SyncProducer [ERROR] Producer connection to sprdargas402:6667 unsuccessful
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!