flink git commit: [FLINK-1406] [documentation] update compatibility notice with link to further documentation

2015-01-23 Thread fhueske
Repository: flink Updated Branches: refs/heads/master 8f8efe2f5 - 96585f149 [FLINK-1406] [documentation] update compatibility notice with link to further documentation This closes #314 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[1/4] flink git commit: [FLINK-1318] [docs] Added documentation for CSV parsing options.

2015-02-05 Thread fhueske
Repository: flink Updated Branches: refs/heads/master 5e1cc9e21 - a19b4a02b [FLINK-1318] [docs] Added documentation for CSV parsing options. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/27a479fe Tree:

[2/4] flink git commit: [FLINK-1318] [api-breaking] Simplified quoted string parsing, made it optional, and use a configurable quote character

2015-02-05 Thread fhueske
[FLINK-1318] [api-breaking] Simplified quoted string parsing, made it optional, and use a configurable quote character This closes #265 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2665cf4e Tree:

[3/4] flink git commit: [FLINK-1443 [api-breaking] Extended split assigner interface by parallel task id.

2015-02-05 Thread fhueske
[FLINK-1443 [api-breaking] Extended split assigner interface by parallel task id. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7452802b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7452802b Diff:

flink git commit: [FLINK-1490][fix][java-api] Fix incorrect local output sorting of nested types with field position keys.

2015-02-06 Thread fhueske
Repository: flink Updated Branches: refs/heads/master a0e71b88a - 6187292bc [FLINK-1490][fix][java-api] Fix incorrect local output sorting of nested types with field position keys. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-1485][documentation] Fix typo in Java join function example.

2015-02-06 Thread fhueske
Repository: flink Updated Branches: refs/heads/master 6187292bc - 76dd725d7 [FLINK-1485][documentation] Fix typo in Java join function example. This closes #369 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/76dd725d

[1/2] flink git commit: [FLINK-1112] Additional checks for KeySelector group sorting and minor fixes

2015-01-15 Thread fhueske
Repository: flink Updated Branches: refs/heads/master ba7a19c10 - 2b16c6042 [FLINK-1112] Additional checks for KeySelector group sorting and minor fixes Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2b16c604 Tree:

flink git commit: [FLINK-1419] [runtime] Fix: distributed cache properly synchronized

2015-02-01 Thread fhueske
Repository: flink Updated Branches: refs/heads/master 31641a68e - 563e54623 [FLINK-1419] [runtime] Fix: distributed cache properly synchronized This closes #339 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/563e5462

[4/4] flink git commit: [FLINK-1443] Added support for replicated data sources. Introduced new PartitioningProperty for any distribution (random partitioning or full replication).

2015-02-05 Thread fhueske
[FLINK-1443] Added support for replicated data sources. Introduced new PartitioningProperty for any distribution (random partitioning or full replication). Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a19b4a02 Tree:

flink git commit: [FLINK-1654] [docs] Fix scala example in programming guide

2015-03-11 Thread fhueske
Repository: flink Updated Branches: refs/heads/master 84e76f4d3 - fd9ca4def [FLINK-1654] [docs] Fix scala example in programming guide This closes #478 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fd9ca4de Tree:

svn commit: r1666595 - /flink/_posts/2015-03-13-peeking-into-Apache-Flinks-Engine-Room.md

2015-03-13 Thread fhueske
Author: fhueske Date: Fri Mar 13 22:04:36 2015 New Revision: 1666595 URL: http://svn.apache.org/r1666595 Log: Fixed typos in join blog post (2) Modified: flink/_posts/2015-03-13-peeking-into-Apache-Flinks-Engine-Room.md Modified: flink/_posts/2015-03-13-peeking-into-Apache-Flinks-Engine

svn commit: r1666430 - in /flink: css/main/main.css site/css/main/main.css

2015-03-13 Thread fhueske
Author: fhueske Date: Fri Mar 13 12:50:03 2015 New Revision: 1666430 URL: http://svn.apache.org/r1666430 Log: Fixed bullet points for unordered lists Modified: flink/css/main/main.css flink/site/css/main/main.css Modified: flink/css/main/main.css URL: http://svn.apache.org/viewvc/flink

flink git commit: [FLINK-1683] [jobmanager] Fix scheduling preference choice for non-unary execution tasks.

2015-03-13 Thread fhueske
Repository: flink Updated Branches: refs/heads/master 81ebe980a - 07a9a56c1 [FLINK-1683] [jobmanager] Fix scheduling preference choice for non-unary execution tasks. This closes #476 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

svn commit: r1666431 - in /flink: _posts/ img/blog/

2015-03-13 Thread fhueske
Author: fhueske Date: Fri Mar 13 12:51:43 2015 New Revision: 1666431 URL: http://svn.apache.org/r1666431 Log: Added ready-to-publish Join Blog Post Added: flink/_posts/2015-03-13-peeking-into-Apache-Flinks-Engine-Room.md flink/img/blog/joins-broadcast.png (with props) flink/img

flink git commit: [FLINK-1683] [jobmanager] Fix scheduling preference choice for non-unary execution tasks.

2015-03-13 Thread fhueske
Repository: flink Updated Branches: refs/heads/release-0.8 9f18cbb3a - 095301e02 [FLINK-1683] [jobmanager] Fix scheduling preference choice for non-unary execution tasks. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-1628] [optimizer] Fix partitioning properties for Joins and CoGroups.

