Hi everyone! I am running a windowed aggregation topology. But the topology restart for no reason. Has anyone met this problem? I am using netty for message transfer. I have tried version 0.9.0-rc3 and 0.9.2 and cannot find reason from logs. Can anyone help me? netty configuration in storm.yaml is
storm.messaging.transport: "backtype.storm.messaging.netty.Context" storm.messaging.netty.buffer_size: 419430400 storm.messaging.netty.server_worker_threads: 1 storm.messaging.netty.client_worker_threads: 1 storm.messaging.netty.buffer_size: 419430400 storm.messaging.netty.max_retries: 100 storm.messaging.netty.max_wait_ms: 1000 storm.messaging.netty.min_wait_ms: 10 topology.acker.executors: 20
