Mailing-List: contact commits-help@beam.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@beam.apache.org
Date: Mon, 12 Jun 2017 14:17:00 +0000 (UTC)
From: "Aviem Zur (JIRA)" <jira@apache.org>
To: commits@beam.apache.org
Message-ID: <JIRA.13077255.1496672829000.1710.1497277020053@Atlassian.JIRA>
In-Reply-To: <JIRA.13077255.1496672829000@Atlassian.JIRA>
References: <JIRA.13077255.1496672829000@Atlassian.JIRA> <JIRA.13077255.1496672829774@jira-lw-us.apache.org>
Subject: [jira] [Assigned] (BEAM-2409) Spark runner produces exactly twice
 the number of results in streaming mode when use triggers to re-window
 results on global window.
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: quoted-printable
archived-at: Mon, 12 Jun 2017 14:17:03 -0000


     [ https://issues.apache.org/jira/browse/BEAM-2409?page=3Dcom.atlassian=
.jira.plugin.system.issuetabpanels:all-tabpanel ]

Aviem Zur reassigned BEAM-2409:
-------------------------------

    Assignee: Amit Sela  (was: Aviem Zur)

> Spark runner produces exactly twice the number of results in streaming mo=
de when use triggers to re-window results on global window.
> -------------------------------------------------------------------------=
-----------------------------------------------------------
>
>                 Key: BEAM-2409
>                 URL: https://issues.apache.org/jira/browse/BEAM-2409
>             Project: Beam
>          Issue Type: Bug
>          Components: runner-spark
>    Affects Versions: 2.0.0
>            Reporter: Isma=C3=ABl Mej=C3=ADa
>            Assignee: Amit Sela
>
> This can be tested with Nexmark query 6. Sorry I don=E2=80=99t have a sma=
ller test case than this, but I think the part of the pipeline that produce=
s the result is this one.
> {code:java}
>         .apply(
>             Window.<KV<Long, Bid>>into(new GlobalWindows())
>                 .triggering(Repeatedly.forever(AfterPane.elementCountAtLe=
ast(1)))
>                 .accumulatingFiredPanes()
>                 .withAllowedLateness(Duration.ZERO))
> {code}


--
This message was sent by Atlassian JIRA
(v6.4.14#64029)