10586973 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Creating new merged beam for identifier[overlord/vidmessage] timestamp[2015-03-20T01:00:00.000-07:00] (target = 16, actual = 0)
10586974 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.control$ - Creating druid indexing task with id: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_0_0_gmlgnnna (service = overlord)
10586995 [finagle/netty3-4] INFO com.metamx.common.scala.control$ - Created druid indexing task with id: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_0_0_gmlgnnna (service = overlord)
10586997 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - Updating instances for service[druid:firehose:vidmessage-08-0000-0000] to Set()
10586998 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Created client for service: druid:firehose:vidmessage-08-0000-0000
10586998 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Created beam: {"interval":"2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00","partition":0,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_0_0_gmlgnnna","firehoseId":"vidmessage-08-0000-0000"}],"timestamp":"2015-03-20T01:00:00.000-07:00"}
10586998 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.druid.DruidBeam - Closing Druid beam for datasource[vidmessage] interval[2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00] (tasks = index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_0_0_gmlgnnna)
10586998 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Closing client for service: druid:firehose:vidmessage-08-0000-0000
10586998 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - No longer monitoring service[druid:firehose:vidmessage-08-0000-0000]
10586999 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.control$ - Creating druid indexing task with id: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_1_0_lhfifnfi (service = overlord)
10587018 [finagle/netty3-4] INFO com.metamx.common.scala.control$ - Created druid indexing task with id: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_1_0_lhfifnfi (service = overlord)
10587021 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - Updating instances for service[druid:firehose:vidmessage-08-0001-0000] to Set()
10587021 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Created client for service: druid:firehose:vidmessage-08-0001-0000
10587021 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Created beam: {"interval":"2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00","partition":1,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_1_0_lhfifnfi","firehoseId":"vidmessage-08-0001-0000"}],"timestamp":"2015-03-20T01:00:00.000-07:00"}
10587021 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.druid.DruidBeam - Closing Druid beam for datasource[vidmessage] interval[2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00] (tasks = index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_1_0_lhfifnfi)
10587021 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Closing client for service: druid:firehose:vidmessage-08-0001-0000
10587021 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - No longer monitoring service[druid:firehose:vidmessage-08-0001-0000]
10587022 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.control$ - Creating druid indexing task with id: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_2_0_jlgbllhj (service = overlord)
10587041 [finagle/netty3-4] INFO com.metamx.common.scala.control$ - Created druid indexing task with id: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_2_0_jlgbllhj (service = overlord)
10587046 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - Updating instances for service[druid:firehose:vidmessage-08-0002-0000] to Set()
10587046 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Created client for service: druid:firehose:vidmessage-08-0002-0000
10587046 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Created beam: {"interval":"2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00","partition":2,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_2_0_jlgbllhj","firehoseId":"vidmessage-08-0002-0000"}],"timestamp":"2015-03-20T01:00:00.000-07:00"}
10587046 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.druid.DruidBeam - Closing Druid beam for datasource[vidmessage] interval[2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00] (tasks = index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_2_0_jlgbllhj)
10587046 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Closing client for service: druid:firehose:vidmessage-08-0002-0000
10587047 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - No longer monitoring service[druid:firehose:vidmessage-08-0002-0000]
10587047 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.control$ - Creating druid indexing task with id: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_3_0_pilkeoad (service = overlord)
10587066 [finagle/netty3-4] INFO com.metamx.common.scala.control$ - Created druid indexing task with id: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_3_0_pilkeoad (service = overlord)
10587069 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - Updating instances for service[druid:firehose:vidmessage-08-0003-0000] to Set()
10587070 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Created client for service: druid:firehose:vidmessage-08-0003-0000
10587070 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Created beam: {"interval":"2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00","partition":3,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_3_0_pilkeoad","firehoseId":"vidmessage-08-0003-0000"}],"timestamp":"2015-03-20T01:00:00.000-07:00"}
10587070 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.druid.DruidBeam - Closing Druid beam for datasource[vidmessage] interval[2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00] (tasks = index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_3_0_pilkeoad)
10587070 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Closing client for service: druid:firehose:vidmessage-08-0003-0000
10587070 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - No longer monitoring service[druid:firehose:vidmessage-08-0003-0000]
10587071 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.control$ - Creating druid indexing task with id: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_4_0_iheblodk (service = overlord)
10587090 [finagle/netty3-4] INFO com.metamx.common.scala.control$ - Created druid indexing task with id: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_4_0_iheblodk (service = overlord)
10587092 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - Updating instances for service[druid:firehose:vidmessage-08-0004-0000] to Set()
10587093 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Created client for service: druid:firehose:vidmessage-08-0004-0000
10587093 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Created beam: {"interval":"2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00","partition":4,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_4_0_iheblodk","firehoseId":"vidmessage-08-0004-0000"}],"timestamp":"2015-03-20T01:00:00.000-07:00"}
10587093 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.druid.DruidBeam - Closing Druid beam for datasource[vidmessage] interval[2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00] (tasks = index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_4_0_iheblodk)
10587093 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Closing client for service: druid:firehose:vidmessage-08-0004-0000
10587093 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - No longer monitoring service[druid:firehose:vidmessage-08-0004-0000]
10587094 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.control$ - Creating druid indexing task with id: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_5_0_oafmfiab (service = overlord)
10587113 [finagle/netty3-4] INFO com.metamx.common.scala.control$ - Created druid indexing task with id: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_5_0_oafmfiab (service = overlord)
10587116 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - Updating instances for service[druid:firehose:vidmessage-08-0005-0000] to Set()
10587116 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Created client for service: druid:firehose:vidmessage-08-0005-0000
10587116 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Created beam: {"interval":"2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00","partition":5,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_5_0_oafmfiab","firehoseId":"vidmessage-08-0005-0000"}],"timestamp":"2015-03-20T01:00:00.000-07:00"}
10587116 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.druid.DruidBeam - Closing Druid beam for datasource[vidmessage] interval[2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00] (tasks = index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_5_0_oafmfiab)
10587116 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Closing client for service: druid:firehose:vidmessage-08-0005-0000
10587116 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - No longer monitoring service[druid:firehose:vidmessage-08-0005-0000]
10587117 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.control$ - Creating druid indexing task with id: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_6_0_fbdjjpcn (service = overlord)
10587137 [finagle/netty3-4] INFO com.metamx.common.scala.control$ - Created druid indexing task with id: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_6_0_fbdjjpcn (service = overlord)
10587139 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - Updating instances for service[druid:firehose:vidmessage-08-0006-0000] to Set()
10587140 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Created client for service: druid:firehose:vidmessage-08-0006-0000
10587140 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Created beam: {"interval":"2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00","partition":6,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_6_0_fbdjjpcn","firehoseId":"vidmessage-08-0006-0000"}],"timestamp":"2015-03-20T01:00:00.000-07:00"}
10587140 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.druid.DruidBeam - Closing Druid beam for datasource[vidmessage] interval[2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00] (tasks = index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_6_0_fbdjjpcn)
10587140 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Closing client for service: druid:firehose:vidmessage-08-0006-0000
10587140 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - No longer monitoring service[druid:firehose:vidmessage-08-0006-0000]
10587141 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.control$ - Creating druid indexing task with id: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_7_0_kgpidmai (service = overlord)
10587160 [finagle/netty3-4] INFO com.metamx.common.scala.control$ - Created druid indexing task with id: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_7_0_kgpidmai (service = overlord)
10587162 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - Updating instances for service[druid:firehose:vidmessage-08-0007-0000] to Set()
10587163 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Created client for service: druid:firehose:vidmessage-08-0007-0000
10587163 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Created beam: {"interval":"2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00","partition":7,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_7_0_kgpidmai","firehoseId":"vidmessage-08-0007-0000"}],"timestamp":"2015-03-20T01:00:00.000-07:00"}
10587163 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.druid.DruidBeam - Closing Druid beam for datasource[vidmessage] interval[2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00] (tasks = index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_7_0_kgpidmai)
10587163 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Closing client for service: druid:firehose:vidmessage-08-0007-0000
10587163 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - No longer monitoring service[druid:firehose:vidmessage-08-0007-0000]
10587164 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.control$ - Creating druid indexing task with id: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_8_0_mddadcgj (service = overlord)
10587183 [finagle/netty3-4] INFO com.metamx.common.scala.control$ - Created druid indexing task with id: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_8_0_mddadcgj (service = overlord)
10587186 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - Updating instances for service[druid:firehose:vidmessage-08-0008-0000] to Set()
10587186 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Created client for service: druid:firehose:vidmessage-08-0008-0000
10587186 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Created beam: {"interval":"2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00","partition":8,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_8_0_mddadcgj","firehoseId":"vidmessage-08-0008-0000"}],"timestamp":"2015-03-20T01:00:00.000-07:00"}
10587186 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.druid.DruidBeam - Closing Druid beam for datasource[vidmessage] interval[2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00] (tasks = index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_8_0_mddadcgj)
10587186 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Closing client for service: druid:firehose:vidmessage-08-0008-0000
10587186 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - No longer monitoring service[druid:firehose:vidmessage-08-0008-0000]
10587187 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.control$ - Creating druid indexing task with id: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_9_0_pecdgglj (service = overlord)
10587206 [finagle/netty3-4] INFO com.metamx.common.scala.control$ - Created druid indexing task with id: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_9_0_pecdgglj (service = overlord)
10587209 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - Updating instances for service[druid:firehose:vidmessage-08-0009-0000] to Set()
10587209 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Created client for service: druid:firehose:vidmessage-08-0009-0000
10587209 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Created beam: {"interval":"2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00","partition":9,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_9_0_pecdgglj","firehoseId":"vidmessage-08-0009-0000"}],"timestamp":"2015-03-20T01:00:00.000-07:00"}
10587209 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.druid.DruidBeam - Closing Druid beam for datasource[vidmessage] interval[2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00] (tasks = index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_9_0_pecdgglj)
10587209 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Closing client for service: druid:firehose:vidmessage-08-0009-0000
10587209 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - No longer monitoring service[druid:firehose:vidmessage-08-0009-0000]
10587210 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.control$ - Creating druid indexing task with id: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_10_0_pjhdaeia (service = overlord)
10587230 [finagle/netty3-4] INFO com.metamx.common.scala.control$ - Created druid indexing task with id: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_10_0_pjhdaeia (service = overlord)
10587233 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - Updating instances for service[druid:firehose:vidmessage-08-0010-0000] to Set()
10587234 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Created client for service: druid:firehose:vidmessage-08-0010-0000
10587234 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Created beam: {"interval":"2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00","partition":10,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_10_0_pjhdaeia","firehoseId":"vidmessage-08-0010-0000"}],"timestamp":"2015-03-20T01:00:00.000-07:00"}
10587234 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.druid.DruidBeam - Closing Druid beam for datasource[vidmessage] interval[2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00] (tasks = index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_10_0_pjhdaeia)
10587234 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Closing client for service: druid:firehose:vidmessage-08-0010-0000
10587234 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - No longer monitoring service[druid:firehose:vidmessage-08-0010-0000]
10587235 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.control$ - Creating druid indexing task with id: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_11_0_ppohahni (service = overlord)
10587254 [finagle/netty3-4] INFO com.metamx.common.scala.control$ - Created druid indexing task with id: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_11_0_ppohahni (service = overlord)
10587257 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - Updating instances for service[druid:firehose:vidmessage-08-0011-0000] to Set()
10587257 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Created client for service: druid:firehose:vidmessage-08-0011-0000
10587258 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Created beam: {"interval":"2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00","partition":11,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_11_0_ppohahni","firehoseId":"vidmessage-08-0011-0000"}],"timestamp":"2015-03-20T01:00:00.000-07:00"}
10587258 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.druid.DruidBeam - Closing Druid beam for datasource[vidmessage] interval[2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00] (tasks = index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_11_0_ppohahni)
10587258 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Closing client for service: druid:firehose:vidmessage-08-0011-0000
10587258 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - No longer monitoring service[druid:firehose:vidmessage-08-0011-0000]
10587259 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.control$ - Creating druid indexing task with id: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_12_0_dnedgnon (service = overlord)
10587278 [finagle/netty3-4] INFO com.metamx.common.scala.control$ - Created druid indexing task with id: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_12_0_dnedgnon (service = overlord)
10587280 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - Updating instances for service[druid:firehose:vidmessage-08-0012-0000] to Set()
10587281 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Created client for service: druid:firehose:vidmessage-08-0012-0000
10587281 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Created beam: {"interval":"2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00","partition":12,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_12_0_dnedgnon","firehoseId":"vidmessage-08-0012-0000"}],"timestamp":"2015-03-20T01:00:00.000-07:00"}
10587281 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.druid.DruidBeam - Closing Druid beam for datasource[vidmessage] interval[2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00] (tasks = index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_12_0_dnedgnon)
10587281 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Closing client for service: druid:firehose:vidmessage-08-0012-0000
10587281 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - No longer monitoring service[druid:firehose:vidmessage-08-0012-0000]
10587282 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.control$ - Creating druid indexing task with id: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_13_0_bgkdmfoi (service = overlord)
10587301 [finagle/netty3-4] INFO com.metamx.common.scala.control$ - Created druid indexing task with id: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_13_0_bgkdmfoi (service = overlord)
10587304 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - Updating instances for service[druid:firehose:vidmessage-08-0013-0000] to Set()
10587304 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Created client for service: druid:firehose:vidmessage-08-0013-0000
10587304 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Created beam: {"interval":"2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00","partition":13,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_13_0_bgkdmfoi","firehoseId":"vidmessage-08-0013-0000"}],"timestamp":"2015-03-20T01:00:00.000-07:00"}
10587304 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.druid.DruidBeam - Closing Druid beam for datasource[vidmessage] interval[2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00] (tasks = index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_13_0_bgkdmfoi)
10587304 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Closing client for service: druid:firehose:vidmessage-08-0013-0000
10587304 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - No longer monitoring service[druid:firehose:vidmessage-08-0013-0000]
10587305 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.control$ - Creating druid indexing task with id: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_14_0_afedbkic (service = overlord)
10587324 [finagle/netty3-4] INFO com.metamx.common.scala.control$ - Created druid indexing task with id: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_14_0_afedbkic (service = overlord)
10587327 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - Updating instances for service[druid:firehose:vidmessage-08-0014-0000] to Set()
10587328 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Created client for service: druid:firehose:vidmessage-08-0014-0000
10587328 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Created beam: {"interval":"2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00","partition":14,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_14_0_afedbkic","firehoseId":"vidmessage-08-0014-0000"}],"timestamp":"2015-03-20T01:00:00.000-07:00"}
10587328 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.druid.DruidBeam - Closing Druid beam for datasource[vidmessage] interval[2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00] (tasks = index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_14_0_afedbkic)
10587328 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Closing client for service: druid:firehose:vidmessage-08-0014-0000
10587328 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - No longer monitoring service[druid:firehose:vidmessage-08-0014-0000]
10587329 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.control$ - Creating druid indexing task with id: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_15_0_mpjdnkgn (service = overlord)
10587351 [finagle/netty3-4] INFO com.metamx.common.scala.control$ - Created druid indexing task with id: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_15_0_mpjdnkgn (service = overlord)
10587353 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - Updating instances for service[druid:firehose:vidmessage-08-0015-0000] to Set()
10587354 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Created client for service: druid:firehose:vidmessage-08-0015-0000
10587354 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Created beam: {"interval":"2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00","partition":15,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_15_0_mpjdnkgn","firehoseId":"vidmessage-08-0015-0000"}],"timestamp":"2015-03-20T01:00:00.000-07:00"}
10587354 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.druid.DruidBeam - Closing Druid beam for datasource[vidmessage] interval[2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00] (tasks = index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_15_0_mpjdnkgn)
10587354 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Closing client for service: druid:firehose:vidmessage-08-0015-0000
10587354 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - No longer monitoring service[druid:firehose:vidmessage-08-0015-0000]
10587355 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Writing new beam data to[/tranquility/beams/overlord/vidmessage/data]: {"latestTime":"2015-03-20T01:00:00.000-07:00","latestCloseTime":"2015-03-19T23:00:00.000-07:00","beams":{"2015-03-20T00:00:00.000-07:00":[{"interval":"2015-03-20T00:00:00.000-07:00/2015-03-20T01:00:00.000-07:00","partition":0,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T00:00:00.000-07:00_0_0_nddpbpjm","firehoseId":"vidmessage-07-0000-0000"}],"timestamp":"2015-03-20T00:00:00.000-07:00"},{"interval":"2015-03-20T00:00:00.000-07:00/2015-03-20T01:00:00.000-07:00","partition":1,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T00:00:00.000-07:00_1_0_ckhkpfdm","firehoseId":"vidmessage-07-0001-0000"}],"timestamp":"2015-03-20T00:00:00.000-07:00"},{"interval":"2015-03-20T00:00:00.000-07:00/2015-03-20T01:00:00.000-07:00","partition":2,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T00:00:00.000-07:00_2_0_nchokcpp","firehoseId":"vidmessage-07-0002-0000"}],"timestamp":"2015-03-20T00:00:00.000-07:00"},{"interval":"2015-03-20T00:00:00.000-07:00/2015-03-20T01:00:00.000-07:00","partition":3,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T00:00:00.000-07:00_3_0_lkpdgpdo","firehoseId":"vidmessage-07-0003-0000"}],"timestamp":"2015-03-20T00:00:00.000-07:00"},{"interval":"2015-03-20T00:00:00.000-07:00/2015-03-20T01:00:00.000-07:00","partition":4,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T00:00:00.000-07:00_4_0_aijhddoe","firehoseId":"vidmessage-07-0004-0000"}],"timestamp":"2015-03-20T00:00:00.000-07:00"},{"interval":"2015-03-20T00:00:00.000-07:00/2015-03-20T01:00:00.000-07:00","partition":5,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T00:00:00.000-07:00_5_0_ejbiealn","firehoseId":"vidmessage-07-0005-0000"}],"timestamp":"2015-03-20T00:00:00.000-07:00"},{"interval":"2015-03-20T00:00:00.000-07:00/2015-03-20T01:00:00.000-07:00","partition":6,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T00:00:00.000-07:00_6_0_hoabfimp","firehoseId":"vidmessage-07-0006-0000"}],"timestamp":"2015-03-20T00:00:00.000-07:00"},{"interval":"2015-03-20T00:00:00.000-07:00/2015-03-20T01:00:00.000-07:00","partition":7,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T00:00:00.000-07:00_7_0_nmbmiehh","firehoseId":"vidmessage-07-0007-0000"}],"timestamp":"2015-03-20T00:00:00.000-07:00"},{"interval":"2015-03-20T00:00:00.000-07:00/2015-03-20T01:00:00.000-07:00","partition":8,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T00:00:00.000-07:00_8_0_idkdekgk","firehoseId":"vidmessage-07-0008-0000"}],"timestamp":"2015-03-20T00:00:00.000-07:00"},{"interval":"2015-03-20T00:00:00.000-07:00/2015-03-20T01:00:00.000-07:00","partition":9,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T00:00:00.000-07:00_9_0_ehcmdhje","firehoseId":"vidmessage-07-0009-0000"}],"timestamp":"2015-03-20T00:00:00.000-07:00"},{"interval":"2015-03-20T00:00:00.000-07:00/2015-03-20T01:00:00.000-07:00","partition":10,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T00:00:00.000-07:00_10_0_gihgomif","firehoseId":"vidmessage-07-0010-0000"}],"timestamp":"2015-03-20T00:00:00.000-07:00"},{"interval":"2015-03-20T00:00:00.000-07:00/2015-03-20T01:00:00.000-07:00","partition":11,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T00:00:00.000-07:00_11_0_caechbba","firehoseId":"vidmessage-07-0011-0000"}],"timestamp":"2015-03-20T00:00:00.000-07:00"},{"interval":"2015-03-20T00:00:00.000-07:00/2015-03-20T01:00:00.000-07:00","partition":12,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T00:00:00.000-07:00_12_0_npbeflhi","firehoseId":"vidmessage-07-0012-0000"}],"timestamp":"2015-03-20T00:00:00.000-07:00"},{"interval":"2015-03-20T00:00:00.000-07:00/2015-03-20T01:00:00.000-07:00","partition":13,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T00:00:00.000-07:00_13_0_cjijcajb","firehoseId":"vidmessage-07-0013-0000"}],"timestamp":"2015-03-20T00:00:00.000-07:00"},{"interval":"2015-03-20T00:00:00.000-07:00/2015-03-20T01:00:00.000-07:00","partition":14,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T00:00:00.000-07:00_14_0_ijfaonih","firehoseId":"vidmessage-07-0014-0000"}],"timestamp":"2015-03-20T00:00:00.000-07:00"},{"interval":"2015-03-20T00:00:00.000-07:00/2015-03-20T01:00:00.000-07:00","partition":15,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T00:00:00.000-07:00_15_0_igkmcajh","firehoseId":"vidmessage-07-0015-0000"}],"timestamp":"2015-03-20T00:00:00.000-07:00"}],"2015-03-20T01:00:00.000-07:00":[{"interval":"2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00","partition":0,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_0_0_gmlgnnna","firehoseId":"vidmessage-08-0000-0000"}],"timestamp":"2015-03-20T01:00:00.000-07:00"},{"interval":"2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00","partition":1,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_1_0_lhfifnfi","firehoseId":"vidmessage-08-0001-0000"}],"timestamp":"2015-03-20T01:00:00.000-07:00"},{"interval":"2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00","partition":2,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_2_0_jlgbllhj","firehoseId":"vidmessage-08-0002-0000"}],"timestamp":"2015-03-20T01:00:00.000-07:00"},{"interval":"2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00","partition":3,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_3_0_pilkeoad","firehoseId":"vidmessage-08-0003-0000"}],"timestamp":"2015-03-20T01:00:00.000-07:00"},{"interval":"2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00","partition":4,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_4_0_iheblodk","firehoseId":"vidmessage-08-0004-0000"}],"timestamp":"2015-03-20T01:00:00.000-07:00"},{"interval":"2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00","partition":5,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_5_0_oafmfiab","firehoseId":"vidmessage-08-0005-0000"}],"timestamp":"2015-03-20T01:00:00.000-07:00"},{"interval":"2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00","partition":6,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_6_0_fbdjjpcn","firehoseId":"vidmessage-08-0006-0000"}],"timestamp":"2015-03-20T01:00:00.000-07:00"},{"interval":"2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00","partition":7,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_7_0_kgpidmai","firehoseId":"vidmessage-08-0007-0000"}],"timestamp":"2015-03-20T01:00:00.000-07:00"},{"interval":"2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00","partition":8,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_8_0_mddadcgj","firehoseId":"vidmessage-08-0008-0000"}],"timestamp":"2015-03-20T01:00:00.000-07:00"},{"interval":"2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00","partition":9,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_9_0_pecdgglj","firehoseId":"vidmessage-08-0009-0000"}],"timestamp":"2015-03-20T01:00:00.000-07:00"},{"interval":"2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00","partition":10,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_10_0_pjhdaeia","firehoseId":"vidmessage-08-0010-0000"}],"timestamp":"2015-03-20T01:00:00.000-07:00"},{"interval":"2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00","partition":11,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_11_0_ppohahni","firehoseId":"vidmessage-08-0011-0000"}],"timestamp":"2015-03-20T01:00:00.000-07:00"},{"interval":"2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00","partition":12,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_12_0_dnedgnon","firehoseId":"vidmessage-08-0012-0000"}],"timestamp":"2015-03-20T01:00:00.000-07:00"},{"interval":"2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00","partition":13,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_13_0_bgkdmfoi","firehoseId":"vidmessage-08-0013-0000"}],"timestamp":"2015-03-20T01:00:00.000-07:00"},{"interval":"2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00","partition":14,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_14_0_afedbkic","firehoseId":"vidmessage-08-0014-0000"}],"timestamp":"2015-03-20T01:00:00.000-07:00"},{"interval":"2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00","partition":15,"tasks":[{"id":"index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_15_0_mpjdnkgn","firehoseId":"vidmessage-08-0015-0000"}],"timestamp":"2015-03-20T01:00:00.000-07:00"}]}}
10587357 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Adding beams for identifier[overlord/vidmessage] timestamp[2015-03-20T01:00:00.000-07:00]: List(Map(interval -> 2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00, partition -> 0, tasks -> ArraySeq(Map(id -> index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_0_0_gmlgnnna, firehoseId -> vidmessage-08-0000-0000)), timestamp -> 2015-03-20T01:00:00.000-07:00), Map(interval -> 2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00, partition -> 1, tasks -> ArraySeq(Map(id -> index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_1_0_lhfifnfi, firehoseId -> vidmessage-08-0001-0000)), timestamp -> 2015-03-20T01:00:00.000-07:00), Map(interval -> 2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00, partition -> 2, tasks -> ArraySeq(Map(id -> index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_2_0_jlgbllhj, firehoseId -> vidmessage-08-0002-0000)), timestamp -> 2015-03-20T01:00:00.000-07:00), Map(interval -> 2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00, partition -> 3, tasks -> ArraySeq(Map(id -> index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_3_0_pilkeoad, firehoseId -> vidmessage-08-0003-0000)), timestamp -> 2015-03-20T01:00:00.000-07:00), Map(interval -> 2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00, partition -> 4, tasks -> ArraySeq(Map(id -> index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_4_0_iheblodk, firehoseId -> vidmessage-08-0004-0000)), timestamp -> 2015-03-20T01:00:00.000-07:00), Map(interval -> 2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00, partition -> 5, tasks -> ArraySeq(Map(id -> index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_5_0_oafmfiab, firehoseId -> vidmessage-08-0005-0000)), timestamp -> 2015-03-20T01:00:00.000-07:00), Map(interval -> 2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00, partition -> 6, tasks -> ArraySeq(Map(id -> index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_6_0_fbdjjpcn, firehoseId -> vidmessage-08-0006-0000)), timestamp -> 2015-03-20T01:00:00.000-07:00), Map(interval -> 2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00, partition -> 7, tasks -> ArraySeq(Map(id -> index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_7_0_kgpidmai, firehoseId -> vidmessage-08-0007-0000)), timestamp -> 2015-03-20T01:00:00.000-07:00), Map(interval -> 2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00, partition -> 8, tasks -> ArraySeq(Map(id -> index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_8_0_mddadcgj, firehoseId -> vidmessage-08-0008-0000)), timestamp -> 2015-03-20T01:00:00.000-07:00), Map(interval -> 2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00, partition -> 9, tasks -> ArraySeq(Map(id -> index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_9_0_pecdgglj, firehoseId -> vidmessage-08-0009-0000)), timestamp -> 2015-03-20T01:00:00.000-07:00), Map(interval -> 2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00, partition -> 10, tasks -> ArraySeq(Map(id -> index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_10_0_pjhdaeia, firehoseId -> vidmessage-08-0010-0000)), timestamp -> 2015-03-20T01:00:00.000-07:00), Map(interval -> 2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00, partition -> 11, tasks -> ArraySeq(Map(id -> index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_11_0_ppohahni, firehoseId -> vidmessage-08-0011-0000)), timestamp -> 2015-03-20T01:00:00.000-07:00), Map(interval -> 2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00, partition -> 12, tasks -> ArraySeq(Map(id -> index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_12_0_dnedgnon, firehoseId -> vidmessage-08-0012-0000)), timestamp -> 2015-03-20T01:00:00.000-07:00), Map(interval -> 2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00, partition -> 13, tasks -> ArraySeq(Map(id -> index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_13_0_bgkdmfoi, firehoseId -> vidmessage-08-0013-0000)), timestamp -> 2015-03-20T01:00:00.000-07:00), Map(interval -> 2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00, partition -> 14, tasks -> ArraySeq(Map(id -> index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_14_0_afedbkic, firehoseId -> vidmessage-08-0014-0000)), timestamp -> 2015-03-20T01:00:00.000-07:00), Map(interval -> 2015-03-20T01:00:00.000-07:00/2015-03-20T02:00:00.000-07:00, partition -> 15, tasks -> ArraySeq(Map(id -> index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_15_0_mpjdnkgn, firehoseId -> vidmessage-08-0015-0000)), timestamp -> 2015-03-20T01:00:00.000-07:00))
10587360 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - Updating instances for service[druid:firehose:vidmessage-08-0000-0000] to Set()
10587360 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Created client for service: druid:firehose:vidmessage-08-0000-0000
10587362 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - Updating instances for service[druid:firehose:vidmessage-08-0001-0000] to Set()
10587362 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Created client for service: druid:firehose:vidmessage-08-0001-0000
10587365 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - Updating instances for service[druid:firehose:vidmessage-08-0002-0000] to Set()
10587366 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Created client for service: druid:firehose:vidmessage-08-0002-0000
10587367 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - Updating instances for service[druid:firehose:vidmessage-08-0003-0000] to Set()
10587368 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Created client for service: druid:firehose:vidmessage-08-0003-0000
10587369 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - Updating instances for service[druid:firehose:vidmessage-08-0004-0000] to Set()
10587370 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Created client for service: druid:firehose:vidmessage-08-0004-0000
10587372 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - Updating instances for service[druid:firehose:vidmessage-08-0005-0000] to Set()
10587372 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Created client for service: druid:firehose:vidmessage-08-0005-0000
10587374 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - Updating instances for service[druid:firehose:vidmessage-08-0006-0000] to Set()
10587374 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Created client for service: druid:firehose:vidmessage-08-0006-0000
10587375 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - Updating instances for service[druid:firehose:vidmessage-08-0007-0000] to Set()
10587376 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Created client for service: druid:firehose:vidmessage-08-0007-0000
10587377 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - Updating instances for service[druid:firehose:vidmessage-08-0008-0000] to Set()
10587378 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Created client for service: druid:firehose:vidmessage-08-0008-0000
10587379 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - Updating instances for service[druid:firehose:vidmessage-08-0009-0000] to Set()
10587379 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Created client for service: druid:firehose:vidmessage-08-0009-0000
10587381 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - Updating instances for service[druid:firehose:vidmessage-08-0010-0000] to Set()
10587382 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Created client for service: druid:firehose:vidmessage-08-0010-0000
10587383 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - Updating instances for service[druid:firehose:vidmessage-08-0011-0000] to Set()
10587384 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Created client for service: druid:firehose:vidmessage-08-0011-0000
10587385 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - Updating instances for service[druid:firehose:vidmessage-08-0012-0000] to Set()
10587386 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Created client for service: druid:firehose:vidmessage-08-0012-0000
10587387 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - Updating instances for service[druid:firehose:vidmessage-08-0013-0000] to Set()
10587388 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Created client for service: druid:firehose:vidmessage-08-0013-0000
10587389 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - Updating instances for service[druid:firehose:vidmessage-08-0014-0000] to Set()
10587390 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Created client for service: druid:firehose:vidmessage-08-0014-0000
10587391 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - Updating instances for service[druid:firehose:vidmessage-08-0015-0000] to Set()
10587391 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Created client for service: druid:firehose:vidmessage-08-0015-0000
10587392 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Removing beams for identifier[overlord/vidmessage] timestamp[1426831200000]
10587392 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.druid.DruidBeam - Closing Druid beam for datasource[vidmessage] interval[2015-03-19T23:00:00.000-07:00/2015-03-20T00:00:00.000-07:00] (tasks = index_realtime_vidmessage_2015-03-19T23:00:00.000-07:00_0_0_ncgaccbh)
10587392 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Closing client for service: druid:firehose:vidmessage-06-0000-0000
10587392 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.druid.DruidBeam - Closing Druid beam for datasource[vidmessage] interval[2015-03-19T23:00:00.000-07:00/2015-03-20T00:00:00.000-07:00] (tasks = index_realtime_vidmessage_2015-03-19T23:00:00.000-07:00_1_0_alihcngb)
10587392 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Closing client for service: druid:firehose:vidmessage-06-0001-0000
10587392 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.druid.DruidBeam - Closing Druid beam for datasource[vidmessage] interval[2015-03-19T23:00:00.000-07:00/2015-03-20T00:00:00.000-07:00] (tasks = index_realtime_vidmessage_2015-03-19T23:00:00.000-07:00_2_0_cbdkkejc)
10587392 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Closing client for service: druid:firehose:vidmessage-06-0002-0000
10587392 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.druid.DruidBeam - Closing Druid beam for datasource[vidmessage] interval[2015-03-19T23:00:00.000-07:00/2015-03-20T00:00:00.000-07:00] (tasks = index_realtime_vidmessage_2015-03-19T23:00:00.000-07:00_3_0_apgdbngi)
10587392 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Closing client for service: druid:firehose:vidmessage-06-0003-0000
10587392 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.druid.DruidBeam - Closing Druid beam for datasource[vidmessage] interval[2015-03-19T23:00:00.000-07:00/2015-03-20T00:00:00.000-07:00] (tasks = index_realtime_vidmessage_2015-03-19T23:00:00.000-07:00_4_0_adeinagp)
10587392 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Closing client for service: druid:firehose:vidmessage-06-0004-0000
10587392 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.druid.DruidBeam - Closing Druid beam for datasource[vidmessage] interval[2015-03-19T23:00:00.000-07:00/2015-03-20T00:00:00.000-07:00] (tasks = index_realtime_vidmessage_2015-03-19T23:00:00.000-07:00_5_0_mjgekfpe)
10587392 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Closing client for service: druid:firehose:vidmessage-06-0005-0000
10587392 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.druid.DruidBeam - Closing Druid beam for datasource[vidmessage] interval[2015-03-19T23:00:00.000-07:00/2015-03-20T00:00:00.000-07:00] (tasks = index_realtime_vidmessage_2015-03-19T23:00:00.000-07:00_6_0_ehheempe)
10587392 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Closing client for service: druid:firehose:vidmessage-06-0006-0000
10587393 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.druid.DruidBeam - Closing Druid beam for datasource[vidmessage] interval[2015-03-19T23:00:00.000-07:00/2015-03-20T00:00:00.000-07:00] (tasks = index_realtime_vidmessage_2015-03-19T23:00:00.000-07:00_7_0_hkjlnhfm)
10587393 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Closing client for service: druid:firehose:vidmessage-06-0007-0000
10587393 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.druid.DruidBeam - Closing Druid beam for datasource[vidmessage] interval[2015-03-19T23:00:00.000-07:00/2015-03-20T00:00:00.000-07:00] (tasks = index_realtime_vidmessage_2015-03-19T23:00:00.000-07:00_8_0_mmbgjpmm)
10587393 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Closing client for service: druid:firehose:vidmessage-06-0008-0000
10587393 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.druid.DruidBeam - Closing Druid beam for datasource[vidmessage] interval[2015-03-19T23:00:00.000-07:00/2015-03-20T00:00:00.000-07:00] (tasks = index_realtime_vidmessage_2015-03-19T23:00:00.000-07:00_9_0_hakkdlpe)
10587393 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Closing client for service: druid:firehose:vidmessage-06-0009-0000
10587393 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.druid.DruidBeam - Closing Druid beam for datasource[vidmessage] interval[2015-03-19T23:00:00.000-07:00/2015-03-20T00:00:00.000-07:00] (tasks = index_realtime_vidmessage_2015-03-19T23:00:00.000-07:00_10_0_kmdgbile)
10587393 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Closing client for service: druid:firehose:vidmessage-06-0010-0000
10587393 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.druid.DruidBeam - Closing Druid beam for datasource[vidmessage] interval[2015-03-19T23:00:00.000-07:00/2015-03-20T00:00:00.000-07:00] (tasks = index_realtime_vidmessage_2015-03-19T23:00:00.000-07:00_11_0_ohodgpbh)
10587393 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Closing client for service: druid:firehose:vidmessage-06-0011-0000
10587393 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.druid.DruidBeam - Closing Druid beam for datasource[vidmessage] interval[2015-03-19T23:00:00.000-07:00/2015-03-20T00:00:00.000-07:00] (tasks = index_realtime_vidmessage_2015-03-19T23:00:00.000-07:00_12_0_pakcipea)
10587393 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Closing client for service: druid:firehose:vidmessage-06-0012-0000
10587393 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.druid.DruidBeam - Closing Druid beam for datasource[vidmessage] interval[2015-03-19T23:00:00.000-07:00/2015-03-20T00:00:00.000-07:00] (tasks = index_realtime_vidmessage_2015-03-19T23:00:00.000-07:00_13_0_daekpjec)
10587393 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Closing client for service: druid:firehose:vidmessage-06-0013-0000
10587393 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.druid.DruidBeam - Closing Druid beam for datasource[vidmessage] interval[2015-03-19T23:00:00.000-07:00/2015-03-20T00:00:00.000-07:00] (tasks = index_realtime_vidmessage_2015-03-19T23:00:00.000-07:00_14_0_ldlmddmk)
10587393 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Closing client for service: druid:firehose:vidmessage-06-0014-0000
10587393 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.druid.DruidBeam - Closing Druid beam for datasource[vidmessage] interval[2015-03-19T23:00:00.000-07:00/2015-03-20T00:00:00.000-07:00] (tasks = index_realtime_vidmessage_2015-03-19T23:00:00.000-07:00_15_0_kkanhadf)
10587393 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.finagle.FinagleRegistry - Closing client for service: druid:firehose:vidmessage-06-0015-0000
10587394 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - No longer monitoring service[druid:firehose:vidmessage-06-0000-0000]
10587394 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - No longer monitoring service[druid:firehose:vidmessage-06-0001-0000]
10587394 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - No longer monitoring service[druid:firehose:vidmessage-06-0002-0000]
10587394 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - No longer monitoring service[druid:firehose:vidmessage-06-0003-0000]
10587394 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - No longer monitoring service[druid:firehose:vidmessage-06-0004-0000]
10587394 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - No longer monitoring service[druid:firehose:vidmessage-06-0005-0000]
10587395 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - No longer monitoring service[druid:firehose:vidmessage-06-0006-0000]
10587395 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - No longer monitoring service[druid:firehose:vidmessage-06-0007-0000]
10587395 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - No longer monitoring service[druid:firehose:vidmessage-06-0008-0000]
10587395 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - No longer monitoring service[druid:firehose:vidmessage-06-0009-0000]
10587395 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - No longer monitoring service[druid:firehose:vidmessage-06-0010-0000]
10587395 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - No longer monitoring service[druid:firehose:vidmessage-06-0011-0000]
10587395 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - No longer monitoring service[druid:firehose:vidmessage-06-0012-0000]
10587395 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - No longer monitoring service[druid:firehose:vidmessage-06-0013-0000]
10587395 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - No longer monitoring service[druid:firehose:vidmessage-06-0014-0000]
10587396 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.common.scala.net.finagle.DiscoResolver - No longer monitoring service[druid:firehose:vidmessage-06-0015-0000]
10587399 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Merged beam already created for identifier[overlord/vidmessage] timestamp[2015-03-20T01:00:00.000-07:00], with sufficient partitions (target = 16, actual = 16)
10587403 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Merged beam already created for identifier[overlord/vidmessage] timestamp[2015-03-20T01:00:00.000-07:00], with sufficient partitions (target = 16, actual = 16)
10587408 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Merged beam already created for identifier[overlord/vidmessage] timestamp[2015-03-20T01:00:00.000-07:00], with sufficient partitions (target = 16, actual = 16)
10587412 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Merged beam already created for identifier[overlord/vidmessage] timestamp[2015-03-20T01:00:00.000-07:00], with sufficient partitions (target = 16, actual = 16)
10587415 [finagle/netty3-5] WARN com.metamx.tranquility.finagle.FutureRetry$ - Transient error, will try again in 232 ms
java.io.IOException: Unable to push events to task: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_1_0_lhfifnfi (status = TaskRunning)
10587415 [finagle/netty3-4] WARN com.metamx.tranquility.finagle.FutureRetry$ - Transient error, will try again in 219 ms
java.io.IOException: Unable to push events to task: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_8_0_mddadcgj (status = TaskRunning)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:160)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:146)
	at com.twitter.util.Future$$anonfun$map$1$$anonfun$apply$4.apply(Future.scala:828)
	at com.twitter.util.Try$.apply(Try.scala:13)
	at com.twitter.util.Future$.apply(Future.scala:84)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:791)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:790)
	at com.twitter.util.Promise$Transformer.liftedTree1$1(Promise.scala:96)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:160)
	at com.twitter.util.Promise$Transformer.k(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:106)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:87)
	at com.twitter.util.Promise$$anon$2.run(Promise.scala:328)
	at com.twitter.concurrent.LocalScheduler$Activation.run(Scheduler.scala:186)
	at com.twitter.concurrent.LocalScheduler$Activation.submit(Scheduler.scala:157)	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:146)
	at com.twitter.util.Future$$anonfun$map$1$$anonfun$apply$4.apply(Future.scala:828)
	at com.twitter.util.Try$.apply(Try.scala:13)
	at com.twitter.util.Future$.apply(Future.scala:84)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:791)

	at com.twitter.concurrent.LocalScheduler.submit(Scheduler.scala:212)
	at com.twitter.concurrent.Scheduler$.submit(Scheduler.scala:86)
	at com.twitter.util.Promise.runq(Promise.scala:314)
	at com.twitter.util.Promise.updateIfEmpty(Promise.scala:609)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:790)
	at com.twitter.util.Promise$Transformer.liftedTree1$1(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.k(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:106)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:87)
	at com.twitter.util.Promise.update(Promise.scala:587)
	at com.twitter.util.Promise.setValue(Promise.scala:563)
	at com.twitter.concurrent.AsyncQueue.offer(AsyncQueue.scala:76)
	at com.twitter.finagle.transport.ChannelTransport.handleUpstream(ChannelTransport.scala:45)
	at com.twitter.util.Promise$$anon$2.run(Promise.scala:328)	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.handler.codec.http.HttpContentDecoder.messageReceived(HttpContentDecoder.java:108)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.http.HttpChunkAggregator.messageReceived(HttpChunkAggregator.java:194)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)

	at org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:459)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.callDecode(ReplayingDecoder.java:536)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.messageReceived(ReplayingDecoder.java:435)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.handler.codec.http.HttpClientCodec.handleUpstream(HttpClientCodec.java:92)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.concurrent.LocalScheduler$Activation.run(Scheduler.scala:186)
	at com.twitter.concurrent.LocalScheduler$Activation.submit(Scheduler.scala:157)
	at com.twitter.concurrent.LocalScheduler.submit(Scheduler.scala:212)
	at com.twitter.concurrent.Scheduler$.submit(Scheduler.scala:86)
	at com.twitter.util.Promise.runq(Promise.scala:314)
	at com.twitter.util.Promise.updateIfEmpty(Promise.scala:609)
	at com.twitter.util.Promise.update(Promise.scala:587)	at com.twitter.finagle.channel.ChannelStatsHandler.messageReceived(ChannelStatsHandler.scala:84)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)

	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelRequestStatsHandler.messageReceived(ChannelRequestStatsHandler.scala:35)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255)
	at com.twitter.util.Promise.setValue(Promise.scala:563)
	at com.twitter.concurrent.AsyncQueue.offer(AsyncQueue.scala:76)
	at com.twitter.finagle.transport.ChannelTransport.handleUpstream(ChannelTransport.scala:45)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.handler.codec.http.HttpContentDecoder.messageReceived(HttpContentDecoder.java:108)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.http.HttpChunkAggregator.messageReceived(HttpChunkAggregator.java:194)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:459)
	at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.callDecode(ReplayingDecoder.java:536)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.messageReceived(ReplayingDecoder.java:435)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.handler.codec.http.HttpClientCodec.handleUpstream(HttpClientCodec.java:92)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelStatsHandler.messageReceived(ChannelStatsHandler.scala:84)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108)
	at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:337)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
	at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
	at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
	at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:780)
