Return-Path: X-Original-To: apmail-beam-commits-archive@minotaur.apache.org Delivered-To: apmail-beam-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 2DB4819BFB for ; Thu, 28 Apr 2016 11:58:15 +0000 (UTC) Received: (qmail 33923 invoked by uid 500); 28 Apr 2016 11:58:15 -0000 Delivered-To: apmail-beam-commits-archive@beam.apache.org Received: (qmail 33871 invoked by uid 500); 28 Apr 2016 11:58:15 -0000 Mailing-List: contact commits-help@beam.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@beam.incubator.apache.org Delivered-To: mailing list commits@beam.incubator.apache.org Received: (qmail 33862 invoked by uid 99); 28 Apr 2016 11:58:15 -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; Thu, 28 Apr 2016 11:58:15 +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 AAF5F1A05FD for ; Thu, 28 Apr 2016 11:58:14 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -4.021 X-Spam-Level: X-Spam-Status: No, score=-4.021 tagged_above=-999 required=6.31 tests=[KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_DNSWL_HI=-5, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RP_MATCHES_RCVD=-0.001] autolearn=disabled Received: from mx2-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 pndT207-Dr_E for ; Thu, 28 Apr 2016 11:58:14 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx2-lw-us.apache.org (ASF Mail Server at mx2-lw-us.apache.org) with SMTP id 969845F256 for ; Thu, 28 Apr 2016 11:58:13 +0000 (UTC) Received: (qmail 33702 invoked by uid 99); 28 Apr 2016 11:58:13 -0000 Received: from arcas.apache.org (HELO arcas) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 28 Apr 2016 11:58:13 +0000 Received: from arcas.apache.org (localhost [127.0.0.1]) by arcas (Postfix) with ESMTP id D65432C1F5D for ; Thu, 28 Apr 2016 11:58:12 +0000 (UTC) Date: Thu, 28 Apr 2016 11:58:12 +0000 (UTC) From: "Maximilian Michels (JIRA)" To: commits@beam.incubator.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Created] (BEAM-235) Remove streaming flag MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 Maximilian Michels created BEAM-235: --------------------------------------- Summary: Remove streaming flag Key: BEAM-235 URL: https://issues.apache.org/jira/browse/BEAM-235 Project: Beam Issue Type: Improvement Components: runner-flink Reporter: Maximilian Michels The streaming flag of the Flink Runner should be removed in favor of an automated decision during translation to execute using either batch or streaming API. For example, if the user specified any unbounded sources, the program could be executed using the Flink streaming API. Otherwise, batch could be chosen. To do that, we need to get the batch execution on par with the streaming execution. The batch part misses windowing. -- This message was sent by Atlassian JIRA (v6.3.4#6332)