GitHub user mjsax opened a pull request:
https://github.com/apache/flink/pull/573
Flink Storm compatibility
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/flink flink-storm-compatibility
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/573.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 #573
----
commit 1470b0f4af86d457d841afc037bd9583cdb9d1c1
Author: mjsax <[email protected]>
Date: 2015-02-24T18:39:27Z
fixed package statement
commit 425acb7a2717bde543ff28f794bd45a00ebdc2fb
Author: mjsax <[email protected]>
Date: 2015-02-25T10:25:54Z
Merge branch 'bug_fix_package_statement'
commit 9ee84ca31c05fb4192a288b5d236c519d162d3e2
Author: mjsax <[email protected]>
Date: 2015-03-10T07:46:32Z
Merge branch 'master' of https://github.com/apache/flink
commit adcac585233ff6249d8cfe10a0773f1f1b624c04
Author: mjsax <[email protected]>
Date: 2015-03-20T16:21:34Z
Merge branch 'master' of https://github.com/apache/flink
commit 8091facd05bb00a4d69499ba86c06ed2e928d9aa
Author: mjsax <[email protected]>
Date: 2015-03-22T00:56:38Z
Merge branch 'master' of https://github.com/apache/flink
commit a21f94747649174f63645c95f1b53731eb17c2ba
Author: mjsax <[email protected]>
Date: 2015-04-06T13:23:06Z
Merge branch 'master' of https://github.com/apache/flink
commit 104d21f13abcd18dbe6e070f6400e46d557b9cb8
Author: mjsax <[email protected]>
Date: 2015-02-26T08:50:30Z
initial commit for storm-compatibility module
commit de3a7a81aae7fa63fb7c95961b15b8906c3e2597
Author: mjsax <[email protected]>
Date: 2015-02-27T14:40:40Z
alpha version of a wrapper machanism to use Storm bolts within a Flink
Streaming program
commit 86ad016461956ada3f4a84d229a42b79f8993adb
Author: mjsax <[email protected]>
Date: 2015-03-04T16:17:52Z
Added test for StormBoltWrapper and its utility classes
commit bd154124ae359e0b19c7e8629caaba5258f56cd6
Author: mjsax <[email protected]>
Date: 2015-03-16T18:03:42Z
added raw output type support
commit 2711b9fdeef739771e233d9a90fb338c9a9a7781
Author: mjsax <[email protected]>
Date: 2015-03-16T21:41:46Z
added StormSpoutWrapper including JUnit and ITCase
fixed bugs and improved existing tests
commit bbaa9b2d8f136b193a952cbae9488b43499ed90f
Author: mjsax <[email protected]>
Date: 2015-03-25T00:59:17Z
extracted Storm Spouts and Bolt to seperate package
improved StormFinitSpoutWrapper
added support for Storm sink-bolts
improved integration of Flink and Storm configuration
commit d8a9e1e57a85d772d891b8e765477c84c28bfd27
Author: mjsax <[email protected]>
Date: 2015-03-27T17:34:58Z
added API compatiblity classes
commit 70d8b49c8c5c7b235d50008447d14c821c00615f
Author: mjsax <[email protected]>
Date: 2015-04-01T07:51:25Z
added isRunning flag to spout wrappers
commit a0a4c4a8ab0e5abb580e5b1f4b7e8e131796a569
Author: mjsax <[email protected]>
Date: 2015-04-01T18:02:30Z
worked on LocalCluster shutdown for integration tests
commit ce932a51f9da275896afb0d6a73abc661d9fb1c9
Author: mjsax <[email protected]>
Date: 2015-04-02T13:37:58Z
Added Storm clients that connect to Flink
added a submit-remote-example
commit 1519d36e439d5d76d1e30cf54509a214f065eb8c
Author: mjsax <[email protected]>
Date: 2015-04-02T14:39:25Z
added new JUnit test
improved existing tests
renamed package org.apache.flink.stormcompatibility.operators to
org.apache.flink.stormcompatibility.wrappers
commit 605de53a9990dbe2941261d1365654fe62a7c91d
Author: mjsax <[email protected]>
Date: 2015-04-02T17:15:32Z
added missing license header
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