Caused by: com.twitter.finagle.NoBrokersAvailableException: No hosts are available for disco!druid:firehose:vidmessage-08-0001-0000
	at com.twitter.finagle.NoStacktrace(Unknown Source)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelRequestStatsHandler.messageReceived(ChannelRequestStatsHandler.scala:35)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255)
	at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108)
	at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:337)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
	at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
	at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
	at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:780)
Caused by: com.twitter.finagle.NoBrokersAvailableException: No hosts are available for disco!druid:firehose:vidmessage-08-0008-0000
	at com.twitter.finagle.NoStacktrace(Unknown Source)
10587418 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Merged beam already created for identifier[overlord/vidmessage] timestamp[2015-03-20T01:00:00.000-07:00], with sufficient partitions (target = 16, actual = 16)
10587425 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Merged beam already created for identifier[overlord/vidmessage] timestamp[2015-03-20T01:00:00.000-07:00], with sufficient partitions (target = 16, actual = 16)
10587429 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Merged beam already created for identifier[overlord/vidmessage] timestamp[2015-03-20T01:00:00.000-07:00], with sufficient partitions (target = 16, actual = 16)
10587435 [finagle/netty3-4] WARN com.metamx.tranquility.finagle.FutureRetry$ - Transient error, will try again in 210 ms
java.io.IOException: Unable to push events to task: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_0_0_gmlgnnna (status = TaskRunning)
10587435 [finagle/netty3-5] WARN com.metamx.tranquility.finagle.FutureRetry$ - Transient error, will try again in 225 ms
java.io.IOException: Unable to push events to task: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_9_0_pecdgglj (status = TaskRunning)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:160)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:146)
	at com.twitter.util.Future$$anonfun$map$1$$anonfun$apply$4.apply(Future.scala:828)
	at com.twitter.util.Try$.apply(Try.scala:13)
	at com.twitter.util.Future$.apply(Future.scala:84)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:791)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:790)
	at com.twitter.util.Promise$Transformer.liftedTree1$1(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.k(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:106)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:87)
	at com.twitter.util.Promise$$anon$2.run(Promise.scala:328)
	at com.twitter.concurrent.LocalScheduler$Activation.run(Scheduler.scala:186)
	at com.twitter.concurrent.LocalScheduler$Activation.submit(Scheduler.scala:157)
	at com.twitter.concurrent.LocalScheduler.submit(Scheduler.scala:212)
	at com.twitter.concurrent.Scheduler$.submit(Scheduler.scala:86)
	at com.twitter.util.Promise.runq(Promise.scala:314)
	at com.twitter.util.Promise.updateIfEmpty(Promise.scala:609)
	at com.twitter.util.Promise.update(Promise.scala:587)
	at com.twitter.util.Promise.setValue(Promise.scala:563)
	at com.twitter.concurrent.AsyncQueue.offer(AsyncQueue.scala:76)
	at com.twitter.finagle.transport.ChannelTransport.handleUpstream(ChannelTransport.scala:45)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.handler.codec.http.HttpContentDecoder.messageReceived(HttpContentDecoder.java:108)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
