From jira-return-10084-archive-asf-public=cust-asf.ponee.io@kafka.apache.org Mon Feb 19 12:39:06 2018 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx-eu-01.ponee.io (Postfix) with SMTP id 22DF5180607 for ; Mon, 19 Feb 2018 12:39:05 +0100 (CET) Received: (qmail 71161 invoked by uid 500); 19 Feb 2018 11:39:05 -0000 Mailing-List: contact jira-help@kafka.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: jira@kafka.apache.org Delivered-To: mailing list jira@kafka.apache.org Received: (qmail 71150 invoked by uid 99); 19 Feb 2018 11:39:05 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 19 Feb 2018 11:39:05 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id C1E631A0010 for ; Mon, 19 Feb 2018 11:39:04 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -102.311 X-Spam-Level: X-Spam-Status: No, score=-102.311 tagged_above=-999 required=6.31 tests=[RCVD_IN_DNSWL_MED=-2.3, SPF_PASS=-0.001, T_RP_MATCHES_RCVD=-0.01, USER_IN_WHITELIST=-100] autolearn=disabled Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id 2B5qnvzc8Jfv for ; Mon, 19 Feb 2018 11:39:04 +0000 (UTC) Received: from mailrelay1-us-west.apache.org (mailrelay1-us-west.apache.org [209.188.14.139]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTP id 087505FB9E for ; Mon, 19 Feb 2018 11:39:01 +0000 (UTC) Received: from jira-lw-us.apache.org (unknown [207.244.88.139]) by mailrelay1-us-west.apache.org (ASF Mail Server at mailrelay1-us-west.apache.org) with ESMTP id C4637E0230 for ; Mon, 19 Feb 2018 11:39:00 +0000 (UTC) Received: from jira-lw-us.apache.org (localhost [127.0.0.1]) by jira-lw-us.apache.org (ASF Mail Server at jira-lw-us.apache.org) with ESMTP id 371AE21E59 for ; Mon, 19 Feb 2018 11:39:00 +0000 (UTC) Date: Mon, 19 Feb 2018 11:39:00 +0000 (UTC) From: "Damian Guy (JIRA)" To: jira@kafka.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Updated] (KAFKA-5313) Improve exception handling on coordinator interactions MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 [ https://issues.apache.org/jira/browse/KAFKA-5313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5313: ------------------------------ Fix Version/s: (was: 1.1.0) > Improve exception handling on coordinator interactions > ------------------------------------------------------ > > Key: KAFKA-5313 > URL: https://issues.apache.org/jira/browse/KAFKA-5313 > Project: Kafka > Issue Type: Sub-task > Components: streams > Affects Versions: 0.11.0.0 > Reporter: Eno Thereska > Assignee: Matthias J. Sax > Priority: Major > > Exceptions during assignment of tasks are caught in ConsumerCoordinator.java and streams becomes aware of them during the StreamThread.onPartitionsAssigned() and StreamThread.onPartitionsRevoked() methods. Eventually these exceptions go through StreamThread.pollRequests() all the way up to StreamThread.runLoop() and will halt the stream thread that is processing these exceptions. Other stream threads may continue processing, however it is likely they will experience problems too soon after. > Exceptions here include LockExceptions that are thrown if tasks cannot use a particular directory due to previous tasks not releasing locks on them during reassignment. -- This message was sent by Atlassian JIRA (v7.6.3#76005)