[
https://issues.apache.org/jira/browse/BEAM-5850?focusedWorklogId=168558&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-168558
]
ASF GitHub Bot logged work on BEAM-5850:
----------------------------------------
Author: ASF GitHub Bot
Created on: 21/Nov/18 22:41
Start Date: 21/Nov/18 22:41
Worklog Time Spent: 10m
Work Description: ajamato commented on issue #6786: [BEAM-5850] Add
BeamFnDataReceiver and make process, finish and start run on the same thread to
support metrics.
URL: https://github.com/apache/beam/pull/6786#issuecomment-440834398
I ran this failing test 50 times on master, and I am seeing several failures
with a TestTimedOutException
It seems that it is failing on master with a high rate of flakeyness
Here is a dump of a grep over the logs and a few build scan links with the
same issue
https://scans.gradle.com/s/hzu3bojfdbd5s
https://scans.gradle.com/s/txhyj6acebkko
https://scans.gradle.com/s/nhju5jthjbdds
org.junit.runners.model.TestTimedOutException: test timed out after 60000
milliseconds
at java.lang.ClassLoader.findBootstrapClass(Native Method)
at java.lang.ClassLoader.findBootstrapClassOrNull(ClassLoader.java:1015)
at java.lang.ClassLoader.loadClass(ClassLoader.java:413)
at java.lang.ClassLoader.loadClass(ClassLoader.java:411)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:339)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:13)
at org.junit.Assert.assertThat(Assert.java:956)
at org.junit.Assert.assertThat(Assert.java:923)
at
org.apache.beam.runners.flink.PortableTimersExecutionTest.testTimerExecution(PortableTimersExecutionTest.java:191)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at
org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:298)
at
org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:292)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.lang.Thread.run(Thread.java:748)
/usr/local/google/home/ajamato/out_queueing_10.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_11.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_12.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_14.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_15.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_16.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_19.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:189
/usr/local/google/home/ajamato/out_queueing_1.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_20.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_21.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_22.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_23.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_24.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_25.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_26.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:189
/usr/local/google/home/ajamato/out_queueing_26.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:189
/usr/local/google/home/ajamato/out_queueing_27.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_28.txt:[TaskExecutorLocalStateStoresManager
shutdown hook] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_29.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_2.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_30.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:189
/usr/local/google/home/ajamato/out_queueing_31.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_32.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_33.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_34.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_36.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_37.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_38.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_39.txt:
org.junit.runners.model.TestTimedOutException
/usr/local/google/home/ajamato/out_queueing_3.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_41.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_43.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:189
/usr/local/google/home/ajamato/out_queueing_44.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_46.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:189
/usr/local/google/home/ajamato/out_queueing_47.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_48.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_49.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_50.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_5.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_6.txt:
org.junit.runners.model.TestTimedOutException
/usr/local/google/home/ajamato/out_queueing_7.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_8.txt:[PermanentBlobCache
shutdown hook] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting
down BLOB cache org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:191
/usr/local/google/home/ajamato/out_queueing_9.txt:
org.junit.runners.model.TestTimedOutException at
PortableTimersExecutionTest.java:189
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
Issue Time Tracking
-------------------
Worklog Id: (was: 168558)
Time Spent: 9h 20m (was: 9h 10m)
> Make process, finish and start run on the same thread to support metrics.
> -------------------------------------------------------------------------
>
> Key: BEAM-5850
> URL: https://issues.apache.org/jira/browse/BEAM-5850
> Project: Beam
> Issue Type: New Feature
> Components: java-fn-execution
> Reporter: Alex Amato
> Assignee: Alex Amato
> Priority: Major
> Time Spent: 9h 20m
> Remaining Estimate: 0h
>
> Update BeamFnDataReceiver to place elements into a Queue and consumer then
> and call the element processing receiver in blockTillReadFinishes
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
