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:
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
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:
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:
[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:
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
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:
[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:
[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:
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
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
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
[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:
[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:
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
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:
16 matches
Mail list logo