Mailing-List: contact issues-help@flink.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@flink.apache.org
Received-SPF: pass (athena.apache.org: message received from 54.164.171.186
 which is an MX secondary for issues@flink.apache.org)
Date: Mon, 4 May 2015 08:21:06 +0000 (UTC)
From: "ASF GitHub Bot (JIRA)" <jira@apache.org>
To: issues@flink.incubator.apache.org
Message-ID: <JIRA.12776552.1424469371000.68235.1430727666323@Atlassian.JIRA>
In-Reply-To: <JIRA.12776552.1424469371000@Atlassian.JIRA>
References: <JIRA.12776552.1424469371000@Atlassian.JIRA>
 <JIRA.12776552.1424469371945@arcas>
Subject: [jira] [Commented] (FLINK-1595) Add a complex integration test for
 Streaming API
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: quoted-printable


    [ https://issues.apache.org/jira/browse/FLINK-1595?page=3Dcom.atlassian=
.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=3D1452=
6404#comment-14526404 ]=20

ASF GitHub Bot commented on FLINK-1595:
---------------------------------------

Github user mbalassi commented on the pull request:

    https://github.com/apache/flink/pull/520#issuecomment-98628873
 =20
    Hey,
   =20
    Sorry for not attending to this for a long time. It needed a rebase for=
 the API of the chaining. Now that I have updated that the test throws the =
following NPE:
   =20
    Caused by: java.lang.NullPointerException
    =09at org.apache.flink.streaming.api.complex.ComplexIntegrationTest$MyT=
imestamp.getTimestamp(ComplexIntegrationTest.java:659)
    =09at org.apache.flink.streaming.api.complex.ComplexIntegrationTest$MyT=
imestamp.getTimestamp(ComplexIntegrationTest.java:654)
    =09at org.apache.flink.streaming.api.windowing.helper.TimestampWrapper.=
getTimestamp(TimestampWrapper.java:34)
    =09at org.apache.flink.streaming.api.windowing.windowbuffer.SlidingTime=
PreReducer.afterEmit(SlidingTimePreReducer.java:71)
    =09at org.apache.flink.streaming.api.windowing.windowbuffer.SlidingPreR=
educer.emitWindow(SlidingPreReducer.java:59)
    =09... 7 more
   =20
    It would be nice if we could separate the individual tests, so it is ea=
sier to track an exception like that. Maybe a solution similar to `Miltiple=
ProgramsTestBase` for streaming would do the trick.
   =20
    @szape, could you please do an update with these, then I'd merge it asa=
p so that it does not get outdated again. Thanks.


> Add a complex integration test for Streaming API
> ------------------------------------------------
>
>                 Key: FLINK-1595
>                 URL: https://issues.apache.org/jira/browse/FLINK-1595
>             Project: Flink
>          Issue Type: Task
>          Components: Streaming
>            Reporter: Gyula Fora
>            Assignee: P=C3=A9ter Szab=C3=B3
>              Labels: Starter
>
> The streaming tests currently lack a sophisticated integration test that =
would test many api features at once.=20
> This should include different merging, partitioning, grouping, aggregatio=
n types, as well as windowing and connected operators.
> The results should be tested for correctness.
> A test like this would help identifying bugs that are hard to detect by u=
nit-tests.


--
This message was sent by Atlassian JIRA
(v6.3.4#6332)