2015-03-10 Thread fhueske
Repository: flink Updated Branches: refs/heads/release-0.8 d573926ab - 88c7ea256 [FLINK-1628] [optimizer] Fix partitioning properties for Joins and CoGroups. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/88c7ea25 Tree:

[1/5] flink git commit: [FLINK-1512] [tests] Add integration tests for CsvReader

2015-03-25 Thread fhueske
Repository: flink Updated Branches: refs/heads/master 033c69f94 - 1b42b6206 [FLINK-1512] [tests] Add integration tests for CsvReader This closes #426 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/43ac967a Tree:

[4/4] flink git commit: [FLINK-1466] Add support for complex types in Flink tuples for HCatInputFormats.

2015-02-20 Thread fhueske
[FLINK-1466] Add support for complex types in Flink tuples for HCatInputFormats. This closes #411 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bed3da4a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/bed3da4a

flink git commit: Add missing import.

2015-03-27 Thread fhueske
Repository: flink Updated Branches: refs/heads/master d11e09108 - 659ddc048 Add missing import. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/659ddc04 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/659ddc04

[2/3] flink git commit: [FLINK-703] [java api] Use complete element as join key

2015-04-22 Thread fhueske
[FLINK-703] [java api] Use complete element as join key Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/30a74c76 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/30a74c76 Diff:

[1/3] flink git commit: [FLINK-703] [scala api] Use complete element as join key

2015-04-22 Thread fhueske
Repository: flink Updated Branches: refs/heads/master e1618e287 - a0147c493 [FLINK-703] [scala api] Use complete element as join key This closes #572 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/45e680c2 Tree:

[3/3] flink git commit: [FLINK-1891] Add check for empty storageDirectory path

2015-04-22 Thread fhueske
[FLINK-1891] Add check for empty storageDirectory path This closes #601 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a0147c49 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a0147c49 Diff:

flink git commit: [FLINK-1978] Fix POJO deserialization for reuse objects with NULL fields

2015-05-07 Thread fhueske
Repository: flink Updated Branches: refs/heads/release-0.8 ffc86f668 - d9afefb0e [FLINK-1978] Fix POJO deserialization for reuse objects with NULL fields Backported fix. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[3/4] flink git commit: [FLINK-1682] Ported optimizer unit tests from Record API to Java API

2015-05-05 Thread fhueske
http://git-wip-us.apache.org/repos/asf/flink/blob/bd96ba8d/flink-optimizer/src/test/java/org/apache/flink/optimizer/PartitioningReusageTest.java -- diff --git

[2/4] flink git commit: [FLINK-1682] Ported optimizer unit tests from Record API to Java API

2015-05-05 Thread fhueske
http://git-wip-us.apache.org/repos/asf/flink/blob/bd96ba8d/flink-optimizer/src/test/java/org/apache/flink/optimizer/util/OperatorResolver.java -- diff --git

