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 5440C200BA3 for ; Thu, 20 Oct 2016 23:49:45 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 52D98160ACC; Thu, 20 Oct 2016 21:49:45 +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 9AAA3160AF2 for ; Thu, 20 Oct 2016 23:49:44 +0200 (CEST) Received: (qmail 30266 invoked by uid 500); 20 Oct 2016 21:49:43 -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 30257 invoked by uid 99); 20 Oct 2016 21:49:43 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 20 Oct 2016 21:49:43 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id 6C49EC195E for ; Thu, 20 Oct 2016 21:49:43 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -7.019 X-Spam-Level: X-Spam-Status: No, score=-7.019 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=-2.999] autolearn=disabled Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id 1W05KwTfDz-b for ; Thu, 20 Oct 2016 21:49:43 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with SMTP id A05525F39A for ; Thu, 20 Oct 2016 21:49:42 +0000 (UTC) Received: (qmail 9787 invoked by uid 99); 20 Oct 2016 21:47:03 -0000 Received: from arcas.apache.org (HELO arcas) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 20 Oct 2016 21:47:03 +0000 Received: from arcas.apache.org (localhost [127.0.0.1]) by arcas (Postfix) with ESMTP id 822832C0D54 for ; Thu, 20 Oct 2016 21:47:03 +0000 (UTC) Date: Thu, 20 Oct 2016 21:47:03 +0000 (UTC) From: "Daniel Halperin (JIRA)" To: commits@beam.incubator.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Closed] (BEAM-235) Remove streaming flag MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Thu, 20 Oct 2016 21:49:45 -0000 [ https://issues.apache.org/jira/browse/BEAM-235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-235. -------------------------------- > 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 > Fix For: 0.2.0-incubating > > > 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)