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 & 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' 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'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 "Used" instead of "Initial" 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" support have parameters constructor. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5795">FLINK-5795</a>] - Improve UDF&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'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>] - 'zookeeper.sasl.disable' 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 "Serializer Configurations" 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 'Free Memory' to 'JVM Heap' +</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 'Metrics' view to 'Task Metrics' +</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'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 & 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 "Upgrading the Flink Framework Version" section for 1.2 -> 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 "Download and Compile" 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: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators." +</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'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'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't scroll +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5361">FLINK-5361</a>] - Flink shouldn'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'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 "re-registering state from an older Flink version" 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'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 'since' 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 "(null)" 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'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: 'MacOS X' under 'Download and Start Flink' 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 'Installing the Scala plugin' 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'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<Row> and DataStream<Row> 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'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<String, List<T>> instead of Map<String, T> +</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 'Compiler Limitation' 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'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'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'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'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'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 "CheckpointedAsynchronously" 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 "time" 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 "Configuration" 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'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>