[1/4] flink git commit: [FLINK-1951] Fix NullPointerException in delta iteration due to missing temp

2015-05-05 Thread fhueske
Repository: flink Updated Branches: refs/heads/master 60ec68308 - bd96ba8d1 [FLINK-1951] Fix NullPointerException in delta iteration due to missing temp This closes #641 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/3] flink-web git commit: Added blog post about how Flink operates on binary data

2015-05-12 Thread fhueske
operations on binary data and makes more data fit into memory./li +liFlink’s DBMS-style operators operate natively on binary data yielding high performance in-memory and destage gracefully to disk if necessary./li +/ul + +pbr +smallWritten by Fabian Hueske (a href=https://twitter.com/fhueske

flink git commit: [FLINK-1975][gelly] Graph getUndirected improvement

2015-05-15 Thread fhueske
Repository: flink Updated Branches: refs/heads/master 8f28f41dc - beb7f3122 [FLINK-1975][gelly] Graph getUndirected improvement This closes #653 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/beb7f312 Tree:

[2/2] flink git commit: [FLINK-1820] Consistent behavior of numeric value parsers.

2015-05-19 Thread fhueske
[FLINK-1820] Consistent behavior of numeric value parsers. This closes #566 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/39d526e6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/39d526e6 Diff:

[2/3] flink git commit: Additional tests for Path.isAbsolute()

2015-04-07 Thread fhueske
Additional tests for Path.isAbsolute() Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/23fe0062 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/23fe0062 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/23fe0062

[3/3] flink git commit: [FLINK-1817] Fix ClassLoaderObjectInputStream to support primitive type classes

2015-04-07 Thread fhueske
[FLINK-1817] Fix ClassLoaderObjectInputStream to support primitive type classes This closes #565 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d33b4454 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d33b4454 Diff:

[5/5] flink git commit: [FLINK-1664] Adds check if a selected sort key is sortable

2015-04-03 Thread fhueske
[FLINK-1664] Adds check if a selected sort key is sortable This closes #541 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f36eb54e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f36eb54e Diff:

[4/5] flink git commit: [FLINK-1776] Add offsets to field indexes of semantic properties for operators with key selectors

2015-04-03 Thread fhueske
[FLINK-1776] Add offsets to field indexes of semantic properties for operators with key selectors This closes #532 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f39aec82 Tree:

[3/5] flink git commit: [FLINK-1776] Add offsets to field indexes of semantic properties for operators with key selectors

2015-04-03 Thread fhueske
http://git-wip-us.apache.org/repos/asf/flink/blob/f39aec82/flink-java/src/test/java/org/apache/flink/api/java/functions/SemanticPropUtilTest.java -- diff --git

[1/3] flink git commit: [FLINK-1832] [scripts] fix conversion to Windows path with spaces

2015-04-08 Thread fhueske
Repository: flink Updated Branches: refs/heads/master 07aff921b - 0afed4dcf [FLINK-1832] [scripts] fix conversion to Windows path with spaces Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ae6ff29d Tree:

[3/3] flink git commit: [FLINK-1840] Fix BLOB manager on Windows

2015-04-08 Thread fhueske
[FLINK-1840] Fix BLOB manager on Windows This closes #578 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0afed4dc Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0afed4dc Diff:

[3/3] flink git commit: [FLINK-1840] Fix BLOB manager on Windows

2015-04-08 Thread fhueske
[FLINK-1840] Fix BLOB manager on Windows Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8f126a31 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8f126a31 Diff:

[1/3] flink git commit: [FLINK-1832] [scripts] fix conversion to Windows path with spaces

2015-04-08 Thread fhueske
Repository: flink Updated Branches: refs/heads/release-0.9.0-milestone-1 287b4e9a3 - 8f126a314 [FLINK-1832] [scripts] fix conversion to Windows path with spaces Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3ec0c190

[2/3] flink git commit: [FLINK-1832] [scripts] fix start scripts for Cygwin and paths with spaces.

2015-04-08 Thread fhueske
[FLINK-1832] [scripts] fix start scripts for Cygwin and paths with spaces. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8b9ba524 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8b9ba524 Diff:

[2/2] flink git commit: [FLINK-1832] [scripts] fix start scripts for Cygwin and paths with spaces.

2015-04-08 Thread fhueske
[FLINK-1832] [scripts] fix start scripts for Cygwin and paths with spaces. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f2ee7838 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f2ee7838 Diff:

flink-web git commit: Fixed link to list of starter tasks

2015-06-05 Thread fhueske
Repository: flink-web Updated Branches: refs/heads/asf-site 5b6e5b6ca - fee4a5dda Fixed link to list of starter tasks Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/fee4a5dd Tree:

flink git commit: [FLINK-2196] [javaAPI] Moved misplaced SortPartitionOperator class

2015-06-10 Thread fhueske
Repository: flink Updated Branches: refs/heads/master b5b71e1c4 - a8e085078 [FLINK-2196] [javaAPI] Moved misplaced SortPartitionOperator class This closes #817 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a8e08507

flink git commit: [FLINK-2199] Escape UTF characters in Scala Shell welcome squirrel.

2015-06-11 Thread fhueske
Repository: flink Updated Branches: refs/heads/master 63b8c3647 - 2ea1e7db2 [FLINK-2199] Escape UTF characters in Scala Shell welcome squirrel. This closes #821 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2ea1e7db

flink git commit: [hotfix] Removed execute() that followed print() in quickstart wordcount jobs

2015-06-16 Thread fhueske
Repository: flink Updated Branches: refs/heads/master b59c81bc4 - d38154129 [hotfix] Removed execute() that followed print() in quickstart wordcount jobs Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d3815412 Tree:

flink git commit: [hotfix] Removed execute() that followed print() in quickstart wordcount jobs

2015-06-16 Thread fhueske
Repository: flink Updated Branches: refs/heads/release-0.9 2359b49f5 - 0a8142a99 [hotfix] Removed execute() that followed print() in quickstart wordcount jobs Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0a8142a9 Tree:

flink git commit: [FLINK-2207] Fix TableAPI conversion documenation and further renamings for consistency.

2015-06-12 Thread fhueske
Repository: flink Updated Branches: refs/heads/master e45c5dc56 - e4b569505 [FLINK-2207] Fix TableAPI conversion documenation and further renamings for consistency. This closes #829 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[1/4] flink git commit: [FLINK-2206] Fix incorrect counts of finished, canceled, and failed jobs in webinterface

2015-06-12 Thread fhueske
Repository: flink Updated Branches: refs/heads/release-0.9 ecfde6dd9 - f5f0709c9 [FLINK-2206] Fix incorrect counts of finished, canceled, and failed jobs in webinterface This closes #826 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[3/4] flink git commit: [FLINK-2072] [ml] Adds quickstart guide

2015-06-12 Thread fhueske
[FLINK-2072] [ml] Adds quickstart guide This closes #792. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/40e2df5a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/40e2df5a Diff:

[4/4] flink git commit: [FLINK-2194] [type extractor] Excludes Writable type from WritableTypeInformation to be treated as an interface

2015-06-12 Thread fhueske
[FLINK-2194] [type extractor] Excludes Writable type from WritableTypeInformation to be treated as an interface This closes #814. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f5f0709c Tree:

[2/4] flink git commit: [FLINK-2207] Fix TableAPI conversion documenation and further renamings for consistency.

2015-06-12 Thread fhueske
[FLINK-2207] Fix TableAPI conversion documenation and further renamings for consistency. This closes #829 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/af0fee51 Tree:

flink git commit: [FLINK-2061] [java api] Fix GenericCsvInputFormat skipping fields error with quoted string

2015-05-29 Thread fhueske
Repository: flink Updated Branches: refs/heads/master 7cb35ea91 - 12cd15622 [FLINK-2061] [java api] Fix GenericCsvInputFormat skipping fields error with quoted string This closes #734 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [quickfix] Made recursive enumeration parameter flag public in FileInputFormat

2015-05-26 Thread fhueske
Repository: flink Updated Branches: refs/heads/master eba6f9a2f - baeedba5d [quickfix] Made recursive enumeration parameter flag public in FileInputFormat Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/baeedba5 Tree:

[1/2] flink git commit: [FLINK-2043] Change the KMeansDataGenerator to allow passing a custom path

2015-05-26 Thread fhueske
Repository: flink Updated Branches: refs/heads/master 21207fd52 - 3586ced35 [FLINK-2043] Change the KMeansDataGenerator to allow passing a custom path This closes #721 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/2] flink git commit: [FLINK-1848] Fix for file paths with Windows drive letters

2015-05-26 Thread fhueske
[FLINK-1848] Fix for file paths with Windows drive letters This closes #712 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7164b2b6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7164b2b6 Diff:

flink git commit: [FLINK-2095][docs] Added missing screenshots to webclient documentation

2015-08-03 Thread fhueske
Repository: flink Updated Branches: refs/heads/master 949ff8dae - 2859f59f8 [FLINK-2095][docs] Added missing screenshots to webclient documentation This closes #976 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-2422] [web client] Added explicit link in case browser is not redirecting properly

2015-08-03 Thread fhueske
Repository: flink Updated Branches: refs/heads/master 2859f59f8 - bb5e61d24 [FLINK-2422] [web client] Added explicit link in case browser is not redirecting properly This closes #946 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-2422] [web client] Added explicit link in case browser is not redirecting properly

2015-08-03 Thread fhueske
Repository: flink Updated Branches: refs/heads/release-0.9 0186a979f - acb6ea81a [FLINK-2422] [web client] Added explicit link in case browser is not redirecting properly Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/4] flink git commit: [FLINK-1882] Removed RemotedCollector classes