10587435 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Merged beam already created for identifier[overlord/vidmessage] timestamp[2015-03-20T01:00:00.000-07:00], with sufficient partitions (target = 16, actual = 16)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:160)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:146)
	at com.twitter.util.Future$$anonfun$map$1$$anonfun$apply$4.apply(Future.scala:828)
	at com.twitter.util.Try$.apply(Try.scala:13)
	at org.jboss.netty.handler.codec.http.HttpChunkAggregator.messageReceived(HttpChunkAggregator.java:194)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:459)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.callDecode(ReplayingDecoder.java:536)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.messageReceived(ReplayingDecoder.java:435)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.handler.codec.http.HttpClientCodec.handleUpstream(HttpClientCodec.java:92)	at com.twitter.util.Future$.apply(Future.scala:84)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:791)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:790)
	at com.twitter.util.Promise$Transformer.liftedTree1$1(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.k(Promise.scala:96)

	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelStatsHandler.messageReceived(ChannelStatsHandler.scala:84)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelRequestStatsHandler.messageReceived(ChannelRequestStatsHandler.scala:35)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:106)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:87)
	at com.twitter.util.Promise$$anon$2.run(Promise.scala:328)
	at com.twitter.concurrent.LocalScheduler$Activation.run(Scheduler.scala:186)
	at com.twitter.concurrent.LocalScheduler$Activation.submit(Scheduler.scala:157)
	at com.twitter.concurrent.LocalScheduler.submit(Scheduler.scala:212)
	at com.twitter.concurrent.Scheduler$.submit(Scheduler.scala:86)
	at com.twitter.util.Promise.runq(Promise.scala:314)
	at com.twitter.util.Promise.updateIfEmpty(Promise.scala:609)
	at com.twitter.util.Promise.update(Promise.scala:587)
	at com.twitter.util.Promise.setValue(Promise.scala:563)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255)	at com.twitter.concurrent.AsyncQueue.offer(AsyncQueue.scala:76)
	at com.twitter.finagle.transport.ChannelTransport.handleUpstream(ChannelTransport.scala:45)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.handler.codec.http.HttpContentDecoder.messageReceived(HttpContentDecoder.java:108)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.http.HttpChunkAggregator.messageReceived(HttpChunkAggregator.java:194)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:459)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.callDecode(ReplayingDecoder.java:536)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.messageReceived(ReplayingDecoder.java:435)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.handler.codec.http.HttpClientCodec.handleUpstream(HttpClientCodec.java:92)
	at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108)
	at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:337)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
	at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
	at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
	at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelStatsHandler.messageReceived(ChannelStatsHandler.scala:84)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)

	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelRequestStatsHandler.messageReceived(ChannelRequestStatsHandler.scala:35)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255)
	at java.lang.Thread.run(Thread.java:780)
