flink git commit: [hotfix] minor: make type explicit to allow Scala test to compile in Eclipse

2016-04-27 Thread mjsax
ttp://git-wip-us.apache.org/repos/asf/flink/tree/8ad264d0 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/8ad264d0 Branch: refs/heads/master Commit: 8ad264d0f9f9cc89de6f95a93ec9c2b835dd591b Parents: 16059ea Author: mjsax Authored: Wed Apr 27 13:28:57 2016 +0200 Committer: mjsax Commit

flink git commit: [Doc] added note to fix Eclipse build

2016-04-26 Thread mjsax
asf/flink/tree/a58cd80f Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a58cd80f Branch: refs/heads/master Commit: a58cd80f90ad2f2f1b50b57e74807c197be694fb Parents: 4a69f72 Author: mjsax Authored: Tue Apr 26 14:16:29 2016 +0200 Committer: mjsax Committed: Tue Apr 26 14:16:29 2016 +0

[6/8] flink-web git commit: rebuild web page

2016-04-11 Thread mjsax
http://git-wip-us.apache.org/repos/asf/flink-web/blob/24f3ba5a/content/blog/index.html -- diff --git a/content/blog/index.html b/content/blog/index.html index d388ac9..4c083bc 100644 --- a/content/blog/index.html +++ b/content/blog

[3/8] flink-web git commit: rebuild web page

2016-04-11 Thread mjsax
http://git-wip-us.apache.org/repos/asf/flink-web/blob/24f3ba5a/content/news/2014/02/18/amazon-elastic-mapreduce-cloud-yarn.html -- diff --git a/content/news/2014/02/18/amazon-elastic-mapreduce-cloud-yarn.html b/content/news/2014/0

[8/8] flink-web git commit: rebuild web page

2016-04-11 Thread mjsax
Branch: refs/heads/asf-site Commit: 24f3ba5a1b8e309dd60c4611f568dc7f06ff56b7 Parents: 52d8fe1 Author: mjsax Authored: Sun Apr 10 14:31:24 2016 +0200 Committer: mjsax Committed: Sun Apr 10 14:31:57 2016 +0200 -- content/blog/feed.xml

[7/8] flink-web git commit: rebuild web page

2016-04-11 Thread mjsax
http://git-wip-us.apache.org/repos/asf/flink-web/blob/24f3ba5a/content/blog/feed.xml -- diff --git a/content/blog/feed.xml b/content/blog/feed.xml index 2c4b25f..ef1a75c 100644 --- a/content/blog/feed.xml +++ b/content/blog/feed.xm

[5/8] flink-web git commit: rebuild web page

2016-04-11 Thread mjsax
http://git-wip-us.apache.org/repos/asf/flink-web/blob/24f3ba5a/content/news/2012/10/15/icde2013.html -- diff --git a/content/news/2012/10/15/icde2013.html b/content/news/2012/10/15/icde2013.html deleted file mode 100644 index 29ad

[4/8] flink-web git commit: rebuild web page

2016-04-11 Thread mjsax
http://git-wip-us.apache.org/repos/asf/flink-web/blob/24f3ba5a/content/news/2014/01/12/0.4-migration-guide.html -- diff --git a/content/news/2014/01/12/0.4-migration-guide.html b/content/news/2014/01/12/0.4-migration-guide.html de

[1/8] flink-web git commit: fixed broken links and removed old stuff (prior Flink)

2016-04-11 Thread mjsax
git-wip-us.apache.org/repos/asf/flink-web/tree/52d8fe19 Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/52d8fe19 Branch: refs/heads/asf-site Commit: 52d8fe19d0a89104178f4c5d4b7564ffacc528da Parents: 029a305 Author: mjsax Authored: Sun Apr 10 14:28:24 2016 +0200 Committer: mjsax Commit

[2/8] flink-web git commit: rebuild web page

2016-04-11 Thread mjsax
http://git-wip-us.apache.org/repos/asf/flink-web/blob/24f3ba5a/content/news/2015/02/09/streaming-example.html -- diff --git a/content/news/2015/02/09/streaming-example.html b/content/news/2015/02/09/streaming-example.html index 69

flink git commit: [FLINK-3523] [Storm-Compatibility] Added SplitStreamMapper to program to get rid of SplitStreamType wrapper - additionally reworked split ITCases * unified to single test * make Wind

