[jira] [Commented] (BEAM-3269) Occasional ClassCastException in ParDoTranslatorTest.testAssertionFailure

["Beam JIRA Bot (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/BEAM-3269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17174884#comment-17174884 ] 

Beam JIRA Bot commented on BEAM-3269:
-------------------------------------

This issue is P2 but has been unassigned without any comment for 60 days so it has been labeled "stale-P2". If this issue is still affecting you, we care! Please comment and remove the label. Otherwise, in 14 days the issue will be moved to P3.

Please see https://beam.apache.org/contribute/jira-priorities/ for a detailed explanation of what these priorities mean.


> Occasional ClassCastException in ParDoTranslatorTest.testAssertionFailure
> -------------------------------------------------------------------------
>
>                 Key: BEAM-3269
>                 URL: https://issues.apache.org/jira/browse/BEAM-3269
>             Project: Beam
>          Issue Type: Bug
>          Components: runner-apex
>            Reporter: Eugene Kirpichov
>            Priority: P2
>              Labels: stale-P2, stale-assigned
>
> A postcommit build failed: 
> https://builds.apache.org/job/beam_PostCommit_Java_MavenInstall/org.apache.beam$beam-runners-apex/5326/testReport/junit/org.apache.beam.runners.apex.translation/ParDoTranslatorTest/testAssertionFailure/
> because the following exception happened instead of the expected PAssert assertion failure exception:
> {code}
> 85212 [1/PAssert$2/GroupGlobally/Create.Values:ApexReadUnboundedInputOperator] INFO  com.datatorrent.stram.StramLocalCluster  - container-10 msg: Stopped running due to an exception. java.lang.ClassCastException: java.lang.String cannot be cast to org.apache.beam.sdk.values.KV
> 	at org.apache.beam.sdk.coders.KvCoder.encode(KvCoder.java:36)
> 	at org.apache.beam.sdk.util.WindowedValue$FullWindowedValueCoder.encode(WindowedValue.java:652)
> 	at org.apache.beam.sdk.util.WindowedValue$FullWindowedValueCoder.encode(WindowedValue.java:599)
> 	at org.apache.beam.runners.apex.translation.utils.ApexStreamTuple$ApexStreamTupleCoder.encode(ApexStreamTuple.java:179)
> 	at org.apache.beam.runners.apex.translation.utils.ApexStreamTuple$ApexStreamTupleCoder.encode(ApexStreamTuple.java:152)
> 	at org.apache.beam.runners.apex.translation.utils.CoderAdapterStreamCodec.toByteArray(CoderAdapterStreamCodec.java:61)
> 	at com.datatorrent.stram.stream.BufferServerPublisher.put(BufferServerPublisher.java:140)
> 	at com.datatorrent.api.DefaultOutputPort.emit(DefaultOutputPort.java:59)
> 	at org.apache.beam.runners.apex.translation.operators.ApexReadUnboundedInputOperator.emitTuples(ApexReadUnboundedInputOperator.java:157)
> 	at com.datatorrent.stram.engine.InputNode.run(InputNode.java:124)
> 	at com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1428)
> {code}
> I wasn't able to reproduce this issue by running the test locally >100 times, but it looks alarming nevertheless.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)