flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rmetz...@apache.org
Subject [4/7] flink-web git commit: Add Flink 1.3.0 release announcement
Date Thu, 01 Jun 2017 14:14:56 GMT
http://git-wip-us.apache.org/repos/asf/flink-web/blob/4e75b86e/content/blog/release_1.3.0-changelog.html
----------------------------------------------------------------------
diff --git a/content/blog/release_1.3.0-changelog.html b/content/blog/release_1.3.0-changelog.html
new file mode 100644
index 0000000..0e62184
--- /dev/null
+++ b/content/blog/release_1.3.0-changelog.html
@@ -0,0 +1,1662 @@
+<!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.3.0 – Changelog</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/flink-header-logo.svg" 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 &amp; 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.3" 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.3" target="_blank">1.3 (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-master" target="_blank">1.4 (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.3/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.3.0 – Changelog</h1>
+
+	<ul id="markdown-toc">
+  <li><a href="#changelog" id="markdown-toc-changelog">Changelog</a></li>
+</ul>
+
+<h2 id="changelog">Changelog</h2>
+
+<p>The 1.3.0 release <a href="https://issues.apache.org/jira/issues/?jql=project+%3D+FLINK+AND+fixVersion+%3D+1.3.0">resolved 772 JIRA issues</a> in total.</p>
+
+<h2>        Sub-task
+</h2>
+<ul>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3722">FLINK-3722</a>] -         The divisions in the InMemorySorters&#39; swap/compare methods hurt performance
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4562">FLINK-4562</a>] -         table examples make an divided module in flink-examples
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4692">FLINK-4692</a>] -         Add tumbling group-windows for batch tables
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4693">FLINK-4693</a>] -         Add session group-windows for batch tables	
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4697">FLINK-4697</a>] -         Gather more detailed checkpoint stats in CheckpointStatsTracker
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4698">FLINK-4698</a>] -         Visualize additional checkpoint information
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4769">FLINK-4769</a>] -         Migrate Metrics configuration options
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4912">FLINK-4912</a>] -         Introduce RECONCILING state in ExecutionGraph
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4959">FLINK-4959</a>] -         Write Documentation for ProcessFunction
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4994">FLINK-4994</a>] -         Don&#39;t Clear Trigger State and Merging Window Set When Purging
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5132">FLINK-5132</a>] -         Introduce the ResourceSpec for grouping different resource factors in API
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5133">FLINK-5133</a>] -         Support to set resource for operator in DataStream and DataSet
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5134">FLINK-5134</a>] -         Aggregate ResourceSpec for chained operators when generating job graph
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5135">FLINK-5135</a>] -         ResourceProfile for slot request should be expanded to correspond with ResourceSpec
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5219">FLINK-5219</a>] -         Add non-grouped session windows for batch tables
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5239">FLINK-5239</a>] -         Properly unpack thrown exceptions in RPC methods
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5268">FLINK-5268</a>] -         Split TableProgramsTestBase into TableProgramsCollectionTestBase and TableProgramsClusterTestBase
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5386">FLINK-5386</a>] -         Refactoring Window Clause
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5417">FLINK-5417</a>] -         Fix the wrong config file name 
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5435">FLINK-5435</a>] -         Cleanup the rules introduced by FLINK-5144 when calcite releases 1.12
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5454">FLINK-5454</a>] -         Add Documentation about how to tune Checkpointing for large state
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5456">FLINK-5456</a>] -         Add docs about new state and checkpointing interfaces
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5457">FLINK-5457</a>] -         Create documentation for Asynchronous I/O
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5458">FLINK-5458</a>] -         Add documentation how to migrate from Flink 1.1. to Flink 1.2
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5459">FLINK-5459</a>] -         Add documentation how to debug classloading issues
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5474">FLINK-5474</a>] -         Extend DC/OS documentation
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5494">FLINK-5494</a>] -         Improve Mesos documentation
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5501">FLINK-5501</a>] -         Determine whether the job starts from last JobManager failure
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5529">FLINK-5529</a>] -         Improve / extends windowing documentation
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5545">FLINK-5545</a>] -         Remove FlinkAggregateExpandDistinctAggregatesRule when upgrading to Calcite 1.12
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5555">FLINK-5555</a>] -         Add documentation about debugging watermarks
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5566">FLINK-5566</a>] -         Introduce structure to hold table and column level statistics
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5567">FLINK-5567</a>] -         Introduce and migrate current table statistics to FlinkStatistics
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5570">FLINK-5570</a>] -         Support register external catalog to table environment
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5618">FLINK-5618</a>] -         Add queryable state documentation
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5640">FLINK-5640</a>] -         configure the explicit Unit Test file suffix
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5653">FLINK-5653</a>] -         Add processing time OVER ROWS BETWEEN x PRECEDING aggregation to SQL
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5654">FLINK-5654</a>] -         Add processing time OVER RANGE BETWEEN x PRECEDING aggregation to SQL
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5655">FLINK-5655</a>] -         Add event time OVER RANGE BETWEEN x PRECEDING aggregation to SQL
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5656">FLINK-5656</a>] -         Add processing time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5658">FLINK-5658</a>] -         Add event time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5693">FLINK-5693</a>] -         ChecksumHashCode DataSetAnalytic
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5694">FLINK-5694</a>] -         Collect DataSetAnalytic
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5716">FLINK-5716</a>] -         Make streaming SourceContexts aware of source idleness
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5723">FLINK-5723</a>] -         Use &quot;Used&quot; instead of &quot;Initial&quot; to make taskmanager tag more readable
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5729">FLINK-5729</a>] -         add hostname option in SocketWindowWordCount example to be more convenient
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5767">FLINK-5767</a>] -         New aggregate function interface and built-in aggregate functions
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5768">FLINK-5768</a>] -         Apply new aggregation functions for datastream and dataset tables
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5777">FLINK-5777</a>] -         Pass savepoint information to CheckpointingOperation
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5794">FLINK-5794</a>] -         update the documentation  about “UDF/UDTF&quot;  support have parameters constructor.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5795">FLINK-5795</a>] -         Improve UDF&amp;UDTF to support constructor with parameter
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5798">FLINK-5798</a>] -         Let the RPCService provide a ScheduledExecutorService
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5799">FLINK-5799</a>] -         Let RpcService.scheduleRunnable return ScheduledFuture
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5803">FLINK-5803</a>] -         Add [partitioned] processing time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5804">FLINK-5804</a>] -         Add [non-partitioned] processing time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5810">FLINK-5810</a>] -         Harden SlotManager
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5821">FLINK-5821</a>] -         Create StateBackend root interface
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5822">FLINK-5822</a>] -         Make Checkpoint Coordinator aware of State Backend
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5825">FLINK-5825</a>] -         In yarn mode, a small pic can not be loaded
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5845">FLINK-5845</a>] -         CEP: unify key and non-keyed operators
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5846">FLINK-5846</a>] -         CEP: make the operators backwards compatible.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5869">FLINK-5869</a>] -         ExecutionGraph use FailoverCoordinator to manage the failover of execution vertexes
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5881">FLINK-5881</a>] -         ScalarFunction(UDF) should support variable types and variable arguments	
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5882">FLINK-5882</a>] -         TableFunction (UDTF) should support variable types and variable arguments
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5897">FLINK-5897</a>] -         Untie Checkpoint Externalization from FileSystems
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5903">FLINK-5903</a>] -         taskmanager.numberOfTaskSlots and yarn.containers.vcores did not work well in YARN mode
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5906">FLINK-5906</a>] -         Add support to register UDAGG in Table and SQL API
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5909">FLINK-5909</a>] -         Interface for GraphAlgorithm results
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5910">FLINK-5910</a>] -         Framework for Gelly examples
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5911">FLINK-5911</a>] -         Command-line parameters
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5912">FLINK-5912</a>] -         Inputs for CSV and graph generators
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5913">FLINK-5913</a>] -         Example drivers
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5915">FLINK-5915</a>] -         Add support for the aggregate on multi fields
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5916">FLINK-5916</a>] -         make env.java.opts.jobmanager and env.java.opts.taskmanager working in YARN mode
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5927">FLINK-5927</a>] -         Remove old Aggregate interface and built-in functions
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5956">FLINK-5956</a>] -         Add retract method into the aggregateFunction
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5963">FLINK-5963</a>] -         Remove preparation mapper of DataSetAggregate
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5981">FLINK-5981</a>] -         SSL version and ciper suites cannot be constrained as configured
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5990">FLINK-5990</a>] -         Add [partitioned] event time OVER ROWS BETWEEN x PRECEDING aggregation to SQL
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6011">FLINK-6011</a>] -         Support TUMBLE, HOP, SESSION window in streaming SQL
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6012">FLINK-6012</a>] -         Support WindowStart / WindowEnd functions in streaming SQL
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6020">FLINK-6020</a>] -         Blob Server cannot handle multiple job submits (with same content) parallelly
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6034">FLINK-6034</a>] -         Add KeyedStateHandle for the snapshots in keyed streams
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6037">FLINK-6037</a>] -         the estimateRowCount method of DataSetCalc didn&#39;t work in SQL
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6089">FLINK-6089</a>] -         Implement decoration phase for rewriting predicated logical plan after volcano optimization phase
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6107">FLINK-6107</a>] -         Add custom checkstyle for flink-streaming-java
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6117">FLINK-6117</a>] -         &#39;zookeeper.sasl.disable&#39;  not takes effet when starting CuratorFramework
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6136">FLINK-6136</a>] -         Separate EmbeddedNonHaServices and NonHaServices
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6149">FLINK-6149</a>] -         add additional flink logical relation nodes
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6155">FLINK-6155</a>] -         Allow to specify endpoint names
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6190">FLINK-6190</a>] -         Write &quot;Serializer Configurations&quot; metainfo along with state
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6191">FLINK-6191</a>] -         Make non-primitive, internal built-in serializers reconfigurable
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6195">FLINK-6195</a>] -         Move gelly-examples jar from opt to examples
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6198">FLINK-6198</a>] -         Update the documentation of the CEP library to include all the new features.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6200">FLINK-6200</a>] -         Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6201">FLINK-6201</a>] -         move python example files from resources to the examples
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6228">FLINK-6228</a>] -         Integrating the OVER windows in the Table API
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6240">FLINK-6240</a>] -         codeGen dataStream aggregates that use AggregateAggFunction
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6241">FLINK-6241</a>] -         codeGen dataStream aggregates that use ProcessFunction
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6242">FLINK-6242</a>] -         codeGen DataSet Goupingwindow Aggregates
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6257">FLINK-6257</a>] -         Post-pass OVER windows
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6261">FLINK-6261</a>] -         Add support for TUMBLE, HOP, SESSION to batch SQL
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6340">FLINK-6340</a>] -         Introduce a TerminationFuture for Execution
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6361">FLINK-6361</a>] -         Finalize the AggregateFunction interface and refactoring built-in aggregates
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6367">FLINK-6367</a>] -         support custom header settings of allow origin
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6392">FLINK-6392</a>] -         Change the alias of Window from optional to essential.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6425">FLINK-6425</a>] -         Integrate serializer reconfiguration into state restore flow to activate serializer upgrades
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6448">FLINK-6448</a>] -         Web UI TaskManager view: Rename &#39;Free Memory&#39; to &#39;JVM Heap&#39;
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6450">FLINK-6450</a>] -         Web UI Subtasks view for TaskManagers has a misleading name
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6451">FLINK-6451</a>] -         Web UI: Rename &#39;Metrics&#39; view to &#39;Task Metrics&#39;
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6470">FLINK-6470</a>] -         Add a utility to parse memory sizes with units
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6475">FLINK-6475</a>] -         Incremental snapshots in RocksDB hold lock during async file upload
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6478">FLINK-6478</a>] -         Add documentation on how to upgrade serializers for managed state
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6504">FLINK-6504</a>] -         Lack of synchronization on materializedSstFiles in RocksDBKEyedStateBackend
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6527">FLINK-6527</a>] -         OperatorSubtaskState has empty implementations of (un)/registerSharedStates
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6533">FLINK-6533</a>] -         Duplicated registration of new shared state when checkpoint confirmations are still pending
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6534">FLINK-6534</a>] -         SharedStateRegistry is disposing state handles from main thread
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6535">FLINK-6535</a>] -         JobID should not be part of the registration key to the SharedStateRegistry
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6545">FLINK-6545</a>] -         Make incremental checkpoints externalizable
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6570">FLINK-6570</a>] -         QueryableStateClient constructor in documentation doesn&#39;t match actual signature
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6618">FLINK-6618</a>] -         Fix GroupWindowStringExpressionTest testcase bug
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6632">FLINK-6632</a>] -         Fix parameter case sensitive error for test passing/rejecting filter API
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6633">FLINK-6633</a>] -         Register with shared state registry before adding to CompletedCheckpointStore
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6640">FLINK-6640</a>] -         Ensure registration of shared state happens before externalizing a checkpoint
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6650">FLINK-6650</a>] -         Fix Non-windowed group-aggregate error when using append-table mode.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6676">FLINK-6676</a>] -         API Migration guide: add QueryableStateClient changes
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6677">FLINK-6677</a>] -         API Migration guide: add Table API changes
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6678">FLINK-6678</a>] -         API Migration guide: add note about removed log4j default logger from core artefacts
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6679">FLINK-6679</a>] -         Document HeapStatebackend
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6680">FLINK-6680</a>] -         App &amp; Flink migration guide: updates for the 1.3 release
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6681">FLINK-6681</a>] -         Update &quot;Upgrading the Flink Framework Version&quot; section for 1.2 -&gt; 1.3
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6683">FLINK-6683</a>] -         building with Scala 2.11 no longer uses change-scala-version.sh
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6700">FLINK-6700</a>] -         Remove &quot;Download and Compile&quot; from quickstart 
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6736">FLINK-6736</a>] -         Fix UDTF codegen bug when window follow by join( UDTF)
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6737">FLINK-6737</a>] -         Fix over expression parse String error.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6782">FLINK-6782</a>] -         Update savepoint documentation
+</li>
+</ul>
+
+<h2>        Bug
+</h2>
+<ul>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2067">FLINK-2067</a>] -         Chained streaming operators should not throw chained exceptions
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2662">FLINK-2662</a>] -         CompilerException: &quot;Bug: Plan generation for Unions picked a ship strategy between binary plan operators.&quot;
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2814">FLINK-2814</a>] -         DeltaIteration: DualInputPlanNode cannot be cast to SingleInputPlanNode
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3679">FLINK-3679</a>] -         Allow Kafka consumer to skip corrupted messages
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4148">FLINK-4148</a>] -         incorrect calculation distance in QuadTree
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4255">FLINK-4255</a>] -         Unstable test WebRuntimeMonitorITCase.testNoEscape
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4813">FLINK-4813</a>] -         Having flink-test-utils as a dependency outside Flink fails the build
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4848">FLINK-4848</a>] -         keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4870">FLINK-4870</a>] -         ContinuousFileMonitoringFunction does not properly handle absolut Windows paths
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4890">FLINK-4890</a>] -         FileInputFormatTest#testExcludeFiles fails on Windows OS
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4905">FLINK-4905</a>] -         Kafka test instability IllegalStateException: Client is not started
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5049">FLINK-5049</a>] -         Instability in QueryableStateITCase.testQueryableStateWithTaskManagerFailure
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5070">FLINK-5070</a>] -         Unable to use Scala&#39;s BeanProperty with classes
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5101">FLINK-5101</a>] -         Test CassandraConnectorITCase instable
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5118">FLINK-5118</a>] -         Inconsistent records sent/received metrics
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5119">FLINK-5119</a>] -         Last taskmanager heartbeat not showing in web frontend
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5122">FLINK-5122</a>] -         Elasticsearch Sink loses documents when cluster has high load
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5150">FLINK-5150</a>] -         WebUI metric-related resource leak
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5165">FLINK-5165</a>] -         Checkpointing tests using FsStatebackend fail on Windows
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5214">FLINK-5214</a>] -         Clean up checkpoint files when failing checkpoint operation on TM
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5229">FLINK-5229</a>] -         Cleanup StreamTaskStates if a checkpoint operation of a subsequent operator fails 
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5247">FLINK-5247</a>] -         Fix incorrect check in allowedLateness() method. Make it a no-op for non-event time windows.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5267">FLINK-5267</a>] -         TaskManager logs not scrollable
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5298">FLINK-5298</a>] -         TaskManager crashes when TM log not existant
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5321">FLINK-5321</a>] -         FlinkMiniCluster does not start Jobmanager MetricQueryService
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5323">FLINK-5323</a>] -         CheckpointNotifier should be removed from docs
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5329">FLINK-5329</a>] -         Metric list is being cut off in the WebFrontend
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5345">FLINK-5345</a>] -         IOManager failed to properly clean up temp file directory
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5349">FLINK-5349</a>] -         Fix code sample for Twitter connector
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5350">FLINK-5350</a>] -         Don&#39;t overwrite existing Jaas config property
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5353">FLINK-5353</a>] -         Elasticsearch Sink loses well-formed documents when there are malformed documents
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5359">FLINK-5359</a>] -         Job Exceptions view doesn&#39;t scroll 
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5361">FLINK-5361</a>] -         Flink shouldn&#39;t require Kerberos credentials
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5364">FLINK-5364</a>] -         Rework JAAS configuration to support user-supplied entries
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5365">FLINK-5365</a>] -         Mesos AppMaster/TaskManager should obey sigterm
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5375">FLINK-5375</a>] -         Fix watermark documentation
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5379">FLINK-5379</a>] -         Flink CliFrontend does not return when not logged in with kerberos
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5380">FLINK-5380</a>] -         Number of outgoing records not reported in web interface
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5381">FLINK-5381</a>] -         Scrolling in some web interface pages doesn&#39;t work (taskmanager details, jobmanager config)
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5382">FLINK-5382</a>] -         Taskmanager log download button causes 404
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5383">FLINK-5383</a>] -         TaskManager fails with SIGBUS when loading RocksDB
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5389">FLINK-5389</a>] -         Fails #testAnswerFailureWhenSavepointReadFails
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5390">FLINK-5390</a>] -         input should be closed in finally block in YarnFlinkApplicationMasterRunner#loadJobGraph()
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5392">FLINK-5392</a>] -         flink-dist build failed when change scala version to 2.11
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5397">FLINK-5397</a>] -         Fail to deserialize savepoints in v1.1 when there exist missing fields in class serialization descriptors
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5400">FLINK-5400</a>] -         Add accessor to folding states in RuntimeContext
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5402">FLINK-5402</a>] -         Fails AkkaRpcServiceTest#testTerminationFuture
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5407">FLINK-5407</a>] -         Savepoint for iterative Task fails.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5408">FLINK-5408</a>] -         RocksDB initialization can fail with an UnsatisfiedLinkError in the presence of multiple classloaders
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5419">FLINK-5419</a>] -         Taskmanager metrics not accessible via REST
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5427">FLINK-5427</a>] -         Typo in the event_timestamps_watermarks doc
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5432">FLINK-5432</a>] -         ContinuousFileMonitoringFunction is not monitoring nested files
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5434">FLINK-5434</a>] -         Remove unsupported project() transformation from Scala DataStream docs
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5444">FLINK-5444</a>] -         Flink UI uses absolute URLs.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5450">FLINK-5450</a>] -         WindowOperator logs about &quot;re-registering state from an older Flink version&quot; even though its not a restored window
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5464">FLINK-5464</a>] -         MetricQueryService throws NullPointerException on JobManager
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5467">FLINK-5467</a>] -         Stateless chained tasks set legacy operator state
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5468">FLINK-5468</a>] -         Restoring from a semi async rocksdb statebackend (1.1) to 1.2 fails with ClassNotFoundException
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5470">FLINK-5470</a>] -         Requesting non-existing log/stdout file from TM crashes the TM
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5473">FLINK-5473</a>] -         setMaxParallelism() higher than 1 is possible on non-parallel operators
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5481">FLINK-5481</a>] -         Simplify Row creation
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5482">FLINK-5482</a>] -         QueryableStateClient does not recover from a failed lookup due to a non-running job
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5484">FLINK-5484</a>] -         Kryo serialization changed between 1.1 and 1.2
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5487">FLINK-5487</a>] -         Proper at-least-once support for ElasticsearchSink
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5489">FLINK-5489</a>] -         maven release:prepare fails due to invalid JDOM comments in pom.xml
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5492">FLINK-5492</a>] -         BootstrapTools log wrong address of started ActorSystem
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5493">FLINK-5493</a>] -         FlinkDistributionOverlay does not properly display missing environment variables
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5495">FLINK-5495</a>] -         ZooKeeperMesosWorkerStore cannot be instantiated
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5496">FLINK-5496</a>] -         ClassCastException when using Mesos HA mode
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5504">FLINK-5504</a>] -         mesos-appmaster.sh logs to wrong directory
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5518">FLINK-5518</a>] -         HadoopInputFormat throws NPE when close() is called before open()
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5520">FLINK-5520</a>] -         Disable outer joins with non-equality predicates
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5530">FLINK-5530</a>] -         race condition in AbstractRocksDBState#getSerializedValue
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5531">FLINK-5531</a>] -         SSl code block formatting is broken
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5532">FLINK-5532</a>] -         Make the marker WindowAssigners for the fast aligned windows non-extendable.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5553">FLINK-5553</a>] -         Job fails during deployment with IllegalStateException from subpartition request
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5556">FLINK-5556</a>] -         BarrierBuffer resets bytes written on spiller roll over
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5560">FLINK-5560</a>] -         Header in checkpoint stats summary misaligned
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5561">FLINK-5561</a>] -         DataInputDeserializer#available returns one too few
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5562">FLINK-5562</a>] -         Driver fixes
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5577">FLINK-5577</a>] -         Each time application is submitted to yarn, application id increases by two
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5585">FLINK-5585</a>] -         NullPointer Exception in JobManager.updateAccumulators
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5602">FLINK-5602</a>] -         Migration with RocksDB job led to NPE for next checkpoint
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5608">FLINK-5608</a>] -         Cancel button not always visible
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5612">FLINK-5612</a>] -         GlobPathFilter not-serializable exception
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5613">FLINK-5613</a>] -         QueryableState: requesting a non-existing key in RocksDBStateBackend is not consistent with the MemoryStateBackend and FsStateBackend
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5616">FLINK-5616</a>] -         YarnPreConfiguredMasterHaServicesTest fails sometimes
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5617">FLINK-5617</a>] -         Check new public APIs in 1.2 release
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5623">FLINK-5623</a>] -         TempBarrier dam has been closed
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5626">FLINK-5626</a>] -         Improve resource release in RocksDBKeyedStateBackend
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5628">FLINK-5628</a>] -         CheckpointStatsTracker implements Serializable but isn&#39;t
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5629">FLINK-5629</a>] -         Unclosed RandomAccessFile in StaticFileServerHandler#respondAsLeader()
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5631">FLINK-5631</a>] -         [yarn] Support downloading additional jars from non-HDFS paths
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5636">FLINK-5636</a>] -         IO Metric for StreamTwoInputProcessor
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5637">FLINK-5637</a>] -         Default Flink configuration contains whitespace characters, causing parser WARNings
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5638">FLINK-5638</a>] -         Deadlock when closing two chained async I/O operators
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5643">FLINK-5643</a>] -         StateUtil.discardStateFuture fails when state future contains null value
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5644">FLINK-5644</a>] -         Task#lastCheckpointSize metric broken
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5645">FLINK-5645</a>] -         IOMetrics transfer through ExecGraph does not work for failed jobs
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5646">FLINK-5646</a>] -         REST api documentation missing details on jar upload
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5650">FLINK-5650</a>] -         Flink-python tests executing cost too long time
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5652">FLINK-5652</a>] -         Memory leak in AsyncDataStream
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5660">FLINK-5660</a>] -         Not properly cleaning PendingCheckpoints up
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5662">FLINK-5662</a>] -         Alias in front of output fails
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5663">FLINK-5663</a>] -         Checkpoint fails because of closed registry
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5666">FLINK-5666</a>] -         Blob files are not cleaned up from ZK storage directory
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5667">FLINK-5667</a>] -         Possible state data loss when task fails while checkpointing
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5669">FLINK-5669</a>] -         flink-streaming-contrib DataStreamUtils.collect in local environment mode fails when offline
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5670">FLINK-5670</a>] -         Local RocksDB directories not cleaned up
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5684">FLINK-5684</a>] -         Add MacOS section to flink-runtime-web README
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5699">FLINK-5699</a>] -         Cancel with savepoint fails with a NPE if savepoint target directory not set
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5701">FLINK-5701</a>] -         FlinkKafkaProducer should check asyncException on checkpoints
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5708">FLINK-5708</a>] -         we should remove duplicated configuration options 
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5712">FLINK-5712</a>] -         update several deprecated configuration options 
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5739">FLINK-5739</a>] -         NullPointerException in CliFrontend
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5747">FLINK-5747</a>] -         Eager Scheduling should deploy all Tasks together
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5749">FLINK-5749</a>] -             unset HADOOP_HOME and HADOOP_CONF_DIR to avoid env in build machine failing the UT and IT
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5751">FLINK-5751</a>] -         404 in documentation
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5759">FLINK-5759</a>] -         Set an UncaughtExceptionHandler for all Thread Pools in JobManager
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5762">FLINK-5762</a>] -         Protect initializeState() and open() by the same lock.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5771">FLINK-5771</a>] -         DelimitedInputFormat does not correctly handle multi-byte delimiters
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5773">FLINK-5773</a>] -         Cannot cast scala.util.Failure to org.apache.flink.runtime.messages.Acknowledge
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5793">FLINK-5793</a>] -         Running slot may not be add to AllocatedMap in SlotPool
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5796">FLINK-5796</a>] -         broken links in the docs
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5797">FLINK-5797</a>] -         incorrect use of port range selector in BootstrapTool
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5806">FLINK-5806</a>] -         TaskExecutionState toString format have wrong key
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5811">FLINK-5811</a>] -         Harden YarnClusterDescriptorTest
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5814">FLINK-5814</a>] -         flink-dist creates wrong symlink when not used with cleaned before
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5817">FLINK-5817</a>] -         Fix test concurrent execution failure by test dir conflicts.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5824">FLINK-5824</a>] -         Fix String/byte conversions without explicit encoding
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5827">FLINK-5827</a>] -         Exception when do filter after join a udtf which returns a POJO type
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5828">FLINK-5828</a>] -         BlobServer create cache dir has concurrency safety problem
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5830">FLINK-5830</a>] -         OutOfMemoryError during notify final state in TaskExecutor may cause job stuck
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5836">FLINK-5836</a>] -         Race condition between slot offering and task deployment
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5838">FLINK-5838</a>] -         Print shell script usage
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5842">FLINK-5842</a>] -         Wrong &#39;since&#39; version for ElasticSearch 5.x connector
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5849">FLINK-5849</a>] -         Kafka Consumer checkpointed state may contain undefined offsets
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5864">FLINK-5864</a>] -         CEP: fix duplicate output patterns problem.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5871">FLINK-5871</a>] -         Enforce uniqueness of pattern names in CEP.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5872">FLINK-5872</a>] -         WebUI shows &quot;(null)&quot; root-exception even without exception
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5885">FLINK-5885</a>] -         Java code snippet instead of scala in documentation
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5890">FLINK-5890</a>] -         GatherSumApply broken when object reuse enabled
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5899">FLINK-5899</a>] -         Fix the bug in EventTimeTumblingWindow for non-partialMerge aggregate
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5904">FLINK-5904</a>] -         jobmanager.heap.mb and taskmanager.heap.mb not work in YARN mode
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5907">FLINK-5907</a>] -         RowCsvInputFormat bug on parsing tsv
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5928">FLINK-5928</a>] -         Externalized checkpoints overwritting each other
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5932">FLINK-5932</a>] -         Order of legacy vs new state initialization in the AbstractStreamOperator.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5933">FLINK-5933</a>] -         Allow Evictor for merging windows
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5934">FLINK-5934</a>] -         Scheduler in ExecutionGraph null if failure happens in ExecutionGraph.restoreLatestCheckpointedState
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5937">FLINK-5937</a>] -         Add documentation about the task lifecycle.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5940">FLINK-5940</a>] -         ZooKeeperCompletedCheckpointStore cannot handle broken state handles
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5942">FLINK-5942</a>] -         Harden ZooKeeperStateHandleStore to deal with corrupted data
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5945">FLINK-5945</a>] -         Close function in OuterJoinOperatorBase#executeOnCollections
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5948">FLINK-5948</a>] -         Error in Python zip_with_index documentation
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5949">FLINK-5949</a>] -         Flink on YARN checks for Kerberos credentials for non-Kerberos authentication methods
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5955">FLINK-5955</a>] -         Merging a list of buffered records will have problem when ObjectReuse is turned on
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5962">FLINK-5962</a>] -         Cancel checkpoint canceller tasks in CheckpointCoordinator
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5965">FLINK-5965</a>] -         Typo on DropWizard wrappers
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5971">FLINK-5971</a>] -         JobLeaderIdService should time out registered jobs
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5972">FLINK-5972</a>] -         Don&#39;t allow shrinking merging windows
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5977">FLINK-5977</a>] -         Rename MAX_ATTEMPTS_HISTORY_SIZE key
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5985">FLINK-5985</a>] -         Flink treats every task as stateful (making topology changes impossible)
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5994">FLINK-5994</a>] -         Add Janino to flink-table JAR file
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6000">FLINK-6000</a>] -         Can not start HA cluster with start-cluster.sh
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6001">FLINK-6001</a>] -         NPE on TumblingEventTimeWindows with ContinuousEventTimeTrigger and allowedLateness
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6002">FLINK-6002</a>] -         Documentation: &#39;MacOS X&#39; under &#39;Download and Start Flink&#39; in Quickstart page is not rendered correctly
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6007">FLINK-6007</a>] -         ConcurrentModificationException in WatermarkCallbackService
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6010">FLINK-6010</a>] -         Documentation: correct IntelliJ IDEA Plugins path in &#39;Installing the Scala plugin&#39; section
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6023">FLINK-6023</a>] -         Fix Scala snippet into Process Function (Low-level Operations) Doc
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6025">FLINK-6025</a>] -         User code ClassLoader not used when KryoSerializer fallbacks to serialization for copying
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6031">FLINK-6031</a>] -         Add parameter for per job yarn clusters to control whether the user code jar is included into the system classloader.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6032">FLINK-6032</a>] -         CEP-Clean up the operator state when not needed.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6040">FLINK-6040</a>] -         DataStreamUserDefinedFunctionITCase occasionally fails
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6044">FLINK-6044</a>] -         TypeSerializerSerializationProxy.read() doesn&#39;t verify the read buffer length
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6051">FLINK-6051</a>] -         Wrong metric scope names in documentation
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6059">FLINK-6059</a>] -         Reject DataSet&lt;Row&gt; and DataStream&lt;Row&gt; without RowTypeInformation
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6061">FLINK-6061</a>] -         NPE on TypeSerializer.serialize with a RocksDBStateBackend calling entries() on a keyed state in the open() function
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6078">FLINK-6078</a>] -         ZooKeeper based high availability services should not close the underlying CuratorFramework
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6079">FLINK-6079</a>] -         Ineffective null check in FlinkKafkaConsumerBase#open()
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6080">FLINK-6080</a>] -         Unclosed ObjectOutputStream in NFA#serialize()
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6084">FLINK-6084</a>] -         Cassandra connector does not declare all dependencies
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6103">FLINK-6103</a>] -         LocalFileSystem rename() uses File.renameTo()
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6104">FLINK-6104</a>] -         Resource leak in ListViaRangeSpeedMiniBenchmark
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6123">FLINK-6123</a>] -         Add support for the NOT pattern.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6129">FLINK-6129</a>] -         MetricRegistry does not stop query actor
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6133">FLINK-6133</a>] -         fix build status in README.md
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6143">FLINK-6143</a>] -         Unprotected access to this.flink in LocalExecutor#endSession()
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6162">FLINK-6162</a>] -         Fix bug in ByteArrayOutputStreamWithPos#setPosition
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6170">FLINK-6170</a>] -         Some checkpoint metrics rely on latest stat snapshot
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6172">FLINK-6172</a>] -         Potentially unclosed RandomAccessFile in HistoryServerStaticFileServerHandler
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6176">FLINK-6176</a>] -         Add JARs to CLASSPATH deterministically
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6181">FLINK-6181</a>] -         Zookeeper scripts use invalid regex
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6182">FLINK-6182</a>] -         Fix possible NPE in SourceStreamTask
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6183">FLINK-6183</a>] -         TaskMetricGroup may not be cleanup when Task.run() is never called or exits early
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6194">FLINK-6194</a>] -         More broken links in docs
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6197">FLINK-6197</a>] -         Add support for iterative conditions.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6203">FLINK-6203</a>] -         DataSet Transformations
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6205">FLINK-6205</a>] -         Put late elements in side output.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6207">FLINK-6207</a>] -         Duplicate type serializers for async snapshots of CopyOnWriteStateTable
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6210">FLINK-6210</a>] -         RocksDB instance should be closed in ListViaMergeSpeedMiniBenchmark
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6211">FLINK-6211</a>] -         Validation error in Kinesis Consumer when using AT_TIMESTAMP as start position
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6217">FLINK-6217</a>] -         ContaineredTaskManagerParameters sets off heap memory size incorrectly
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6246">FLINK-6246</a>] -         Fix generic type of OutputTag in operator Output
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6256">FLINK-6256</a>] -         Fix documentation of ProcessFunction.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6259">FLINK-6259</a>] -         Fix a small spelling error
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6265">FLINK-6265</a>] -         Fix consecutive() for times() pattern.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6271">FLINK-6271</a>] -         NumericBetweenParametersProvider NullPointer
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6279">FLINK-6279</a>] -         the digest of VolcanoRuleMatch matched different table sources with same field names may be same
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6282">FLINK-6282</a>] -         Some words was spelled wrong
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6284">FLINK-6284</a>] -         Incorrect sorting of completed checkpoints in ZooKeeperCompletedCheckpointStore
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6286">FLINK-6286</a>] -         hbase command not found error
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6287">FLINK-6287</a>] -         Flakey JobManagerRegistrationTest
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6290">FLINK-6290</a>] -         SharedBuffer is improperly released when multiple edges between entries
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6292">FLINK-6292</a>] -         Travis: transfer.sh not accepting uploads via http:// anymore
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6293">FLINK-6293</a>] -         Flakey JobManagerITCase
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6295">FLINK-6295</a>] -         Update suspended ExecutionGraph to lower latency
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6298">FLINK-6298</a>] -         Local execution is not setting RuntimeContext for RichOutputFormat
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6300">FLINK-6300</a>] -         PID1 of docker images does not behave correctly
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6311">FLINK-6311</a>] -         NPE in FlinkKinesisConsumer if source was closed before run
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6312">FLINK-6312</a>] -         Update curator version to 2.12.0
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6313">FLINK-6313</a>] -         Some words was spelled wrong and incorrect LOG.error without print
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6317">FLINK-6317</a>] -         History server - wrong default directory
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6327">FLINK-6327</a>] -         Bug in CommonCalc&#39;s estimateRowCount() method
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6328">FLINK-6328</a>] -         Savepoints must not be counted as retained checkpoints
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6330">FLINK-6330</a>] -         Improve Docker documentation
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6341">FLINK-6341</a>] -         JobManager can go to definite message sending loop when TaskManager registered
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6342">FLINK-6342</a>] -         Start ZooKeeperLeaderElectionService under lock to avoid race condition
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6356">FLINK-6356</a>] -         Make times() eager and enable allowing combinations.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6368">FLINK-6368</a>] -         Grouping keys in stream aggregations have wrong order
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6371">FLINK-6371</a>] -         Return matched patterns as Map&lt;String, List&lt;T&gt;&gt; instead of Map&lt;String, T&gt; 
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6384">FLINK-6384</a>] -         PythonStreamer does not close python processes
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6386">FLINK-6386</a>] -         Missing bracket in &#39;Compiler Limitation&#39; section
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6394">FLINK-6394</a>] -         GroupCombine reuses instances even though object reuse is disabled
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6396">FLINK-6396</a>] -         FsSavepointStreamFactoryTest fails on Windows
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6397">FLINK-6397</a>] -         MultipleProgramsTestBase does not reset ContextEnvironment
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6398">FLINK-6398</a>] -         RowSerializer&#39;s duplicate should always return a new instance
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6400">FLINK-6400</a>] -         Lack of protection accessing masterHooks in CheckpointCoordinator#triggerCheckpoint
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6401">FLINK-6401</a>] -         RocksDBPerformanceTest.testRocksDbRangeGetPerformance fails on Travis
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6404">FLINK-6404</a>] -         Ensure PendingCheckpoint is registered when calling Checkpoint Hooks
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6409">FLINK-6409</a>] -         TUMBLE/HOP/SESSION_START/END do not resolve time field correctly
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6410">FLINK-6410</a>] -         build fails after changing Scala to 2.11
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6411">FLINK-6411</a>] -         YarnApplicationMasterRunner should not interfere with RunningJobsRegistry
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6415">FLINK-6415</a>] -         Make sure core Flink artifacts have no specific logger dependency
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6416">FLINK-6416</a>] -         Potential divide by zero issue in InputGateMetrics#refreshAndGetAvg()
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6427">FLINK-6427</a>] -         BucketingSink does not sync file length in case of cancel
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6435">FLINK-6435</a>] -         AsyncWaitOperator does not handle exceptions properly
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6436">FLINK-6436</a>] -         Bug in CommonCorrelate&#39;s generateCollector method when using udtf with udf
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6439">FLINK-6439</a>] -         Unclosed InputStream in OperatorSnapshotUtil#readStateHandle()
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6440">FLINK-6440</a>] -         Noisy logs from metric fetcher
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6445">FLINK-6445</a>] -         Fix NullPointerException in CEP pattern without condition
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6463">FLINK-6463</a>] -         Throw exception when NOT-NEXT is after OPTIONAL
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6474">FLINK-6474</a>] -         Potential loss of precision in 32 bit integer multiplication
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6479">FLINK-6479</a>] -         Fix IndexOutOfBoundsException bug
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6486">FLINK-6486</a>] -         Pass RowTypeInfo to CodeGenerator instead of CRowTypeInfo 
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6491">FLINK-6491</a>] -         Add QueryConfig to specify state retention time for streaming queries
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6501">FLINK-6501</a>] -         Make sure NOTICE files are bundled into shaded JAR files
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6506">FLINK-6506</a>] -         Some tests in flink-tests exceed the memory resources in containerized Travis builds
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6508">FLINK-6508</a>] -         Include license files of packaged dependencies
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6509">FLINK-6509</a>] -         TestingListener might miss JobLeader notifications
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6514">FLINK-6514</a>] -         Cannot start Flink Cluster in standalone mode
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6515">FLINK-6515</a>] -         KafkaConsumer checkpointing fails because of ClassLoader issues
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6517">FLINK-6517</a>] -         Support multiple consecutive windows
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6520">FLINK-6520</a>] -         FlinkKafkaConsumer09+ does not overwrite props to disable auto commit offsets when commit mode is OffsetCommitMode.ON_CHECKPOINTS
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6530">FLINK-6530</a>] -         Unclosed Response in DatadogHttpClient#validateApiKey()
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6531">FLINK-6531</a>] -         Deserialize checkpoint hooks with user classloader
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6536">FLINK-6536</a>] -         Improve error message in SharedBuffer::put()
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6542">FLINK-6542</a>] -         Non-keyed, non-windowed aggregation fails
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6548">FLINK-6548</a>] -         AvroOutputFormatTest fails on Windows
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6561">FLINK-6561</a>] -         GlobFilePathFilterTest#testExcludeFilenameWithStart fails on Windows
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6562">FLINK-6562</a>] -         Support implicit table references for nested fields in SQL
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6564">FLINK-6564</a>] -         Build fails on file systems that do not distinguish between upper and lower case
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6574">FLINK-6574</a>] -         Support nested catalogs in ExternalCatalog
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6578">FLINK-6578</a>] -         SharedBuffer creates self-loops when having elements with same value/timestamp.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6579">FLINK-6579</a>] -         Add proper support for BasicArrayTypeInfo
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6580">FLINK-6580</a>] -         Flink on YARN doesnt start with default parameters
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6581">FLINK-6581</a>] -         Dynamic property parsing broken for YARN
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6582">FLINK-6582</a>] -         Project from maven archetype is not buildable by default due to ${scala.binary.version}
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6583">FLINK-6583</a>] -         Enable QueryConfig in count base GroupWindow
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6585">FLINK-6585</a>] -         Table examples are not runnable in IDE
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6586">FLINK-6586</a>] -         InputGateMetrics#refreshAndGetMin returns Integer.MAX_VALUE for local channels
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6587">FLINK-6587</a>] -         Java Table API cannot parse function names starting with keywords
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6593">FLINK-6593</a>] -         Fix Bug in ProctimeAttribute or RowtimeAttribute with CodeGenerator
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6595">FLINK-6595</a>] -         Nested SQL queries do not expose proctime / rowtime attributes
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6598">FLINK-6598</a>] -         Remove useless param rowRelDataType of DataStreamGroupAggregate.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6604">FLINK-6604</a>] -         Remove Java Serialization from the CEP library.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6606">FLINK-6606</a>] -         Create checkpoint hook with user classloader
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6609">FLINK-6609</a>] -         Wrong version assignment when multiple TAKEs transitions
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6612">FLINK-6612</a>] -         ZooKeeperStateHandleStore does not guard against concurrent delete operations
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6614">FLINK-6614</a>] -         Applying function on window auxiliary function fails
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6628">FLINK-6628</a>] -         Cannot start taskmanager with cygwin in directory containing spaces
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6629">FLINK-6629</a>] -         ClusterClient cannot submit jobs to HA cluster if address not set in configuration
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6634">FLINK-6634</a>] -         NFA serializer does not serialize the ComputationState counter.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6635">FLINK-6635</a>] -         ClientConnectionTest is broken because the ClusterClient lazily connects to the JobManager
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6639">FLINK-6639</a>] -         Java/Scala code tabs broken in CEP docs
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6641">FLINK-6641</a>] -         HA recovery on YARN: ClusterClient calls HighAvailabilityServices#closeAndCleanupAll
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6644">FLINK-6644</a>] -         Don&#39;t register HUP unix signal handler on Windows
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6646">FLINK-6646</a>] -         YARN session doesn&#39;t work with HA
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6651">FLINK-6651</a>] -         Clearing registeredStates map should be protected in SharedStateRegistry#clear
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6656">FLINK-6656</a>] -         Migrate CEP PriorityQueue to MapState
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6662">FLINK-6662</a>] -         ClassNotFoundException: o.a.f.r.j.t.JobSnapshottingSettings recovering job
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6671">FLINK-6671</a>] -         RocksDBStateBackendTest.testCancelRunningSnapshot unstable
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6702">FLINK-6702</a>] -         SIGABRT after CEPOperatorTest#testCEPOperatorSerializationWRocksDB() during GC
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6704">FLINK-6704</a>] -         Cannot disable YARN user jar inclusion
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6714">FLINK-6714</a>] -         Operator state backend should set user classloader as context classloader when snapshotting
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6753">FLINK-6753</a>] -         Flaky SqlITCase
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-6780">FLINK-6780</a>] -         ExternalTableSource should add time attributes in the row type
+</li>
+</ul>
+
+<h2>        Improvement
+</h2>
+<ul>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2211">FLINK-2211</a>] -         Generalize ALS API
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2908">FLINK-2908</a>] -         Web interface redraw web plan when browser resized
+</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-3150">FLINK-3150</a>] -         Make YARN container invocation configurable
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3163">FLINK-3163</a>] -         Configure Flink for NUMA systems
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3318">FLINK-3318</a>] -         Add support for quantifiers to CEP&#39;s pattern API
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3347">FLINK-3347</a>] -         TaskManager (or its ActorSystem) need to restart in case they notice quarantine
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3360">FLINK-3360</a>] -         Clear up StateBackend, AbstractStateBackend abstractions
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3398">FLINK-3398</a>] -         Flink Kafka consumer should support auto-commit opt-outs
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3427">FLINK-3427</a>] -         Add watermark monitoring to JobManager web frontend
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3703">FLINK-3703</a>] -         Add sequence matching semantics to discard matched events
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4288">FLINK-4288</a>] -         Make it possible to unregister tables
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4326">FLINK-4326</a>] -         Flink start-up scripts should optionally start services on the foreground
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4396">FLINK-4396</a>] -         GraphiteReporter class not found at startup of jobmanager
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4410">FLINK-4410</a>] -         Report more information about operator checkpoints
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4450">FLINK-4450</a>] -         update storm version to 1.0.0
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4552">FLINK-4552</a>] -         Refactor WindowOperator/Trigger Tests
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4673">FLINK-4673</a>] -         TypeInfoFactory for Either type
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4754">FLINK-4754</a>] -         Make number of retained checkpoints user configurable
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4917">FLINK-4917</a>] -         Deprecate &quot;CheckpointedAsynchronously&quot; interface
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4920">FLINK-4920</a>] -         Add a Scala Function Gauge
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4949">FLINK-4949</a>] -         Refactor Gelly driver inputs
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4953">FLINK-4953</a>] -         Allow access to &quot;time&quot; in ProcessWindowFunction.Context
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5059">FLINK-5059</a>] -         only serialise events once in RecordWriter#broadcastEvent
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5066">FLINK-5066</a>] -         add more efficient isEvent check to EventSerializer
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5067">FLINK-5067</a>] -         Make Flink compile with 1.8 Java compiler
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5113">FLINK-5113</a>] -         Make all Testing Functions implement CheckpointedFunction Interface.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5129">FLINK-5129</a>] -         make the BlobServer use a distributed file system
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5153">FLINK-5153</a>] -         Allow setting custom application tags for Flink on YARN
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5183">FLINK-5183</a>] -         [py] Support multiple jobs per Python plan file
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5222">FLINK-5222</a>] -         Rename StateBackend interface to StateBinder
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5237">FLINK-5237</a>] -         Consolidate and harmonize Window Translation Tests
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5277">FLINK-5277</a>] -         missing unit test for ensuring ResultPartition#add always recycles buffers
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5280">FLINK-5280</a>] -         Refactor TableSource
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5306">FLINK-5306</a>] -         Display checkpointing configuration details in web UI &quot;Configuration&quot; tab
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5331">FLINK-5331</a>] -         PythonPlanBinderTest idling extremely long
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5348">FLINK-5348</a>] -         Support custom field names for RowTypeInfo
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5358">FLINK-5358</a>] -         Support RowTypeInfo extraction in TypeExtractor by Row instance
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5368">FLINK-5368</a>] -         Let Kafka consumer show something when it fails to read one topic out of topic list
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5377">FLINK-5377</a>] -         Improve savepoint docs
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5385">FLINK-5385</a>] -         Add a help function to create Row
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5388">FLINK-5388</a>] -         Remove private access of edges and vertices of Gelly Graph class
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5395">FLINK-5395</a>] -         support locally build distribution by script create_release_files.sh
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5399">FLINK-5399</a>] -         Add more information to checkpoint result of TriggerSavepointSuccess
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5404">FLINK-5404</a>] -         Consolidate and update S3 documentation
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5412">FLINK-5412</a>] -         Enable RocksDB tests on Windows
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5414">FLINK-5414</a>] -         Bump up Calcite version to 1.11
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5415">FLINK-5415</a>] -         ContinuousFileProcessingTest failed on travis
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5424">FLINK-5424</a>] -         Improve Restart Strategy Logging
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5438">FLINK-5438</a>] -         Typo in JobGraph generator Exception 
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5442">FLINK-5442</a>] -         Add test to fix ordinals of serialized enum StateDescriptor.Type
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5446">FLINK-5446</a>] -         System metrics reference incomplete
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5448">FLINK-5448</a>] -         Fix typo in StateAssignmentOperation Exception
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5451">FLINK-5451</a>] -         Extend JMX metrics documentation section
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5452">FLINK-5452</a>] -         Make table unit tests pass under cluster mode
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5461">FLINK-5461</a>] -         Remove Superflous TypeInformation Declaration
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5466">FLINK-5466</a>] -         Make production environment default in gulpfile
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5480">FLINK-5480</a>] -         User-provided hashes for operators
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5485">FLINK-5485</a>] -         Mark compiled web frontend files as binary when processed by git diff
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5497">FLINK-5497</a>] -         remove duplicated tests
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5499">FLINK-5499</a>] -         Try to reuse the resource location of prior execution attempt in allocating slot
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5503">FLINK-5503</a>] -         mesos-appmaster.sh script could print return value message
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5507">FLINK-5507</a>] -         remove queryable list state sink
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5508">FLINK-5508</a>] -         Remove Mesos dynamic class loading
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5515">FLINK-5515</a>] -         fix unused kvState.getSerializedValue call in KvStateServerHandler
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5516">FLINK-5516</a>] -         Hardcoded paths in flink-python/.../PythonPlanBinder.java
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5517">FLINK-5517</a>] -         Upgrade hbase version to 1.3.0
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5519">FLINK-5519</a>] -         scala-maven-plugin version all change to 3.2.2
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5521">FLINK-5521</a>] -         remove unused KvStateRequestSerializer#serializeList
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5522">FLINK-5522</a>] -         Storm LocalCluster can&#39;t run with powermock
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5524">FLINK-5524</a>] -         Support early out for code generated conjunctive conditions
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5528">FLINK-5528</a>] -         tests: reduce the retry delay in QueryableStateITCase
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5543">FLINK-5543</a>] -         customCommandLine tips in CliFrontend
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5559">FLINK-5559</a>] -         queryable state: KvStateRequestSerializer#deserializeKeyAndNamespace() throws an IOException without own failure message if deserialisation fails
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5563">FLINK-5563</a>] -         Add density to vertex metrics
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5574">FLINK-5574</a>] -         Add checkpoint statistics docs
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5575">FLINK-5575</a>] -         in old releases, warn users and guide them to the latest stable docs
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5576">FLINK-5576</a>] -         extend deserialization functions of KvStateRequestSerializer to detect unconsumed bytes
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5581">FLINK-5581</a>] -         Improve Kerberos security related documentation
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5583">FLINK-5583</a>] -         Support flexible error handling in the Kafka consumer
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5586">FLINK-5586</a>] -         Extend TableProgramsTestBase for object reuse modes
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5590">FLINK-5590</a>] -         Create a proper internal state hierarchy
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5597">FLINK-5597</a>] -         Improve the LocalClusteringCoefficient documentation
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5598">FLINK-5598</a>] -         Return jar name when jar is uploaded
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5609">FLINK-5609</a>] -         Add last update time to docs
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5610">FLINK-5610</a>] -         Rename Installation and Setup to Project Setup
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5615">FLINK-5615</a>] -         queryable state: execute the QueryableStateITCase for all three state back-ends
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5624">FLINK-5624</a>] -         Support tumbling window on streaming tables in the SQL API
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5625">FLINK-5625</a>] -         Let Date format for timestamp-based start position in Kinesis consumer be configurable.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5630">FLINK-5630</a>] -         Followups to AggregationFunction
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5632">FLINK-5632</a>] -         Typo in StreamGraph
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5635">FLINK-5635</a>] -         Improve Docker tooling to make it easier to build images and launch Flink via Docker tools
+</li>
+<li>[<a href="https://issues.apache

<TRUNCATED>

Mime
View raw message