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

["Tyson Hamilton (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/BEAM-3269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Tyson Hamilton updated BEAM-3269:
---------------------------------
    Status: Resolved  (was: Open)

> 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: P3
>              Labels: 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)