2015-08-05 Thread fhueske
[FLINK-1882] Removed RemotedCollector classes This closes #985 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/100e8c5f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/100e8c5f Diff:

[3/4] flink git commit: [FLINK-1680] Remove Tachyon test and rename Maven module to flink-fs-tests

2015-08-05 Thread fhueske
[FLINK-1680] Remove Tachyon test and rename Maven module to flink-fs-tests This closes #987 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fb7e6342 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fb7e6342 Diff:

[4/4] flink git commit: [FLINK-2467] Example WordCountStorm.jar is not packaged correctly - fixed assembly xml file

2015-08-05 Thread fhueske
[FLINK-2467] Example WordCountStorm.jar is not packaged correctly - fixed assembly xml file This closes #974 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0aa6f0cb Tree:

[1/4] flink git commit: [FLINK-2447] [java api] TypeExtractor returns wrong type info when a Tuple has two fields of the same POJO type

2015-08-05 Thread fhueske
Repository: flink Updated Branches: refs/heads/master 941ac6dfd - fb7e63422 [FLINK-2447] [java api] TypeExtractor returns wrong type info when a Tuple has two fields of the same POJO type This closes #986 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-2447] [java api] TypeExtractor returns wrong type info when a Tuple has two fields of the same POJO type

2015-08-05 Thread fhueske
Repository: flink Updated Branches: refs/heads/release-0.9 80d3478c0 - ec3b98327 [FLINK-2447] [java api] TypeExtractor returns wrong type info when a Tuple has two fields of the same POJO type Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: Revert API-breaking change: [FLINK-2238][api] Generalized fromCollection(Seq) to fromCollection(Iterable)

