[
https://issues.apache.org/jira/browse/BEAM-6354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16749510#comment-16749510
]
Kenneth Knowles commented on BEAM-6354:
---------------------------------------
One the BoundedReadFromUnboundedSourceTest I noticed logs filled with
{code}
[direct-runner-worker] WARN org.apache.beam.sdk.util.MutationDetectors - Coder
of type class org.apache.beam.sdk.coders.KvCoder has a #structuralValue method
which does not return true when the encoding of the elements is equal. Element
KV{-1096158736,
Shard{source=org.apache.beam.sdk.io.BoundedReadFromUnboundedSourceTest$TestCountingSource@b310c3,
maxNumRecords=9223372036854775807, maxReadTime=PT0.200S}}
{code}
> 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)
