[FLINK-5021] Makes the ContinuousFileReaderOperator rescalable. - ASF JIRA

XML

Word

Printable

JSON

Details

Type: Improvement
Status: Closed
Priority: Major
Resolution: Fixed
Affects Version/s: None
Fix Version/s: 1.2.0
Component/s: Connectors / FileSystem
Labels:
None

Description

This targets integrating the ContinuousFileReaderOperator with the new rescalable state abstractions, so that the operator can change parallelism without jeopardizing the guarantees offered by it.

Attachments

Issue Links

links to

GitHub Pull Request #2763

Activity

People

Assignee:: Kostas Kloudas

Reporter:: Kostas Kloudas

Votes:: 0 Vote for this issue

Watchers:: 3 Start watching this issue

Dates

Created:: 04/Nov/16 15:25

Updated:: 11/Nov/16 13:19

Resolved:: 11/Nov/16 13:19