[
https://issues.apache.org/jira/browse/FLINK-2243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14594523#comment-14594523
]
ASF GitHub Bot commented on FLINK-2243:
---------------------------------------
GitHub user szape opened a pull request:
https://github.com/apache/flink/pull/853
[FLINK-2243] [storm-compat] Added finite spout functionality to Storm
compatibility layer
Added finite spout functionality to Storm compatibility layer
Storm spouts emit infinite streams. It is important to support the users of
Flink's Storm compatibility layer by providing an interface that can add a
finite nature to any storm spouts, given that Flink actually supports finite
source streams.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mbalassi/flink finite-storm-spout
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/853.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 #853
----
commit ce3c1cb6d80c51dcb2e27409448ce84eeec96f12
Author: szape <nemderogator...@gmail.com>
Date: 2015-06-19T08:18:09Z
[storm-compat] Removed failing simple join example
commit d0a80b382c5de332f91e231cd9530efd357cd051
Author: szape <nemderogator...@gmail.com>
Date: 2015-06-19T08:22:04Z
[storm-compat] Added finite spout functionality to Storm compatibility layer
commit d1a325e9f287300c5eca2bdfb90027aa5f27b6a6
Author: szape <nemderogator...@gmail.com>
Date: 2015-06-19T08:43:10Z
[storm-compat] Demonstrating finite Storm spout functionality on
exclamation example
-minor renaming
-improving JavaDocs
commit 4a59aa6704d3bd4b9a6e334ed93160a3e4eea68f
Author: szape <nemderogator...@gmail.com>
Date: 2015-06-19T08:44:32Z
[storm-compat] Fixing JavaDocs in word count example
----
> Add finite spout functionality to Storm compatibility layer
> -----------------------------------------------------------
>
> Key: FLINK-2243
> URL: https://issues.apache.org/jira/browse/FLINK-2243
> Project: Flink
> Issue Type: Improvement
> Components: flink-contrib
> Reporter: Péter Szabó
> Assignee: Péter Szabó
> Priority: Minor
>
> Add finite spout functionality to Storm compatibility layer
> Storm spouts emit infinite streams. It is important to support the users of
> Flink's Storm compatibility layer by providing an interface that can add a
> finite nature to any storm spouts, given that Flink actually supports finite
> source streams.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
