- The NetUtils class (in flink-core) contains all methods usable without runtime dependency
  - The runtime NetUtils class (to find connectiong addresses) is now called ConnectionUtil.

Setting a strict upper limit for the direct memory size can cause
problems with the direct memory allocation of the Netty network stack
leading to OutOfMemoryExceptions.

This closes #1203.

This closes #1194

This closes #1181

As part of continuing theme and effort to help make the code more consistent, adding cleanup to Utils classes:
-) Add final class modifier to the XXXUtils and XXXUtil classes to make sure can not be extended.
-) Add missing Javadoc header classs to some public classes.
-) Add private constructor to Utils classes to avoid instantiation.
-) Remove unused test/java/org/apache/flink/test/recordJobs/util/ConfigUtils.java class

Author: hsaputra <hsaputra@apache.org>

Closes #1189 from hsaputra/add_missing_javadocs_class and squashes the following commits:

0dfba19 [hsaputra] Cleanup code as part of theme to be more consistent: -) Add final class modifier to the XXXUtils and XXXUtil classes to make sure could not be extended. -) Add missing Javadoc header classs to some public classes. -) Add private constructor to Utils classes to avoid instantiation. -) Remove unused test/java/org/apache/flink/test/recordJobs/util/ConfigUtils.java class

This closes #1177

def createLocalEnvironment(parallelism: Int = Runtime.getRuntime.availableProcessors()))
//issue1: In the end, there is a extra ")"

def createRemoteEnvironment(host: String, port: String, jarFiles: String*)
def createRemoteEnvironment(host: String, port: String, parallelism: Int, jarFiles: String*)
//issue2: the parameter of port should be "Int", not "String"

This closes #1193

This closes #1180

This closes #1115

[FLINK-2754] Fixed FixedLengthRecordSorter write to multi memory pages issue and add more unit tests.

This closes #1178

This closes #1169

This closes #1182

This closes #1185

This closes #1188

This closes #1183

add tests for newly added operations.

Add completeness test: fromCsvReader method is missing.

add-remove edges/vertices, difference, graph creation methods,
validate, getTriplets. Add missing utility mappers.

The api package is also called windowing, this harmonizes the package
names.

This follows the API design outlined in https://cwiki.apache.org/confluence/display/FLINK/Streams+and+Operations+on+Streams

This is API breaking because it adds new generic type parameters to Java and Scala classes, breaking binary compatibility.

[FLINK-2690] [api-breaking] [scala api] [java api] Adds functionality to the CsvInputFormat to find fields defined in a super class of a Pojo. Refactors CsvInputFormat to share code between this format and ScalaCsvInputFormat.

This closes #1141.

Closes #1168

Closes #1179

This closes #885

[FLINK-2616] [test-stability] Fixes ZooKeeperLeaderElectionTest.testMultipleLeaders by introducing a second retrieval service to retrieve the leader address after the faulty address has been written.

This closes #1173.

  - Improve conditional "active" class for dropdown menu
  - Fix unclosed A tag

This closes #1176.

This squashes the following commits:

[FLINK-1520] [gelly] add named types methods for reading a Graph from CSV input,
with and without vertex/edge values. Change the examples and the tests accordingly.

[FLINK-1520] [gelly] corrections in Javadocs; updated documentation

This closes #1149

This squashes the following commit:

[FLINK-1520] [gelly]Changed the methods for specifying types.
Created a new file for tests. Made appropriate changes in gelly_guide.md