[2/6] flink git commit: [FLINK-1295] Address pull request review comments

2015-01-23 Thread rmetzger
[FLINK-1295] Address pull request review comments Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2c1c91e2 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2c1c91e2 Diff:

[5/6] flink git commit: [FLINK-1295][FLINK-883] Allow to deploy 'job only' YARN cluster. Add tests to YARN

2015-01-23 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/2af65867/flink-addons/flink-yarn/src/main/scala/org/apache/flink/yarn/YarnTaskManager.scala -- diff --git

[6/6] flink git commit: [FLINK-1295][FLINK-883] Allow to deploy 'job only' YARN cluster. Add tests to YARN

2015-01-23 Thread rmetzger
[FLINK-1295][FLINK-883] Allow to deploy 'job only' YARN cluster. Add tests to YARN - users can now also deploy Flink on YARN for executing a single job. - The flink-yarn project has been moved out of the flink-addons module - the MiniYARNCluster is used for testing Flink on YARN - There is now a

[4/6] flink git commit: [FLINK-1295][FLINK-883] Allow to deploy 'job only' YARN cluster. Add tests to YARN

2015-01-23 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/2af65867/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java -- diff --git a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java

[3/6] flink git commit: [FLINK-1295][FLINK-883] Allow to deploy 'job only' YARN cluster. Add tests to YARN

2015-01-23 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/2af65867/flink-yarn/src/main/scala/org/apache/flink/yarn/Messages.scala -- diff --git a/flink-yarn/src/main/scala/org/apache/flink/yarn/Messages.scala

[1/2] flink git commit: [FLINK-592] Address pull request comments: fail early on missing auth, load log4j-cli.properties and do not set 'default' as default queue

2015-02-04 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master 7ac6447fd - 48d8dd5a5 [FLINK-592] Address pull request comments: fail early on missing auth, load log4j-cli.properties and do not set 'default' as default queue This closes #358 Project: http://git-wip-us.apache.org/repos/asf/flink/repo

[2/2] flink git commit: [FLINK-592] Add support for Kerberos secured YARN setups to Flink.

2015-02-04 Thread rmetzger
[FLINK-592] Add support for Kerberos secured YARN setups to Flink. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/17ac128c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/17ac128c Diff:

