[
https://issues.apache.org/jira/browse/BEAM-3706?focusedWorklogId=84514&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-84514
]
ASF GitHub Bot logged work on BEAM-3706:
----------------------------------------
Author: ASF GitHub Bot
Created on: 26/Mar/18 19:30
Start Date: 26/Mar/18 19:30
Worklog Time Spent: 10m
Work Description: youngoli commented on a change in pull request #4924:
[BEAM-3706] Removing side inputs from CombinePayload proto.
URL: https://github.com/apache/beam/pull/4924#discussion_r177207394
##########
File path:
runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkBatchTransformTranslators.java
##########
@@ -396,12 +396,8 @@ public void translateNode(
// construct a map from side input to WindowingStrategy so that
// the DoFn runner can map main-input windows to side input windows
Map<PCollectionView<?>, WindowingStrategy<?, ?>> sideInputStrategies =
new HashMap<>();
- List<PCollectionView<?>> sideInputs;
- try {
- sideInputs =
CombineTranslation.getSideInputs(context.getCurrentTransform());
- } catch (IOException e) {
- throw new RuntimeException(e);
- }
+ List<PCollectionView<?>> sideInputs = new ArrayList<>();
Review comment:
Removed all references in this function and left TODOs in
FlinkReduceFunction and FlinkPartialReduceFunction.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
Issue Time Tracking
-------------------
Worklog Id: (was: 84514)
Time Spent: 2h (was: 1h 50m)
> Update CombinePayload to improved model for Portability
> -------------------------------------------------------
>
> Key: BEAM-3706
> URL: https://issues.apache.org/jira/browse/BEAM-3706
> Project: Beam
> Issue Type: Sub-task
> Components: beam-model
> Reporter: Daniel Oliveira
> Assignee: Daniel Oliveira
> Priority: Minor
> Labels: portability
> Time Spent: 2h
> Remaining Estimate: 0h
>
> This will mean changing the proto definition in beam_runner_api, most likely
> trimming out fields that are no longer necessary and adding any new ones that
> could be useful. The majority of work will probably be in investigating if
> some existing fields can actually be removed (SideInputs and Parameters for
> example).
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