2015-08-03 Thread fhueske
Repository: flink Updated Branches: refs/heads/release-0.9 012dd0503 - 0186a979f Revert API-breaking change: [FLINK-2238][api] Generalized fromCollection(Seq) to fromCollection(Iterable) This reverts commit 3e31ea647c76c85cd2371427b5735cb2d9a84266. Project:

[4/5] flink git commit: [FLINK-2105] [tests] Move duplicate utility classes to testutil package

2015-08-04 Thread fhueske
[FLINK-2105] [tests] Move duplicate utility classes to testutil package Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/df9f4819 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/df9f4819 Diff:

[5/5] flink git commit: [FLINK-2105] Implement Sort-Merge Outer Join algorithm

2015-08-04 Thread fhueske
[FLINK-2105] Implement Sort-Merge Outer Join algorithm This closes #907 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/941ac6df Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/941ac6df Diff:

[3/5] flink git commit: [FLINK-2105] [tests] Move duplicate utility classes to testutil package

2015-08-04 Thread fhueske
http://git-wip-us.apache.org/repos/asf/flink/blob/df9f4819/flink-runtime/src/test/java/org/apache/flink/runtime/operators/testutils/MatchRemovingMatcher.java -- diff --git

[2/3] flink git commit: [FLINK-2205] Fix confusing entries in JobManager WebUI JobConfig section.