[22/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging'

2015-02-02 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/f94112fb/flink-staging/flink-hadoop-compatibility/src/test/java/org/apache/flink/test/hadoopcompatibility/mapred/HadoopReduceFunctionITCase.java -- diff --git

[33/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging'

2015-02-02 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/f94112fb/flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/state/checkpoint/MapCheckpoint.java -- diff --git

[27/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging'

2015-02-02 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/f94112fb/flink-addons/flink-streaming/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/DataStream.scala -- diff --git

[15/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging'

2015-02-02 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/f94112fb/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/StreamProjection.java -- diff --git

[43/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging'

2015-02-02 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/f94112fb/flink-addons/flink-streaming/flink-streaming-connectors/src/main/java/org/apache/flink/streaming/connectors/flume/FlumeTopology.java -- diff --git

[30/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging'

2015-02-02 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/f94112fb/flink-addons/flink-streaming/flink-streaming-examples/pom.xml -- diff --git a/flink-addons/flink-streaming/flink-streaming-examples/pom.xml

[17/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging'

2015-02-02 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/f94112fb/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/StreamingJobGraphGenerator.java -- diff --git

[42/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging'

2015-02-02 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/f94112fb/flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/StreamConfig.java -- diff --git

[10/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging'

2015-02-02 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/f94112fb/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/deltafunction/EuclideanDistance.java -- diff --git

[45/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging'

2015-02-02 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/f94112fb/flink-addons/flink-jdbc/src/test/java/org/apache/flink/api/java/record/io/jdbc/JDBCOutputFormatTest.java -- diff --git

[14/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging'

2015-02-02 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/f94112fb/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/WindowedDataStream.java -- diff --git

[11/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging'

2015-02-02 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/f94112fb/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/invokable/operator/WindowReduceInvokable.java -- diff --git

[16/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging'

2015-02-02 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/f94112fb/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java -- diff --git

[51/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging'

2015-02-02 Thread rmetzger
[FLINK-1452] Rename 'flink-addons' to 'flink-staging' Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f94112fb Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f94112fb Diff:

[12/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging'

2015-02-02 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/f94112fb/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/function/source/FromElementsFunction.java -- diff --git

[04/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging'

2015-02-02 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/f94112fb/flink-staging/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/twitter/util/TwitterStreamData.java -- diff --git

[13/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging'

2015-02-02 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/f94112fb/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/function/aggregation/AggregationFunction.java -- diff --git

[37/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging'

2015-02-02 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/f94112fb/flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/function/source/FromElementsFunction.java -- diff --git

[20/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging'

2015-02-02 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/f94112fb/flink-staging/flink-spargel/src/main/java/org/apache/flink/spargel/java/OutgoingEdge.java -- diff --git

[02/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging'

2015-02-02 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/f94112fb/flink-staging/flink-streaming/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/DataStream.scala -- diff --git

[47/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging'

2015-02-02 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/f94112fb/flink-addons/flink-hadoop-compatibility/src/test/java/org/apache/flink/test/hadoopcompatibility/mapred/HadoopInputFormatTest.java -- diff --git

[03/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging'

2015-02-02 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/f94112fb/flink-staging/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/windowing/DeltaExtractExample.java -- diff --git

[08/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging'

2015-02-02 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/f94112fb/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/state/checkpoint/MapCheckpoint.java -- diff --git

[49/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging'

2015-02-02 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/f94112fb/flink-addons/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/HadoopInputFormat.java -- diff --git

[35/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging'

2015-02-02 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/f94112fb/flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/deltafunction/EuclideanDistance.java -- diff --git

[29/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging'

2015-02-02 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/f94112fb/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/twitter/util/TwitterStreamData.java -- diff --git

[07/52] [partial] flink git commit: [FLINK-1452] Rename 'flink-addons' to 'flink-staging'

2015-02-02 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/f94112fb/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/invokable/operator/FilterTest.java -- diff --git

flink git commit: [FLINK-1473] Simplify SplittableIterator interface

2015-02-04 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master d5393017b - 7ac6447fd [FLINK-1473] Simplify SplittableIterator interface Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7ac6447f Tree:

flink git commit: [FLINK-1480] Set Hadoop version to 2.6.0 for travis tests

2015-02-05 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master d033fa8fa - 140faa945 [FLINK-1480] Set Hadoop version to 2.6.0 for travis tests Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/140faa94 Tree:

flink git commit: [FLINK-1477] Respect HADOOP_HOME when starting Flink

2015-02-05 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master 48d8dd5a5 - 5e1cc9e21 [FLINK-1477] Respect HADOOP_HOME when starting Flink Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5e1cc9e2 Tree:

svn commit: r1657551 [1/9] - in /flink/site: blog/ docs/0.6-incubating/ docs/0.6-incubating/css/ docs/0.6-incubating/img/ docs/0.6-incubating/img/quickstart-example/ docs/0.8/

2015-02-05 Thread rmetzger
Author: rmetzger Date: Thu Feb 5 12:21:38 2015 New Revision: 1657551 URL: http://svn.apache.org/r1657551 Log: Fix broken download links in 0.8 documentation of flink Modified: flink/site/blog/feed.xml flink/site/docs/0.6-incubating/building.html flink/site/docs/0.6-incubating

svn commit: r1657551 [5/9] - in /flink/site: blog/ docs/0.6-incubating/ docs/0.6-incubating/css/ docs/0.6-incubating/img/ docs/0.6-incubating/img/quickstart-example/ docs/0.8/

2015-02-05 Thread rmetzger
Modified: flink/site/docs/0.6-incubating/internal_general_arch.html URL: http://svn.apache.org/viewvc/flink/site/docs/0.6-incubating/internal_general_arch.html?rev=1657551r1=1657550r2=1657551view=diff == ---

svn commit: r1657551 [7/9] - in /flink/site: blog/ docs/0.6-incubating/ docs/0.6-incubating/css/ docs/0.6-incubating/img/ docs/0.6-incubating/img/quickstart-example/ docs/0.8/

2015-02-05 Thread rmetzger
Modified: flink/site/docs/0.6-incubating/local_setup.html URL: http://svn.apache.org/viewvc/flink/site/docs/0.6-incubating/local_setup.html?rev=1657551r1=1657550r2=1657551view=diff == ---

svn commit: r1657551 [3/9] - in /flink/site: blog/ docs/0.6-incubating/ docs/0.6-incubating/css/ docs/0.6-incubating/img/ docs/0.6-incubating/img/quickstart-example/ docs/0.8/

2015-02-05 Thread rmetzger
Modified: flink/site/docs/0.6-incubating/example_connectors.html URL: http://svn.apache.org/viewvc/flink/site/docs/0.6-incubating/example_connectors.html?rev=1657551r1=1657550r2=1657551view=diff == ---

svn commit: r1657551 [9/9] - in /flink/site: blog/ docs/0.6-incubating/ docs/0.6-incubating/css/ docs/0.6-incubating/img/ docs/0.6-incubating/img/quickstart-example/ docs/0.8/

2015-02-05 Thread rmetzger
Modified: flink/site/docs/0.8/faq.html URL: http://svn.apache.org/viewvc/flink/site/docs/0.8/faq.html?rev=1657551r1=1657550r2=1657551view=diff == --- flink/site/docs/0.8/faq.html (original) +++

svn commit: r1657551 [4/9] - in /flink/site: blog/ docs/0.6-incubating/ docs/0.6-incubating/css/ docs/0.6-incubating/img/ docs/0.6-incubating/img/quickstart-example/ docs/0.8/

2015-02-05 Thread rmetzger
Modified: flink/site/docs/0.6-incubating/how_to_contribute.html URL: http://svn.apache.org/viewvc/flink/site/docs/0.6-incubating/how_to_contribute.html?rev=1657551r1=1657550r2=1657551view=diff == ---

svn commit: r1657551 [2/9] - in /flink/site: blog/ docs/0.6-incubating/ docs/0.6-incubating/css/ docs/0.6-incubating/img/ docs/0.6-incubating/img/quickstart-example/ docs/0.8/

2015-02-05 Thread rmetzger
Modified: flink/site/docs/0.6-incubating/cluster_setup.html URL: http://svn.apache.org/viewvc/flink/site/docs/0.6-incubating/cluster_setup.html?rev=1657551r1=1657550r2=1657551view=diff == ---

flink git commit: [FLINK-1166] Add qa-check.sh tool

2015-02-06 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master b483230a0 - f6c85bc59 [FLINK-1166] Add qa-check.sh tool The ./tools/qa-check.sh tool allows developers to check for common errors before opening a pull request. The qa-checks are designed to be easily extensible by further checks. This

flink git commit: [FLINK-1488][yarn] Fix broken log file access

2015-02-06 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master e9c91e14c - a0e71b88a [FLINK-1488][yarn] Fix broken log file access Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a0e71b88 Tree:

svn commit: r1652422 [2/2] - in /flink: ./ _includes/ _layouts/ blog/ site/ site/blog/ site/blog/page2/ site/blog/page3/ site/docs/ site/news/2012/08/21/ site/news/2012/10/15/ site/news/2012/11/12/ si

2015-01-16 Thread rmetzger
Modified: flink/site/news/2014/04/16/stratosphere-goes-apache-incubator.html URL: http://svn.apache.org/viewvc/flink/site/news/2014/04/16/stratosphere-goes-apache-incubator.html?rev=1652422r1=1652421r2=1652422view=diff ==

Git Push Summary

2015-01-21 Thread rmetzger
Repository: flink Updated Tags: refs/tags/release-0.7.0 [created] 401ad4773 refs/tags/release-0.8.0 [created] 8b3a671b2

flink git commit: [FLINK-1504] support for secure HDFS access using kerberos

2015-02-11 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master aedbacfc5 - 82cda12ef [FLINK-1504] support for secure HDFS access using kerberos This closes #383 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/82cda12e Tree:

flink git commit: [FLINK-1492] Fix exceptions on blob store shutdown

2015-02-10 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master 7407076d3 - b88f909ce [FLINK-1492] Fix exceptions on blob store shutdown This closes #376 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b88f909c Tree:

flink git commit: [FLINK-1492] Fix exceptions on blob store shutdown

2015-02-10 Thread rmetzger
Repository: flink Updated Branches: refs/heads/release-0.8 e01712111 - 5b420d847 [FLINK-1492] Fix exceptions on blob store shutdown Conflicts: flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobCache.java

flink git commit: Commit for release 0.8.1

2015-02-10 Thread rmetzger
Repository: flink Updated Branches: refs/heads/release-0.8.1-rc0 [created] 70943ad56 Commit for release 0.8.1 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/70943ad5 Tree:

flink git commit: [build system] Add rat ignores for generated files

2015-02-12 Thread rmetzger
Repository: flink Updated Branches: refs/heads/release-0.8 90ab2bb4b - 65338cf61 [build system] Add rat ignores for generated files Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/65338cf6 Tree:

flink git commit: [build tools] Improve release scripts

2015-02-12 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master bc1432a2f - 988602b03 [build tools] Improve release scripts Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/988602b0 Tree:

flink git commit: Commit for release 0.8.1

2015-02-13 Thread rmetzger
Repository: flink Updated Branches: refs/heads/release-0.8.1-rc1 [created] bf1d877c0 Commit for release 0.8.1 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bf1d877c Tree:

flink git commit: Commit for release 0.8.1

2015-02-16 Thread rmetzger
Repository: flink Updated Branches: refs/heads/release-0.8.1-rc2 [created] b35e74602 Commit for release 0.8.1 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b35e7460 Tree:

svn commit: r1661087 - in /flink: ./ site/ site/blog/ site/blog/page2/ site/blog/page3/ site/docs/ site/docs/0.6-incubating/api/java/ site/docs/0.6-incubating/api/java/org/apache/flink/addons/hbase/ s

2015-02-20 Thread rmetzger
Author: rmetzger Date: Fri Feb 20 10:54:18 2015 New Revision: 1661087 URL: http://svn.apache.org/r1661087 Log: Update website for flink 0.8.1 [This commit notification would consist of 71 parts, which exceeds the limit of 50 ones, so it was shortened to the summary.]

flink git commit: Update references in 'release-0.8' branch to release 0.8.1

2015-02-20 Thread rmetzger
Repository: flink Updated Branches: refs/heads/release-0.8 8038d227d - ed0599fb6 Update references in 'release-0.8' branch to release 0.8.1 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ed0599fb Tree:

Git Push Summary

2015-02-20 Thread rmetzger
Repository: flink Updated Tags: refs/tags/release-0.8.1 [created] f9d6d3ce2

flink git commit: Update references in master to 0.8.1 release

2015-02-20 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master a51c02f6e - c46bdff0e Update references in master to 0.8.1 release Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c46bdff0 Tree:

[7/7] flink git commit: [FLINK-1567] Add option to switch between Avro and Kryo serialization

2015-02-18 Thread rmetzger
[FLINK-1567] Add option to switch between Avro and Kryo serialization This closes #393 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e6754a6d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e6754a6d Diff:

[2/7] flink git commit: [FLINK-1417] Automatically register types with Kryo

2015-02-18 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/354efec0/flink-java/src/test/java/org/apache/flink/api/java/typeutils/runtime/KryoVersusAvroMinibenchmark.java -- diff --git

[5/7] flink git commit: [FLINK-1391] Add support for using Avro-POJOs and Avro types with Kryo

2015-02-18 Thread rmetzger
[FLINK-1391] Add support for using Avro-POJOs and Avro types with Kryo Conflicts: flink-java/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/KryoSerializer.java Project:

[1/7] flink git commit: [FLINK-1417] Automatically register types with Kryo

2015-02-18 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master cfce493fe - e6754a6da http://git-wip-us.apache.org/repos/asf/flink/blob/354efec0/pom.xml -- diff --git a/pom.xml b/pom.xml index 85db257..f8a03b4 100644 --- a/pom.xml +++

[4/7] flink git commit: [FLINK-1395] Add support for JodaTime in KryoSerializer

2015-02-18 Thread rmetzger
[FLINK-1395] Add support for JodaTime in KryoSerializer Also fix tests for JodaTime. Conflicts: flink-dist/src/main/flink-bin/LICENSE flink-java/pom.xml flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/KryoSerializer.java

[6/7] flink git commit: [FLINK-1392] Add Kryo serializer for Protobuf

2015-02-18 Thread rmetzger
[FLINK-1392] Add Kryo serializer for Protobuf Conflicts: flink-java/pom.xml flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/KryoSerializer.java Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[3/7] flink git commit: [FLINK-1417] Automatically register types with Kryo

2015-02-18 Thread rmetzger
[FLINK-1417] Automatically register types with Kryo Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/354efec0 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/354efec0 Diff:

flink git commit: Fix NullPointerException in TaskManager

2015-02-17 Thread rmetzger
Repository: flink Updated Branches: refs/heads/release-0.8 eec39a2da - af50e5619 Fix NullPointerException in TaskManager Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/af50e561 Tree:

svn commit: r1654662 - in /flink: community.md site/community.html

2015-01-25 Thread rmetzger
Author: rmetzger Date: Sun Jan 25 15:13:35 2015 New Revision: 1654662 URL: http://svn.apache.org/r1654662 Log: [FLINK-1431] Add news@f.a.o list to website Modified: flink/community.md flink/site/community.html Modified: flink/community.md URL: http://svn.apache.org/viewvc/flink

flink git commit: [docs] Address comment from outdated github pull request This is the comment: https://github.com/apache/flink/pull/295#discussion_r22783345 The pull request has been merged through a

2015-01-26 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master e01057e8e - 5bc93e877 [docs] Address comment from outdated github pull request This is the comment: https://github.com/apache/flink/pull/295#discussion_r22783345 The pull request has been merged through a different commit. This closes

flink git commit: [FLINK-1389] Allow changing the filenames of the files created when writing to a directory

2015-01-26 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master ad31f6111 - 268ff7a06 [FLINK-1389] Allow changing the filenames of the files created when writing to a directory This closes #301 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-1389] Allow changing the filenames of the files created when writing to a directory

2015-01-26 Thread rmetzger
Repository: flink Updated Branches: refs/heads/release-0.8 cd96caf36 - 00117f7ff [FLINK-1389] Allow changing the filenames of the files created when writing to a directory This closes #301 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

svn commit: r1654661 - in /flink: how-to-contribute.md site/how-to-contribute.html

2015-01-25 Thread rmetzger
Author: rmetzger Date: Sun Jan 25 14:57:04 2015 New Revision: 1654661 URL: http://svn.apache.org/r1654661 Log: Remove all 'incubator' references from how to contribute guide Modified: flink/how-to-contribute.md flink/site/how-to-contribute.html Modified: flink/how-to-contribute.md URL

svn commit: r1654660 - in /flink: how-to-contribute.md site/how-to-contribute.html

2015-01-25 Thread rmetzger
Author: rmetzger Date: Sun Jan 25 14:49:55 2015 New Revision: 1654660 URL: http://svn.apache.org/r1654660 Log: [FLINK-1441] Fix svn repo url. Patch by Rahul Mahindrakar Modified: flink/how-to-contribute.md flink/site/how-to-contribute.html Modified: flink/how-to-contribute.md URL: http

flink git commit: Undo erroneous commit 86f87537

2015-01-12 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master 9f07373f3 - aba76171f Undo erroneous commit 86f87537 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/aba76171 Tree:

flink git commit: [FLINK-1495][yarn] Make Akka timeout configurable in YARN client.

2015-02-09 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master 52d9806ba - 46e052619 [FLINK-1495][yarn] Make Akka timeout configurable in YARN client. This closes #377 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/46e05261

flink git commit: [FLINK-1179] [jobmanager] Add button to JobManager web interface to request stack trace of a TaskManager

2015-02-14 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master 589b539c5 - da8c02b91 [FLINK-1179] [jobmanager] Add button to JobManager web interface to request stack trace of a TaskManager This closes #374 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-1473] Make abstract methods public in SplittableIterator

2015-02-11 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master c699557c1 - 1e9b68164 [FLINK-1473] Make abstract methods public in SplittableIterator Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1e9b6816 Tree:

flink git commit: [FLINK-1475] Decrease log level for yarn tests

2015-02-09 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master 6d49d1d6f - 2f16ca2db [FLINK-1475] Decrease log level for yarn tests Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2f16ca2d Tree:

[4/4] flink git commit: [FLINK-1391] Add support for using Avro-POJOs and Avro types with Kryo

2015-02-09 Thread rmetzger
[FLINK-1391] Add support for using Avro-POJOs and Avro types with Kryo Conflicts: flink-java/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/KryoSerializer.java Conflicts:

[3/4] flink git commit: [hotfix] Also use java closure cleaner on grouped operations

2015-02-09 Thread rmetzger
[hotfix] Also use java closure cleaner on grouped operations Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/95958a9b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/95958a9b Diff:

[1/4] flink git commit: [backports] Cleanup and port changes to 0.8 branch.

2015-02-09 Thread rmetzger
Repository: flink Updated Branches: refs/heads/release-0.8 02b6f85fe - 944e2e3d5 [backports] Cleanup and port changes to 0.8 branch. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/944e2e3d Tree:

[2/4] flink git commit: [FLINK-1392] Add Kryo serializer for Protobuf

2015-02-09 Thread rmetzger
[FLINK-1392] Add Kryo serializer for Protobuf Conflicts: flink-java/pom.xml flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/KryoSerializer.java Conflicts: flink-shaded/pom.xml pom.xml Project:

[1/3] flink git commit: [FLINK-1376] [runtime] Add proper shared slot release in case of a fatal TaskManager failure.

2015-02-09 Thread rmetzger
Repository: flink Updated Branches: refs/heads/release-0.8 44b799d6e - 91382bb8c http://git-wip-us.apache.org/repos/asf/flink/blob/91382bb8/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/scheduler/ScheduleWithCoLocationHintTest.java

[1/2] flink git commit: [FLINK-1391] Register common Avro types at Kryo

2015-02-12 Thread rmetzger
Repository: flink Updated Branches: refs/heads/release-0.8 bab2d4992 - 10f89c73b [FLINK-1391] Register common Avro types at Kryo Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/10f89c73 Tree:

Git Push Summary

2015-02-12 Thread rmetzger
Repository: flink Updated Branches: refs/heads/release-0.8.1-rc0 [deleted] 70943ad56

[2/2] flink git commit: [FLINK-1510] Make AvroInputFormat splittable

2015-02-12 Thread rmetzger
[FLINK-1510] Make AvroInputFormat splittable Conflicts: flink-runtime/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopDataInputStream.java flink-runtime/src/main/java/org/apache/flink/runtime/fs/s3/S3DataInputStream.java Project:

flink git commit: [FLINK-1510] Make AvroInputFormat splittable

2015-02-12 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master 46a675ccb - 3241214c7 [FLINK-1510] Make AvroInputFormat splittable This closes #387 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3241214c Tree:

flink git commit: [FLINK-1504] Fix YARN tests

2015-02-12 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master 004c115f7 - 081a7ddda [FLINK-1504] Fix YARN tests Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/081a7ddd Tree:

flink git commit: [yarn-tests] Fix potential NullPointerException

2015-03-16 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master 36b762e43 - 1950d0568 [yarn-tests] Fix potential NullPointerException Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1950d056 Tree:

flink git commit: [hotfix] Fix issue with nested Avro types

2015-03-15 Thread rmetzger
Repository: flink Updated Branches: refs/heads/release-0.8 095301e02 - 2f94d4257 [hotfix] Fix issue with nested Avro types Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2f94d425 Tree:

svn commit: r1667227 - in /flink: _posts/ site/blog/ site/blog/page2/ site/blog/page3/ site/img/blog/ site/news/2015/03/13/

2015-03-17 Thread rmetzger
Author: rmetzger Date: Tue Mar 17 10:05:20 2015 New Revision: 1667227 URL: http://svn.apache.org/r1667227 Log: Add join blog post to website Added: flink/site/img/blog/joins-broadcast.png (with props) flink/site/img/blog/joins-dist-perf.png (with props) flink/site/img/blog/joins

svn commit: r1667244 - in /flink: _config.yml downloads.md site/downloads.html

2015-03-17 Thread rmetzger
Author: rmetzger Date: Tue Mar 17 10:28:25 2015 New Revision: 1667244 URL: http://svn.apache.org/r1667244 Log: Remove YARN nightly from website Modified: flink/_config.yml flink/downloads.md flink/site/downloads.html Modified: flink/_config.yml URL: http://svn.apache.org/viewvc

[1/3] flink git commit: [FLINK-1752][streaming] Rework and improve Kafka connectors

2015-03-19 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master 5c6603e29 - c0917f237 [FLINK-1752][streaming] Rework and improve Kafka connectors Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b18c66b5 Tree:

[3/3] flink git commit: [FLINK-1752][streaming] Add KafkaITCase and various bugfixes

2015-03-19 Thread rmetzger
[FLINK-1752][streaming] Add KafkaITCase and various bugfixes This closes #500 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c0917f23 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c0917f23 Diff:

[2/3] flink git commit: [FLINK-1752][streaming] Add KafkaITCase and various bugfixes

2015-03-19 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/c0917f23/flink-staging/flink-streaming/flink-streaming-connectors/src/main/java/org/apache/flink/streaming/connectors/kafka/config/EncoderWrapper.java -- diff --git

flink git commit: [FLINK-1637] Reduce number of files in uberjar for java 6

2015-03-09 Thread rmetzger
/create_release_files.sh @@ -28,6 +28,11 @@ # # https://github.com/apache/spark/blob/master/dev/create-release/create-release.sh # + +# Added by rmetzger +echo Please make sure to use java 6 OPENJDK (not oracle) to build the release binaries +exit 1 + CURR_DIR=`pwd` if [[ `basename $CURR_DIR

[2/2] flink git commit: [FLINK-1629][FLINK-1630][FLINK-1547] Add option to start Flink on YARN in a detached mode. YARN container reallocation.

2015-03-12 Thread rmetzger
[FLINK-1629][FLINK-1630][FLINK-1547] Add option to start Flink on YARN in a detached mode. YARN container reallocation. This commit is changing: [FLINK-1629]: users can now fire and forget jobs to YARN or YARN sessions to there. (Detached mode) [FLINK-1630]: YARN is now reallocating failed YARN

[1/2] flink git commit: [FLINK-1629][FLINK-1630][FLINK-1547] Add option to start Flink on YARN in a detached mode. YARN container reallocation.

2015-03-12 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master fd9ca4def - 13bb21b1b http://git-wip-us.apache.org/repos/asf/flink/blob/13bb21b1/flink-yarn/src/main/scala/org/apache/flink/yarn/ApplicationMasterActor.scala -- diff --git

flink git commit: [FLINK-1567] Add switch to use the AvroSerializer for GenericTypeInfo

2015-03-10 Thread rmetzger
Repository: flink Updated Branches: refs/heads/release-0.8 88c7ea256 - 9f18cbb3a [FLINK-1567] Add switch to use the AvroSerializer for GenericTypeInfo This closes #413 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

  1   2   3   4   5   6   7   8   9   >