[
https://issues.apache.org/jira/browse/FLINK-13764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang resolved FLINK-13764.
------------------------------
Resolution: Fixed
Fixed in master : a7f1fee876cde130d3b84848685ba78ba0fb6c11
> Pass the counter of numRecordsIn into the constructor of StreamInputProcessor
> -----------------------------------------------------------------------------
>
> Key: FLINK-13764
> URL: https://issues.apache.org/jira/browse/FLINK-13764
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Metrics, Runtime / Task
> Reporter: zhijiang
> Assignee: zhijiang
> Priority: Minor
> Labels: pull-request-available
> Time Spent: 20m
> Remaining Estimate: 0h
>
> Currently the counter of numRecordsIn is setup while processing input in
> processor. In order to integrate the processing logic based on
> StreamTaskInput#emitNext(Output) later, we need to pass the counter into
> output functions then. So there are three reasons to do this:
> * It is the precondition of following integration work.
> * We could make the counter as final fields in StreamInputProcessor and
> StreamTwoInputSelectableProcessor.
> * We could reuse the counter setup logic for all the input processors.
> There should be no side effects if we make the counter setup a bit earlier
> than the previous way.
--
This message was sent by Atlassian Jira
(v8.3.2#803003)
