[
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)
