So I left it running in this state for 15 minutes and then it started up. Usually the app takes about 10 seconds to initialize.
> On Nov 20, 2015, at 10:23 AM, Rick Mangi <r...@chartbeat.com> wrote: > > Just started getting this error this morning. On startup the consumer trying > to reload the kv-store changelog starts throwing this exception and keeps > restarting and failing. > > > > 2015-11-20 10:16:19 [main] TaskStorageManager [DEBUG] Stopping consumers for > stores. > 2015-11-20 10:16:19 [main] BrokerProxy [INFO] Shutting down BrokerProxy for > devstream03.chartbeat.net <http://devstream03.chartbeat.net/>:9092 > 2015-11-20 10:16:19 [main] BrokerProxy [INFO] closing simple consumer... > 2015-11-20 10:16:19 [main] DefaultFetchSimpleConsumer [DEBUG] Disconnecting > from devstream03.chartbeat.net <http://devstream03.chartbeat.net/>:9092 > 2015-11-20 10:16:19 [SAMZA-BROKER-PROXY-BrokerProxy thread pointed at > devstream03.chartbeat.net <http://devstream03.chartbeat.net/>:9092 for client > samza_consumer-t_key_aggregator_dev-dev-1448032450060-10] > DefaultFetchSimpleConsumer [INFO] Reconnect due to socket error: > java.nio.channels.ClosedChannelException > 2015-11-20 10:16:19 [SAMZA-BROKER-PROXY-BrokerProxy thread pointed at > devstream03.chartbeat.net <http://devstream03.chartbeat.net/>:9092 for client > samza_consumer-t_key_aggregator_dev-dev-1448032450060-10] > DefaultFetchSimpleConsumer [DEBUG] Disconnecting from > devstream03.chartbeat.net <http://devstream03.chartbeat.net/>:9092 > 2015-11-20 10:16:19 [SAMZA-BROKER-PROXY-BrokerProxy thread pointed at > devstream03.chartbeat.net <http://devstream03.chartbeat.net/>:9092 for client > samza_consumer-t_key_aggregator_dev-dev-1448032450060-10] > DefaultFetchSimpleConsumer [DEBUG] Disconnecting from > devstream03.chartbeat.net <http://devstream03.chartbeat.net/>:9092 > 2015-11-20 10:16:19 [SAMZA-BROKER-PROXY-BrokerProxy thread pointed at > devstream03.chartbeat.net <http://devstream03.chartbeat.net/>:9092 for client > samza_consumer-t_key_aggregator_dev-dev-1448032450060-10] > DefaultFetchSimpleConsumer [DEBUG] Disconnecting from > devstream03.chartbeat.net <http://devstream03.chartbeat.net/>:9092 > 2015-11-20 10:16:19 [SAMZA-BROKER-PROXY-BrokerProxy thread pointed at > devstream03.chartbeat.net <http://devstream03.chartbeat.net/>:9092 for client > samza_consumer-t_key_aggregator_dev-dev-1448032450060-10] BrokerProxy [WARN] > Restarting consumer due to java.nio.channels.ClosedChannelException. > Releasing ownership of all partitions, and restarting consumer. Turn on > debugging to get a full stack trace. > 2015-11-20 10:16:19 [SAMZA-BROKER-PROXY-BrokerProxy thread pointed at > devstream03.chartbeat.net <http://devstream03.chartbeat.net/>:9092 for client > samza_consumer-t_key_aggregator_dev-dev-1448032450060-10] BrokerProxy [DEBUG] > Exception detail: > java.nio.channels.ClosedChannelException > at kafka.network.BlockingChannel.send(BlockingChannel.scala:100) > at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:78) > at > kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:68) > at > kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:112) > at > kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:112) > at > kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:112) > at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33) > at > kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:111) > at > kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:111) > at > kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:111) > at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33) > at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:110) > at > org.apache.samza.system.kafka.DefaultFetchSimpleConsumer.fetch(DefaultFetchSimpleConsumer.scala:48) > at > org.apache.samza.system.kafka.DefaultFetchSimpleConsumer.defaultFetch(DefaultFetchSimpleConsumer.scala:41) > at > org.apache.samza.system.kafka.BrokerProxy.org$apache$samza$system$kafka$BrokerProxy$$fetchMessages(BrokerProxy.scala:179) > at > org.apache.samza.system.kafka.BrokerProxy$$anon$1$$anonfun$run$1.apply(BrokerProxy.scala:147) > at > org.apache.samza.system.kafka.BrokerProxy$$anon$1$$anonfun$run$1.apply(BrokerProxy.scala:134) > at > org.apache.samza.util.ExponentialSleepStrategy.run(ExponentialSleepStrategy.scala:82) > at > org.apache.samza.system.kafka.BrokerProxy$$anon$1.run(BrokerProxy.scala:133) > at java.lang.Thread.run(Thread.java:745) >
signature.asc
Description: Message signed with OpenPGP using GPGMail
