acrites commented on issue #38094:
URL: https://github.com/apache/beam/issues/38094#issuecomment-4292309844
Here's the StreamingDataflowWorkerTest failure I found from the first run
you posted. It's in `testBasicHarness`:
```
java.lang.AssertionError: Should have received 2000 more commits beyond 0
commits already seen, but after 10s have only seen 1917. Exceptions seen: []
at org.junit.Assert.fail(Assert.java:89)
at org.junit.Assert.assertTrue(Assert.java:42)
at org.junit.Assert.assertFalse(Assert.java:65)
at
org.apache.beam.runners.dataflow.worker.FakeWindmillServer.waitForAndGetCommits(FakeWindmillServer.java:502)
at
org.apache.beam.runners.dataflow.worker.StreamingDataflowWorkerTest.testBasicHarness(StreamingDataflowWorkerTest.java:958)
at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:566)
at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at
org.apache.beam.runners.dataflow.worker.StreamingDataflowWorkerTest$BlockingFn$1.evaluate(StreamingDataflowWorkerTest.java:4492)
at org.junit.rules.Verifier$1.evaluate(Verifier.java:35)
at
org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:288)
at
org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:282)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.lang.Thread.run(Thread.java:829)
```
I wonder if it's just flaky in that we need to wait longer than 10s for all
2000 commits to come in.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
