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 529B0200BF8 for ; Fri, 13 Jan 2017 11:27:23 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 51292160B3F; Fri, 13 Jan 2017 10:27:23 +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 9DD06160B32 for ; Fri, 13 Jan 2017 11:27:22 +0100 (CET) Received: (qmail 69583 invoked by uid 500); 13 Jan 2017 10:27:21 -0000 Mailing-List: contact dev-help@apex.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@apex.apache.org Delivered-To: mailing list dev@apex.apache.org Received: (qmail 69571 invoked by uid 99); 13 Jan 2017 10:27:21 -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, 13 Jan 2017 10:27:21 +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 E032F1A0074 for ; Fri, 13 Jan 2017 10:27:20 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.479 X-Spam-Level: ** X-Spam-Status: No, score=2.479 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, HTML_MESSAGE=2, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RCVD_IN_SORBS_SPAM=0.5, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd2-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=datatorrent-com.20150623.gappssmtp.com Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id ZjX47uAhz02b for ; Fri, 13 Jan 2017 10:27:19 +0000 (UTC) Received: from mail-oi0-f51.google.com (mail-oi0-f51.google.com [209.85.218.51]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTPS id 3EF145F29A for ; Fri, 13 Jan 2017 10:27:19 +0000 (UTC) Received: by mail-oi0-f51.google.com with SMTP id u143so52577486oif.3 for ; Fri, 13 Jan 2017 02:27:19 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=datatorrent-com.20150623.gappssmtp.com; s=20150623; h=mime-version:from:date:message-id:subject:to; bh=cLYWbpBCpGvI5tTM5dJ1x57CY4VYYFLo5a8rHpop12w=; b=FAYNs0UoBCHEf90vTaa9y7WYhsHKgJrmGlbM6ME41Tx1u4ekD2EFdLjGxE3tWcmbcV eVSZJXNKTK3drZGg1kpJWrRe6VJK2dlvXrtaVOwLZqyAXEzP7gOxYTRl4m3EKG16ACV8 bVSryGzYlCa6vlcHn27QFexwySmJcj4oKx95f9lWmM68hwfglEJk9oNmWOLSdFI9pSG+ oyogPqvdeOtJc68YitmMq69IQllYLygjadIm5g7HfxFTklFFUdECUxBwV1efO/2rMs0J Hb9sLFKYpmxQoycq7w8S947bl9XsjwfnXZQ1/36nYwL4Sp4UQ4cOOS18IP84PueFtXF/ 0MHQ== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:mime-version:from:date:message-id:subject:to; bh=cLYWbpBCpGvI5tTM5dJ1x57CY4VYYFLo5a8rHpop12w=; b=rQRIFUf4WVHOPyIaOwY3hcANDn44bRx2PxN2JPsO40zY+XLonrLh0pWrUryZzBZ9ic RMvtTFtsG4pSZJNhfouatjTihpmphW+Ji+Lp/56UzPpI4O8CPrAJuzlRoFK6auygbaEG WUyA9Qj79vkDLKf4jys+2vmWDLUUFHkEhtUUmK6CbyJ+vygznHRatcGX68HKJjAP5zyl EYtsCfMNe0IMzmI9nzD0NCt4iQsBZ4lXM5zgjbVILWY2p9g7b1iJ6333lqdJiuL/AA7R dIQYgobr6/asltv5bsIPYLayZo8ugWxPb+5ombCYbfcLidfSoIAaTb+jbQQLCR8x4Je1 icwg== X-Gm-Message-State: AIkVDXKYNBVB0pv5JPUWq936W6Bxw3nNt/7/aeWV4MR4lBq+xpAZYXk4Cgaa16zQqTt4rQ5FESDlKTeC8dSqr+bO X-Received: by 10.202.8.71 with SMTP id 68mr7320436oii.59.1484303238455; Fri, 13 Jan 2017 02:27:18 -0800 (PST) MIME-Version: 1.0 Received: by 10.182.24.196 with HTTP; Fri, 13 Jan 2017 02:27:18 -0800 (PST) From: Hitesh Kapoor Date: Fri, 13 Jan 2017 15:57:18 +0530 Message-ID: Subject: APEXMALHAR-2382 User needs to create dt_meta table while using JdbcPOJOInsertOutputOperator To: dev@apex.apache.org Content-Type: multipart/alternative; boundary=94eb2c12f8b4446f7b0545f747d0 archived-at: Fri, 13 Jan 2017 10:27:23 -0000 --94eb2c12f8b4446f7b0545f747d0 Content-Type: text/plain; charset=UTF-8 Hi All, Currently to use JdbcPOJOInsertOutputOperator, user needs to create "dt_meta" table to enforce exactly-once processing semantic. If the user fails to create this table before launching the application an exception is thrown. To handle this scenario we can automate the process of creating this table, assuming the user has the appropriate privileges. The problem with this approach is that it may not be a very good idea to modify user's database automatically , also if the user doesn't has the appropriate privileges it will eventually throw an exception (however a different exception). So I need your opinion if we should automate the creation of this internal table (if it doesn't exists) or continue with the existing behaviour or anything else. Regards, Hitesh --94eb2c12f8b4446f7b0545f747d0--