2016-04-06 Thread mjsax
org/repos/asf/flink/diff/02ef68fb Branch: refs/heads/master Commit: 02ef68fb4adbd413fa159c35980412f280179cbf Parents: 593463b Author: mjsax Authored: Fri Apr 1 01:23:30 2016 +0200 Committer: mjsax Committed: Wed Apr 6 16:25:01 2016 +0

flink-web git commit: fixed incorrect link

2016-04-04 Thread mjsax
ink-web/tree/0144d452 Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/0144d452 Branch: refs/heads/asf-site Commit: 0144d4521a7ecea537323e3fb8cc7e70f6c8aecd Parents: 036df30 Author: mjsax Authored: Mon Apr 4 12:31:12 2016 +0200 Committer: mjsax Committed: Mon Apr 4 12:31:12 2016 +0

flink git commit: [docs] Fixed typo in Storm Compatibility page

2016-02-10 Thread mjsax
wip-us.apache.org/repos/asf/flink/tree/aeee6efd Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/aeee6efd Branch: refs/heads/master Commit: aeee6efd451dcbdda37ed05779bda74291079ed5 Parents: 0a63797 Author: Georgios Andrianakis Authored: Wed Feb 10 14:30:46 2016 +0200 Committer: mjsax Commit

[1/2] flink git commit: [FLINK-2721] [Storm Compatibility] Add Tuple meta information

2016-02-07 Thread mjsax
Repository: flink Updated Branches: refs/heads/master 168c1f0a1 -> 7eb6edd57 http://git-wip-us.apache.org/repos/asf/flink/blob/7eb6edd5/flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/wrappers/StormTupleTest.java ---

[2/2] flink git commit: [FLINK-2721] [Storm Compatibility] Add Tuple meta information

2016-02-07 Thread mjsax
-us.apache.org/repos/asf/flink/diff/7eb6edd5 Branch: refs/heads/master Commit: 7eb6edd573211f6f65449ad5ed13eb588cebfe67 Parents: 168c1f0 Author: mjsax Authored: Fri Feb 5 00:02:41 2016 +0100 Committer: mjsax Committed: Sun Feb 7 19:39:08 2016 +0100

flink git commit: [FLINK-2831] [Storm Compatibility Tests] Fixed instable test

2016-01-19 Thread mjsax
ree: http://git-wip-us.apache.org/repos/asf/flink/tree/046f044d Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/046f044d Branch: refs/heads/master Commit: 046f044df47d2711e614455f047c760a9c066cde Parents: 82ff716 Author: mjsax Authored: Mon Jan 18 17:37:03 2016 +0100 Committer: mjsax Commit

flink git commit: [hotfix] moved files to correct folder to match package statements

2016-01-15 Thread mjsax
8db Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a65cd8db Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a65cd8db Branch: refs/heads/master Commit: a65cd8db1c8e966fe43f68f3a427d9b1d09fe165 Parents: 615cf42 Author: mjsax Authored: Thu Jan 14 23:46:29 2016 +0100 Committer: mj

flink git commit: [Storm-Compatibility] Forward Storm Kryo registrations to Flink

2016-01-14 Thread mjsax
b7a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/be055b7a Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/be055b7a Branch: refs/heads/master Commit: be055b7a9f8ecb09e5e4e0bbddb98639173a09a7 Parents: d1c93d2 Author: mjsax Authored: Sun Jan 10 16:59:37 2016 +0100 Committer: mj

flink git commit: [FLINK-2586] Unstable Storm Compatibility Tests - added BLOCKING flag to FlinkLocalCluster - added NullTerminatingSpout and SpoutOutputCollectorObserver plus tests - reworked test ac

2016-01-14 Thread mjsax
wip-us.apache.org/repos/asf/flink/diff/d1c93d28 Branch: refs/heads/master Commit: d1c93d286b95f069f6ba0a4e60e3a34655a395e3 Parents: e4d8944 Author: mjsax Authored: Wed Jan 13 17:47:32 2016 +0100 Committer: mjsax Committed: Thu Jan 14 22:07:14 2016 +0

flink git commit: [Docs] Fixed code example in streaming docs

2016-01-12 Thread mjsax
wip-us.apache.org/repos/asf/flink/tree/a065ed09 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a065ed09 Branch: refs/heads/master Commit: a065ed0910fa5636a26c47b3ece5cb48cdbf33f7 Parents: b9a6a5c Author: mjsax Authored: Tue Jan 12 10:32:38 2016 +0100 Committer: mjsax Committed: Tue Jan 12

