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:
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:
[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:
[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:
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:
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
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:
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
[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:
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:
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
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
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:
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
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:
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:
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:
[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
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
[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:
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:
[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:
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:
http://git-wip-us.apache.org/repos/asf/flink/blob/bd96ba8d/flink-optimizer/src/test/java/org/apache/flink/optimizer/PartitioningReusageTest.java
--
diff --git
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
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:
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
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:
[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:
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
[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:
[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:
[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:
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
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:
[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:
[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:
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
[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:
[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:
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:
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
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
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:
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:
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:
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:
[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:
[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:
[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:
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:
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:
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:
[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:
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:
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:
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:
[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:
[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:
[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:
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:
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:
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:
[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:
[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:
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
[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:
[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:
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:
[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:
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.
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:
[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:
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
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:
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:
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:
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:
[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
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
[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:
[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:
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:
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
[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
[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:
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
[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:
[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:
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
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
[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:
[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:
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
[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:
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
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
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
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
[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 - 100 of 1411 matches
Mail list logo