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>