flink git commit: [FLINK-2837] [Storm Compatibility] FlinkTopologyBuilder cannot handle multiple input streams - removed BoltWrapperTwoInputs - add generic multi-input stream bolt wrapper - updated Fl

2015-12-28 Thread mjsax
git-wip-us.apache.org/repos/asf/flink/tree/f7b113d9 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f7b113d9 Branch: refs/heads/master Commit: f7b113d965fd30db993cac99b63194dcd7869ad4 Parents: 8e95214 Author: mjsax Authored: Sun Dec 27 00:52:30 2015 +0100 Committer: mjsax Committed: Mon

flink git commit: [CLI] Set current class loader to user-class loader and disable class initialization. Enalbes submission of Flink programs written in Clojure.

2015-12-18 Thread mjsax
fe4 Author: mjsax Authored: Tue Dec 15 14:14:17 2015 +0100 Committer: mjsax Committed: Fri Dec 18 11:50:39 2015 +0100 -- .../org/apache/flink/client/program/PackagedProgram.java| 9 - 1 file changed, 8 insertions(+)

[4/4] flink-web git commit: rebuild website

2015-12-11 Thread mjsax
/diff/1e63786d Branch: refs/heads/asf-site Commit: 1e63786d39cc70cafc9638c6180d41c3304c5784 Parents: 17debea Author: mjsax Authored: Mon Dec 7 18:01:49 2015 +0100 Committer: mjsax Committed: Fri Dec 11 10:46:22 2015 +0100

[2/4] flink-web git commit: rebuild website

2015-12-11 Thread mjsax
http://git-wip-us.apache.org/repos/asf/flink-web/blob/1e63786d/content/blog/index.html -- diff --git a/content/blog/index.html b/content/blog/index.html index a375a85..7ecedfb 100644 --- a/content/blog/index.html +++ b/content/blog

[1/4] flink-web git commit: Added blog post about Storm Compatibility

2015-12-11 Thread mjsax
wip-us.apache.org/repos/asf/flink-web/tree/17debeae Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/17debeae Branch: refs/heads/asf-site Commit: 17debeae21141cdc1c9341e0593ef84e792fa15a Parents: 0507169 Author: mjsax Authored: Fri Sep 11 01:27:57 2015 +0200 Committer: mjsax Committed: Fri Dec 11

[3/4] flink-web git commit: rebuild website

2015-12-11 Thread mjsax
http://git-wip-us.apache.org/repos/asf/flink-web/blob/1e63786d/content/blog/feed.xml -- diff --git a/content/blog/feed.xml b/content/blog/feed.xml index 3b2b4a1..17afaf1 100644 --- a/content/blog/feed.xml +++ b/content/blog/feed.xm

flink git commit: [Storm Compatibility] Updated README.md and documenation

2015-12-09 Thread mjsax
wip-us.apache.org/repos/asf/flink/tree/1190f3b1 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/1190f3b1 Branch: refs/heads/master Commit: 1190f3b1d9911e4d098b3c7ef27f4a1659ef Parents: b2aa1d9 Author: mjsax Authored: Wed Dec 9 16:27:35 2015 +0100 Committer: mjsax Committed: Wed Dec 9 16:27:35 2

flink git commit: [FLINK-2861] Fields grouping on split streams fails

2015-11-24 Thread mjsax
git-wip-us.apache.org/repos/asf/flink/tree/4c46b2fe Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/4c46b2fe Branch: refs/heads/master Commit: 4c46b2feee2c1ecda21e5ba62d02dfd7df73e256 Parents: 85e7b28 Author: mjsax Authored: Fri Nov 6 11:51:31 2015 +0100 Committer: mjsax Committed: Tue

flink git commit: [FLINK-3017] [Docu] Fix broken 'Slots' link on Streaming Guide.

2015-11-16 Thread mjsax
feb6994f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/feb6994f Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/feb6994f Branch: refs/heads/master Commit: feb6994ffca04e4b7ad6174ca08048ea452e19f6 Parents: 9a911c8 Author: smarthi Authored: Mon Nov 16 00:05:24 2015 -0500 Com

[1/2] flink-web git commit: Added Pyhton API examples link to third-party libraries

2015-11-13 Thread mjsax
git-wip-us.apache.org/repos/asf/flink-web/tree/27ad740f Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/27ad740f Branch: refs/heads/asf-site Commit: 27ad740fc3dae64901a2302e8de54707ce7efacd Parents: c3e5f14 Author: mjsax Authored: Fri Nov 13 11:10:06 2015 +0100 Committer: mjsax Commit