2015-08-04 Thread fhueske
[FLINK-2205] Fix confusing entries in JobManager WebUI JobConfig section. Default display for 'Number of execution retries' is now 'deactivated' and for 'Job parallelism' is 'auto', as suggested in JIRA. This closes #927 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/2] flink git commit: [FLINK-2442] [fix] FieldPositionKeys support Pojo fields

2015-08-04 Thread fhueske
[FLINK-2442] [fix] FieldPositionKeys support Pojo fields Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/80d3478c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/80d3478c Diff:

[1/3] flink git commit: [FLINK-2005] Remove Record API from jdbc module

2015-08-04 Thread fhueske
Repository: flink Updated Branches: refs/heads/master d570d078a - 30761572b [FLINK-2005] Remove Record API from jdbc module This closes #982 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/06b37bf5 Tree:

[3/3] flink git commit: [FLINK-2442] [fix] FieldPositionKeys support Pojo fields

2015-08-04 Thread fhueske
[FLINK-2442] [fix] FieldPositionKeys support Pojo fields This closes #963 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/30761572 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/30761572 Diff:

[1/2] flink git commit: [FLINK-2205] Fix confusing entries in JobManager WebUI JobConfig section.

2015-08-04 Thread fhueske
Repository: flink Updated Branches: refs/heads/release-0.9 acb6ea81a - 80d3478c0 [FLINK-2205] Fix confusing entries in JobManager WebUI JobConfig section. Default display for 'Number of execution retries' is now 'deactivated' and for 'Job parallelism' is 'auto', as suggested in JIRA.

[1/5] flink git commit: [FLINK-2105] Extract abstract superclass, interface from MergeMatchIterators, KeyGroupedIterators

2015-08-04 Thread fhueske
Repository: flink Updated Branches: refs/heads/master 30761572b - 941ac6dfd [FLINK-2105] Extract abstract superclass, interface from MergeMatchIterators, KeyGroupedIterators Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/5] flink git commit: [FLINK-2105] Add support for sorted but sparse test data generation

2015-08-04 Thread fhueske
[FLINK-2105] Add support for sorted but sparse test data generation Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/db0b0087 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/db0b0087 Diff:

flink git commit: [FLINK-2359] [java api] Add factory methods to the Java TupleX types

2015-07-17 Thread fhueske
Repository: flink Updated Branches: refs/heads/master 08ca9ffa9 - 2d191ab05 [FLINK-2359] [java api] Add factory methods to the Java TupleX types This closes #911 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2d191ab0

flink git commit: [FLINK-2353] Respect JobConfigurable interface in Hadoop mapred wrappers

2015-07-14 Thread fhueske
Repository: flink Updated Branches: refs/heads/master 84b39dcb5 - 91675296e [FLINK-2353] Respect JobConfigurable interface in Hadoop mapred wrappers This closes #908 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-2280] GenericTypeComparator.compare() respects ascending flag

2015-07-14 Thread fhueske
Repository: flink Updated Branches: refs/heads/release-0.9 acd43176e - 451eb8245 [FLINK-2280] GenericTypeComparator.compare() respects ascending flag This closes #894 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-1963] Improve distinct() transformation

2015-07-16 Thread fhueske
Repository: flink Updated Branches: refs/heads/master c06213706 - 08ca9ffa9 [FLINK-1963] Improve distinct() transformation This closes #905 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/08ca9ffa Tree:

[1/2] flink git commit: [FLINK-2874] Fix Avro getter/setter recognition

2015-10-23 Thread fhueske
Repository: flink Updated Branches: refs/heads/release-0.9 96099951e -> ab694a3b2 [FLINK-2874] Fix Avro getter/setter recognition This closes #1252 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4392cf25 Tree:

[2/4] flink git commit: [FLINK-2893] [runtime] Consistent naming of recovery config parameters

