[
https://issues.apache.org/jira/browse/FLINK-4960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-4960:
----------------------------------
Description:
Currently the AbstractStreamOperatorTestHarness allows for testing an
operator when scaling up, through snapshot and restore. This is not enough
as many interesting corner cases arise when scaling down or during
arbitrary combinations of scaling up and down.
This issue targets to add this functionality so that an operator can snapshot
its state, restore with different parallelism, and later scale down or further
up.
was:
Currently the AbstractStreamOperatorTestHarness allows for testing scaling
up scenarios through snapshot and restore. This is not enough to check
scaling down scenarios or different combinations of up and down.
This issue targets to add this functionality so that an operator can snapshot
its state, restore with different parallelism, and later scale down or further
up.
> Allow the AbstractStreamOperatorTestHarness to test scaling down
> ----------------------------------------------------------------
>
> Key: FLINK-4960
> URL: https://issues.apache.org/jira/browse/FLINK-4960
> Project: Flink
> Issue Type: New Feature
> Components: Tests
> Reporter: Kostas Kloudas
> Assignee: Kostas Kloudas
> Fix For: 1.2.0
>
>
> Currently the AbstractStreamOperatorTestHarness allows for testing an
> operator when scaling up, through snapshot and restore. This is not enough
> as many interesting corner cases arise when scaling down or during
> arbitrary combinations of scaling up and down.
> This issue targets to add this functionality so that an operator can snapshot
> its state, restore with different parallelism, and later scale down or
> further up.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