[2/2] flink-web git commit: Rebuild web page

2015-11-13 Thread mjsax
Branch: refs/heads/asf-site Commit: f463ac5f55efca27902195de1da5f88bccc3d1f8 Parents: 27ad740 Author: mjsax Authored: Fri Nov 13 11:12:24 2015 +0100 Committer: mjsax Committed: Fri Nov 13 11:12:24 2015 +0100 -- content

flink git commit: [Documanation] Fix constructor name of WordWithCount example.

2015-11-13 Thread mjsax
ree: http://git-wip-us.apache.org/repos/asf/flink/tree/955ce530 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/955ce530 Branch: refs/heads/master Commit: 955ce5304d549e255c5e439b5d65d685dd0c1df7 Parents: 824074a Author: Jun Aoki Authored: Tue Nov 3 17:34:39 2015 -0800 Committer: mj

[3/5] flink-web git commit: Rebuild web page

2015-11-09 Thread mjsax
http://git-wip-us.apache.org/repos/asf/flink-web/blob/c3e5f146/content/news/2014/01/26/optimizer_plan_visualization_tool.html -- diff --git a/content/news/2014/01/26/optimizer_plan_visualization_tool.html b/content/news/2014/01/26

[4/5] flink-web git commit: Rebuild web page

2015-11-09 Thread mjsax
ecution engine soon. Albert Bifet introduced SAMOA on Flink at his http://www.slideshare.net/FlinkForward/albert-bifet-apache-samoa-mining-big-data-streams-with-apache-flink?ref=http://flink-forward.org/?session=apache-samoa-mining-big-data-streams-with-apac

[5/5] flink-web git commit: Rebuild web page

2015-11-09 Thread mjsax
Branch: refs/heads/asf-site Commit: c3e5f14633a543ecd15c799cedf5692c5146bd64 Parents: d629a2d Author: mjsax Authored: Mon Nov 9 11:56:32 2015 +0100 Committer: mjsax Committed: Mon Nov 9 11:56:32 2015 +0100 -- content/blog/feed.xml

[1/5] flink-web git commit: [FLINK-2752] Documentation is not easily differentiable from the Flink homepage - improved menu (only improvement on FLINK-2752; does not resolve it)

2015-11-09 Thread mjsax
362 Parents: 7d20b8a Author: mjsax Authored: Mon Nov 9 11:53:25 2015 +0100 Committer: mjsax Committed: Mon Nov 9 11:53:25 2015 +0100 -- _includes/navbar.html | 8 1 file changed, 4 insertions(+), 4 deleti

[2/5] flink-web git commit: Rebuild web page

2015-11-09 Thread mjsax
http://git-wip-us.apache.org/repos/asf/flink-web/blob/c3e5f146/content/news/2015/04/07/march-in-flink.html -- diff --git a/content/news/2015/04/07/march-in-flink.html b/content/news/2015/04/07/march-in-flink.html index dbb3544..fc

flink-web git commit: Extended slide list on Material page

2015-11-09 Thread mjsax
git-wip-us.apache.org/repos/asf/flink-web/tree/7d20b8a0 Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/7d20b8a0 Branch: refs/heads/asf-site Commit: 7d20b8a05dc90198bfb555835e5cfbf7af923d39 Parents: be1af3b Author: mjsax Authored: Mon Nov 9 11:45:37 2015 +0100 Committer: mjsax Commit

flink-web git commit: added third-party-library section fixed broken link

2015-11-09 Thread mjsax
wip-us.apache.org/repos/asf/flink-web/tree/be1af3ba Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/be1af3ba Branch: refs/heads/asf-site Commit: be1af3ba37c7fce824b6f9e648f15e0349b6443a Parents: 57ea246 Author: mjsax Authored: Mon Oct 26 23:39:48 2015 +0100 Committer: mjsax Committed:

