Export - CSV (All fields)
Export - CSV (Current fields)
FLINK-34691
failed to convert time type when using mysql to doris pipeline.FLINK-4389
Expose metrics to Webfrontend
Show metrics in WebFrontend
Measure latency of elements and expose it as a metric
Added configuration subsection in webinterface
Added globalConfig subsection in WebInterface
Fix dependency exclusion for examples in yarn-uberjar
Fix maven enforcer plugin warnings in Eclipse
Add test for broken type extraction in with Java 6 JVM.
Type extractor fails in Java 6
Pitfall due to additional superstep after the iteration has stopped
Error when compiling from the source
Using broadcast variables in UDFs within iterations leads to CompilerException
Adding graph centrality closeness implementation
ML example for java API
Webclient
Webclient: optimizer plan not showing up
Webclient does not show System.out messages
Fix data sources and data sinks with splits #766FLINK-898
Clean up distribution default config
Bug in scheduler for job graph instance sharing
Fixes bugs where the TypeExtractor throws an NPE instead of the operators
Exemplary implementation of map function with Java 8 Lambdas.
Some examples are broken
Inconsistent Iteration Step Function gives nonesense error message
Offer buffer-oriented API for I/O and replace custom Java NIO TCP/IP code with Netty 4 library
Potential bug due to unnecessary cast from long to int
Code from documentation does not compile [0.5-rc2]
Improve JobManager heap space memory configuration for YARN
Add missing Usercode Classloader for the "info" command in the CliFrontend
DistCache: executable flag, directories
Using another drive C:/D: other than where the stratosphere distribution is, results in file not found
Program with two BroadcastVars causes CompilerException
Generating a JSON plan with Client leads to NPE
Some generic changes to have an error free IDE with Java 8.
Make sure progress bar label is visible by making the minimum width to 20%
fixes toString return value of min aggregation
Aligned the Scala KMeans with the Java KMeans example.
Distinct Operator Implementation
KMeans Scala example does not work with Quick Start
Improved partitioning hash
Functions can now implement ResultTypeQueryable to supply TypeInformation manually.
Webinterface JobHistory does not work offline
new ToString for CsvOutputFormat
Fixes an issue when generating a type erasure exception in TypeExtractor.
Add description of mutable object iterators (GroupReduce, CoGroup) to documentation
Make aggregations combinable and remove AVG aggregation
Sensible toString for CsvOutputFormat
Make aggregations combinable
groupBy operator followed by a reduceGroup does not group Writables correctly