Caused by: com.twitter.finagle.NoBrokersAvailableException: No hosts are available for disco!druid:firehose:vidmessage-08-0000-0000
	at com.twitter.finagle.NoStacktrace(Unknown Source)
	at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108)
	at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:337)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
	at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
	at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
	at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:780)
Caused by: com.twitter.finagle.NoBrokersAvailableException: No hosts are available for disco!druid:firehose:vidmessage-08-0009-0000
	at com.twitter.finagle.NoStacktrace(Unknown Source)
10587441 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Merged beam already created for identifier[overlord/vidmessage] timestamp[2015-03-20T01:00:00.000-07:00], with sufficient partitions (target = 16, actual = 16)
10587445 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Merged beam already created for identifier[overlord/vidmessage] timestamp[2015-03-20T01:00:00.000-07:00], with sufficient partitions (target = 16, actual = 16)
10587450 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Merged beam already created for identifier[overlord/vidmessage] timestamp[2015-03-20T01:00:00.000-07:00], with sufficient partitions (target = 16, actual = 16)
10587455 [finagle/netty3-5] WARN com.metamx.tranquility.finagle.FutureRetry$ - Transient error, will try again in 216 ms
java.io.IOException: Unable to push events to task: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_10_0_pjhdaeia (status = TaskRunning)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:160)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:146)
	at com.twitter.util.Future$$anonfun$map$1$$anonfun$apply$4.apply(Future.scala:828)
	at com.twitter.util.Try$.apply(Try.scala:13)
	at com.twitter.util.Future$.apply(Future.scala:84)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
