Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id B3709200CED for ; Fri, 18 Aug 2017 10:08:13 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id B1FCF16C1A6; Fri, 18 Aug 2017 08:08:13 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 0B79616C1B9 for ; Fri, 18 Aug 2017 10:08:12 +0200 (CEST) Received: (qmail 48430 invoked by uid 500); 18 Aug 2017 08:08:11 -0000 Mailing-List: contact dev-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list dev@flink.apache.org Received: (qmail 48409 invoked by uid 99); 18 Aug 2017 08:08:11 -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; Fri, 18 Aug 2017 08:08:11 +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 0B2F61A050A for ; Fri, 18 Aug 2017 08:08:11 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -100.002 X-Spam-Level: X-Spam-Status: No, score=-100.002 tagged_above=-999 required=6.31 tests=[RP_MATCHES_RCVD=-0.001, SPF_PASS=-0.001, 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 CN1samLYji67 for ; Fri, 18 Aug 2017 08:08:10 +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 B28E65F659 for ; Fri, 18 Aug 2017 08:08:09 +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 C1999E0DF4 for ; Fri, 18 Aug 2017 08:08:06 +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 4635625386 for ; Fri, 18 Aug 2017 08:08:03 +0000 (UTC) Date: Fri, 18 Aug 2017 08:08:03 +0000 (UTC) From: "Piotr Nowojski (JIRA)" To: dev@flink.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Created] (FLINK-7476) Try to recover from failure in TwoPhaseCommitSinkFunction.beginTransaction MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Fri, 18 Aug 2017 08:08:13 -0000 Piotr Nowojski created FLINK-7476: ------------------------------------- Summary: Try to recover from failure in TwoPhaseCommitSinkFunction.beginTransaction Key: FLINK-7476 URL: https://issues.apache.org/jira/browse/FLINK-7476 Project: Flink Issue Type: Bug Components: Streaming Reporter: Piotr Nowojski Assignee: Piotr Nowojski Currently when using TwoPhaseCommitSinkFunction, if there is some intermittent failure in "beginTransaction", not only the snapshot that triggered this call fail, but also any subsequent write requests will fail also, rendering such sink unusable until application restart. This issue is in code that hasn't been released yet. -- This message was sent by Atlassian JIRA (v6.4.14#64029)