[
https://issues.apache.org/jira/browse/FLINK-5163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15696174#comment-15696174
]
ASF GitHub Bot commented on FLINK-5163:
---------------------------------------
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/2871
[FLINK-5163] Ports the production functions to the new state abstraction.
This includes the following functions:
1) `StatefulSequenceSource`
2) `MessageAcknowledgingSourceBase`
3) `FromElementsFunction`
4) `ContinuousFileMonitoringFunction`
Each of them is a separate commit, for ease of reviewing.
Most of the functions assume parallelism of 1. The only exception is the
`StatefulSequenceSource`.
R @aljoscha
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/kl0u/flink dop1-source-rescaling
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/2871.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #2871
----
commit 3a436c5ef7d0123f0f244700f8a62bb325fac118
Author: kl0u <[email protected]>
Date: 2016-11-17T13:54:08Z
[FLINK-5163] Port the ContinuousFileMonitoringFunction to the new state
abstractions.
commit a49fce791553c94dc866140c7616f52354d788fc
Author: kl0u <[email protected]>
Date: 2016-11-17T15:52:50Z
[FLINK-5163] Port the FromElementsFunction to the new state abstractions.
commit ecee88819bc7be09681047fc0f8c2e347ddbdd06
Author: kl0u <[email protected]>
Date: 2016-11-18T15:07:45Z
[FLINK-5163] Port the MessageAcknowledgingSourceBase to the new state
abstractions.
commit 1dde7c7d7b978cfac086ee93eb775069763b7788
Author: kl0u <[email protected]>
Date: 2016-11-21T17:50:30Z
[FLINK-5163] Port the StatefulSequenceSource to the new state abstractions.
----
> Make the production functions rescalable (apart from the Rolling/Bucketing
> Sinks)
> ---------------------------------------------------------------------------------
>
> Key: FLINK-5163
> URL: https://issues.apache.org/jira/browse/FLINK-5163
> Project: Flink
> Issue Type: Improvement
> Affects Versions: 1.2.0
> Reporter: Kostas Kloudas
> Assignee: Kostas Kloudas
> Fix For: 1.2.0
>
>
> This issue targets porting all the functions in the production code to the
> new state abstractions. These functions are:
> 1) StatefulSequenceSource
> 2) MessageAcknowledgingSourceBase
> 3) FromElementsFunction
> 4) ContinuousFileMonitoringFunction
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