10587455 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Merged beam already created for identifier[overlord/vidmessage] timestamp[2015-03-20T01:00:00.000-07:00], with sufficient partitions (target = 16, actual = 16)
10587455 [finagle/netty3-4] WARN com.metamx.tranquility.finagle.FutureRetry$ - Transient error, will try again in 196 ms
java.io.IOException: Unable to push events to task: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_5_0_oafmfiab (status = TaskRunning)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:791)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:790)
	at com.twitter.util.Promise$Transformer.liftedTree1$1(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.k(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:106)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:87)
	at com.twitter.util.Promise$$anon$2.run(Promise.scala:328)
	at com.twitter.concurrent.LocalScheduler$Activation.run(Scheduler.scala:186)
	at com.twitter.concurrent.LocalScheduler$Activation.submit(Scheduler.scala:157)
	at com.twitter.concurrent.LocalScheduler.submit(Scheduler.scala:212)
	at com.twitter.concurrent.Scheduler$.submit(Scheduler.scala:86)
	at com.twitter.util.Promise.runq(Promise.scala:314)
	at com.twitter.util.Promise.updateIfEmpty(Promise.scala:609)
	at com.twitter.util.Promise.update(Promise.scala:587)
	at com.twitter.util.Promise.setValue(Promise.scala:563)
	at com.twitter.concurrent.AsyncQueue.offer(AsyncQueue.scala:76)
	at com.twitter.finagle.transport.ChannelTransport.handleUpstream(ChannelTransport.scala:45)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:160)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:146)
	at com.twitter.util.Future$$anonfun$map$1$$anonfun$apply$4.apply(Future.scala:828)
	at com.twitter.util.Try$.apply(Try.scala:13)
	at com.twitter.util.Future$.apply(Future.scala:84)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:791)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:790)

	at org.jboss.netty.handler.codec.http.HttpContentDecoder.messageReceived(HttpContentDecoder.java:108)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.http.HttpChunkAggregator.messageReceived(HttpChunkAggregator.java:194)
	at com.twitter.util.Promise$Transformer.liftedTree1$1(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.k(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:106)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:87)
	at com.twitter.util.Promise$$anon$2.run(Promise.scala:328)
	at com.twitter.concurrent.LocalScheduler$Activation.run(Scheduler.scala:186)
	at com.twitter.concurrent.LocalScheduler$Activation.submit(Scheduler.scala:157)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:459)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.callDecode(ReplayingDecoder.java:536)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.messageReceived(ReplayingDecoder.java:435)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.handler.codec.http.HttpClientCodec.handleUpstream(HttpClientCodec.java:92)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at com.twitter.concurrent.LocalScheduler.submit(Scheduler.scala:212)
	at com.twitter.concurrent.Scheduler$.submit(Scheduler.scala:86)
	at com.twitter.util.Promise.runq(Promise.scala:314)
	at com.twitter.util.Promise.updateIfEmpty(Promise.scala:609)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelStatsHandler.messageReceived(ChannelStatsHandler.scala:84)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at com.twitter.util.Promise.update(Promise.scala:587)
	at com.twitter.util.Promise.setValue(Promise.scala:563)
	at com.twitter.concurrent.AsyncQueue.offer(AsyncQueue.scala:76)
	at com.twitter.finagle.transport.ChannelTransport.handleUpstream(ChannelTransport.scala:45)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.handler.codec.http.HttpContentDecoder.messageReceived(HttpContentDecoder.java:108)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.http.HttpChunkAggregator.messageReceived(HttpChunkAggregator.java:194)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:459)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.callDecode(ReplayingDecoder.java:536)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.messageReceived(ReplayingDecoder.java:435)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelRequestStatsHandler.messageReceived(ChannelRequestStatsHandler.scala:35)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255)
	at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108)
	at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:337)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
	at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
	at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
	at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
	at org.jboss.netty.handler.codec.http.HttpClientCodec.handleUpstream(HttpClientCodec.java:92)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelStatsHandler.messageReceived(ChannelStatsHandler.scala:84)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)

	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:780)
Caused by: com.twitter.finagle.NoBrokersAvailableException: No hosts are available for disco!druid:firehose:vidmessage-08-0010-0000
	at com.twitter.finagle.NoStacktrace(Unknown Source)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelRequestStatsHandler.messageReceived(ChannelRequestStatsHandler.scala:35)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255)
	at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108)
	at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:337)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
	at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
	at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
	at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:780)
Caused by: com.twitter.finagle.NoBrokersAvailableException: No hosts are available for disco!druid:firehose:vidmessage-08-0005-0000
	at com.twitter.finagle.NoStacktrace(Unknown Source)
10587460 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Merged beam already created for identifier[overlord/vidmessage] timestamp[2015-03-20T01:00:00.000-07:00], with sufficient partitions (target = 16, actual = 16)
10587465 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Merged beam already created for identifier[overlord/vidmessage] timestamp[2015-03-20T01:00:00.000-07:00], with sufficient partitions (target = 16, actual = 16)
10587471 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Merged beam already created for identifier[overlord/vidmessage] timestamp[2015-03-20T01:00:00.000-07:00], with sufficient partitions (target = 16, actual = 16)
10587475 [finagle/netty3-4] WARN com.metamx.tranquility.finagle.FutureRetry$ - Transient error, will try again in 228 ms
java.io.IOException: Unable to push events to task: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_13_0_bgkdmfoi (status = TaskRunning)
10587475 [finagle/netty3-5] WARN com.metamx.tranquility.finagle.FutureRetry$ - Transient error, will try again in 193 ms
java.io.IOException: Unable to push events to task: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_9_0_pecdgglj (status = TaskRunning)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:160)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:146)
	at com.twitter.util.Future$$anonfun$map$1$$anonfun$apply$4.apply(Future.scala:828)
	at com.twitter.util.Try$.apply(Try.scala:13)
	at com.twitter.util.Future$.apply(Future.scala:84)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:791)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:790)
	at com.twitter.util.Promise$Transformer.liftedTree1$1(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.k(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:106)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:87)
	at com.twitter.util.Promise$$anon$2.run(Promise.scala:328)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:160)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:146)
	at com.twitter.util.Future$$anonfun$map$1$$anonfun$apply$4.apply(Future.scala:828)
	at com.twitter.util.Try$.apply(Try.scala:13)
	at com.twitter.util.Future$.apply(Future.scala:84)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.concurrent.LocalScheduler$Activation.run(Scheduler.scala:186)
	at com.twitter.concurrent.LocalScheduler$Activation.submit(Scheduler.scala:157)
	at com.twitter.concurrent.LocalScheduler.submit(Scheduler.scala:212)
	at com.twitter.concurrent.Scheduler$.submit(Scheduler.scala:86)
	at com.twitter.util.Promise.runq(Promise.scala:314)
	at com.twitter.util.Promise.updateIfEmpty(Promise.scala:609)
	at com.twitter.util.Promise.update(Promise.scala:587)
	at com.twitter.util.Promise.setValue(Promise.scala:563)
	at com.twitter.concurrent.AsyncQueue.offer(AsyncQueue.scala:76)
	at com.twitter.finagle.transport.ChannelTransport.handleUpstream(ChannelTransport.scala:45)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.handler.codec.http.HttpContentDecoder.messageReceived(HttpContentDecoder.java:108)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:791)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:790)
	at com.twitter.util.Promise$Transformer.liftedTree1$1(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.k(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:106)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:87)
	at com.twitter.util.Promise$$anon$2.run(Promise.scala:328)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.http.HttpChunkAggregator.messageReceived(HttpChunkAggregator.java:194)
	at com.twitter.concurrent.LocalScheduler$Activation.run(Scheduler.scala:186)
	at com.twitter.concurrent.LocalScheduler$Activation.submit(Scheduler.scala:157)
	at com.twitter.concurrent.LocalScheduler.submit(Scheduler.scala:212)
	at com.twitter.concurrent.Scheduler$.submit(Scheduler.scala:86)
	at com.twitter.util.Promise.runq(Promise.scala:314)
	at com.twitter.util.Promise.updateIfEmpty(Promise.scala:609)
	at com.twitter.util.Promise.update(Promise.scala:587)
	at com.twitter.util.Promise.setValue(Promise.scala:563)
	at com.twitter.concurrent.AsyncQueue.offer(AsyncQueue.scala:76)
	at com.twitter.finagle.transport.ChannelTransport.handleUpstream(ChannelTransport.scala:45)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.handler.codec.http.HttpContentDecoder.messageReceived(HttpContentDecoder.java:108)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.http.HttpChunkAggregator.messageReceived(HttpChunkAggregator.java:194)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:459)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.callDecode(ReplayingDecoder.java:536)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.messageReceived(ReplayingDecoder.java:435)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.handler.codec.http.HttpClientCodec.handleUpstream(HttpClientCodec.java:92)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelStatsHandler.messageReceived(ChannelStatsHandler.scala:84)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)

	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelRequestStatsHandler.messageReceived(ChannelRequestStatsHandler.scala:35)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255)
	at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108)
	at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:337)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
	at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
	at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
	at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:459)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.callDecode(ReplayingDecoder.java:536)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.messageReceived(ReplayingDecoder.java:435)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.handler.codec.http.HttpClientCodec.handleUpstream(HttpClientCodec.java:92)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)

	at java.lang.Thread.run(Thread.java:780)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelStatsHandler.messageReceived(ChannelStatsHandler.scala:84)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelRequestStatsHandler.messageReceived(ChannelRequestStatsHandler.scala:35)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
Caused by: 	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255)
	at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108)
	at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:337)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
	at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
	at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
	at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:780)com.twitter.finagle.NoBrokersAvailableException: No hosts are available for disco!druid:firehose:vidmessage-08-0009-0000
	at com.twitter.finagle.NoStacktrace(Unknown Source)

Caused by: com.twitter.finagle.NoBrokersAvailableException: No hosts are available for disco!druid:firehose:vidmessage-08-0013-0000
	at com.twitter.finagle.NoStacktrace(Unknown Source)
