You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/30 13:27:00 UTC
[jira] [Created] (FLINK-11041)
ReinterpretDataStreamAsKeyedStreamITCase.testReinterpretAsKeyedStream
failed on Travis
Till Rohrmann created FLINK-11041:
-------------------------------------
Summary: 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
Fix For: 1.8.0
{{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)