You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/05/19 11:12:00 UTC
[jira] [Issue Comment Deleted] (FLINK-17806)
CollectSinkFunctionTest.testCheckpointedFunction fails with expected:<50>
but was:<0>
[ https://issues.apache.org/jira/browse/FLINK-17806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Caizhi Weng updated FLINK-17806:
--------------------------------
Comment: was deleted
(was: This is due to the port reuse. See this [stack overflow question|https://stackoverflow.com/questions/61848302/how-to-disable-port-reuse-when-binding-serversocket-in-java8].
I actually have no idea how to solve this in Java8. To just prevent the tests from failing we can bind the testing TM with loopback address, but for users who do not bind their TMs, with very small probability they'll also meet this problem.
I'll fix the tests immediately. Maybe we'll need to change the communication method from sockets to RPC calls one day.)
> CollectSinkFunctionTest.testCheckpointedFunction fails with expected:<50> but was:<0>
> --------------------------------------------------------------------------------------
>
> Key: FLINK-17806
> URL: https://issues.apache.org/jira/browse/FLINK-17806
> Project: Flink
> Issue Type: Bug
> Components: API / DataStream
> Affects Versions: 1.11.0
> Reporter: Robert Metzger
> Assignee: Caizhi Weng
> Priority: Blocker
> Labels: test-stability
> Fix For: 1.11.0
>
>
> CI https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=1793&view=logs&j=0da23115-68bb-5dcd-192c-bd4c8adebde1&t=4ed44b66-cdd6-5dcf-5f6a-88b07dda665d
> {code}
> 2020-05-19T04:28:24.6400821Z [INFO] Running org.apache.flink.streaming.runtime.io.benchmark.StreamNetworkBroadcastThroughputBenchmarkTest
> 2020-05-19T04:28:25.7508457Z java.util.concurrent.TimeoutException
> 2020-05-19T04:28:25.7511469Z at java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1784)
> 2020-05-19T04:28:25.7512331Z at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928)
> 2020-05-19T04:28:25.7513238Z at org.apache.flink.streaming.api.operators.collect.CollectSinkFunctionTest.sendRequest(CollectSinkFunctionTest.java:391)
> 2020-05-19T04:28:25.7514280Z at org.apache.flink.streaming.api.operators.collect.CollectSinkFunctionTest.access$300(CollectSinkFunctionTest.java:60)
> 2020-05-19T04:28:25.7515499Z at org.apache.flink.streaming.api.operators.collect.CollectSinkFunctionTest$TestCollectRequestSender.sendRequest(CollectSinkFunctionTest.java:465)
> 2020-05-19T04:28:25.7516628Z at org.apache.flink.streaming.api.operators.collect.utils.TestCollectClient.run(TestCollectClient.java:77)
> 2020-05-19T04:28:25.7517231Z java.lang.InterruptedException
> 2020-05-19T04:28:25.7517907Z at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.reportInterruptAfterWait(AbstractQueuedSynchronizer.java:2014)
> 2020-05-19T04:28:25.7518816Z at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2048)
> 2020-05-19T04:28:25.7519745Z at org.apache.flink.streaming.api.operators.collect.CollectSinkFunction.invoke(CollectSinkFunction.java:246)
> 2020-05-19T04:28:25.7520773Z at org.apache.flink.streaming.api.operators.collect.CollectSinkFunctionTest$CheckpointedDataFeeder.run(CollectSinkFunctionTest.java:574)
> 2020-05-19T04:28:25.7600809Z [ERROR] Tests run: 4, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 53.526 s <<< FAILURE! - in org.apache.flink.streaming.api.operators.collect.CollectSinkFunctionTest
> 2020-05-19T04:28:25.7602305Z [ERROR] testCheckpointedFunction(org.apache.flink.streaming.api.operators.collect.CollectSinkFunctionTest) Time elapsed: 26.262 s <<< FAILURE!
> 2020-05-19T04:28:25.7603126Z java.lang.AssertionError: expected:<50> but was:<0>
> 2020-05-19T04:28:25.7603600Z at org.junit.Assert.fail(Assert.java:88)
> 2020-05-19T04:28:25.7604100Z at org.junit.Assert.failNotEquals(Assert.java:834)
> 2020-05-19T04:28:25.7604810Z at org.junit.Assert.assertEquals(Assert.java:645)
> 2020-05-19T04:28:25.7605373Z at org.junit.Assert.assertEquals(Assert.java:631)
> 2020-05-19T04:28:25.7606127Z at org.apache.flink.streaming.api.operators.collect.CollectSinkFunctionTest.assertResultsEqual(CollectSinkFunctionTest.java:430)
> 2020-05-19T04:28:25.7607201Z at org.apache.flink.streaming.api.operators.collect.CollectSinkFunctionTest.assertResultsEqualAfterSort(CollectSinkFunctionTest.java:441)
> 2020-05-19T04:28:25.7608296Z at org.apache.flink.streaming.api.operators.collect.CollectSinkFunctionTest.testCheckpointedFunction(CollectSinkFunctionTest.java:321)
> 2020-05-19T04:28:25.7609371Z at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2020-05-19T04:28:25.7610031Z at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2020-05-19T04:28:25.7610819Z at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2020-05-19T04:28:25.7611665Z at java.lang.reflect.Method.invoke(Method.java:498)
> 2020-05-19T04:28:25.7612348Z at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
> 2020-05-19T04:28:25.7613094Z at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> 2020-05-19T04:28:25.7613785Z at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
> 2020-05-19T04:28:25.7614493Z at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> 2020-05-19T04:28:25.7615370Z at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
> 2020-05-19T04:28:25.7616067Z at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
> 2020-05-19T04:28:25.7616711Z at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
> 2020-05-19T04:28:25.7617574Z at org.junit.rules.RunRules.evaluate(RunRules.java:20)
> 2020-05-19T04:28:25.7618159Z at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
> 2020-05-19T04:28:25.7618789Z at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
> 2020-05-19T04:28:25.7619486Z at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
> 2020-05-19T04:28:25.7620134Z at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
> 2020-05-19T04:28:25.7620788Z at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
> 2020-05-19T04:28:25.7621528Z at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
> 2020-05-19T04:28:25.7622174Z at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
> 2020-05-19T04:28:25.7622835Z at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
> 2020-05-19T04:28:25.7623473Z at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
> 2020-05-19T04:28:25.7624165Z at org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:365)
> 2020-05-19T04:28:25.7625144Z at org.apache.maven.surefire.junit4.JUnit4Provider.executeWithRerun(JUnit4Provider.java:273)
> 2020-05-19T04:28:25.7625939Z at org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:238)
> 2020-05-19T04:28:25.7626730Z at org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:159)
> 2020-05-19T04:28:25.7627545Z at org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:384)
> 2020-05-19T04:28:25.7628322Z at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:345)
> 2020-05-19T04:28:25.7629082Z at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:126)
> 2020-05-19T04:28:25.7629737Z at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:418)
> 2020-05-19T04:28:25.7630123Z
> 2020-05-19T04:28:26.3490861Z [INFO] Running org.apache.flink.streaming.runtime.io.benchmark.StreamNetworkThroughputBenchmarkTest
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)