10587477 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Merged beam already created for identifier[overlord/vidmessage] timestamp[2015-03-20T01:00:00.000-07:00], with sufficient partitions (target = 16, actual = 16)
10587482 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Merged beam already created for identifier[overlord/vidmessage] timestamp[2015-03-20T01:00:00.000-07:00], with sufficient partitions (target = 16, actual = 16)
10587489 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Merged beam already created for identifier[overlord/vidmessage] timestamp[2015-03-20T01:00:00.000-07:00], with sufficient partitions (target = 16, actual = 16)
10587495 [finagle/netty3-4] WARN com.metamx.tranquility.finagle.FutureRetry$ - Transient error, will try again in 152 ms
java.io.IOException: Unable to push events to task: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_2_0_jlgbllhj (status = TaskRunning)
10587495 [finagle/netty3-5] WARN com.metamx.tranquility.finagle.FutureRetry$ - Transient error, will try again in 155 ms
java.io.IOException: Unable to push events to task: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_3_0_pilkeoad (status = TaskRunning)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:160)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:146)
10587495 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Merged beam already created for identifier[overlord/vidmessage] timestamp[2015-03-20T01:00:00.000-07:00], with sufficient partitions (target = 16, actual = 16)
	at com.twitter.util.Future$$anonfun$map$1$$anonfun$apply$4.apply(Future.scala:828)
	at com.twitter.util.Try$.apply(Try.scala:13)
	at com.twitter.util.Future$.apply(Future.scala:84)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:791)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:790)
	at com.twitter.util.Promise$Transformer.liftedTree1$1(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.k(Promise.scala:96)	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:160)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:146)
	at com.twitter.util.Future$$anonfun$map$1$$anonfun$apply$4.apply(Future.scala:828)
	at com.twitter.util.Try$.apply(Try.scala:13)
	at com.twitter.util.Future$.apply(Future.scala:84)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:791)

	at com.twitter.util.Promise$Transformer.apply(Promise.scala:106)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:87)
	at com.twitter.util.Promise$$anon$2.run(Promise.scala:328)
	at com.twitter.concurrent.LocalScheduler$Activation.run(Scheduler.scala:186)
	at com.twitter.concurrent.LocalScheduler$Activation.submit(Scheduler.scala:157)
	at com.twitter.concurrent.LocalScheduler.submit(Scheduler.scala:212)
	at com.twitter.concurrent.Scheduler$.submit(Scheduler.scala:86)	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:790)
	at com.twitter.util.Promise$Transformer.liftedTree1$1(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.k(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:106)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:87)

	at com.twitter.util.Promise.runq(Promise.scala:314)
	at com.twitter.util.Promise.updateIfEmpty(Promise.scala:609)
	at com.twitter.util.Promise.update(Promise.scala:587)
	at com.twitter.util.Promise.setValue(Promise.scala:563)
	at com.twitter.concurrent.AsyncQueue.offer(AsyncQueue.scala:76)
	at com.twitter.finagle.transport.ChannelTransport.handleUpstream(ChannelTransport.scala:45)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.handler.codec.http.HttpContentDecoder.messageReceived(HttpContentDecoder.java:108)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at com.twitter.util.Promise$$anon$2.run(Promise.scala:328)
	at com.twitter.concurrent.LocalScheduler$Activation.run(Scheduler.scala:186)
	at com.twitter.concurrent.LocalScheduler$Activation.submit(Scheduler.scala:157)
	at com.twitter.concurrent.LocalScheduler.submit(Scheduler.scala:212)
	at com.twitter.concurrent.Scheduler$.submit(Scheduler.scala:86)
	at com.twitter.util.Promise.runq(Promise.scala:314)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)	at com.twitter.util.Promise.updateIfEmpty(Promise.scala:609)
	at com.twitter.util.Promise.update(Promise.scala:587)
	at com.twitter.util.Promise.setValue(Promise.scala:563)
	at com.twitter.concurrent.AsyncQueue.offer(AsyncQueue.scala:76)
	at com.twitter.finagle.transport.ChannelTransport.handleUpstream(ChannelTransport.scala:45)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)

	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.handler.codec.http.HttpContentDecoder.messageReceived(HttpContentDecoder.java:108)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.http.HttpChunkAggregator.messageReceived(HttpChunkAggregator.java:194)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:459)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.callDecode(ReplayingDecoder.java:536)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.messageReceived(ReplayingDecoder.java:435)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.handler.codec.http.HttpClientCodec.handleUpstream(HttpClientCodec.java:92)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)	at org.jboss.netty.handler.codec.http.HttpChunkAggregator.messageReceived(HttpChunkAggregator.java:194)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)

	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelStatsHandler.messageReceived(ChannelStatsHandler.scala:84)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelRequestStatsHandler.messageReceived(ChannelRequestStatsHandler.scala:35)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:459)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.callDecode(ReplayingDecoder.java:536)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255)
	at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108)
	at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:337)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.messageReceived(ReplayingDecoder.java:435)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.handler.codec.http.HttpClientCodec.handleUpstream(HttpClientCodec.java:92)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
	at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
	at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:780)
Caused by: 	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelStatsHandler.messageReceived(ChannelStatsHandler.scala:84)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)com.twitter.finagle.NoBrokersAvailableException: No hosts are available for disco!druid:firehose:vidmessage-08-0002-0000
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelRequestStatsHandler.messageReceived(ChannelRequestStatsHandler.scala:35)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255)
	at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108)
	at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:337)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
	at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)

	at com.twitter.finagle.NoStacktrace(Unknown Source)
	at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
	at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:780)
Caused by: com.twitter.finagle.NoBrokersAvailableException: No hosts are available for disco!druid:firehose:vidmessage-08-0003-0000
	at com.twitter.finagle.NoStacktrace(Unknown Source)
10587500 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Merged beam already created for identifier[overlord/vidmessage] timestamp[2015-03-20T01:00:00.000-07:00], with sufficient partitions (target = 16, actual = 16)
10587505 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Merged beam already created for identifier[overlord/vidmessage] timestamp[2015-03-20T01:00:00.000-07:00], with sufficient partitions (target = 16, actual = 16)
10587515 [finagle/netty3-4] WARN com.metamx.tranquility.finagle.FutureRetry$ - Transient error, will try again in 251 ms
java.io.IOException: Unable to push events to task: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_11_0_ppohahni (status = TaskRunning)
10587515 [finagle/netty3-5] WARN com.metamx.tranquility.finagle.FutureRetry$ - Transient error, will try again in 303 ms
java.io.IOException: Unable to push events to task: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_4_0_iheblodk (status = TaskRunning)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:160)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:146)
	at com.twitter.util.Future$$anonfun$map$1$$anonfun$apply$4.apply(Future.scala:828)
	at com.twitter.util.Try$.apply(Try.scala:13)
	at com.twitter.util.Future$.apply(Future.scala:84)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:791)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:790)
	at com.twitter.util.Promise$Transformer.liftedTree1$1(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.k(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:106)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:160)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:146)
	at com.twitter.util.Future$$anonfun$map$1$$anonfun$apply$4.apply(Future.scala:828)
	at com.twitter.util.Try$.apply(Try.scala:13)
	at com.twitter.util.Future$.apply(Future.scala:84)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:791)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:790)
	at com.twitter.util.Promise$Transformer.liftedTree1$1(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.k(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:106)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:87)
	at com.twitter.util.Promise$$anon$2.run(Promise.scala:328)
	at com.twitter.concurrent.LocalScheduler$Activation.run(Scheduler.scala:186)
	at com.twitter.concurrent.LocalScheduler$Activation.submit(Scheduler.scala:157)
	at com.twitter.concurrent.LocalScheduler.submit(Scheduler.scala:212)
	at com.twitter.concurrent.Scheduler$.submit(Scheduler.scala:86)
	at com.twitter.util.Promise.runq(Promise.scala:314)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:87)
	at com.twitter.util.Promise$$anon$2.run(Promise.scala:328)
	at com.twitter.concurrent.LocalScheduler$Activation.run(Scheduler.scala:186)
	at com.twitter.concurrent.LocalScheduler$Activation.submit(Scheduler.scala:157)
	at com.twitter.concurrent.LocalScheduler.submit(Scheduler.scala:212)
	at com.twitter.concurrent.Scheduler$.submit(Scheduler.scala:86)
	at com.twitter.util.Promise.runq(Promise.scala:314)
	at com.twitter.util.Promise.updateIfEmpty(Promise.scala:609)
	at com.twitter.util.Promise.update(Promise.scala:587)
	at com.twitter.util.Promise.setValue(Promise.scala:563)
	at com.twitter.concurrent.AsyncQueue.offer(AsyncQueue.scala:76)
	at com.twitter.finagle.transport.ChannelTransport.handleUpstream(ChannelTransport.scala:45)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.handler.codec.http.HttpContentDecoder.messageReceived(HttpContentDecoder.java:108)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at com.twitter.util.Promise.updateIfEmpty(Promise.scala:609)
	at com.twitter.util.Promise.update(Promise.scala:587)
	at com.twitter.util.Promise.setValue(Promise.scala:563)
	at com.twitter.concurrent.AsyncQueue.offer(AsyncQueue.scala:76)
	at com.twitter.finagle.transport.ChannelTransport.handleUpstream(ChannelTransport.scala:45)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.handler.codec.http.HttpContentDecoder.messageReceived(HttpContentDecoder.java:108)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.http.HttpChunkAggregator.messageReceived(HttpChunkAggregator.java:194)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.http.HttpChunkAggregator.messageReceived(HttpChunkAggregator.java:194)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:459)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.callDecode(ReplayingDecoder.java:536)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.messageReceived(ReplayingDecoder.java:435)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.handler.codec.http.HttpClientCodec.handleUpstream(HttpClientCodec.java:92)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelStatsHandler.messageReceived(ChannelStatsHandler.scala:84)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelRequestStatsHandler.messageReceived(ChannelRequestStatsHandler.scala:35)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:459)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.callDecode(ReplayingDecoder.java:536)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.messageReceived(ReplayingDecoder.java:435)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.handler.codec.http.HttpClientCodec.handleUpstream(HttpClientCodec.java:92)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255)
	at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelStatsHandler.messageReceived(ChannelStatsHandler.scala:84)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelRequestStatsHandler.messageReceived(ChannelRequestStatsHandler.scala:35)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:337)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
	at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
	at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
	at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255)
	at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88)
	at java.lang.Thread.run(Thread.java:780)	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108)
	at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:337)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
	at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
	at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
	at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)

Caused by: com.twitter.finagle.NoBrokersAvailableException: No hosts are available for disco!druid:firehose:vidmessage-08-0011-0000
	at com.twitter.finagle.NoStacktrace(Unknown Source)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:780)
Caused by: com.twitter.finagle.NoBrokersAvailableException: No hosts are available for disco!druid:firehose:vidmessage-08-0004-0000
	at com.twitter.finagle.NoStacktrace(Unknown Source)
10587520 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Merged beam already created for identifier[overlord/vidmessage] timestamp[2015-03-20T01:00:00.000-07:00], with sufficient partitions (target = 16, actual = 16)
10587527 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Merged beam already created for identifier[overlord/vidmessage] timestamp[2015-03-20T01:00:00.000-07:00], with sufficient partitions (target = 16, actual = 16)
10587533 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Merged beam already created for identifier[overlord/vidmessage] timestamp[2015-03-20T01:00:00.000-07:00], with sufficient partitions (target = 16, actual = 16)
10587535 [finagle/netty3-4] WARN com.metamx.tranquility.finagle.FutureRetry$ - Transient error, will try again in 178 ms
java.io.IOException: Unable to push events to task: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_0_0_gmlgnnna (status = TaskRunning)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:160)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:146)
	at com.twitter.util.Future$$anonfun$map$1$$anonfun$apply$4.apply(Future.scala:828)
	at com.twitter.util.Try$.apply(Try.scala:13)
	at com.twitter.util.Future$.apply(Future.scala:84)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:791)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:790)
	at com.twitter.util.Promise$Transformer.liftedTree1$1(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.k(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:106)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:87)
	at com.twitter.util.Promise$$anon$2.run(Promise.scala:328)
	at com.twitter.concurrent.LocalScheduler$Activation.run(Scheduler.scala:186)
	at com.twitter.concurrent.LocalScheduler$Activation.submit(Scheduler.scala:157)
	at com.twitter.concurrent.LocalScheduler.submit(Scheduler.scala:212)
	at com.twitter.concurrent.Scheduler$.submit(Scheduler.scala:86)
	at com.twitter.util.Promise.runq(Promise.scala:314)
	at com.twitter.util.Promise.updateIfEmpty(Promise.scala:609)
	at com.twitter.util.Promise.update(Promise.scala:587)
	at com.twitter.util.Promise.setValue(Promise.scala:563)
	at com.twitter.concurrent.AsyncQueue.offer(AsyncQueue.scala:76)
	at com.twitter.finagle.transport.ChannelTransport.handleUpstream(ChannelTransport.scala:45)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.handler.codec.http.HttpContentDecoder.messageReceived(HttpContentDecoder.java:108)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.http.HttpChunkAggregator.messageReceived(HttpChunkAggregator.java:194)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:459)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.callDecode(ReplayingDecoder.java:536)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.messageReceived(ReplayingDecoder.java:435)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.handler.codec.http.HttpClientCodec.handleUpstream(HttpClientCodec.java:92)
