[ https://issues.apache.org/jira/browse/STORM-1928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15370913#comment-15370913 ]
ASF GitHub Bot commented on STORM-1928: --------------------------------------- Github user revans2 commented on the issue: https://github.com/apache/storm/pull/1526 The file without a license is external/storm-kafka-monitor/src/main/java/org/apache/storm/kafka/monitor/KafkaPartitionOffsetLag.java I'll file a separate JIRA for that. > ShellSpout should check heartbeat while ShellSpout is waiting for subprocess > to sync > ------------------------------------------------------------------------------------ > > Key: STORM-1928 > URL: https://issues.apache.org/jira/browse/STORM-1928 > Project: Apache Storm > Issue Type: Bug > Components: storm-multilang > Reporter: Jungtaek Lim > Assignee: Jungtaek Lim > Priority: Critical > > It affects Storm releases which are greater than 0.9.3 so I didn't set affect > version/s. All version lines are affected. > When nextTuple is not calling at any chances (max spout pending, backpressure > introduced at 1.0.0, and so on) multi-lang spout don't receive any message > from ShellSpout, thus no messages from multi-lang spout side. (because > multilang spout and ShellSpout communicates like ping-pong, unlike multilang > bolt and ShellBolt) > In result, no heartbeat is being marked, and finally raises subprocess > heartbeat timeout. -- This message was sent by Atlassian JIRA (v6.3.4#6332)