flink git commit: [FLINK-3067] Enforce zkclient 0.7 for Kafka

2015-11-25 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master 008060f16 -> 2c507f933 [FLINK-3067] Enforce zkclient 0.7 for Kafka This closes #1399 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2c507f93 Tree:

[1/2] flink git commit: [FLINK-3000] Adds shutdown hook to clean up lingering yarn sessions

2015-11-25 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master 90c76ad1c -> 008060f16 [FLINK-3000] Adds shutdown hook to clean up lingering yarn sessions This closes #1354 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/aad99f25

flink git commit: [docs][streaming] fix code examples which use 'implements'

2015-11-25 Thread mxm
Repository: flink Updated Branches: refs/heads/master 6216acf30 -> 8fddbf06c [docs][streaming] fix code examples which use 'implements' - replace "implements" with "extends" where applicable Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-3067] Enforce zkclient 0.7 for Kafka

2015-11-25 Thread rmetzger
Repository: flink Updated Branches: refs/heads/release-0.10 86b6605d6 -> 0b6adc4c5 [FLINK-3067] Enforce zkclient 0.7 for Kafka This closes #1399 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0b6adc4c Tree:

[2/2] flink git commit: [hotfix] Register signal handler for JobManager and TaskManager

2015-11-25 Thread rmetzger
[hotfix] Register signal handler for JobManager and TaskManager This closes #1400 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/008060f1 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/008060f1 Diff:

flink git commit: [github] change tab size to 4 spaces

2015-11-25 Thread mxm
Repository: flink Updated Branches: refs/heads/master 2c507f933 -> 6216acf30 [github] change tab size to 4 spaces The default tab size on GitHub is 8 spaces. This change decreases the tab size to 4. I think this will make reviewing of code on GitHub much easier. This commit also introduces

[1/2] flink git commit: [docs] Fix typos in streaming documentation

2015-11-25 Thread fhueske
Repository: flink Updated Branches: refs/heads/release-0.10 0b6adc4c5 -> 16e5ab09f [docs] Fix typos in streaming documentation Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/efbfc6ae Tree:

[2/2] flink git commit: [docs][hotfix] Fix wrong window definitions in the docs

2015-11-25 Thread fhueske
[docs][hotfix] Fix wrong window definitions in the docs This closes #1407 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/16e5ab09 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/16e5ab09 Diff:

[6/8] flink git commit: [FLINK-3059] Improve JavaDocs for DataSet.writeAsText()

2015-11-25 Thread fhueske
[FLINK-3059] Improve JavaDocs for DataSet.writeAsText() Currently the JavaDocs of writeAsText() state it simply generates a file, but this is not always true and it depends on the environment configuration. This commit improves the JavaDocs of writeAsText(). This closes #1392 Project:

[3/8] flink git commit: [FLINK-2906] Remove Record API

2015-11-25 Thread fhueske
http://git-wip-us.apache.org/repos/asf/flink/blob/c787a037/flink-java/src/main/java/org/apache/flink/api/java/record/operators/DeltaIteration.java -- diff --git

[2/8] flink git commit: [FLINK-2906] Remove Record API

2015-11-25 Thread fhueske
http://git-wip-us.apache.org/repos/asf/flink/blob/c787a037/flink-java/src/test/java/org/apache/flink/api/java/record/ReduceWrappingFunctionTest.java -- diff --git

[1/8] flink git commit: [FLINK-2906] Remove Record API

2015-11-25 Thread fhueske
Repository: flink Updated Branches: refs/heads/master 8fddbf06c -> dcce6def9 http://git-wip-us.apache.org/repos/asf/flink/blob/c787a037/flink-test-utils/src/main/java/org/apache/flink/test/util/RecordAPITestBase.java -- diff

[8/8] flink git commit: [docs][hotfix] Fix wrong window definitions in the docs

2015-11-25 Thread fhueske
[docs][hotfix] Fix wrong window definitions in the docs This closes #1407 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/dcce6def Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/dcce6def Diff:

[7/8] flink git commit: [typo-fix] Fix typo in DelimitedInputFormat.java

2015-11-25 Thread fhueske
[typo-fix] Fix typo in DelimitedInputFormat.java This closes #1405 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/804611ce Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/804611ce Diff:

[4/8] flink git commit: [FLINK-2906] Remove Record API

2015-11-25 Thread fhueske
http://git-wip-us.apache.org/repos/asf/flink/blob/c787a037/flink-java/src/main/java/org/apache/flink/api/java/record/io/DelimitedOutputFormat.java -- diff --git

flink git commit: [FLINK-3072] [streaming] Ensure Derby server starts before running any tests

2015-11-25 Thread gyfora
Repository: flink Updated Branches: refs/heads/master 25ef3240c -> 90c76ad1c [FLINK-3072] [streaming] Ensure Derby server starts before running any tests Closes #1401 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: