beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Eugene Kirpichov (JIRA)" <j...@apache.org>
Subject [jira] [Created] (BEAM-3269) Occasional ClassCastException in ParDoTranslatorTest.testAssertionFailure
Date Tue, 28 Nov 2017 23:56:00 GMT
Eugene Kirpichov created BEAM-3269:
--------------------------------------

             Summary: 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
            Assignee: Thomas Weise


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
(v6.4.14#64029)

Mime
View raw message