failed pipeline which contains global stores hangs on error shutdown until shutdown timeout occurs

amient / affinity

Library and a Framework for building fast, scalable, fault-tolerant Data APIs based on Akka, Avro, ZooKeeper and Kafka

Apache License 2.0

26 stars 4 forks source link

failed pipeline which contains global stores hangs on error shutdown until shutdown timeout occurs #257

Open michal-harish opened 5 years ago

michal-harish commented 5 years ago

this could be simply caused by the underlying failed futures in the input processor work waiting to be completed - however if they failed they should be completed