You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by rm...@apache.org on 2017/01/18 14:10:43 UTC
[36/78] [abbrv] flink-web git commit: Revert "Rebuild website"
http://git-wip-us.apache.org/repos/asf/flink-web/blob/16a92b0c/content/blog/release_1.0.0-changelog_known_issues.html
----------------------------------------------------------------------
diff --git a/content/blog/release_1.0.0-changelog_known_issues.html b/content/blog/release_1.0.0-changelog_known_issues.html
deleted file mode 100644
index 9b7ddc7..0000000
--- a/content/blog/release_1.0.0-changelog_known_issues.html
+++ /dev/null
@@ -1,1139 +0,0 @@
-<!DOCTYPE html>
-<html lang="en">
- <head>
- <meta charset="utf-8">
- <meta http-equiv="X-UA-Compatible" content="IE=edge">
- <meta name="viewport" content="width=device-width, initial-scale=1">
- <!-- The above 3 meta tags *must* come first in the head; any other head content must come *after* these tags -->
- <title>Apache Flink: Release 1.0.0 \u2013 Changelog and Known Issues</title>
- <link rel="shortcut icon" href="/favicon.ico" type="image/x-icon">
- <link rel="icon" href="/favicon.ico" type="image/x-icon">
-
- <!-- Bootstrap -->
- <link rel="stylesheet" href="https://maxcdn.bootstrapcdn.com/bootstrap/3.3.4/css/bootstrap.min.css">
- <link rel="stylesheet" href="/css/flink.css">
- <link rel="stylesheet" href="/css/syntax.css">
-
- <!-- Blog RSS feed -->
- <link href="/blog/feed.xml" rel="alternate" type="application/rss+xml" title="Apache Flink Blog: RSS feed" />
-
- <!-- jQuery (necessary for Bootstrap's JavaScript plugins) -->
- <!-- We need to load Jquery in the header for custom google analytics event tracking-->
- <script src="https://ajax.googleapis.com/ajax/libs/jquery/1.11.2/jquery.min.js"></script>
-
- <!-- HTML5 shim and Respond.js for IE8 support of HTML5 elements and media queries -->
- <!-- WARNING: Respond.js doesn't work if you view the page via file:// -->
- <!--[if lt IE 9]>
- <script src="https://oss.maxcdn.com/html5shiv/3.7.2/html5shiv.min.js"></script>
- <script src="https://oss.maxcdn.com/respond/1.4.2/respond.min.js"></script>
- <![endif]-->
- </head>
- <body>
-
-
- <!-- Main content. -->
- <div class="container">
- <div class="row">
-
-
- <div id="sidebar" class="col-sm-3">
- <!-- Top navbar. -->
- <nav class="navbar navbar-default">
- <!-- The logo. -->
- <div class="navbar-header">
- <button type="button" class="navbar-toggle collapsed" data-toggle="collapse" data-target="#bs-example-navbar-collapse-1">
- <span class="icon-bar"></span>
- <span class="icon-bar"></span>
- <span class="icon-bar"></span>
- </button>
- <div class="navbar-logo">
- <a href="/">
- <img alt="Apache Flink" src="/img/navbar-brand-logo.png" width="147px" height="73px">
- </a>
- </div>
- </div><!-- /.navbar-header -->
-
- <!-- The navigation links. -->
- <div class="collapse navbar-collapse" id="bs-example-navbar-collapse-1">
- <ul class="nav navbar-nav navbar-main">
-
- <!-- Downloads -->
- <li class=""><a class="btn btn-info" href="/downloads.html">Download Flink</a></li>
-
- <!-- Overview -->
- <li><a href="/index.html">Home</a></li>
-
- <!-- Intro -->
- <li><a href="/introduction.html">Introduction to Flink</a></li>
-
- <!-- Use cases -->
- <li><a href="/usecases.html">Flink Use Cases</a></li>
-
- <!-- Powered by -->
- <li><a href="/poweredby.html">Powered by Flink</a></li>
-
- <!-- Ecosystem -->
- <li><a href="/ecosystem.html">Ecosystem</a></li>
-
- <!-- Community -->
- <li><a href="/community.html">Community & Project Info</a></li>
-
- <!-- Contribute -->
- <li><a href="/how-to-contribute.html">How to Contribute</a></li>
-
- <!-- Blog -->
- <li class=" active hidden-md hidden-sm"><a href="/blog/"><b>Flink Blog</b></a></li>
-
- <hr />
-
-
-
- <!-- Documentation -->
- <!-- <li>
- <a href="http://ci.apache.org/projects/flink/flink-docs-release-1.1" target="_blank">Documentation <small><span class="glyphicon glyphicon-new-window"></span></small></a>
- </li> -->
- <li class="dropdown">
- <a class="dropdown-toggle" data-toggle="dropdown" href="#">Documentation
- <span class="caret"></span></a>
- <ul class="dropdown-menu">
- <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-1.1" target="_blank">1.1 (Latest stable release) <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
- <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-1.2" target="_blank">1.2 (Snapshot) <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
- </ul>
- </li>
-
- <!-- Quickstart -->
- <li>
- <a href="http://ci.apache.org/projects/flink/flink-docs-release-1.1/quickstart/setup_quickstart.html" target="_blank">Quickstart <small><span class="glyphicon glyphicon-new-window"></span></small></a>
- </li>
-
- <!-- GitHub -->
- <li>
- <a href="https://github.com/apache/flink" target="_blank">Flink on GitHub <small><span class="glyphicon glyphicon-new-window"></span></small></a>
- </li>
-
-
-
-
-
-
- </ul>
-
-
-
- <ul class="nav navbar-nav navbar-bottom">
- <hr />
-
- <!-- FAQ -->
- <li ><a href="/faq.html">Project FAQ</a></li>
-
- <!-- Twitter -->
- <li><a href="https://twitter.com/apacheflink" target="_blank">@ApacheFlink <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
-
- <!-- Visualizer -->
- <li class=" hidden-md hidden-sm"><a href="/visualizer/" target="_blank">Plan Visualizer <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
-
- </ul>
- </div><!-- /.navbar-collapse -->
- </nav>
-
- </div>
- <div class="col-sm-9">
- <div class="row-fluid">
- <div class="col-sm-12">
- <h1>Release 1.0.0 \u2013 Changelog and Known Issues</h1>
-
- <ul id="markdown-toc">
- <li><a href="#changelog" id="markdown-toc-changelog">Changelog</a> <ul>
- <li><a href="#sub-task" id="markdown-toc-sub-task">Sub-task</a></li>
- <li><a href="#bug" id="markdown-toc-bug">Bug</a></li>
- <li><a href="#improvement" id="markdown-toc-improvement">Improvement</a></li>
- <li><a href="#task" id="markdown-toc-task">Task</a></li>
- <li><a href="#test" id="markdown-toc-test">Test</a></li>
- <li><a href="#wish" id="markdown-toc-wish">Wish</a></li>
- </ul>
- </li>
- <li><a href="#known-issues" id="markdown-toc-known-issues">Known Issues</a></li>
-</ul>
-
-<h2 id="changelog">Changelog</h2>
-
-<h3 id="sub-task">Sub-task</h3>
-
-<ul>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-7">FLINK-7</a>] - [GitHub] Enable Range Partitioner
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-146">FLINK-146</a>] - Sorted output not working
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-1982">FLINK-1982</a>] - Remove dependencies on Record for Flink runtime and core
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2676">FLINK-2676</a>] - Add abstraction for keyed window state
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2680">FLINK-2680</a>] - Create a dedicated aligned-event time window operator
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2730">FLINK-2730</a>] - Add CPU/Network utilization graphs to new web dashboard
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2732">FLINK-2732</a>] - Add access to the TaskManagers' log file and out file in the web dashboard.
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2850">FLINK-2850</a>] - Limit the types of jobs which can run in detached mode
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2853">FLINK-2853</a>] - Apply JMH on MutableHashTablePerformanceBenchmark class.
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2869">FLINK-2869</a>] - Apply JMH on IOManagerPerformanceBenchmark class.
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2889">FLINK-2889</a>] - Apply JMH on LongSerializationSpeedBenchmark class
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2890">FLINK-2890</a>] - Apply JMH on StringSerializationSpeedBenchmark class.
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2900">FLINK-2900</a>] - Remove Record-API dependencies from Hadoop Compat module
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2901">FLINK-2901</a>] - Several flink-test ITCases depend on Record API features
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2906">FLINK-2906</a>] - Remove Record-API
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2919">FLINK-2919</a>] - Apply JMH on FieldAccessMinibenchmark class.
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2920">FLINK-2920</a>] - Apply JMH on KryoVersusAvroMinibenchmark class.
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2933">FLINK-2933</a>] - Flink scala libraries exposed with maven should carry scala version
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2972">FLINK-2972</a>] - Remove Twitter Chill dependency from flink-java module
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3057">FLINK-3057</a>] - [py] Provide a way to pass information back to the plan process
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3070">FLINK-3070</a>] - Create an asynchronous state handle interface
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3071">FLINK-3071</a>] - Add asynchronous materialization thread
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3140">FLINK-3140</a>] - NULL value data layout in Row Serializer/Comparator
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3195">FLINK-3195</a>] - Restructure examples projects and package streaming examples
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3201">FLINK-3201</a>] - Enhance Partitioned State Interface with State Types
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3208">FLINK-3208</a>] - Rename Gelly vertex-centric model to scatter-gather
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3224">FLINK-3224</a>] - The Streaming API does not call setInputType if a format implements InputTypeConfigurable
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3275">FLINK-3275</a>] - [py] Add support for Dataset.setParallelism()
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3285">FLINK-3285</a>] - Skip Maven deployment of flink-java8
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3312">FLINK-3312</a>] - Add convenience accessor methods for extended state interface
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3327">FLINK-3327</a>] - Attach the ExecutionConfig to the JobGraph and make it accessible to the AbstractInvocable.
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3363">FLINK-3363</a>] - JobManager does not shut down dedicated executor properly
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3365">FLINK-3365</a>] - BlobLibraryCacheManager does not shutdown Timer thread
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3371">FLINK-3371</a>] - Move TriggerCotext and TriggerResult to their own classes
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3384">FLINK-3384</a>] - Create atomic closable queue for communication between Kafka Threads
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3388">FLINK-3388</a>] - Expose task accumulators via JMX
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3401">FLINK-3401</a>] - AscendingTimestampExtractor should not fail on order violation
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3437">FLINK-3437</a>] - Fix UI router state for job plan
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3468">FLINK-3468</a>] - Change Timestamp Extractors to not support negative timestamps
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3470">FLINK-3470</a>] - EventTime WindowAssigners should error on negative timestamps
-</li>
-</ul>
-
-<h3 id="bug">Bug</h3>
-
-<ul>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-1278">FLINK-1278</a>] - Remove the Record special code paths
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-1644">FLINK-1644</a>] - WebClient dies when no ExecutionEnvironment in main method
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-1989">FLINK-1989</a>] - Sorting of POJO data set from TableEnv yields NotSerializableException
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2115">FLINK-2115</a>] - TableAPI throws ExpressionException for "Dangling GroupBy operation"
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2263">FLINK-2263</a>] - ExecutionGraph uses Thread.sleep to delay execution retries
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2315">FLINK-2315</a>] - Hadoop Writables cannot exploit implementing NormalizableKey
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2348">FLINK-2348</a>] - IterateExampleITCase failing
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2351">FLINK-2351</a>] - Deprecate config builders in InputFormats and Output formats
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2369">FLINK-2369</a>] - On Windows, in testFailingSortingDataSinkTask the temp file is not removed
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2392">FLINK-2392</a>] - Instable test in flink-yarn-tests
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2443">FLINK-2443</a>] - [CompactingHashTable] GSA Connected Components fails with NPE
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2491">FLINK-2491</a>] - Operators are not participating in state checkpointing in some cases
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2504">FLINK-2504</a>] - ExternalSortLargeRecordsITCase.testSortWithLongAndShortRecordsMixed failed spuriously
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2586">FLINK-2586</a>] - Unstable Storm Compatibility Tests
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2608">FLINK-2608</a>] - Arrays.asList(..) does not work with CollectionInputFormat
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2622">FLINK-2622</a>] - Scala DataStream API does not have writeAsText method which supports WriteMode
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2624">FLINK-2624</a>] - RabbitMQ source / sink should participate in checkpointing
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2662">FLINK-2662</a>] - CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2671">FLINK-2671</a>] - Instable Test StreamCheckpointNotifierITCase
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2674">FLINK-2674</a>] - Rework windowing logic
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2695">FLINK-2695</a>] - KafkaITCase.testConcurrentProducerConsumerTopology failed on Travis
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2719">FLINK-2719</a>] - ProcessFailureStreamingRecoveryITCase>AbstractProcessFailureRecoveryTest.testTaskManagerProcessFailure failed on Travis
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2739">FLINK-2739</a>] - Release script depends on the order of parent module information
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2747">FLINK-2747</a>] - TypeExtractor does not correctly analyze Scala Immutables (AnyVal)
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2752">FLINK-2752</a>] - Documentation is not easily differentiable from the Flink homepage
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2757">FLINK-2757</a>] - DataSinkTaskTest fails on Windows
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2758">FLINK-2758</a>] - TaskManagerRegistrationTest fails on Windows
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2759">FLINK-2759</a>] - TaskManagerProcessReapingTest fails on Windows
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2769">FLINK-2769</a>] - Web dashboard port not configurable on client side
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2771">FLINK-2771</a>] - IterateTest.testSimpleIteration fails on Travis
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2797">FLINK-2797</a>] - CLI: Missing option to submit jobs in detached mode
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2799">FLINK-2799</a>] - Yarn tests cannot be executed with DEBUG log level
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2800">FLINK-2800</a>] - kryo serialization problem
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2823">FLINK-2823</a>] - YARN client should report a proper exception if Hadoop Env variables are not set
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2826">FLINK-2826</a>] - transformed is modified in BroadcastVariableMaterialization#decrementReferenceInternal without proper locking
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2827">FLINK-2827</a>] - Potential resource leak in TwitterSource#loadAuthenticationProperties()
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2832">FLINK-2832</a>] - Failing test: RandomSamplerTest.testReservoirSamplerWithReplacement
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2838">FLINK-2838</a>] - Inconsistent use of URL and Path classes for resources
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2845">FLINK-2845</a>] - TimestampITCase.testWatermarkPropagation
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2879">FLINK-2879</a>] - Links in documentation are broken
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2913">FLINK-2913</a>] - Close of ObjectOutputStream should be enclosed in finally block in FsStateBackend
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2914">FLINK-2914</a>] - Missing break in ZooKeeperSubmittedJobGraphStore#SubmittedJobGraphsPathCacheListener#childEvent()
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2930">FLINK-2930</a>] - ExecutionConfig execution retry delay not respected
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2934">FLINK-2934</a>] - Remove placehoder pages in Web dashboard
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2937">FLINK-2937</a>] - Typo in Quickstart->Scala API->Alternative Build Tools: SBT
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2938">FLINK-2938</a>] - Streaming docs not in sync with latest state changes
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2942">FLINK-2942</a>] - Dangling operators in web UI's program visualization (non-deterministic)
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2950">FLINK-2950</a>] - Markdown presentation problem in SVM documentation
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2954">FLINK-2954</a>] - Not able to pass custom environment variables in cluster to processes that spawning TaskManager
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2958">FLINK-2958</a>] - StreamingJobGraphGenerator sets hard coded number execution retry
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2963">FLINK-2963</a>] - Dependence on SerializationUtils#deserialize() should be avoided
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2967">FLINK-2967</a>] - TM address detection might not always detect the right interface on slow networks / overloaded JMs
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2977">FLINK-2977</a>] - Cannot access HBase in a Kerberos secured Yarn cluster
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2979">FLINK-2979</a>] - RollingSink does not work with Hadoop 2.7.1
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2987">FLINK-2987</a>] - Flink 0.10 fails to start on YARN 2.6.0
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2989">FLINK-2989</a>] - Job Cancel button doesn't work on Yarn
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2990">FLINK-2990</a>] - Scala 2.11 build fails to start on YARN
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2992">FLINK-2992</a>] - New Windowing code is using SerializationUtils with wrong classloader
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3000">FLINK-3000</a>] - Add ShutdownHook to YARN CLI to prevent lingering sessions
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3005">FLINK-3005</a>] - Commons-collections object deserialization remote command execution vulnerability
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3009">FLINK-3009</a>] - Cannot build docs with Jekyll 3.0.0
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3011">FLINK-3011</a>] - Cannot cancel failing/restarting streaming job from the command line
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3013">FLINK-3013</a>] - Incorrect package declaration in GellyScalaAPICompletenessTest.scala
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3019">FLINK-3019</a>] - CLI does not list running/restarting jobs
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3020">FLINK-3020</a>] - Local streaming execution: set number of task manager slots to the maximum parallelism
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3022">FLINK-3022</a>] - Broken link 'Working With State' in Fault Tolerance Section of Stream Programming Guide
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3024">FLINK-3024</a>] - TimestampExtractor Does not Work When returning Long.MIN_VALUE
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3025">FLINK-3025</a>] - Flink Kafka consumer may get stuck due to Kafka/Zookeeper client bug
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3032">FLINK-3032</a>] - Flink does not start on Hadoop 2.7.1 (HDP), due to class conflict
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3043">FLINK-3043</a>] - Kafka Connector description in Streaming API guide is wrong/outdated
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3047">FLINK-3047</a>] - Local batch execution: set number of task manager slots to the maximum parallelism
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3048">FLINK-3048</a>] - DataSinkTaskTest.testCancelDataSinkTask
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3052">FLINK-3052</a>] - Optimizer does not push properties out of bulk iterations
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3054">FLINK-3054</a>] - Remove R (return) type variable from SerializationSchema
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3059">FLINK-3059</a>] - Javadoc fix for DataSet.writeAsText()
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3061">FLINK-3061</a>] - Kafka Consumer is not failing if broker is not available
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3062">FLINK-3062</a>] - Kafka Producer is not failing if broker is not available/no partitions available
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3067">FLINK-3067</a>] - Kafka source fails during checkpoint notifications with NPE
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3080">FLINK-3080</a>] - Cannot union a data stream with a product of itself
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3081">FLINK-3081</a>] - Kafka Periodic Offset Committer does not properly terminate on canceling
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3082">FLINK-3082</a>] - Confusing error about ManualTimestampSourceFunction
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3087">FLINK-3087</a>] - Table API do not support multi count in aggregation.
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3098">FLINK-3098</a>] - Cast from Date to Long throw compile error.
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3100">FLINK-3100</a>] - Signal handler prints error on normal shutdown of cluster
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3101">FLINK-3101</a>] - Flink Kafka consumer crashes with NPE when it sees deleted record
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3103">FLINK-3103</a>] - Remove synchronization in FsStateBackend#FsCheckpointStateOutputStream#close()
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3108">FLINK-3108</a>] - JoinOperator's with() calls the wrong TypeExtractor method
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3117">FLINK-3117</a>] - Storm Tick Tuples are not supported
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3118">FLINK-3118</a>] - Check if MessageFunction implements ResultTypeQueryable
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3121">FLINK-3121</a>] - Watermark forwarding does not work for sources not producing any data
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3125">FLINK-3125</a>] - Web dashboard does not start when log files are not found
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3134">FLINK-3134</a>] - Make YarnJobManager's allocate call asynchronous
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3136">FLINK-3136</a>] - Scala Closure Cleaner uses wrong ASM import
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3138">FLINK-3138</a>] - Method References are not supported as lambda expressions
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3143">FLINK-3143</a>] - Update Clojure Cleaner's ASM references to ASM5
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3144">FLINK-3144</a>] - [storm] LocalCluster prints nothing without a configured logger
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3145">FLINK-3145</a>] - Storm examples can't be run without flink-java as dependency
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3151">FLINK-3151</a>] - YARN kills Flink TM containers due to memory overuse (outside heap/offheap)
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3156">FLINK-3156</a>] - FlinkKafkaConsumer fails with NPE on notifyCheckpointComplete
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3157">FLINK-3157</a>] - Web frontend json files contain author attribution
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3166">FLINK-3166</a>] - The first program in ObjectReuseITCase has the wrong expected result, and it succeeds
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3171">FLINK-3171</a>] - Consolidate zoo of wrapper classes for input/output-stream to data-input/output-view
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3173">FLINK-3173</a>] - Bump org.apache.httpcomponents.httpclient version to 4.2.6
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3175">FLINK-3175</a>] - KafkaITCase.testOffsetAutocommitTest
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3179">FLINK-3179</a>] - Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3180">FLINK-3180</a>] - MemoryLogger does not log direct memory
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3185">FLINK-3185</a>] - Silent failure during job graph recovery
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3188">FLINK-3188</a>] - Deletes in Kafka source should be passed on to KeyedDeserializationSchema
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3189">FLINK-3189</a>] - Error while parsing job arguments passed by CLI
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3196">FLINK-3196</a>] - InputStream should be closed in EnvironmentInformation#getRevisionInformation()
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3197">FLINK-3197</a>] - InputStream not closed in BinaryInputFormat#createStatistics
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3206">FLINK-3206</a>] - Heap size for non-pre-allocated off-heap memory
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3218">FLINK-3218</a>] - Merging Hadoop configurations overrides user parameters
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3220">FLINK-3220</a>] - Flink does not start on Hortonworks Sandbox 2.3.2 due to missing class
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3236">FLINK-3236</a>] - Flink user code classloader should have Flink classloader as parent classloader
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3240">FLINK-3240</a>] - Remove or document DataStream(.global|.forward)
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3242">FLINK-3242</a>] - User-specified StateBackend is not Respected if Checkpointing is Disabled
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3243">FLINK-3243</a>] - Fix Interplay of TimeCharacteristic and Time Windows
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3247">FLINK-3247</a>] - Kafka Connector unusable with quickstarts - shading issue
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3248">FLINK-3248</a>] - RMQSource does not provide a constructor for credentials or other options
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3250">FLINK-3250</a>] - Savepoint coordinator requires too strict parallelism match
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3251">FLINK-3251</a>] - Checkpoint stats show ghost numbers
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3252">FLINK-3252</a>] - Checkpoint stats only displayed after click on graph
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3254">FLINK-3254</a>] - CombineFunction interface not respected
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3255">FLINK-3255</a>] - Chaining behavior should not depend on parallelism
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3260">FLINK-3260</a>] - ExecutionGraph gets stuck in state FAILING
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3261">FLINK-3261</a>] - Tasks should eagerly report back when they cannot start a checkpoint
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3266">FLINK-3266</a>] - LocalFlinkMiniCluster leaks resources when multiple jobs are submitted
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3267">FLINK-3267</a>] - Disable reference tracking in Kryo fallback serializer
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3268">FLINK-3268</a>] - Unstable test JobManagerSubmittedJobGraphsRecoveryITCase
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3271">FLINK-3271</a>] - Using webhdfs in a flink topology throws classnotfound exception
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3274">FLINK-3274</a>] - Prefix Kafka connector accumulators with unique id
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3280">FLINK-3280</a>] - Wrong usage of Boolean.getBoolean()
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3281">FLINK-3281</a>] - IndexOutOfBoundsException when range-partitioning empty DataSet
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3286">FLINK-3286</a>] - Remove JDEB Debian Package code from flink-dist
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3287">FLINK-3287</a>] - Flink Kafka Consumer fails due to Curator version conflict
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3289">FLINK-3289</a>] - Double reference to flink-contrib
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3292">FLINK-3292</a>] - Bug in flink-jdbc. Not all JDBC drivers supported
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3293">FLINK-3293</a>] - Custom Application Name on YARN is ignored in deploy jobmanager mode
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3296">FLINK-3296</a>] - DataStream.write*() methods are not flushing properly
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3300">FLINK-3300</a>] - Concurrency Bug in Yarn JobManager
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3304">FLINK-3304</a>] - AvroOutputFormat.setSchema() doesn't work in yarn-cluster mode
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3314">FLINK-3314</a>] - Early cancel calls can cause Tasks to not cancel properly
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3322">FLINK-3322</a>] - MemoryManager creates too much GC pressure with iterative jobs
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3328">FLINK-3328</a>] - Incorrectly shaded dependencies in flink-runtime
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3333">FLINK-3333</a>] - Documentation about object reuse should be improved
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3337">FLINK-3337</a>] - mvn test fails on flink-runtime because curator classes not found
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3338">FLINK-3338</a>] - Kafka deserialization issue - ClassNotFoundException
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3339">FLINK-3339</a>] - Checkpointing NPE when using filterWithState
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3340">FLINK-3340</a>] - Fix object juggling in drivers
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3341">FLINK-3341</a>] - Kafka connector's 'auto.offset.reset' inconsistent with Kafka
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3342">FLINK-3342</a>] - Operator checkpoint statistics state size overflow
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3350">FLINK-3350</a>] - Increase timeouts on Travis Builds
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3351">FLINK-3351</a>] - RocksDB Backend cannot determine correct local db path
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3352">FLINK-3352</a>] - RocksDB Backend cannot determine correct hdfs path
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3353">FLINK-3353</a>] - CSV-related tests may fail depending on locale
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3357">FLINK-3357</a>] - Drop JobId.toShortString()
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3359">FLINK-3359</a>] - Make RocksDB file copies asynchronous
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3361">FLINK-3361</a>] - Wrong error messages for execution retry delay and akka ask pause config values
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3368">FLINK-3368</a>] - Kafka 0.8 consumer fails to recover from broker shutdowns
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3369">FLINK-3369</a>] - RemoteTransportException should be instance of CancelTaskException
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3373">FLINK-3373</a>] - Using a newer library of Apache HttpClient than 4.2.6 will get class loading problems
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3385">FLINK-3385</a>] - Fix outer join skipping unprobed partitions
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3392">FLINK-3392</a>] - Unprotected access to elements in ClosableBlockingQueue#size()
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3393">FLINK-3393</a>] - ExternalProcessRunner wait to finish copying error stream
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3394">FLINK-3394</a>] - Clear up the contract of MutableObjectIterator.next(reuse)
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3396">FLINK-3396</a>] - Job submission Savepoint restore logic flawed
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3400">FLINK-3400</a>] - RocksDB Backend does not work when not in Flink lib folder
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3412">FLINK-3412</a>] - Remove implicit conversions JavaStream / ScalaStream
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3415">FLINK-3415</a>] - TimestampExctractor accepts negative watermarks
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3416">FLINK-3416</a>] - [py] .bat files fail when path contains spaces
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3420">FLINK-3420</a>] - Remove "ReadTextFileWithValue" from StreamExecutionEnvironment
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3423">FLINK-3423</a>] - ExternalProcessRunnerTest fails on Windows
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3424">FLINK-3424</a>] - FileStateBackendtest.testStateOutputStream fails on windows
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3425">FLINK-3425</a>] - DataSinkTaskTest.Failing[Sorting]DataSinkTask fails on Windows
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3426">FLINK-3426</a>] - JobManagerLeader[Re]ElectionTest.testleaderElection fails on Windows
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3432">FLINK-3432</a>] - ZookeeperOffsetHandlerTest fails on windows
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3434">FLINK-3434</a>] - Return value from flinkYarnClient#deploy() should be checked against null
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3438">FLINK-3438</a>] - ExternalProcessRunner fails to detect ClassNotFound exception because of locale settings
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3439">FLINK-3439</a>] - Remove final Long.MAX_VALUE Watermark in StreamSource
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3440">FLINK-3440</a>] - Kafka should also checkpoint partitions where no initial offset was retrieved
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3448">FLINK-3448</a>] - WebRuntimeMonitor: Move initialization of handlers to start() method
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3449">FLINK-3449</a>] - createInput swallows exception if TypeExtractor fails
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3450">FLINK-3450</a>] - RocksDB Backed Window Fails with KryoSerializer
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3453">FLINK-3453</a>] - Fix TaskManager logs exception when sampling backpressure while task completes
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3458">FLINK-3458</a>] - Shading broken in flink-shaded-hadoop
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3478">FLINK-3478</a>] - Flink serves arbitary files through the web interface
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3483">FLINK-3483</a>] - Job graph visualization not working properly in OS X Chrome
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3485">FLINK-3485</a>] - The SerializedListAccumulator value doest seem to be right
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3499">FLINK-3499</a>] - Possible ghost references in ZooKeeper completed checkpoint store
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3511">FLINK-3511</a>] - Flink library examples not runnable without adding dependencies
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3512">FLINK-3512</a>] - Savepoint backend should not revert to "jobmanager"
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3513">FLINK-3513</a>] - Fix interplay of automatic Operator UID and Changing name of WindowOperator
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3518">FLINK-3518</a>] - Stale docs for quickstart setup
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3525">FLINK-3525</a>] - Missing call to super#close() in TimestampsAndPeriodicWatermarksOperator#close()
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3526">FLINK-3526</a>] - ProcessingTime Window Assigner and Trigger are broken
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3534">FLINK-3534</a>] - Cancelling a running job can lead to restart instead of stopping
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3540">FLINK-3540</a>] - Hadoop 2.6.3 build contains /com/google/common (guava) classes in flink-dist.jar
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3554">FLINK-3554</a>] - Bounded sources should emit a Max Watermark when they are done
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3556">FLINK-3556</a>] - Unneeded check in HA blob store configuration
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3562">FLINK-3562</a>] - Update docs in the course of EventTimeSourceFunction removal
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3565">FLINK-3565</a>] - FlinkKafkaConsumer does not work with Scala 2.11
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3569">FLINK-3569</a>] - Test cases fail due to Maven Shade plugin
-</li>
-</ul>
-
-<h3 id="improvement">Improvement</h3>
-
-<ul>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-8">FLINK-8</a>] - [GitHub] Implement automatic sample histogram building for Range Partitioning
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-553">FLINK-553</a>] - Add getGroupKey() method to group-at-time operators
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-573">FLINK-573</a>] - Clean-up MapOperators in optimizer
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-734">FLINK-734</a>] - Integrate web job client into JobManager web interface
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-987">FLINK-987</a>] - Extend TypeSerializers and -Comparators to work directly on Memory Segments
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-1045">FLINK-1045</a>] - Remove Combinable Annotation
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-1228">FLINK-1228</a>] - Add REST Interface to JobManager
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-1240">FLINK-1240</a>] - We cannot use sortGroup on a global reduce
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-1513">FLINK-1513</a>] - Remove GlobalConfiguration Singleton
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-1666">FLINK-1666</a>] - Clean-up Field Expression Code
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-1702">FLINK-1702</a>] - Authenticate via Kerberos from the client only
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-1778">FLINK-1778</a>] - Improve normalized keys in composite key case
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-1903">FLINK-1903</a>] - Joins where one side uses a field more than once don't work
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-1947">FLINK-1947</a>] - Make Avro and Tachyon test logging less verbose
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2017">FLINK-2017</a>] - Add predefined required parameters to ParameterTool
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2021">FLINK-2021</a>] - Rework examples to use ParameterTool
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2075">FLINK-2075</a>] - Shade akka and protobuf dependencies away
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2185">FLINK-2185</a>] - Rework semantics for .setSeed function of SVM
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2213">FLINK-2213</a>] - Configure number of vcores
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2239">FLINK-2239</a>] - print() on DataSet: stream results and print incrementally
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2342">FLINK-2342</a>] - Add new fit operation and more tests for StandardScaler
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2344">FLINK-2344</a>] - Deprecate/Remove the old Pact Pair type
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2380">FLINK-2380</a>] - Allow to configure default FS for file inputs
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2399">FLINK-2399</a>] - Fail when actor versions don't match
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2455">FLINK-2455</a>] - Misleading I/O manager error log messages
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2488">FLINK-2488</a>] - Expose attemptNumber in RuntimeContext
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2518">FLINK-2518</a>] - Avoid predetermination of ports for network services
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2523">FLINK-2523</a>] - Make task canceling interrupt interval configurable
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2524">FLINK-2524</a>] - Add "getTaskNameWithSubtasks()" to RuntimeContext
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2559">FLINK-2559</a>] - Fix Javadoc (e.g. Code Examples)
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2646">FLINK-2646</a>] - Rich functions should provide a method "closeAfterFailure()"
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2667">FLINK-2667</a>] - Rework configuration parameters
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2716">FLINK-2716</a>] - Checksum method for DataSet and Graph
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2788">FLINK-2788</a>] - Add type hint with TypeExtactor call on Hint Type
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2795">FLINK-2795</a>] - Print JobExecutionResult for interactively invoked jobs
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2882">FLINK-2882</a>] - Improve performance of string conversions
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2893">FLINK-2893</a>] - Rename recovery configuration keys
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2895">FLINK-2895</a>] - Duplicate immutable object creation
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2897">FLINK-2897</a>] - Use distinct initial indices for OutputEmitter round-robin
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2898">FLINK-2898</a>] - Invert Travis CI build order
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2902">FLINK-2902</a>] - Web interface sort tasks newest first
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2904">FLINK-2904</a>] - Web interface truncated task counts
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2932">FLINK-2932</a>] - Flink quickstart docs should ask users to download from https, not http
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2936">FLINK-2936</a>] - ClassCastException when using EventTimeSourceFunction in non-EventTime program
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2940">FLINK-2940</a>] - Deploy multiple Scala versions for Maven artifacts
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2947">FLINK-2947</a>] - Coloured Scala Shell
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2949">FLINK-2949</a>] - Add method 'writeSequencefile' to DataSet
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2961">FLINK-2961</a>] - Add support for basic type Date in Table API
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2962">FLINK-2962</a>] - Cluster startup script refers to unused variable
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2966">FLINK-2966</a>] - Improve the way job duration is reported on web frontend.
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2974">FLINK-2974</a>] - Add periodic offset commit to Kafka Consumer if checkpointing is disabled
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2976">FLINK-2976</a>] - Save and load checkpoints manually
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2981">FLINK-2981</a>] - Update README for building docs
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2984">FLINK-2984</a>] - Support lenient parsing of SVMLight input files
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2991">FLINK-2991</a>] - Extend Window Operators to Allow Efficient Fold Operation
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2993">FLINK-2993</a>] - Set default DelayBetweenExecutionRetries to 0
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2994">FLINK-2994</a>] - Client sysout logging does not report exceptions
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3003">FLINK-3003</a>] - Add container allocation timeout to YARN CLI
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3017">FLINK-3017</a>] - Broken 'Slots' link on Streaming Programming Guide
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3023">FLINK-3023</a>] - Show Flink version + commit id for -SNAPSHOT versions in web frontend
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3028">FLINK-3028</a>] - Cannot cancel restarting job via web frontend
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3030">FLINK-3030</a>] - Enhance Dashboard to show Execution Attempts
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3039">FLINK-3039</a>] - Trigger KeyValueState cannot be Scala Int
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3040">FLINK-3040</a>] - Add docs describing how to configure State Backends
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3042">FLINK-3042</a>] - Define a way to let types create their own TypeInformation
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3044">FLINK-3044</a>] - In YARN mode, configure FsStateBackend by default.
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3045">FLINK-3045</a>] - Properly expose the key of a kafka message
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3046">FLINK-3046</a>] - Integrate the Either Java type with the TypeExtractor
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3049">FLINK-3049</a>] - Move "Either" type to package "org.apache.flink.types"
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3050">FLINK-3050</a>] - Add custom Exception type to suppress job restarts
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3051">FLINK-3051</a>] - Define a maximum number of concurrent inflight checkpoints
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3055">FLINK-3055</a>] - ExecutionVertex has duplicate method getParallelSubtaskIndex and getSubTaskIndex
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3056">FLINK-3056</a>] - Show bytes sent/received as MBs/GB and so on in web interface
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3063">FLINK-3063</a>] - [py] Remove combiner
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3069">FLINK-3069</a>] - Make state materialization asynchronous
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3073">FLINK-3073</a>] - Activate streaming mode by default
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3074">FLINK-3074</a>] - Make ApplicationMaster/JobManager akka port configurable
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3076">FLINK-3076</a>] - Display channel exchange mode in the plan visualizer
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3077">FLINK-3077</a>] - Add "version" command to CliFrontend for showing the version of the installation
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3083">FLINK-3083</a>] - Add docs how to configure streaming fault tolerance
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3084">FLINK-3084</a>] - File State Backend should not write very small state into files
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3085">FLINK-3085</a>] - Move State Backend Initialization from "registerInputOutput()" to "invoke()"
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3114">FLINK-3114</a>] - Read cluster's default parallelism upon remote job submission
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3115">FLINK-3115</a>] - Update Elasticsearch connector to 2.X
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3116">FLINK-3116</a>] - Remove RecordOperator
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3120">FLINK-3120</a>] - Set number of event loop thread and number of buffer pool arenas to same number
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3122">FLINK-3122</a>] - Generalize value type in LabelPropagation
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3123">FLINK-3123</a>] - Allow setting custom start-offsets for the Kafka consumer
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3124">FLINK-3124</a>] - Introduce a TaskInfo object to better represent task name, index, attempt number etc.
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3127">FLINK-3127</a>] - Measure backpressure in Flink jobs
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3131">FLINK-3131</a>] - Expose checkpoint metrics
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3132">FLINK-3132</a>] - Restructure streaming guide
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3133">FLINK-3133</a>] - Introduce collect()/coun()/print() methods in DataStream API
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3135">FLINK-3135</a>] - Add chainable driver for UNARY_NO_OP strategy
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3147">FLINK-3147</a>] - HadoopOutputFormatBase should expose fields as protected
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3154">FLINK-3154</a>] - Update Kryo version from 2.24.0 to 3.0.3
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3160">FLINK-3160</a>] - Aggregate operator statistics by TaskManager
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3161">FLINK-3161</a>] - Externalize cluster start-up and tear-down when available
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3169">FLINK-3169</a>] - Drop type from Record Data Model
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3172">FLINK-3172</a>] - Specify jobmanager port in HA mode
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3174">FLINK-3174</a>] - Add merging WindowAssigner
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3176">FLINK-3176</a>] - Window Apply Website Example
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3178">FLINK-3178</a>] - Make Closing Behavior of Window Operators Configurable
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3181">FLINK-3181</a>] - The vertex-centric SSSP example and library method send unnecessary messages during the first superstep
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3194">FLINK-3194</a>] - Remove web client
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3198">FLINK-3198</a>] - Rename Grouping.getDataSet() method and add JavaDocs
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3200">FLINK-3200</a>] - Use Partitioned State Abstraction in WindowOperator
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3209">FLINK-3209</a>] - Remove Unused ProcessingTime, EventTime and AbstractTime
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3213">FLINK-3213</a>] - Union of two streams with different parallelism should adjust parallelism automatically
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3219">FLINK-3219</a>] - Implement DataSet.count using a single operator
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3232">FLINK-3232</a>] - Add option to eagerly deploy channels
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3233">FLINK-3233</a>] - PartitionOperator does not support expression keys on atomic types
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3234">FLINK-3234</a>] - SortPartition does not support KeySelectorFunctions
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3235">FLINK-3235</a>] - Drop Flink-on-Tez code
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3244">FLINK-3244</a>] - Add log messages to savepoint coordinator restore
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3246">FLINK-3246</a>] - Consolidate maven project names with *-parent suffix
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3249">FLINK-3249</a>] - Wrong "unknown partition state/input gate" error messages
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3258">FLINK-3258</a>] - Merge AbstractInvokable's registerInputOutput and invoke
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3259">FLINK-3259</a>] - Redirect programming guides to new layout
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3262">FLINK-3262</a>] - Remove fuzzy versioning from Bower dependencies
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3265">FLINK-3265</a>] - RabbitMQ Source not threadsafe: ConcurrentModificationException
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3270">FLINK-3270</a>] - Add example for reading and writing to Kafka
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3273">FLINK-3273</a>] - Remove Scala dependency from flink-streaming-java
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3276">FLINK-3276</a>] - Move runtime parts of flink-streaming-java to flink-runtime
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3278">FLINK-3278</a>] - Add Partitioned State Backend Based on RocksDB
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3290">FLINK-3290</a>] - [py] Generalize OperationInfo transfer
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3299">FLINK-3299</a>] - Remove ApplicationID from Environment
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3303">FLINK-3303</a>] - Move all non-batch specific classes in flink-java to flink-core
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3305">FLINK-3305</a>] - Remove JavaKaffee serializer util
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3306">FLINK-3306</a>] - Auto type registration at Kryo is buggy
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3308">FLINK-3308</a>] - [py] Remove debug mode
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3309">FLINK-3309</a>] - [py] Resolve maven warnings
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3310">FLINK-3310</a>] - Add back pressure statistics to web frontend
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3334">FLINK-3334</a>] - Change default log4j.properties Conversion pattern to include year-month-day in the timestamp
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3336">FLINK-3336</a>] - Add Semi-Rebalance Data Shipping for DataStream
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3347">FLINK-3347</a>] - TaskManager ActorSystems need to restart themselves in case they notice quarantine
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3348">FLINK-3348</a>] - taskmanager.memory.off-heap missing bc documentation
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3355">FLINK-3355</a>] - Allow passing RocksDB Option to RocksDBStateBackend
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3358">FLINK-3358</a>] - Create constructors for FsStateBackend in RocksDBBackens
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3364">FLINK-3364</a>] - Don't initialize SavepointStore in JobManager constructor
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3375">FLINK-3375</a>] - Allow Watermark Generation in the Kafka Source
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3376">FLINK-3376</a>] - Add an illustration of Event Time and Watermarks to the docs
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3378">FLINK-3378</a>] - Consolidate TestingCluster and FokableFlinkMiniCluster
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3379">FLINK-3379</a>] - Refactor TimestampExtractor
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3386">FLINK-3386</a>] - Kafka consumers are not properly respecting the "auto.offset.reset" behavior
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3389">FLINK-3389</a>] - Add Pre-defined Options settings for RocksDB State backend
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3395">FLINK-3395</a>] - Polishing the web UI
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3402">FLINK-3402</a>] - Refactor Common Parts of Stream/Batch Documentation
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3413">FLINK-3413</a>] - Remove implicit Seq to DataStream conversion
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3419">FLINK-3419</a>] - Drop partitionByHash from DataStream
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3421">FLINK-3421</a>] - Remove all unused ClassTag context bounds in the Streaming Scala API
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3422">FLINK-3422</a>] - Scramble HashPartitioner hashes
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3430">FLINK-3430</a>] - Remove "no POJO" warning in TypeAnalyzer
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3435">FLINK-3435</a>] - Change interplay of Ingestion Time and Event Time
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3436">FLINK-3436</a>] - Remove ComplexIntegrationITCase
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3455">FLINK-3455</a>] - Bump Kafka 0.9 connector dependency to Kafka 0.9.0.1
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3459">FLINK-3459</a>] - Make build SBT compatible
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3460">FLINK-3460</a>] - Make flink-streaming-connectors' flink dependencies provided
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3461">FLINK-3461</a>] - Remove duplicate condition check in ZooKeeperLeaderElectionService
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3469">FLINK-3469</a>] - Improve documentation for grouping keys
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3509">FLINK-3509</a>] - Update Hadoop versions in release script and on travis to the latest minor version
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3520">FLINK-3520</a>] - Periodic watermark operator should emit current watermark in close()
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3521">FLINK-3521</a>] - Make Iterable part of method signature for WindowFunction
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3522">FLINK-3522</a>] - Storm examples "PrintSampleStream" throws an error if called without arguments
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3527">FLINK-3527</a>] - Scala DataStream has no transform method
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3528">FLINK-3528</a>] - Add Incremental Fold for Non-Keyed Window Operator
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3535">FLINK-3535</a>] - Decrease logging verbosity of StackTraceSampleCoordinator
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3536">FLINK-3536</a>] - Make clearer distinction between event time and processing time
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3538">FLINK-3538</a>] - DataStream join API does not enforce consistent usage
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3548">FLINK-3548</a>] - Remove unnecessary generic parameter from SingleOutputStreamOperator
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3559">FLINK-3559</a>] - Don't print pid file check if no active PID
-</li>
-</ul>
-
-<h3> New Feature
-</h3>
-<ul>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-1723">FLINK-1723</a>] - Add cross validation for model evaluation
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2157">FLINK-2157</a>] - Create evaluation framework for ML library
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2390">FLINK-2390</a>] - Replace iteration timeout with algorithm for detecting termination
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2411">FLINK-2411</a>] - Add basic graph summarization algorithm
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2435">FLINK-2435</a>] - Add support for custom CSV field parsers
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2720">FLINK-2720</a>] - Add Storm-CountMetric in flink-stormcompatibility
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2728">FLINK-2728</a>] - Add missing features to new web dashboard
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2871">FLINK-2871</a>] - Add OuterJoin strategy with HashTable on outer side
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2905">FLINK-2905</a>] - Add intersect method to Graph class
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2951">FLINK-2951</a>] - Add Union operator to Table API.
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2955">FLINK-2955</a>] - Add operations introduction in Table API page.
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2978">FLINK-2978</a>] - Integrate web submission interface into the new dashboard
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2996">FLINK-2996</a>] - Add config entry to define BlobServer port
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3001">FLINK-3001</a>] - Add Support for Java 8 Optional type
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3002">FLINK-3002</a>] - Add an EitherType to the Java API
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3058">FLINK-3058</a>] - Add Kafka consumer for new 0.9.0.0 Kafka API
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3093">FLINK-3093</a>] - Introduce annotations for interface stability
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3102">FLINK-3102</a>] - Allow reading from multiple topics with one FlinkKafkaConsumer
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3170">FLINK-3170</a>] - Expose task manager metrics via JMX
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3192">FLINK-3192</a>] - Add explain support to print ast and sql physical execution plan.
-</li>
-</ul>
-
-<h3 id="task">Task</h3>
-
-<ul>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-1681">FLINK-1681</a>] - Remove the old Record API
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2973">FLINK-2973</a>] - Add flink-benchmark with compliant licenses again
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3112">FLINK-3112</a>] - Remove unused RecordModelPostPass class
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3113">FLINK-3113</a>] - Remove unused global order methods from GenericDataSinkBase
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3155">FLINK-3155</a>] - Update Flink docker version to latest stable Flink version
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3186">FLINK-3186</a>] - Deprecate DataSink.sortLocalOutput() methods
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3366">FLINK-3366</a>] - Rename @Experimental annotation to @PublicEvolving
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3367">FLINK-3367</a>] - Annotate all user-facing API classes with @Public or @PublicEvolving
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3484">FLINK-3484</a>] - Add setSlotSharingGroup documentation
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3490">FLINK-3490</a>] - Bump Chill version to 0.7.4
-</li>
-</ul>
-
-<h3 id="test">Test</h3>
-
-<ul>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2480">FLINK-2480</a>] - Improving tests coverage for org.apache.flink.streaming.api
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2573">FLINK-2573</a>] - Add Kerberos test case
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2803">FLINK-2803</a>] - Add test case for Flink's memory allocation
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3517">FLINK-3517</a>] - Number of job and task managers not checked in scripts
-</li>
-</ul>
-
-<h3 id="wish">Wish</h3>
-
-<ul>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2429">FLINK-2429</a>] - Remove the "enableCheckpointing()" without interval variant
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2995">FLINK-2995</a>] - Set default number of retries to larger than 0
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3377">FLINK-3377</a>] - Remove final flag from ResultPartitionWriter class
-</li>
-</ul>
-
-<h2 id="known-issues">Known Issues</h2>
-
-<ul>
- <li>The <code>mvn clean verify</code> command does not succeed for the source release, because of issues with the Maven shade plugin. This has been resolved in the <code>release-1.0</code> branch.</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3578">FLINK-3578</a> - Scala DataStream API does not support Rich Window Functions.</li>
-</ul>
-
-
- </div>
-</div>
-
- </div>
- </div>
-
- <hr />
-
- <div class="row">
- <div class="footer text-center col-sm-12">
- <p>Copyright � 2014-2016 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
- <p>Apache Flink, Apache, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation.</p>
- <p><a href="/privacy-policy.html">Privacy Policy</a> · <a href="/blog/feed.xml">RSS feed</a></p>
- </div>
- </div>
- </div><!-- /.container -->
-
- <!-- Include all compiled plugins (below), or include individual files as needed -->
- <script src="https://maxcdn.bootstrapcdn.com/bootstrap/3.3.4/js/bootstrap.min.js"></script>
- <script src="/js/codetabs.js"></script>
- <script src="/js/stickysidebar.js"></script>
-
-
- <!-- Google Analytics -->
- <script>
- (function(i,s,o,g,r,a,m){i['GoogleAnalyticsObject']=r;i[r]=i[r]||function(){
- (i[r].q=i[r].q||[]).push(arguments)},i[r].l=1*new Date();a=s.createElement(o),
- m=s.getElementsByTagName(o)[0];a.async=1;a.src=g;m.parentNode.insertBefore(a,m)
- })(window,document,'script','//www.google-analytics.com/analytics.js','ga');
-
- ga('create', 'UA-52545728-1', 'auto');
- ga('send', 'pageview');
- </script>
- </body>
-</html>