2015-10-23 Thread fhueske
[FLINK-2893] [runtime] Consistent naming of recovery config parameters Rename config key prefix from 'ha.zookeeper' to 'recovery.zookeeper' Rename config key from 'state.backend.fs.dir.recovery' => 'state.backend.fs.recoverydir' Move ZooKeeper file system state backend configuration keys This

[3/4] flink git commit: [FLINK-1982] [record-api] Remove dependencies on Record API from flink-runtime tests

2015-10-23 Thread fhueske
http://git-wip-us.apache.org/repos/asf/flink/blob/c0d7073a/flink-runtime/src/test/java/org/apache/flink/runtime/operators/MatchTaskTest.java -- diff --git

[2/5] flink git commit: [FLINK-1982] [record-api] Remove dependencies on Record API from flink-runtime tests

2015-10-23 Thread fhueske
[FLINK-1982] [record-api] Remove dependencies on Record API from flink-runtime tests Rename Match*Test to Join*Test and MapTaskTest to FlatMapTaskTest This closes #1294 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[4/4] flink git commit: [FLINK-1982] [record-api] Remove dependencies on Record API from flink-runtime tests

2015-10-23 Thread fhueske
[FLINK-1982] [record-api] Remove dependencies on Record API from flink-runtime tests Rename Match*Test to Join*Test and MapTaskTest to FlatMapTaskTest This closes #1294 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[1/4] flink git commit: [FLINK-2895] Duplicate immutable object creation

2015-10-23 Thread fhueske
Repository: flink Updated Branches: refs/heads/release-0.10 712c868eb -> 15d3f10c1 [FLINK-2895] Duplicate immutable object creation Operators defer object creation when object reuse is disabled. This closes #1288 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[1/5] flink git commit: [FLINK-1982] [record-api] Remove dependencies on Record API from flink-runtime tests

2015-10-23 Thread fhueske
Repository: flink Updated Branches: refs/heads/master 7ff071f66 -> bbb75c599 http://git-wip-us.apache.org/repos/asf/flink/blob/3c8a6588/flink-runtime/src/test/java/org/apache/flink/runtime/operators/MatchTaskTest.java -- diff

[3/5] flink git commit: [FLINK-2893] [runtime] Consistent naming of recovery config parameters

2015-10-23 Thread fhueske
[FLINK-2893] [runtime] Consistent naming of recovery config parameters Rename config key prefix from 'ha.zookeeper' to 'recovery.zookeeper' Rename config key from 'state.backend.fs.dir.recovery' => 'state.backend.fs.recoverydir' Move ZooKeeper file system state backend configuration keys This

[4/5] flink git commit: [FLINK-2898] [build] Invert Travis CI build order

2015-10-23 Thread fhueske
[FLINK-2898] [build] Invert Travis CI build order This closes #1290 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d2e4a27d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d2e4a27d Diff:

[1/8] flink git commit: [FLINK-2890] Port StringSerializationSpeedBenchmark to JMH. [FLINK-2889] Port LongSerializationSpeedBenchmark to JMH.

2015-10-26 Thread fhueske
Repository: flink Updated Branches: refs/heads/master daa357aca -> 6a8e90b36 http://git-wip-us.apache.org/repos/asf/flink/blob/75a52574/flink-core/src/test/java/org/apache/flink/core/memory/benchmarks/PureOffHeapMemorySegmentOutView.java

[5/8] flink git commit: [FLINK-2890] Port StringSerializationSpeedBenchmark to JMH. [FLINK-2889] Port LongSerializationSpeedBenchmark to JMH.

2015-10-26 Thread fhueske
[FLINK-2890] Port StringSerializationSpeedBenchmark to JMH. [FLINK-2889] Port LongSerializationSpeedBenchmark to JMH. This closes #1284 This closes #1283 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/75a52574 Tree:

[7/8] flink git commit: [FLINK-2827] Close FileInputStream through try-with-resources to avoid unused open stream.

2015-10-26 Thread fhueske
[FLINK-2827] Close FileInputStream through try-with-resources to avoid unused open stream. This closes #1276 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6a8e90b3 Tree:

[3/8] flink git commit: [FLINK-2890] Port StringSerializationSpeedBenchmark to JMH. [FLINK-2889] Port LongSerializationSpeedBenchmark to JMH.