flink git commit: [FLINK-2752] Documentation is not easily differentiable from the Flink homepage - added auto-redirect for coding_guidelines and how_to_contribute pages (to keep external links workin

2015-11-09 Thread mjsax
wip-us.apache.org/repos/asf/flink/tree/c6075495 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/c6075495 Branch: refs/heads/master Commit: c607549537894d3a3ffc0cdc4aad088b2ef8 Parents: 044fe5f Author: mjsax Authored: Thu Nov 5 17:35:06 2015 +0100 Committer: mjsax Committed: Mon Nov 9

flink git commit: [FLINK-2862] [Storm Compatibility] FlinkTopologyBuilder should use proper generic types

2015-10-24 Thread mjsax
asf/flink/commit/fa88d9eb Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fa88d9eb Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/fa88d9eb Branch: refs/heads/master Commit: fa88d9eb1b88641d6ca03b38e2058d30971c7a2f Parents: 4a31516 Author: mjsax Authored: Tue Oct 20 18:06:00 2015 +0

flink git commit: Change "it's" contraction to possession "its"

2015-10-14 Thread mjsax
7ab4f37 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f7ab4f37 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f7ab4f37 Branch: refs/heads/master Commit: f7ab4f3732aa2cd6be99b99513f5df36fa963406 Parents: a7a1cbc Author: Chris Brinkman Authored: Tue Oct 13 20:19:16 2015 -0400 Comm

flink git commit: [FLINK-2831] [Storm Compatibility] Failing Test: WrapperSetupHelperTest

2015-10-09 Thread mjsax
ttp://git-wip-us.apache.org/repos/asf/flink/tree/998be1bb Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/998be1bb Branch: refs/heads/master Commit: 998be1bbbc823e1299dcb6bfe56774ec2f7286ab Parents: c9088a4 Author: mjsax Authored: Fri Oct 9 11:11:57 2015 +0200 Committer: mjsax Committed: Fri

flink git commit: [FLINK-2381] [Storm Compatibility] Failing Test: WrapperSetupHelperTest

2015-10-07 Thread mjsax
ttp://git-wip-us.apache.org/repos/asf/flink/tree/f332fa57 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f332fa57 Branch: refs/heads/master Commit: f332fa579635878a82594aa749db050272f1a35a Parents: 5c2c112 Author: mjsax Authored: Wed Oct 7 21:22:49 2015 +0200 Committer: mjsax Committed: Wed

flink git commit: [FLINK-2825] FlinkClient.killTopology fails due to missing leader session ID

2015-10-06 Thread mjsax
ttp://git-wip-us.apache.org/repos/asf/flink/tree/b489c367 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b489c367 Branch: refs/heads/master Commit: b489c367385453404671d0136ea59a9e63434ea7 Parents: af1e03e Author: mjsax Authored: Tue Oct 6 23:27:45 2015 +0200 Committer: mjsax Committed:

[02/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed

2015-10-06 Thread mjsax
http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/util/AbstractTest.java -- diff --git a/flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/util/A

[07/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed

2015-10-06 Thread mjsax
http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-examples/src/main/java/org/apache/flink/stormcompatibility/wordcount/stormoperators/WordCountDataPojos.java --

[10/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed

2015-10-06 Thread mjsax
http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/test/java/org/apache/flink/stormcompatibility/wrappers/StormBoltWrapperTest.java -- diff --git a

[12/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed

2015-10-06 Thread mjsax
http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/api/SplitStreamTypeKeySelector.java -- diff --git

[14/15] flink git commit: [FLINK-2566] FlinkTopologyContext not populated completely - extended FlinkTopologyContext to be populted with all supportable attributes - added JUnit test - updated README.

2015-10-06 Thread mjsax
http://git-wip-us.apache.org/repos/asf/flink/blob/7a67a60f/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/test/java/org/apache/flink/stormcompatibility/util/FiniteTestSpout.java -- diff --git a/flink-co

[05/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed

2015-10-06 Thread mjsax
http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/wordcount/WordCountLocalByName.java -- diff --git a/flink-contrib/flink-storm-examples/src/main/jav

[06/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed

2015-10-06 Thread mjsax
http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/excamation/ExclamationLocal.java -- diff --git a/flink-contrib/flink-storm-examples/src/main/java/o

[08/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed

2015-10-06 Thread mjsax
http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-examples/src/main/java/org/apache/flink/stormcompatibility/util/FiniteStormInMemorySpout.java -- diff --gi

[04/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed

2015-10-06 Thread mjsax
http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/wordcount/WordCountLocalITCase.java -- diff --git a/flink-contrib/flink-storm-examples/src/test/jav

[11/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed

2015-10-06 Thread mjsax
http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/wrappers/StormSpoutWrapper.java -- diff --git a/fl

[01/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed

2015-10-06 Thread mjsax
Repository: flink Updated Branches: refs/heads/master 39115abe4 -> 4cb967089 http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/wrappers/WrapperSetupHelperTest.java ---

[09/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed

2015-10-06 Thread mjsax
http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-examples/pom.xml -- diff --git a/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-exampl

[03/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed

2015-10-06 Thread mjsax
http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm/src/main/java/org/apache/flink/storm/wrappers/AbstractStormCollector.java -- diff --git a/flink-contrib/flink-storm/src/main/java/org/apache/flin

[15/15] flink git commit: [FLINK-2566] FlinkTopologyContext not populated completely - extended FlinkTopologyContext to be populted with all supportable attributes - added JUnit test - updated README.

2015-10-06 Thread mjsax
: 7a67a60f934123863ca96a95e30471c99bb8088a Parents: 39115ab Author: mjsax Authored: Tue Sep 15 23:59:31 2015 +0200 Committer: mjsax Committed: Tue Oct 6 13:29:32 2015 +0200 -- .../flink-storm-compatibility-core/README.md| 2 +- .../api

[13/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed

2015-10-06 Thread mjsax
95588e4442d0d Parents: 7a67a60 Author: mjsax Authored: Fri Oct 2 18:43:38 2015 +0200 Committer: mjsax Committed: Tue Oct 6 13:29:32 2015 +0200 -- docs/apis/storm_compatibility.md| 111 ++-- .../flink-storm-compati

flink git commit: [FLINK-2525] Add configuration support in Storm-compatibility

2015-10-02 Thread mjsax
Committer: mjsax Committed: Fri Oct 2 10:48:48 2015 +0200 -- docs/apis/storm_compatibility.md| 31 + .../flink-storm-compatibility-core/README.md| 1 - .../stormcompatibility/api/FlinkClient.java

flink git commit: [doc] fixed typos in "Internals -> Fault Tolerance for Data Streaming"

2015-10-01 Thread mjsax
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/bbd97354 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/bbd97354 Branch: refs/heads/master Commit: bbd97354b8e681dd68f8ad7528eef433227c5c89 Parents: 846ad70 Author: mjsax Authored: Thu Oct 1 14:06:49 2015 +0200 Committer: mjsax Comm

flink git commit: [FLINK-2764] [WebClient] WebClient cannot display multiple Jobs

2015-09-29 Thread mjsax
ree: http://git-wip-us.apache.org/repos/asf/flink/tree/622c1be8 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/622c1be8 Branch: refs/heads/master Commit: 622c1be8c61c3a9a37c30454c717c99982edd236 Parents: 136347d Author: mjsax Authored: Wed Sep 23 16:21:29 2015 +0200 Committer: mj

flink git commit: [FLINK-2658] fieldsGrouping for multiple output streams fails - added SplitStreamTypeKeySelector and JUnit tests

2015-09-14 Thread mjsax
nts: dbae51a Author: mjsax Authored: Fri Sep 11 13:52:04 2015 +0200 Committer: mjsax Committed: Mon Sep 14 18:17:49 2015 +0200 -- .../api/FlinkTopologyBuilder.java | 22 --- .../api/SplitStreamTypeKeySelector.j

flink git commit: [FLINK-2658] fieldsGrouping for multiple output streams fails - added SplitStreamTypeKeySelector and JUnit tests

2015-09-14 Thread mjsax
wip-us.apache.org/repos/asf/flink/commit/ce68cbd9 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ce68cbd9 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ce68cbd9 Branch: refs/heads/master Commit: ce68cbd91621b1a58cb34b33ab27762c6525cfa0 Parents: 8acd15d Author: mjsax Authored:

flink git commit: [FLINK-2475] Rename Flink Client log file

2015-09-03 Thread mjsax
wip-us.apache.org/repos/asf/flink/tree/9f96b32b Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/9f96b32b Branch: refs/heads/master Commit: 9f96b32bf8a0c77accdd91b7cfada2f6e751c167 Parents: 14ba66b Author: mjsax Authored: Sat Aug 29 16:52:31 2015 +0200 Committer: mjsax Committed: Thu Sep 3 12:43

flink-web git commit: Added mjsax to the people list of community page

2015-09-02 Thread mjsax
Repository: flink-web Updated Branches: refs/heads/asf-site fde49bf45 -> b7ab5c60c Added mjsax to the people list of community page Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/b7ab5c60 Tree: http://git-