10587536 [finagle/netty3-5] WARN com.metamx.tranquility.finagle.FutureRetry$ - Transient error, will try again in 262 ms
java.io.IOException: Unable to push events to task: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_15_0_mpjdnkgn (status = TaskRunning)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelStatsHandler.messageReceived(ChannelStatsHandler.scala:84)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelRequestStatsHandler.messageReceived(ChannelRequestStatsHandler.scala:35)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255)
	at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108)
	at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:337)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:160)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:146)
	at com.twitter.util.Future$$anonfun$map$1$$anonfun$apply$4.apply(Future.scala:828)
	at com.twitter.util.Try$.apply(Try.scala:13)
	at com.twitter.util.Future$.apply(Future.scala:84)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
	at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
	at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
	at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:791)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:790)
	at com.twitter.util.Promise$Transformer.liftedTree1$1(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.k(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:106)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:87)
	at com.twitter.util.Promise$$anon$2.run(Promise.scala:328)
	at com.twitter.concurrent.LocalScheduler$Activation.run(Scheduler.scala:186)
	at com.twitter.concurrent.LocalScheduler$Activation.submit(Scheduler.scala:157)
	at java.lang.Thread.run(Thread.java:780)
Caused by: com.twitter.finagle.NoBrokersAvailableException: No hosts are available for disco!druid:firehose:vidmessage-08-0000-0000
	at com.twitter.finagle.NoStacktrace(Unknown Source)
	at com.twitter.concurrent.LocalScheduler.submit(Scheduler.scala:212)
	at com.twitter.concurrent.Scheduler$.submit(Scheduler.scala:86)
	at com.twitter.util.Promise.runq(Promise.scala:314)
	at com.twitter.util.Promise.updateIfEmpty(Promise.scala:609)
	at com.twitter.util.Promise.update(Promise.scala:587)
	at com.twitter.util.Promise.setValue(Promise.scala:563)
	at com.twitter.concurrent.AsyncQueue.offer(AsyncQueue.scala:76)
	at com.twitter.finagle.transport.ChannelTransport.handleUpstream(ChannelTransport.scala:45)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.handler.codec.http.HttpContentDecoder.messageReceived(HttpContentDecoder.java:108)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.http.HttpChunkAggregator.messageReceived(HttpChunkAggregator.java:194)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:459)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.callDecode(ReplayingDecoder.java:536)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.messageReceived(ReplayingDecoder.java:435)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.handler.codec.http.HttpClientCodec.handleUpstream(HttpClientCodec.java:92)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelStatsHandler.messageReceived(ChannelStatsHandler.scala:84)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelRequestStatsHandler.messageReceived(ChannelRequestStatsHandler.scala:35)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255)
	at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108)
	at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:337)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
	at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
	at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
	at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:780)
Caused by: com.twitter.finagle.NoBrokersAvailableException: No hosts are available for disco!druid:firehose:vidmessage-08-0015-0000
	at com.twitter.finagle.NoStacktrace(Unknown Source)
10587538 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Merged beam already created for identifier[overlord/vidmessage] timestamp[2015-03-20T01:00:00.000-07:00], with sufficient partitions (target = 16, actual = 16)
10587545 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Merged beam already created for identifier[overlord/vidmessage] timestamp[2015-03-20T01:00:00.000-07:00], with sufficient partitions (target = 16, actual = 16)
10587552 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Merged beam already created for identifier[overlord/vidmessage] timestamp[2015-03-20T01:00:00.000-07:00], with sufficient partitions (target = 16, actual = 16)
10587554 [finagle/netty3-4] WARN com.metamx.tranquility.finagle.FutureRetry$ - Transient error, will try again in 240 ms
java.io.IOException: Unable to push events to task: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_5_0_oafmfiab (status = TaskRunning)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:160)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:146)
	at com.twitter.util.Future$$anonfun$map$1$$anonfun$apply$4.apply(Future.scala:828)
	at com.twitter.util.Try$.apply(Try.scala:13)
	at com.twitter.util.Future$.apply(Future.scala:84)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:791)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:790)
	at com.twitter.util.Promise$Transformer.liftedTree1$1(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.k(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:106)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:87)
	at com.twitter.util.Promise$$anon$2.run(Promise.scala:328)
	at com.twitter.concurrent.LocalScheduler$Activation.run(Scheduler.scala:186)
	at com.twitter.concurrent.LocalScheduler$Activation.submit(Scheduler.scala:157)
	at com.twitter.concurrent.LocalScheduler.submit(Scheduler.scala:212)
	at com.twitter.concurrent.Scheduler$.submit(Scheduler.scala:86)
	at com.twitter.util.Promise.runq(Promise.scala:314)
	at com.twitter.util.Promise.updateIfEmpty(Promise.scala:609)
	at com.twitter.util.Promise.update(Promise.scala:587)
	at com.twitter.util.Promise.setValue(Promise.scala:563)
	at com.twitter.concurrent.AsyncQueue.offer(AsyncQueue.scala:76)
	at com.twitter.finagle.transport.ChannelTransport.handleUpstream(ChannelTransport.scala:45)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
10587554 [finagle/netty3-5] WARN com.metamx.tranquility.finagle.FutureRetry$ - Transient error, will try again in 193 ms
java.io.IOException: Unable to push events to task: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_10_0_pjhdaeia (status = TaskRunning)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.handler.codec.http.HttpContentDecoder.messageReceived(HttpContentDecoder.java:108)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.http.HttpChunkAggregator.messageReceived(HttpChunkAggregator.java:194)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:459)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.callDecode(ReplayingDecoder.java:536)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.messageReceived(ReplayingDecoder.java:435)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.handler.codec.http.HttpClientCodec.handleUpstream(HttpClientCodec.java:92)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelStatsHandler.messageReceived(ChannelStatsHandler.scala:84)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:160)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:146)
	at com.twitter.util.Future$$anonfun$map$1$$anonfun$apply$4.apply(Future.scala:828)
	at com.twitter.util.Try$.apply(Try.scala:13)
	at com.twitter.util.Future$.apply(Future.scala:84)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelRequestStatsHandler.messageReceived(ChannelRequestStatsHandler.scala:35)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:791)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:790)
	at com.twitter.util.Promise$Transformer.liftedTree1$1(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.k(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:106)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:87)
	at com.twitter.util.Promise$$anon$2.run(Promise.scala:328)
	at com.twitter.concurrent.LocalScheduler$Activation.run(Scheduler.scala:186)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255)
	at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108)
	at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:337)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
	at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
	at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
	at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at com.twitter.concurrent.LocalScheduler$Activation.submit(Scheduler.scala:157)
	at com.twitter.concurrent.LocalScheduler.submit(Scheduler.scala:212)
	at com.twitter.concurrent.Scheduler$.submit(Scheduler.scala:86)
	at com.twitter.util.Promise.runq(Promise.scala:314)
	at com.twitter.util.Promise.updateIfEmpty(Promise.scala:609)
	at com.twitter.util.Promise.update(Promise.scala:587)
	at com.twitter.util.Promise.setValue(Promise.scala:563)
	at com.twitter.concurrent.AsyncQueue.offer(AsyncQueue.scala:76)
	at com.twitter.finagle.transport.ChannelTransport.handleUpstream(ChannelTransport.scala:45)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at java.lang.Thread.run(Thread.java:780)
Caused by: com.twitter.finagle.NoBrokersAvailableException: No hosts are available for disco!druid:firehose:vidmessage-08-0005-0000
	at com.twitter.finagle.NoStacktrace(Unknown Source)
	at org.jboss.netty.handler.codec.http.HttpContentDecoder.messageReceived(HttpContentDecoder.java:108)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.http.HttpChunkAggregator.messageReceived(HttpChunkAggregator.java:194)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:459)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.callDecode(ReplayingDecoder.java:536)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.messageReceived(ReplayingDecoder.java:435)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.handler.codec.http.HttpClientCodec.handleUpstream(HttpClientCodec.java:92)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelStatsHandler.messageReceived(ChannelStatsHandler.scala:84)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelRequestStatsHandler.messageReceived(ChannelRequestStatsHandler.scala:35)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255)
	at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108)
	at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:337)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
	at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
	at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
	at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:780)
Caused by: com.twitter.finagle.NoBrokersAvailableException: No hosts are available for disco!druid:firehose:vidmessage-08-0010-0000
	at com.twitter.finagle.NoStacktrace(Unknown Source)
10587557 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Merged beam already created for identifier[overlord/vidmessage] timestamp[2015-03-20T01:00:00.000-07:00], with sufficient partitions (target = 16, actual = 16)
10587563 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Merged beam already created for identifier[overlord/vidmessage] timestamp[2015-03-20T01:00:00.000-07:00], with sufficient partitions (target = 16, actual = 16)
10587569 [ClusteredBeam-ZkFuturePool-05a28cf9-d20b-41b4-8f6e-465d209debbf] INFO com.metamx.tranquility.beam.ClusteredBeam - Merged beam already created for identifier[overlord/vidmessage] timestamp[2015-03-20T01:00:00.000-07:00], with sufficient partitions (target = 16, actual = 16)
10587574 [finagle/netty3-5] WARN com.metamx.tranquility.finagle.FutureRetry$ - Transient error, will try again in 197 ms
java.io.IOException: Unable to push events to task: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_1_0_lhfifnfi (status = TaskRunning)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:160)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:146)
	at com.twitter.util.Future$$anonfun$map$1$$anonfun$apply$4.apply(Future.scala:828)
	at com.twitter.util.Try$.apply(Try.scala:13)
	at com.twitter.util.Future$.apply(Future.scala:84)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:791)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:790)
	at com.twitter.util.Promise$Transformer.liftedTree1$1(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.k(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:106)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:87)
	at com.twitter.util.Promise$$anon$2.run(Promise.scala:328)
	at com.twitter.concurrent.LocalScheduler$Activation.run(Scheduler.scala:186)
	at com.twitter.concurrent.LocalScheduler$Activation.submit(Scheduler.scala:157)
	at com.twitter.concurrent.LocalScheduler.submit(Scheduler.scala:212)
	at com.twitter.concurrent.Scheduler$.submit(Scheduler.scala:86)
	at com.twitter.util.Promise.runq(Promise.scala:314)
