Hi all!
Please find below a list of commits that I would propose to include in the
bugfix release.
It does not contain any streaming commits. Marton, Gyula, can you add that?
Thing is: it contains 90% of all commits. I put some in parenthesis that
are not bug fixes, but minor additions that are useful also in a minor
release.
We might as well just take all commits and make it 0.8.0 ;-)
Greetings,
Stephan
------------------------------------------------------------------
770ce23 [FLINK-1301] Added Apache license headers to Markdown, HTML, SVG,
Pyt
979837a [scala] Fix TupleSerializerTest for corrected CaseClassSerializer
3470b37 [scala] Fix non-reuse copy in CaseClassSerializer
a677c77 [FLINK-1157] Document TaskManager slots and minor fixes.
858d1bc [Java API] [docs] Rephrase Javadoc of minBy/maxBy and link from
min/max
bc41197 [FLINK-1292] Allow for longer normalized keys when using composite
keys
33724f0 [Docs] Fix rendering issue and typo
e3eaac2 [FLINK-984] Compiler tests for distinct().
84d6da8 [FLINK-1291] Remove default GC options from the shell scripts …
4e9c32f [Docs] Just a typo in docs/index.md
a9b7cbe [scala] [runtime] Add extra tests for sorting of case classes
45fb6d8 [FLINK-1290] Fix Optimizer to create plans when encountering
incompat
d554faa [FLINK-1273] [runtime] Add Void type to basic types
17bc479 [FLINK-1095] [clients] Remove '-d' option in info from CliFrontend
bbe54ac [FLINK-1270] [APIs] FS.get() supports relative paths
3d242fd Removed TypeSerializerFactory from ScalaCsvInputFormat. The
TypeSeria… …
1a7a50f [scala] Add equals() to TraversableTypeInfo
1dd8b8d Rewrite TPC-H Q3 to use Long instead of Integer …
1a91132 [scala] Fix slow building of adjacency list in Scala PageRank
f66892d [runtime] CaseClassSerializer correctly treated as stateful
2ae366b [docs] Fix paths to work with local builds
( e8e7abb [scala] Add ClosureCleaner for Scala Lambdas )
74bc7dd [FLINK-1282] [docs] Make Flink logo link back to frontpage
8a8155e [FLINK-1282] [docs] Added {{ site.baseurl }} to css and image paths
112b3a9 [Scala API] Case Class serializer can work with classes that
cannot b… …
48b6d01 [FLINK-1278] [runtime] (part 1) Remove special code paths for the
Rec… …
d858930 [FLINK-1286] [APIs] [runtime] Fix serialization in
CollectionInputFor… …
82f5154 [FLINK-1282] [docs] Update layout of docs …
87497b7 [runtime] Quick fix for error with unsupported ship strategy
392683f [FLINK-658] [APIs] Add group sorting to CoGroup
606a6d4 [Java API] Fix various warnings
8724bf7 Small changes and tests for the newly introduced EnumType
( 65d85f1 [FLINK-1221] Use StackTraceElement methods instead of String
parsing )
c03237a [FLINK-1221] Use only method name and location as default
operator names
( bcdd167 [FLINK-1249] [APIs] [compiler] Add custom partitioner for
CoGroup )
4838efe Fixes FLINK-1276
42fe874 Minor code cleanups - left from previous patches
cf54a1c [FLINK-1263] [optimizer] Implement compatibility checks for binary
operators
d7853fd [APIs] Enhance test coverage for CollectionInputFormat and add
tests...
02e2857 Log memory usage stats at INFO level instead of DEBUG
a69d60a Removed object reusage in GenericArraySerializer's deserialize
method.
98ff76b [FLINK-820] [compiler] Support for disconnected data flows
d0f2db0 [FLINK-1264] [compiler] Properly forward custom partitioners to
the runtime
b3e5ed0 [Flink-1262] inconsistency between CsvReader.java and
TupleGenerator.
4a74f32 [FLINK-1265] Fix user classloader bug for registerInputOutput()
method
a77d752 Added binary input and output format which uses the objects'
TypeSeri… …
8af0473 [FLINK-1252] address pull request comments
8081ddc [FLINK-1251] Enums are now handled properly by the collection
input format
591f16d [FLINK-1252] Add support for serializing Date and Enums in the
Java API
4203bf9 Minor code clean up …
5c3dceb [FLINK-1142] Log information about I/O manager temp dirs …
( 3ac4df8 [FLINK-993] Primitive input format fails for invalid input. )
d640b6c [FLINK-933] Add primitive input format to read a sequence of
primitives …
ae505ad [FLINK-1253] [tests] Make sure tests do not die with garbage
collecti… …
ce822bf [FLINK-1254] [compiler] Fix compiler bug for pipeline breaker
placement
54aa41b Added getExecutionEnvironment to the DataSet of the Scala API.
da60630 Add byte array serialization to InstantiationUtil
f84e4ec Minor code clean up to get rid of IntelliJ IDEA warnings …
1ecacf0 [FLINK-1247] [docs] Fix broken links in documentation
9f6a0b8 [FLINK-1250] [config] [docs] Correct and document config keys for
hea… …
b264221 [FLINK-1209] [compiler] Improve error messages when forgetting to
clo… …
6989cec [bin] Remove MaxPermSize parameter for JVM 1.8 …
( 2000b45 [FLINK-1237] Add support for custom partitioners )
83d0256 [FLINK-1207] Context environments are realized through factories …
ae07abe [build] Manage version of joda-time to prevent conflicts between
depe… …
06c259f [tests] Various stability fixes to tests
f76eb15 [FLINK-1246] Add additional debug output to flaky recovery test
2d1532f Fix flaky test SumMinMaxITCase
9c1585e [FLINK-1172] [docs] Fix broken links in documentation …
a296f40 [FLINK-1244] setCombinable() returns operator …
7f8296e [FLINK-890] [docs] Adjust examples to show reader methods and
correct… …
42828f2 [FLINK-1008] Fix createProgramPlan() throws exception …
e23874c [FLINK-1242] Fix streaming-examples and scala-examples POMs to
work p… …
922f478 [docs] Add description of Quasiquotes compiler plugin in Eclipse
to FAQ
8a955e5 [FLINK-1233] Fix flaky AggregateITCase
d7d7238 [FLINK-1239] [streaming] IterateExample fix and parallelism
setting i… …
c339c26 [FLINK-1218] Replace new Integer with Integer.valueOf in tests …
9ff2e5b [scala] Self-contained build for scala examples …
8f9d8ea Fix caching of receivers
c6dd9b1 [FLINK-1204] [streaming] Individual, self-contained packaging for
str… …
818ebda [FLINK-1221] Use the source line as the default operator name …
b253cb2 [FLINK-1230] Add documentation and an example for collection-based
ex… …
b3c290f [FLINK-1226] Add API support for passing Configurations to
InputFormats …
21b1b97 [FLINK-1235] Compiler accepts iterations referenced from the
static p… …
3772d30 Improved input type inference, bug fixing, code simplification …
57ecbcc [FLINK-1233] Improve error message when not enough slots are
availabl… …
e855ef4 [FLINK-1223] Allow value escaping in CSV files …
2f1176a [FLINK-983] Fix WebClient truncated function names …
( c9cfe3b [FLINK-1323] Refactor I/O Manager Readers and Writers to
interfaces )
8e4c772 [FLINK-1186] Fix wrong flat key position when using expression key
fo… …
65d0359 Make sure S3 directory paths are suffixed with '/' on creation
81c5b2a [FLINK-1215] Increase robustness to spurious failures when
creating o… …
4b75d83 [FLINK-1213] Added .gitattributes to normalize EOL …
90730fe [FLINK-1212] Fixed shell script interpreter directive …
1e979e9 [Flink-1113] clean up JQuery dependencies
e580497 [FLINK-1215] Fix spurious failures when creating output
directories
ef9a373 [runtime] In local mode, make sure taskmanagers have completed
regist
ef40691 [FLINK-1222] Tasks send close acknowledgements early.
a959dd5 [FLINK-1220] Promote various log statements to INFO level. Add log
st… …
17e0186 Add test case for TaskManager connection loss, leading to task
failure.
6ecd0f8 [FLINK-1214] Prevent partitionings on subsets of fields from being
pushed down
a586614 [FLINK-1005] By default, new objects are created for each element
in group reduce
c3835cd [scala] Add union operation to Scala ExecutionEnvironment
e21d78d [scala] Make getType public in Scala DataSet
bd66a08 [FLINK-1191] Add support for Scala Collections and Special Types
1e1df6d [scala] Add macroparadise to enable Quasiquotes
3510bf9 Change TypeExtractor to support interfaces within classes
233161b [FLINK-1210] Improve error message in delta iterations when the
next
9b6561d [doc] Fix programming guide link in iterations.md
9b25942 Temporarily disable fork reuse in flink-tests Unit tests
(workaround
ca9e6ab Make sure that operator names are properly escaped for display in
the web frontend
( 7d2db95 [FLINK-1198] Fix nullpointer exception in broadcast variable
material )
( e1fd689 [FLINK-1198] Broadcast variables can share initialization )
( d8052d4 [FLINK-1198] Make Broadcast variables shared per taskmanager,
rather )
( cc76653 [FLINK-1198] Broadcast variables are shared between tasks in
the same )
bbd8209 [FLINK-1203] Use forked execution in all tests, except in the
end-to-end tests
a6152c3 [FLINK-1205] Fix library cache manager to track references to
tasks a… …
5e48fc9 Make sure TaskManager does not accept task deployments when
shutting … …
8b39ba9 Improve error messages in case of invalid file paths or URIs …
( f0fd882 Introduce a delay before restarts to make sure that
taskmanager failurs )
( dd687bc Implement coarse-grained fault tolerance )
2557832 Remove obsolete collection execution example.
a747b61 [FLINK-1202] Remove incomplete file outputs on failure …
f42dcc3 [FLINK-1203] Deactivate fork reuse in tests
f5898a0 Another round to remove final modifier to private methods because
it
0ee60d3 [FLINK-1181] Fix IOReadableWritable checks in RPC service …
b0c1af5 [FLINK-1182] Improve error messages for POJO type mismatches
( eebe510 Add DeltaPageRank example )
3f33278 [FLINK-1194] Fix Java quickstart archetype POM file
73ee385 Remove unnecessary final modifier in
PlanExecutor.loadExecutorClass m… …
f2b8650 [FLINK-1178] Changed type preference to ValueType, WritableType,
Case… …
