[ https://issues.apache.org/jira/browse/BEAM-6354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16746906#comment-16746906 ]
Ruoyun Huang commented on BEAM-6354: ------------------------------------ If I understand it correctly, my input is bounded, thus maybe not relevant? My code is like this: final PCollectionView<Integer> view = pipeline.apply("Create47", Create.of(47)).apply(View.asSingleton()); I was tracing down the code path based on your suggestion. I am 90% sure that the reason for empty output is trigger not filed (evidence being, onTrigger() function never been executed). > Hanging BoundedReadFromUnboundedSourceTest#testTimeBound and > SplittableDoFnTest#testLateData > -------------------------------------------------------------------------------------------- > > Key: BEAM-6354 > URL: https://issues.apache.org/jira/browse/BEAM-6354 > Project: Beam > Issue Type: Bug > Components: sdk-java-core > Reporter: Gleb Kanterov > Assignee: Kenneth Knowles > Priority: Major > Fix For: 2.10.0 > > > It seems that they have a similar root cause because both of them use > unbounded streams. -- This message was sent by Atlassian JIRA (v7.6.3#76005)