[jira] [Closed] (FLINK-11041) ReinterpretDataStreamAsKeyedStreamITCase.testReinterpretAsKeyedStream failed on Travis

["Till Rohrmann (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-11041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Till Rohrmann closed FLINK-11041.
---------------------------------
       Resolution: Fixed
    Fix Version/s: 1.7.1
                   1.6.3

Fixed via
1.8.0: https://github.com/apache/flink/commit/70b2029f8a3d4ca2d3cb7bd7fddac9bb5b3e8f07
1.7.1: https://github.com/apache/flink/commit/ae2c29e234ea19387f88d070739168e553bcd400
1.6.3: https://github.com/apache/flink/commit/d6926664daed100fdefae0b875b5e4a291a0193b

> ReinterpretDataStreamAsKeyedStreamITCase.testReinterpretAsKeyedStream failed on Travis
> --------------------------------------------------------------------------------------
>
>                 Key: FLINK-11041
>                 URL: https://issues.apache.org/jira/browse/FLINK-11041
>             Project: Flink
>          Issue Type: Bug
>          Components: Tests
>    Affects Versions: 1.8.0
>            Reporter: Till Rohrmann
>            Assignee: Stefan Richter
>            Priority: Critical
>              Labels: pull-request-available, test-stability
>             Fix For: 1.6.3, 1.8.0, 1.7.1
>
>
> {{ReinterpretDataStreamAsKeyedStreamITCase.testReinterpretAsKeyedStream}} failed on Travis: 
> https://api.travis-ci.org/v3/job/461707550/log.txt
> https://travis-ci.org/apache/flink/jobs/461707550
> It seems that the test job is producing wrong results:
> {code}
> testReinterpretAsKeyedStream(org.apache.flink.streaming.api.datastream.ReinterpretDataStreamAsKeyedStreamITCase)  Time elapsed: 8.357 sec  <<< ERROR!
> org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
> 	at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:146)
> 	at org.apache.flink.runtime.minicluster.MiniCluster.executeJobBlocking(MiniCluster.java:647)
> 	at org.apache.flink.streaming.api.environment.LocalStreamEnvironment.execute(LocalStreamEnvironment.java:123)
> 	at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1510)
> 	at org.apache.flink.streaming.api.datastream.ReinterpretDataStreamAsKeyedStreamITCase.testReinterpretAsKeyedStream(ReinterpretDataStreamAsKeyedStreamITCase.java:107)
> Caused by: java.lang.AssertionError: expected:<300> but was:<301>
> 	at org.junit.Assert.fail(Assert.java:88)
> 	at org.junit.Assert.failNotEquals(Assert.java:834)
> 	at org.junit.Assert.assertEquals(Assert.java:645)
> 	at org.junit.Assert.assertEquals(Assert.java:631)
> 	at org.apache.flink.streaming.api.datastream.ReinterpretDataStreamAsKeyedStreamITCase$ValidatingSink.close(ReinterpretDataStreamAsKeyedStreamITCase.java:295)
> 	at org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:43)
> 	at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.close(AbstractUdfStreamOperator.java:109)
> 	at org.apache.flink.streaming.runtime.tasks.StreamTask.closeAllOperators(StreamTask.java:442)
> 	at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:317)
> 	at org.apache.flink.runtime.taskmanager.Task.run(Task.java:704)
> 	at java.lang.Thread.run(Thread.java:748)
> {code}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)