flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mjsax <...@git.apache.org>
Subject [GitHub] flink pull request: Flink Storm compatibility
Date Mon, 06 Apr 2015 16:11:29 GMT
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 <mjsax@informatik.hu-berlin.de>
Date:   2015-02-24T18:39:27Z

    fixed package statement

commit 425acb7a2717bde543ff28f794bd45a00ebdc2fb
Author: mjsax <mjsax@informatik.hu-berlin.de>
Date:   2015-02-25T10:25:54Z

    Merge branch 'bug_fix_package_statement'

commit 9ee84ca31c05fb4192a288b5d236c519d162d3e2
Author: mjsax <mjsax@informatik.hu-berlin.de>
Date:   2015-03-10T07:46:32Z

    Merge branch 'master' of https://github.com/apache/flink

commit adcac585233ff6249d8cfe10a0773f1f1b624c04
Author: mjsax <mjsax@informatik.hu-berlin.de>
Date:   2015-03-20T16:21:34Z

    Merge branch 'master' of https://github.com/apache/flink

commit 8091facd05bb00a4d69499ba86c06ed2e928d9aa
Author: mjsax <mjsax@informatik.hu-berlin.de>
Date:   2015-03-22T00:56:38Z

    Merge branch 'master' of https://github.com/apache/flink

commit a21f94747649174f63645c95f1b53731eb17c2ba
Author: mjsax <mjsax@informatik.hu-berlin.de>
Date:   2015-04-06T13:23:06Z

    Merge branch 'master' of https://github.com/apache/flink

commit 104d21f13abcd18dbe6e070f6400e46d557b9cb8
Author: mjsax <mjsax@informatik.hu-berlin.de>
Date:   2015-02-26T08:50:30Z

    initial commit for storm-compatibility module

commit de3a7a81aae7fa63fb7c95961b15b8906c3e2597
Author: mjsax <mjsax@informatik.hu-berlin.de>
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 <mjsax@informatik.hu-berlin.de>
Date:   2015-03-04T16:17:52Z

    Added test for StormBoltWrapper and its utility classes

commit bd154124ae359e0b19c7e8629caaba5258f56cd6
Author: mjsax <mjsax@informatik.hu-berlin.de>
Date:   2015-03-16T18:03:42Z

    added raw output type support

commit 2711b9fdeef739771e233d9a90fb338c9a9a7781
Author: mjsax <mjsax@informatik.hu-berlin.de>
Date:   2015-03-16T21:41:46Z

    added StormSpoutWrapper including JUnit and ITCase
    fixed bugs and improved existing tests

commit bbaa9b2d8f136b193a952cbae9488b43499ed90f
Author: mjsax <mjsax@informatik.hu-berlin.de>
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 <mjsax@informatik.hu-berlin.de>
Date:   2015-03-27T17:34:58Z

    added API compatiblity classes

commit 70d8b49c8c5c7b235d50008447d14c821c00615f
Author: mjsax <mjsax@informatik.hu-berlin.de>
Date:   2015-04-01T07:51:25Z

    added isRunning flag to spout wrappers

commit a0a4c4a8ab0e5abb580e5b1f4b7e8e131796a569
Author: mjsax <mjsax@informatik.hu-berlin.de>
Date:   2015-04-01T18:02:30Z

    worked on LocalCluster shutdown for integration tests

commit ce932a51f9da275896afb0d6a73abc661d9fb1c9
Author: mjsax <mjsax@informatik.hu-berlin.de>
Date:   2015-04-02T13:37:58Z

    Added Storm clients that connect to Flink
    added a submit-remote-example

commit 1519d36e439d5d76d1e30cf54509a214f065eb8c
Author: mjsax <mjsax@informatik.hu-berlin.de>
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 <mjsax@informatik.hu-berlin.de>
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 infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

Mime
View raw message