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

["Kenneth Knowles (Jira)" <ji...@apache.org>]

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

Kenneth Knowles updated BEAM-3269:
----------------------------------
    Resolution: Fixed
        Status: Resolved  (was: Resolved)

Hello! Due to a bug in our Jira configuration, this issue had status:Resolved but resolution:Unresolved.

I am bulk editing these issues to have resolution:Fixed

If a different resolution is appropriate, please change it. To do this, click the "Resolve" button (you can do this even for closed issues) and set the Resolution field to the right value.

> 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)