[ https://issues.apache.org/jira/browse/BEAM-10016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113474#comment-17113474 ]
Brian Hulette commented on BEAM-10016: -------------------------------------- Removing fix version 2.22.0 since, as Kyle indicated, this test was only added recently (https://github.com/apache/beam/pull/11666) so it's likely not a regression or release blocker. > Flink postcommits failing testFlattenWithDifferentInputAndOutputCoders2 > ----------------------------------------------------------------------- > > Key: BEAM-10016 > URL: https://issues.apache.org/jira/browse/BEAM-10016 > Project: Beam > Issue Type: Bug > Components: test-failures > Reporter: Kyle Weaver > Assignee: Maximilian Michels > Priority: P2 > > Both beam_PostCommit_Java_PVR_Flink_Batch and > beam_PostCommit_Java_PVR_Flink_Streaming are failing newly added test > org.apache.beam.sdk.transforms.FlattenTest.testFlattenWithDifferentInputAndOutputCoders2. > SEVERE: Error in task code: CHAIN MapPartition (MapPartition at [6]{Values, > FlatMapElements, PAssert$0}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map > (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: > PAssert$0/GroupGlobally/GatherAllOutputs/GroupByKey) -> Map (Key Extractor) > (2/2) java.lang.ClassCastException: org.apache.beam.sdk.values.KV cannot be > cast to [B > at > org.apache.beam.sdk.coders.ByteArrayCoder.encode(ByteArrayCoder.java:41) > at > org.apache.beam.sdk.coders.LengthPrefixCoder.encode(LengthPrefixCoder.java:56) > at org.apache.beam.sdk.coders.Coder.encode(Coder.java:136) > at > org.apache.beam.sdk.util.WindowedValue$FullWindowedValueCoder.encode(WindowedValue.java:590) > at > org.apache.beam.sdk.util.WindowedValue$FullWindowedValueCoder.encode(WindowedValue.java:581) > at > org.apache.beam.sdk.util.WindowedValue$FullWindowedValueCoder.encode(WindowedValue.java:541) > at > org.apache.beam.sdk.fn.data.BeamFnDataSizeBasedBufferingOutboundObserver.accept(BeamFnDataSizeBasedBufferingOutboundObserver.java:109) > at > org.apache.beam.runners.fnexecution.control.SdkHarnessClient$CountingFnDataReceiver.accept(SdkHarnessClient.java:667) > at > org.apache.beam.runners.flink.translation.functions.FlinkExecutableStageFunction.processElements(FlinkExecutableStageFunction.java:271) > at > org.apache.beam.runners.flink.translation.functions.FlinkExecutableStageFunction.mapPartition(FlinkExecutableStageFunction.java:203) > at > org.apache.flink.runtime.operators.MapPartitionDriver.run(MapPartitionDriver.java:103) > at org.apache.flink.runtime.operators.BatchTask.run(BatchTask.java:504) > at > org.apache.flink.runtime.operators.BatchTask.invoke(BatchTask.java:369) > at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:705) > at org.apache.flink.runtime.taskmanager.Task.run(Task.java:530) > at java.lang.Thread.run(Thread.java:748) -- This message was sent by Atlassian Jira (v8.3.4#803005)