2015-10-26 Thread fhueske
http://git-wip-us.apache.org/repos/asf/flink/blob/75a52574/flink-benchmark/src/test/java/org/apache/flink/benchmark/core/memory/segments/PureOffHeapMemorySegmentOutView.java -- diff --git

[2/8] flink git commit: [FLINK-2890] Port StringSerializationSpeedBenchmark to JMH. [FLINK-2889] Port LongSerializationSpeedBenchmark to JMH.

2015-10-26 Thread fhueske
http://git-wip-us.apache.org/repos/asf/flink/blob/75a52574/flink-core/src/test/java/org/apache/flink/core/memory/benchmarks/PureHeapMemorySegment.java -- diff --git

[6/8] flink git commit: [FLINK-2853] Port MutableHashTablePerformanceBenchmark to JMH.

2015-10-26 Thread fhueske
[FLINK-2853] Port MutableHashTablePerformanceBenchmark to JMH. This closes #1267 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e5ee55bd Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e5ee55bd Diff:

[8/8] flink git commit: [FLINK-2919] Port FieldAccessMinibenchmark to JMH.

2015-10-26 Thread fhueske
[FLINK-2919] Port FieldAccessMinibenchmark to JMH. This closes #1300 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7265d81f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7265d81f Diff:

[01/10] flink git commit: [FLINK-2800] [kryo] Fix Kryo serialization to clear buffered data

2015-10-29 Thread fhueske
Repository: flink Updated Branches: refs/heads/release-0.10 51ac46e80 -> e1f30b046 [FLINK-2800] [kryo] Fix Kryo serialization to clear buffered data The Kryo serializer uses Kryo's Output class to buffer individual write operations before it is written to the underlying output stream. This

[10/10] flink git commit: [FLINK-2559] Clean up JavaDocs

2015-10-29 Thread fhueske
[FLINK-2559] Clean up JavaDocs - Remove broken HTML tags like , , ... - close unclosed HTML tags - replaces special chars by HTML escaping, e.g., '<' by - wrap code examples by {@code} - fix incorrect @see and @link references - fix incorrect @throws - fix typos This closes #1298 Project:

[04/10] flink git commit: [FLINK-2934] Remove placeholder pages for job.statistics, taskmanager.log and taskmanager.stdout

2015-10-29 Thread fhueske
http://git-wip-us.apache.org/repos/asf/flink/blob/6a13b9ff/flink-runtime-web/web-dashboard/web/js/index.js -- diff --git a/flink-runtime-web/web-dashboard/web/js/index.js b/flink-runtime-web/web-dashboard/web/js/index.js index

[09/10] flink git commit: [FLINK-2559] Clean up JavaDocs

2015-10-29 Thread fhueske
http://git-wip-us.apache.org/repos/asf/flink/blob/e1f30b04/flink-examples/flink-java-examples/src/main/java/org/apache/flink/examples/java/relational/WebLogAnalysis.java -- diff --git

[03/10] flink git commit: [FLINK-2934] Remove placeholder pages for job.statistics, taskmanager.log and taskmanager.stdout

2015-10-29 Thread fhueske
http://git-wip-us.apache.org/repos/asf/flink/blob/6a13b9ff/flink-runtime-web/web-dashboard/web/partials/jobs/job.html -- diff --git a/flink-runtime-web/web-dashboard/web/partials/jobs/job.html

[07/10] flink git commit: [FLINK-2559] Clean up JavaDocs

2015-10-29 Thread fhueske
http://git-wip-us.apache.org/repos/asf/flink/blob/e1f30b04/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/SingleOutputStreamOperator.java -- diff --git

[09/13] flink git commit: [FLINK-2559] Clean up JavaDocs

2015-10-29 Thread fhueske
[FLINK-2559] Clean up JavaDocs - Remove broken HTML tags like , , ... - close unclosed HTML tags - replaces special chars by HTML escaping, e.g., '<' by - wrap code examples by {@code} - fix incorrect @see and @link references - fix incorrect @throws - fix typos This closes #1298 Project:

  1   2   3   4   5   6   7   8   9   10   >