10587574 [finagle/netty3-4] WARN com.metamx.tranquility.finagle.FutureRetry$ - Transient error, will try again in 213 ms
java.io.IOException: Unable to push events to task: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_14_0_afedbkic (status = TaskRunning)
	at com.twitter.util.Promise.updateIfEmpty(Promise.scala:609)
	at com.twitter.util.Promise.update(Promise.scala:587)
	at com.twitter.util.Promise.setValue(Promise.scala:563)
	at com.twitter.concurrent.AsyncQueue.offer(AsyncQueue.scala:76)
	at com.twitter.finagle.transport.ChannelTransport.handleUpstream(ChannelTransport.scala:45)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.handler.codec.http.HttpContentDecoder.messageReceived(HttpContentDecoder.java:108)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.http.HttpChunkAggregator.messageReceived(HttpChunkAggregator.java:194)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:459)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.callDecode(ReplayingDecoder.java:536)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.messageReceived(ReplayingDecoder.java:435)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.handler.codec.http.HttpClientCodec.handleUpstream(HttpClientCodec.java:92)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:160)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:146)
	at com.twitter.util.Future$$anonfun$map$1$$anonfun$apply$4.apply(Future.scala:828)
	at com.twitter.util.Try$.apply(Try.scala:13)
	at com.twitter.util.Future$.apply(Future.scala:84)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:791)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:790)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelStatsHandler.messageReceived(ChannelStatsHandler.scala:84)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at com.twitter.util.Promise$Transformer.liftedTree1$1(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.k(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:106)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:87)
	at com.twitter.util.Promise$$anon$2.run(Promise.scala:328)
	at com.twitter.concurrent.LocalScheduler$Activation.run(Scheduler.scala:186)
	at com.twitter.concurrent.LocalScheduler$Activation.submit(Scheduler.scala:157)
	at com.twitter.concurrent.LocalScheduler.submit(Scheduler.scala:212)
	at com.twitter.concurrent.Scheduler$.submit(Scheduler.scala:86)
	at com.twitter.util.Promise.runq(Promise.scala:314)
	at com.twitter.util.Promise.updateIfEmpty(Promise.scala:609)
	at com.twitter.util.Promise.update(Promise.scala:587)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at com.twitter.util.Promise.setValue(Promise.scala:563)
	at com.twitter.concurrent.AsyncQueue.offer(AsyncQueue.scala:76)
	at com.twitter.finagle.transport.ChannelTransport.handleUpstream(ChannelTransport.scala:45)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.handler.codec.http.HttpContentDecoder.messageReceived(HttpContentDecoder.java:108)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelRequestStatsHandler.messageReceived(ChannelRequestStatsHandler.scala:35)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255)
	at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108)
	at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:337)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
	at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
	at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.http.HttpChunkAggregator.messageReceived(HttpChunkAggregator.java:194)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:459)
	at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:780)
Caused by: com.twitter.finagle.NoBrokersAvailableException: No hosts are available for disco!druid:firehose:vidmessage-08-0001-0000
	at com.twitter.finagle.NoStacktrace(Unknown Source)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.callDecode(ReplayingDecoder.java:536)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.messageReceived(ReplayingDecoder.java:435)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.handler.codec.http.HttpClientCodec.handleUpstream(HttpClientCodec.java:92)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelStatsHandler.messageReceived(ChannelStatsHandler.scala:84)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelRequestStatsHandler.messageReceived(ChannelRequestStatsHandler.scala:35)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255)
	at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108)
	at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:337)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
	at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
	at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
	at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:780)
Caused by: com.twitter.finagle.NoBrokersAvailableException: No hosts are available for disco!druid:firehose:vidmessage-08-0014-0000
	at com.twitter.finagle.NoStacktrace(Unknown Source)
10587593 [finagle/netty3-4] WARN com.metamx.tranquility.finagle.FutureRetry$ - Transient error, will try again in 145 ms
java.io.IOException: Unable to push events to task: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_9_0_pecdgglj (status = TaskRunning)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:160)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:146)
	at com.twitter.util.Future$$anonfun$map$1$$anonfun$apply$4.apply(Future.scala:828)
	at com.twitter.util.Try$.apply(Try.scala:13)
	at com.twitter.util.Future$.apply(Future.scala:84)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:791)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:790)
	at com.twitter.util.Promise$Transformer.liftedTree1$1(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.k(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:106)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:87)
	at com.twitter.util.Promise$$anon$2.run(Promise.scala:328)
	at com.twitter.concurrent.LocalScheduler$Activation.run(Scheduler.scala:186)
	at com.twitter.concurrent.LocalScheduler$Activation.submit(Scheduler.scala:157)
	at com.twitter.concurrent.LocalScheduler.submit(Scheduler.scala:212)
	at com.twitter.concurrent.Scheduler$.submit(Scheduler.scala:86)
	at com.twitter.util.Promise.runq(Promise.scala:314)
	at com.twitter.util.Promise.updateIfEmpty(Promise.scala:609)
	at com.twitter.util.Promise.update(Promise.scala:587)
	at com.twitter.util.Promise.setValue(Promise.scala:563)
	at com.twitter.concurrent.AsyncQueue.offer(AsyncQueue.scala:76)
	at com.twitter.finagle.transport.ChannelTransport.handleUpstream(ChannelTransport.scala:45)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.handler.codec.http.HttpContentDecoder.messageReceived(HttpContentDecoder.java:108)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.http.HttpChunkAggregator.messageReceived(HttpChunkAggregator.java:194)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
10587594 [finagle/netty3-5] WARN com.metamx.tranquility.finagle.FutureRetry$ - Transient error, will try again in 205 ms
java.io.IOException: Unable to push events to task: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_6_0_fbdjjpcn (status = TaskRunning)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:459)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.callDecode(ReplayingDecoder.java:536)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.messageReceived(ReplayingDecoder.java:435)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.handler.codec.http.HttpClientCodec.handleUpstream(HttpClientCodec.java:92)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelStatsHandler.messageReceived(ChannelStatsHandler.scala:84)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelRequestStatsHandler.messageReceived(ChannelRequestStatsHandler.scala:35)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:160)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:146)
	at com.twitter.util.Future$$anonfun$map$1$$anonfun$apply$4.apply(Future.scala:828)
	at com.twitter.util.Try$.apply(Try.scala:13)
	at com.twitter.util.Future$.apply(Future.scala:84)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255)
	at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:791)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:790)
	at com.twitter.util.Promise$Transformer.liftedTree1$1(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.k(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:106)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:87)
	at com.twitter.util.Promise$$anon$2.run(Promise.scala:328)
	at com.twitter.concurrent.LocalScheduler$Activation.run(Scheduler.scala:186)
	at com.twitter.concurrent.LocalScheduler$Activation.submit(Scheduler.scala:157)
	at com.twitter.concurrent.LocalScheduler.submit(Scheduler.scala:212)
	at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:337)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
	at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
	at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
	at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:780)
Caused by: com.twitter.finagle.NoBrokersAvailableException: No hosts are available for disco!druid:firehose:vidmessage-08-0009-0000
	at com.twitter.finagle.NoStacktrace(Unknown Source)
	at com.twitter.concurrent.Scheduler$.submit(Scheduler.scala:86)
	at com.twitter.util.Promise.runq(Promise.scala:314)
	at com.twitter.util.Promise.updateIfEmpty(Promise.scala:609)
	at com.twitter.util.Promise.update(Promise.scala:587)
	at com.twitter.util.Promise.setValue(Promise.scala:563)
	at com.twitter.concurrent.AsyncQueue.offer(AsyncQueue.scala:76)
	at com.twitter.finagle.transport.ChannelTransport.handleUpstream(ChannelTransport.scala:45)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.handler.codec.http.HttpContentDecoder.messageReceived(HttpContentDecoder.java:108)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.http.HttpChunkAggregator.messageReceived(HttpChunkAggregator.java:194)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:459)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.callDecode(ReplayingDecoder.java:536)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.messageReceived(ReplayingDecoder.java:435)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.handler.codec.http.HttpClientCodec.handleUpstream(HttpClientCodec.java:92)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelStatsHandler.messageReceived(ChannelStatsHandler.scala:84)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelRequestStatsHandler.messageReceived(ChannelRequestStatsHandler.scala:35)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255)
	at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108)
	at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:337)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
	at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
	at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
	at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:780)
Caused by: com.twitter.finagle.NoBrokersAvailableException: No hosts are available for disco!druid:firehose:vidmessage-08-0006-0000
	at com.twitter.finagle.NoStacktrace(Unknown Source)
10587612 [finagle/netty3-4] WARN com.metamx.tranquility.finagle.FutureRetry$ - Transient error, will try again in 205 ms
java.io.IOException: Unable to push events to task: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_13_0_bgkdmfoi (status = TaskRunning)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:160)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:146)
	at com.twitter.util.Future$$anonfun$map$1$$anonfun$apply$4.apply(Future.scala:828)
	at com.twitter.util.Try$.apply(Try.scala:13)
	at com.twitter.util.Future$.apply(Future.scala:84)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:791)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:790)
	at com.twitter.util.Promise$Transformer.liftedTree1$1(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.k(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:106)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:87)
	at com.twitter.util.Promise$$anon$2.run(Promise.scala:328)
	at com.twitter.concurrent.LocalScheduler$Activation.run(Scheduler.scala:186)
	at com.twitter.concurrent.LocalScheduler$Activation.submit(Scheduler.scala:157)
	at com.twitter.concurrent.LocalScheduler.submit(Scheduler.scala:212)
	at com.twitter.concurrent.Scheduler$.submit(Scheduler.scala:86)
	at com.twitter.util.Promise.runq(Promise.scala:314)
	at com.twitter.util.Promise.updateIfEmpty(Promise.scala:609)
	at com.twitter.util.Promise.update(Promise.scala:587)
	at com.twitter.util.Promise.setValue(Promise.scala:563)
	at com.twitter.concurrent.AsyncQueue.offer(AsyncQueue.scala:76)
	at com.twitter.finagle.transport.ChannelTransport.handleUpstream(ChannelTransport.scala:45)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.handler.codec.http.HttpContentDecoder.messageReceived(HttpContentDecoder.java:108)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.http.HttpChunkAggregator.messageReceived(HttpChunkAggregator.java:194)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:459)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.callDecode(ReplayingDecoder.java:536)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.messageReceived(ReplayingDecoder.java:435)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.handler.codec.http.HttpClientCodec.handleUpstream(HttpClientCodec.java:92)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelStatsHandler.messageReceived(ChannelStatsHandler.scala:84)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.SimpleChannelHandler.messageReceived(SimpleChannelHandler.java:142)
	at com.twitter.finagle.channel.ChannelRequestStatsHandler.messageReceived(ChannelRequestStatsHandler.scala:35)
	at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255)
	at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108)
	at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:337)
	at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
	at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
	at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
	at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:780)
Caused by: 10587613 [finagle/netty3-5] WARN com.metamx.tranquility.finagle.FutureRetry$ - Transient error, will try again in 218 ms
java.io.IOException: Unable to push events to task: index_realtime_vidmessage_2015-03-20T01:00:00.000-07:00_2_0_jlgbllhj (status = TaskRunning)
com.twitter.finagle.NoBrokersAvailableException: No hosts are available for disco!druid:firehose:vidmessage-08-0013-0000
	at com.twitter.finagle.NoStacktrace(Unknown Source)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:160)
	at com.metamx.tranquility.druid.DruidBeam$$anonfun$4$$anonfun$apply$4$$anonfun$apply$6$$anonfun$apply$7$$anonfun$apply$3$$anonfun$applyOrElse$2.apply(DruidBeam.scala:146)
	at com.twitter.util.Future$$anonfun$map$1$$anonfun$apply$4.apply(Future.scala:828)
	at com.twitter.util.Try$.apply(Try.scala:13)
	at com.twitter.util.Future$.apply(Future.scala:84)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$map$1.apply(Future.scala:828)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:791)
	at com.twitter.util.Future$$anonfun$flatMap$1.apply(Future.scala:790)
	at com.twitter.util.Promise$Transformer.liftedTree1$1(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.k(Promise.scala:96)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:106)
	at com.twitter.util.Promise$Transformer.apply(Promise.scala:87)
	at com.twitter.util.Promise$$anon$2.run(Promise.scala:328)
	at com.twitter.concurrent.LocalScheduler$Activation.run(Scheduler.scala:186)
	at com.twitter.concurrent.LocalScheduler$Activation.submit(Scheduler.scala:157)
	at com.twitter.concurrent.LocalScheduler.submit(Scheduler.scala:212)
	at com.twitter.concurrent.Scheduler$.submit(Scheduler.scala:86)
	at com.twitter.util.Promise.runq(Promise.scala:314)
	at com.twitter.util.Promise.updateIfEmpty(Promise.scala:609)
	at com.twitter.util.Promise.update(Promise.scala:587)
	at com.twitter.util.Promise.setValue(Promise.scala:563)
	at com.twitter.concurrent.AsyncQueue.offer(AsyncQueue.scala:76)
	at com.twitter.finagle.transport.ChannelTransport.handleUpstream(ChannelTransport.scala:45)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.handler.codec.http.HttpContentDecoder.messageReceived(HttpContentDecoder.java:108)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.http.HttpChunkAggregator.messageReceived(HttpChunkAggregator.java:194)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
	at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
	at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
	at org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:459)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.callDecode(ReplayingDecoder.java:536)
	at org.jboss.netty.handler.codec.replay.ReplayingDecoder.messageReceived(ReplayingDecoder.java:435)
	at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
	at org.jboss.netty.handler.codec.http.HttpClientCodec.handleUpstream(HttpClientCodec.java:92)