File tree Expand file tree Collapse file tree
sdks/java/harness/src/main/java/org/apache/beam/fn/harness Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -1180,18 +1180,18 @@ private HandlesSplits.SplitResult trySplitForElementAndRestriction(
11801180 splitResult .getWindowSplit (),
11811181 PTransformTranslation .SPLITTABLE_PROCESS_SIZED_ELEMENTS_AND_RESTRICTIONS_URN
11821182 + "/GetSize" );
1183+ Coder fullInputCoder = WindowedValues .getFullCoder (inputCoder , windowCoder );
1184+ return constructSplitResult (
1185+ windowedSplitResult ,
1186+ null ,
1187+ fullInputCoder ,
1188+ initialWatermark ,
1189+ watermarkAndState ,
1190+ pTransformId ,
1191+ mainInputId ,
1192+ pTransform .getOutputsMap ().keySet (),
1193+ resumeDelay );
11831194 }
1184- Coder fullInputCoder = WindowedValues .getFullCoder (inputCoder , windowCoder );
1185- return constructSplitResult (
1186- windowedSplitResult ,
1187- null ,
1188- fullInputCoder ,
1189- initialWatermark ,
1190- watermarkAndState ,
1191- pTransformId ,
1192- mainInputId ,
1193- pTransform .getOutputsMap ().keySet (),
1194- resumeDelay );
11951195 }
11961196
11971197 private <K > void processTimer (
You can’t perform that action at this time.
0 commit comments