http://git-wip-us.apache.org/repos/asf/flink-web/blob/5b25f84e/content/blog/release_1.2.0-changelog.html ---------------------------------------------------------------------- diff --git a/content/blog/release_1.2.0-changelog.html b/content/blog/release_1.2.0-changelog.html new file mode 100644 index 0000000..01ab822 --- /dev/null +++ b/content/blog/release_1.2.0-changelog.html @@ -0,0 +1,1545 @@ +<!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.2.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/navbar-brand-logo.png" width="147px" height="73px"> + </a> + </div> + </div><!-- /.navbar-header --> + + <!-- The navigation links. --> + <div class="collapse navbar-collapse" id="bs-example-navbar-collapse-1"> + <ul class="nav navbar-nav navbar-main"> + + <!-- Downloads --> + <li class=""><a class="btn btn-info" href="/downloads.html">Download Flink</a></li> + + <!-- Overview --> + <li><a href="/index.html">Home</a></li> + + <!-- Intro --> + <li><a href="/introduction.html">Introduction to Flink</a></li> + + <!-- Use cases --> + <li><a href="/usecases.html">Flink Use Cases</a></li> + + <!-- Powered by --> + <li><a href="/poweredby.html">Powered by Flink</a></li> + + <!-- Ecosystem --> + <li><a href="/ecosystem.html">Ecosystem</a></li> + + <!-- Community --> + <li><a href="/community.html">Community & Project Info</a></li> + + <!-- Contribute --> + <li><a href="/how-to-contribute.html">How to Contribute</a></li> + + <!-- Blog --> + <li class=" active hidden-md hidden-sm"><a href="/blog/"><b>Flink Blog</b></a></li> + + <hr /> + + + + <!-- Documentation --> + <!-- <li> + <a href="http://ci.apache.org/projects/flink/flink-docs-release-1.1"; target="_blank">Documentation <small><span class="glyphicon glyphicon-new-window"></span></small></a> + </li> --> + <li class="dropdown"> + <a class="dropdown-toggle" data-toggle="dropdown" href="#">Documentation + <span class="caret"></span></a> + <ul class="dropdown-menu"> + <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-1.1"; target="_blank">1.1 (Latest stable release) <small><span class="glyphicon glyphicon-new-window"></span></small></a></li> + <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-1.2"; target="_blank">1.2 (Snapshot) <small><span class="glyphicon glyphicon-new-window"></span></small></a></li> + </ul> + </li> + + <!-- Quickstart --> + <li> + <a href="http://ci.apache.org/projects/flink/flink-docs-release-1.1/quickstart/setup_quickstart.html"; target="_blank">Quickstart <small><span class="glyphicon glyphicon-new-window"></span></small></a> + </li> + + <!-- GitHub --> + <li> + <a href="https://github.com/apache/flink"; target="_blank">Flink on GitHub <small><span class="glyphicon glyphicon-new-window"></span></small></a> + </li> + + + + + + + </ul> + + + + <ul class="nav navbar-nav navbar-bottom"> + <hr /> + + <!-- FAQ --> + <li ><a href="/faq.html">Project FAQ</a></li> + + <!-- Twitter --> + <li><a href="https://twitter.com/apacheflink"; target="_blank">@ApacheFlink <small><span class="glyphicon glyphicon-new-window"></span></small></a></li> + + <!-- Visualizer --> + <li class=" hidden-md hidden-sm"><a href="/visualizer/" target="_blank">Plan Visualizer <small><span class="glyphicon glyphicon-new-window"></span></small></a></li> + + </ul> + </div><!-- /.navbar-collapse --> + </nav> + + </div> + <div class="col-sm-9"> + <div class="row-fluid"> + <div class="col-sm-12"> + <h1>Release 1.2.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.2.0 release <a href="https://issues.apache.org/jira/issues/?jql=project+%3D+FLINK+AND+fixVersion+%3D+1.2.0";>resolved 650 JIRA issues</a> in total.</p> + +<h2> Sub-task +</h2> +<ul> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3202";>FLINK-3202</a>] - Make Timer/Trigger Service Scoped to Key/Namespace +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3580";>FLINK-3580</a>] - Reintroduce Date/Time and implement scalar functions for it +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3660";>FLINK-3660</a>] - Measure latency of elements and expose it as a metric +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3761";>FLINK-3761</a>] - Refactor State Backends/Make Keyed State Key-Group Aware +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3950";>FLINK-3950</a>] - Add Meter Metric Type +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4174";>FLINK-4174</a>] - Enhance Window Evictor +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4221";>FLINK-4221</a>] - Show metrics in WebFrontend +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4273";>FLINK-4273</a>] - Refactor JobClientActor to watch already submitted jobs +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4312";>FLINK-4312</a>] - Remove Serializabiliy of ExecutionGraph +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4317";>FLINK-4317</a>] - Restructure documentation layout +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4320";>FLINK-4320</a>] - Fix misleading ScheduleMode names +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4324";>FLINK-4324</a>] - Enable Akka SSL +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4325";>FLINK-4325</a>] - Implement Web UI HTTPS +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4380";>FLINK-4380</a>] - Introduce KeyGroupAssigner and Max-Parallelism Parameter +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4381";>FLINK-4381</a>] - Refactor State to Prepare For Key-Group State Backends +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4384";>FLINK-4384</a>] - Add a "scheduleRunAsync()" feature to the RpcEndpoint +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4386";>FLINK-4386</a>] - Add as way to assert that code runs in the RpcEndpoint's Main Thread +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4389";>FLINK-4389</a>] - Expose metrics to Webfrontend +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4392";>FLINK-4392</a>] - Make RPC Service Thread Safe +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4403";>FLINK-4403</a>] - RPC proxy classloading should use Flink class' classloader +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4404";>FLINK-4404</a>] - Implement Data Transfer SSL +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4405";>FLINK-4405</a>] - Implement Blob Server SSL +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4434";>FLINK-4434</a>] - Add a testing RPC service +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4490";>FLINK-4490</a>] - Decouple Slot and Instance +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4507";>FLINK-4507</a>] - Deprecate savepoint backend config +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4509";>FLINK-4509</a>] - Specify savepoint directory per savepoint +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4510";>FLINK-4510</a>] - Always create CheckpointCoordinator +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4512";>FLINK-4512</a>] - Add option for persistent checkpoints +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4670";>FLINK-4670</a>] - Add watch mechanism on current RPC framework +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4685";>FLINK-4685</a>] - Gather operator checkpoint durations data sizes from the runtime +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4691";>FLINK-4691</a>] - Add group-windows for streaming 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-4748";>FLINK-4748</a>] - Fix shutdown of automatic watermark context +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4749";>FLINK-4749</a>] - Remove redundant processing time timers and futures in the window operator +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4750";>FLINK-4750</a>] - Ensure that active processing time triggers complete before closing operators +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4768";>FLINK-4768</a>] - Migrate High Availability configuration options +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4826";>FLINK-4826</a>] - Add keytab based kerberos support for Mesos environment +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4877";>FLINK-4877</a>] - Refactorings around FLINK-3674 (User Function Timers) +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4884";>FLINK-4884</a>] - Eagerly Store MergingWindowSet in State in WindowOperator +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4899";>FLINK-4899</a>] - Implement DCOS package +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4900";>FLINK-4900</a>] - Implement Docker image support +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4901";>FLINK-4901</a>] - Build DCOS Docker image +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4918";>FLINK-4918</a>] - Add SSL support to Mesos artifact server +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4921";>FLINK-4921</a>] - Upgrade to Mesos 1.0.1 +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4922";>FLINK-4922</a>] - Write documentation +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4937";>FLINK-4937</a>] - Add incremental group window aggregation for streaming Table API +</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-4984";>FLINK-4984</a>] - Add Cancellation Barriers to BarrierTracker and BarrierBuffer +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4985";>FLINK-4985</a>] - Report Declined/Canceled Checkpoints to Checkpoint Coordinator +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4987";>FLINK-4987</a>] - Harden slot pool logic +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4993";>FLINK-4993</a>] - Don't Allow Trigger.onMerge() to return TriggerResult +</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-5042";>FLINK-5042</a>] - Convert old savepoints to new savepoints +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5043";>FLINK-5043</a>] - Converting keyed state from Flink 1.1 backend implementations to their new counterparts in 1.2 +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5044";>FLINK-5044</a>] - Converting operator and function state from Flink 1.1 for all changed operators in 1.2 +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5091";>FLINK-5091</a>] - Formalize the AppMaster environment for docker compability +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5290";>FLINK-5290</a>] - Ensure backwards compatibility of the hashes used to generate JobVertexIds +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5293";>FLINK-5293</a>] - Make the Kafka consumer backwards compatible. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5294";>FLINK-5294</a>] - Make the WindowOperator backwards compatible. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5295";>FLINK-5295</a>] - Migrate the AlignedWindowOperators to the WindowOperator and make it backwards compatible. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5317";>FLINK-5317</a>] - Make the continuous file processing code backwards compatible, +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5318";>FLINK-5318</a>] - Make the Rolling sink backwards compatible. +</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-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-5455";>FLINK-5455</a>] - Create documentation how to upgrade jobs and Flink framework versions +</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-5460";>FLINK-5460</a>] - Add documentation how to use Flink with Docker +</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-5502";>FLINK-5502</a>] - Add documentation about migrating functions from 1.1 to 1.2 +</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-5555";>FLINK-5555</a>] - Add documentation about debugging watermarks +</li> +</ul> + +<h2> Bug +</h2> +<ul> +<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-2821";>FLINK-2821</a>] - Change Akka configuration to allow accessing actors from different URLs +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2839";>FLINK-2839</a>] - Failing test: OperatorStatsAccumulatorTest.testAccumulatorAllStatistics +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3138";>FLINK-3138</a>] - Method References are not supported as lambda expressions +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3680";>FLINK-3680</a>] - Remove or improve (not set) text in the Job Plan UI +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3706";>FLINK-3706</a>] - YARNSessionCapacitySchedulerITCase.testNonexistingQueue unstable +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3813";>FLINK-3813</a>] - YARNSessionFIFOITCase.testDetachedMode failed on Travis +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3888";>FLINK-3888</a>] - Custom Aggregator with Convergence can't be registered directly with DeltaIteration +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3918";>FLINK-3918</a>] - Not configuring any time characteristic leads to a ClassCastException +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4021";>FLINK-4021</a>] - Problem of setting autoread for netty channel when more tasks sharing the same Tcp connection +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4035";>FLINK-4035</a>] - Add Apache Kafka 0.10 connector +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4073";>FLINK-4073</a>] - YARNSessionCapacitySchedulerITCase.testTaskManagerFailure failed on Travis +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4081";>FLINK-4081</a>] - FieldParsers should support empty strings +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4100";>FLINK-4100</a>] - RocksDBStateBackend#close() can throw NPE +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4108";>FLINK-4108</a>] - NPE in Row.productArity +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4140";>FLINK-4140</a>] - CheckpointCoordinator fails to discard completed checkpoint +</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-4155";>FLINK-4155</a>] - Get Kafka producer partition info in open method instead of constructor +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4177";>FLINK-4177</a>] - CassandraConnectorTest.testCassandraCommitter causing unstable builds +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4219";>FLINK-4219</a>] - Quote PDSH opts in start-cluster.sh +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4226";>FLINK-4226</a>] - Typo: Define Keys using Field Expressions example should use window and not reduce +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4236";>FLINK-4236</a>] - Flink Dashboard stops showing list of uploaded jars if main method cannot be looked up +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4252";>FLINK-4252</a>] - Table program cannot be compiled +</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-4257";>FLINK-4257</a>] - Handle delegating algorithm change of class +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4259";>FLINK-4259</a>] - Unclosed FSDataOutputStream in FileCache#copy() +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4263";>FLINK-4263</a>] - SQL's VALUES does not work properly +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4270";>FLINK-4270</a>] - 'as' in front of join does not work +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4271";>FLINK-4271</a>] - There is no way to set parallelism of operators produced by CoGroupedStreams +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4276";>FLINK-4276</a>] - TextInputFormatTest.testNestedFileRead fails on Windows OS +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4285";>FLINK-4285</a>] - Non-existing example in Flink quickstart setup documentation +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4289";>FLINK-4289</a>] - Source files have executable flag set +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4290";>FLINK-4290</a>] - CassandraConnectorTest deadlocks +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4291";>FLINK-4291</a>] - No log entry for unscheduled reporters +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4292";>FLINK-4292</a>] - HCatalog project incorrectly set up +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4293";>FLINK-4293</a>] - Malformatted Apache Headers +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4296";>FLINK-4296</a>] - Scheduler accepts more tasks than it has task slots available +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4297";>FLINK-4297</a>] - Yarn client can't determine fat jar location if path contains spaces +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4298";>FLINK-4298</a>] - Clean up Storm Compatibility Dependencies +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4304";>FLINK-4304</a>] - Jar names that contain whitespace cause problems in web client +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4307";>FLINK-4307</a>] - Broken user-facing API for ListState +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4309";>FLINK-4309</a>] - Potential null pointer dereference in DelegatingConfiguration#keySet() +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4311";>FLINK-4311</a>] - TableInputFormat fails when reused on next split +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4313";>FLINK-4313</a>] - Inconsistent code for Key/Value in the CheckpointCoordinator +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4314";>FLINK-4314</a>] - Test instability in JobManagerHAJobGraphRecoveryITCase.testJobPersistencyWhenJobManagerShutdown +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4316";>FLINK-4316</a>] - Make flink-core independent of Hadoop +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4323";>FLINK-4323</a>] - Checkpoint Coordinator Removes HA Checkpoints in Shutdown +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4329";>FLINK-4329</a>] - Fix Streaming File Source Timestamps/Watermarks Handling +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4332";>FLINK-4332</a>] - Savepoint Serializer mixed read()/readFully() +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4333";>FLINK-4333</a>] - Name mixup in Savepoint versions +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4337";>FLINK-4337</a>] - Remove unnecessary Scala suffix from Hadoop1 artifact +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4341";>FLINK-4341</a>] - Kinesis connector does not emit maximum watermark properly +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4342";>FLINK-4342</a>] - Fix dependencies of flink-connector-filesystem +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4385";>FLINK-4385</a>] - Union on Timestamp fields does not work +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4387";>FLINK-4387</a>] - Instability in KvStateClientTest.testClientServerIntegration() +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4388";>FLINK-4388</a>] - Race condition during initialization of MemorySegmentFactory +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4394";>FLINK-4394</a>] - RMQSource: The QueueName is not accessible to subclasses +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4398";>FLINK-4398</a>] - Unstable test KvStateServerHandlerTest.testSimpleQuery +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4409";>FLINK-4409</a>] - class conflict between jsr305-1.3.9.jar and flink-shaded-hadoop2-1.1.1.jar +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4411";>FLINK-4411</a>] - [py] Chained dual input children are not properly propagated +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4412";>FLINK-4412</a>] - [py] Chaining does not properly handle broadcast variables +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4417";>FLINK-4417</a>] - Checkpoints should be subsumed by CheckpointID not, by timestamp +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4418";>FLINK-4418</a>] - ClusterClient/ConnectionUtils#findConnectingAddress fails immediately if InetAddress.getLocalHost throws exception +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4425";>FLINK-4425</a>] - "Out Of Memory" during savepoint deserialization +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4436";>FLINK-4436</a>] - Unclosed DataOutputBuffer in Utils#setTokensFor() +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4437";>FLINK-4437</a>] - Lock evasion around lastTriggeredCheckpoint may lead to lost updates to related fields +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4453";>FLINK-4453</a>] - Scala code example in Window documentation shows Java +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4454";>FLINK-4454</a>] - Lookups for JobManager address in config +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4482";>FLINK-4482</a>] - numUnsuccessfulCheckpointsTriggers is accessed without holding triggerLock +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4485";>FLINK-4485</a>] - Finished jobs in yarn session fill /tmp filesystem +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4486";>FLINK-4486</a>] - JobManager not fully running when yarn-session.sh finishes +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4488";>FLINK-4488</a>] - Prevent cluster shutdown after job execution for non-detached jobs +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4506";>FLINK-4506</a>] - CsvOutputFormat defaults allowNullValues to false, even though doc and declaration says true +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4514";>FLINK-4514</a>] - ExpiredIteratorException in Kinesis Consumer on long catch-ups to head of stream +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4522";>FLINK-4522</a>] - Gelly link broken in homepage +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4526";>FLINK-4526</a>] - ApplicationClient: remove redundant proxy messages +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4544";>FLINK-4544</a>] - TaskManager metrics are vulnerable to custom JMX bean installation +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4556";>FLINK-4556</a>] - Make Queryable State Key-Group Aware +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4559";>FLINK-4559</a>] - Kinesis Producer not setting credentials provider properly when AWS_CREDENTIALS_PROVIDER is "AUTO" +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4563";>FLINK-4563</a>] - [metrics] scope caching not adjusted for multiple reporters +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4564";>FLINK-4564</a>] - [metrics] Delimiter should be configured per reporter +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4566";>FLINK-4566</a>] - ProducerFailedException does not properly preserve Exception causes +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4567";>FLINK-4567</a>] - Enhance SerializedThrowable to properly preserver cause chains +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4570";>FLINK-4570</a>] - Scalastyle Maven plugin fails undeterministically +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4572";>FLINK-4572</a>] - Convert to negative in LongValueToIntValue +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4573";>FLINK-4573</a>] - Potential resource leak due to unclosed RandomAccessFile in TaskManagerLogHandler +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4581";>FLINK-4581</a>] - Table API throws "No suitable driver found for jdbc:calcite" +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4586";>FLINK-4586</a>] - NumberSequenceIterator and Accumulator threading issue +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4588";>FLINK-4588</a>] - Fix Merging of Covering Window in MergingWindowSet +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4589";>FLINK-4589</a>] - Fix Merging of Covering Window in MergingWindowSet +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4590";>FLINK-4590</a>] - Some Table API tests are failing when debug lvl is set to DEBUG +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4592";>FLINK-4592</a>] - Fix flaky test ScalarFunctionsTest.testCurrentTimePoint +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4594";>FLINK-4594</a>] - Validate lower bound in MathUtils.checkedDownCast +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4601";>FLINK-4601</a>] - Check for empty string properly +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4603";>FLINK-4603</a>] - KeyedStateBackend cannot restore user code classes +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4609";>FLINK-4609</a>] - Remove redundant check for null in CrossOperator +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4612";>FLINK-4612</a>] - Close FileWriter using try with resources +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4614";>FLINK-4614</a>] - Kafka connector documentation refers to Flink 1.2-SNAPSHOT +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4618";>FLINK-4618</a>] - FlinkKafkaConsumer09 should start from the next record on startup from offsets in Kafka +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4619";>FLINK-4619</a>] - JobManager does not answer to client when restore from savepoint fails +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4622";>FLINK-4622</a>] - CLI help message should include 'savepoint' action +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4624";>FLINK-4624</a>] - Gelly's summarization algorithm cannot deal with null vertex group values +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4626";>FLINK-4626</a>] - Missing break in MetricStore#add() +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4628";>FLINK-4628</a>] - User class loader unavailable during input split assignment +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4631";>FLINK-4631</a>] - NullPointerException during stream task cleanup +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4640";>FLINK-4640</a>] - Serialization of the initialValue of a Fold on WindowedStream fails +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4645";>FLINK-4645</a>] - Hard to register Kryo Serializers due to generics +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4651";>FLINK-4651</a>] - Re-register processing time timers at the WindowOperator upon recovery. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4652";>FLINK-4652</a>] - Don't pass credentials explicitly to AmazonClient - use credentials provider instead +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4659";>FLINK-4659</a>] - Potential resource leak due to unclosed InputStream in SecurityContext#populateSystemSecurityProperties() +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4663";>FLINK-4663</a>] - Flink JDBCOutputFormat logs wrong WARN message +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4665";>FLINK-4665</a>] - Remove boxing/unboxing to parse a primitive +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4666";>FLINK-4666</a>] - Make constants to be final in ParameterTool +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4667";>FLINK-4667</a>] - Yarn Session CLI not listening on correct ZK namespace when HA is enabled to use ZooKeeper backend +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4671";>FLINK-4671</a>] - Table API can not be built +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4672";>FLINK-4672</a>] - TaskManager accidentally decorates Kill messages +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4677";>FLINK-4677</a>] - Jars with no job executions produces NullPointerException in ClusterClient +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4696";>FLINK-4696</a>] - Limit the number of Akka Dispatcher Threads in LocalMiniCluster +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4700";>FLINK-4700</a>] - Harden the TimeProvider test +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4702";>FLINK-4702</a>] - Kafka consumer must commit offsets asynchronously +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4708";>FLINK-4708</a>] - Scope Mini Kerberos Cluster dependencies as test dependencies +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4709";>FLINK-4709</a>] - InputStreamFSInputWrapper does not close wrapped stream +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4710";>FLINK-4710</a>] - Remove transitive Guice dependency from Hadoop +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4711";>FLINK-4711</a>] - TaskManager can crash due to failing onPartitionStateUpdate call +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4718";>FLINK-4718</a>] - Confusing label in Parallel Streams Diagram +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4727";>FLINK-4727</a>] - Kafka 0.9 Consumer should also checkpoint auto retrieved offsets even when no data is read +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4730";>FLINK-4730</a>] - Introduce CheckpointMetaData +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4731";>FLINK-4731</a>] - HeapKeyedStateBackend restoring broken for scale-in +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4732";>FLINK-4732</a>] - Maven junction plugin security threat +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4741";>FLINK-4741</a>] - WebRuntimeMonitor does not shut down all of it's threads (EventLoopGroups) on exit. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4743";>FLINK-4743</a>] - The sqrt/power function not accept the real data types. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4744";>FLINK-4744</a>] - Introduce usercode class loader to deserialize partitionable operator state +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4747";>FLINK-4747</a>] - Instability due to pending processing timers on operator close +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4753";>FLINK-4753</a>] - Kafka 0.8 connector's Periodic Offset Committer should synchronize on checkpoint lock +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4774";>FLINK-4774</a>] - QueryScopeInfo scope concatenation broken +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4777";>FLINK-4777</a>] - ContinuousFileMonitoringFunction may throw IOException when files are moved +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4784";>FLINK-4784</a>] - MetricQueryService actor name collision +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4786";>FLINK-4786</a>] - BarrierBufferTest test instability +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4788";>FLINK-4788</a>] - State backend class cannot be loaded, because fully qualified name converted to lower-case +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4791";>FLINK-4791</a>] - Fix issues caused by expression reduction +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4793";>FLINK-4793</a>] - Using a local method with :: notation in Java 8 causes index out of bounds +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4794";>FLINK-4794</a>] - partition_by_hash() crashes if no parameter is provided +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4795";>FLINK-4795</a>] - CsvStringify crashes in case of tuple in tuple, t.e. ("a", True, (1,5)) +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4798";>FLINK-4798</a>] - CEPITCase.testSimpleKeyedPatternCEP test failure +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4801";>FLINK-4801</a>] - Input type inference is faulty with custom Tuples and RichFunctions +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4804";>FLINK-4804</a>] - Grouping.first() function usage fails +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4805";>FLINK-4805</a>] - Stringify() crashes with Python3 (run with pyflink3) +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4824";>FLINK-4824</a>] - CliFrontend shows misleading error message when main() method returns before env.execute() +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4827";>FLINK-4827</a>] - The scala example of SQL on Streaming Tables with wrong variable name in flink document +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4829";>FLINK-4829</a>] - Accumulators are not thread safe +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4833";>FLINK-4833</a>] - Unstable test OperatorStatsAccumulatorTest.testAccumulatorHeavyHitterCountMinSketch +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4838";>FLINK-4838</a>] - remove STREAM keyword in StreamSQLExample +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4845";>FLINK-4845</a>] - Fix Job Exceptions page +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4852";>FLINK-4852</a>] - ClassCastException when assigning Watermarks with TimeCharacteristic.ProcessingTime +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4862";>FLINK-4862</a>] - NPE on EventTimeSessionWindows with ContinuousEventTimeTrigger +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4866";>FLINK-4866</a>] - Make Trigger.clear() Abstract to Enforce Implementation +</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-4872";>FLINK-4872</a>] - Type erasure problem exclusively on cluster execution +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4875";>FLINK-4875</a>] - operator name not correctly inferred +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4879";>FLINK-4879</a>] - class KafkaTableSource should be public just like KafkaTableSink +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4887";>FLINK-4887</a>] - Replace ActorGateway by TaskManagerGateway interface +</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-4907";>FLINK-4907</a>] - Add Test for Timers/State Provided by AbstractStreamOperator +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4932";>FLINK-4932</a>] - Don't let ExecutionGraph fail when in state Restarting +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4933";>FLINK-4933</a>] - ExecutionGraph.scheduleOrUpdateConsumers can fail the ExecutionGraph +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4941";>FLINK-4941</a>] - Show ship strategy in web interface +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4945";>FLINK-4945</a>] - KafkaConsumer logs wrong warning about confirmation for unknown checkpoint +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4967";>FLINK-4967</a>] - RockDB state backend fails on Windows +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4973";>FLINK-4973</a>] - Flakey Yarn tests due to recently added latency marker +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4977";>FLINK-4977</a>] - Enum serialization does not work in all cases +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4991";>FLINK-4991</a>] - TestTask hangs in testWatchDogInterruptsTask +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4998";>FLINK-4998</a>] - ResourceManager fails when num task slots > Yarn vcores +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5002";>FLINK-5002</a>] - Lack of synchronization in LocalBufferPool#getNumberOfUsedBuffers +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5007";>FLINK-5007</a>] - Retain externalized checkpoint on suspension +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5011";>FLINK-5011</a>] - TraversableSerializer does not perform a deep copy of the elements it is traversing +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5014";>FLINK-5014</a>] - RocksDBStateBackend misses good toString +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5016";>FLINK-5016</a>] - EventTimeWindowCheckpointingITCase testTumblingTimeWindowWithKVStateMaxMaxParallelism with RocksDB hangs +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5019";>FLINK-5019</a>] - Proper isRestored result for tasks that did not write state +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5027";>FLINK-5027</a>] - FileSource finishes successfully with a wrong path +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5028";>FLINK-5028</a>] - Stream Tasks must not go through clean shutdown logic on cancellation +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5032";>FLINK-5032</a>] - CsvOutputFormatTest fails on Windows OS +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5033";>FLINK-5033</a>] - CEP operators don't properly advance time +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5037";>FLINK-5037</a>] - Instability in AbstractUdfStreamOperatorLifecycleTest +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5038";>FLINK-5038</a>] - Errors in the "cancelTask" method prevent closeables from being closed early +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5039";>FLINK-5039</a>] - Avro GenericRecord support is broken +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5040";>FLINK-5040</a>] - Set correct input channel types with eager scheduling +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5048";>FLINK-5048</a>] - Kafka Consumer (0.9/0.10) threading model leads problematic cancellation behavior +</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-5050";>FLINK-5050</a>] - JSON.org license is CatX +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5055";>FLINK-5055</a>] - Security feature crashes JM for certain Hadoop versions even though using no Kerberos +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5056";>FLINK-5056</a>] - BucketingSink deletes valid data when checkpoint notification is slow. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5057";>FLINK-5057</a>] - Cancellation timeouts are picked from wrong config +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5058";>FLINK-5058</a>] - taskManagerMemory attribute set wrong value in FlinkShell +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5063";>FLINK-5063</a>] - State handles are not properly cleaned up for declined or expired checkpoints +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5071";>FLINK-5071</a>] - YARN: yarn.containers.vcores config not respected when checking for vcores +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5073";>FLINK-5073</a>] - ZooKeeperCompleteCheckpointStore executes blocking delete operation in ZooKeeper client thread +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5075";>FLINK-5075</a>] - Kinesis consumer incorrectly determines shards as newly discovered when tested against Kinesalite +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5082";>FLINK-5082</a>] - Pull ExecutionService lifecycle management out of the JobManager +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5085";>FLINK-5085</a>] - Execute CheckpointCoodinator's state discard calls asynchronously +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5097";>FLINK-5097</a>] - The TypeExtractor is missing input type information in some Graph methods +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5102";>FLINK-5102</a>] - Connection establishment does not react to interrupt +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5109";>FLINK-5109</a>] - Invalid Content-Encoding Header in REST API responses +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5111";>FLINK-5111</a>] - Change the assignToKeyGroup() method to not use Object.hashCode() +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5112";>FLINK-5112</a>] - Remove unused accumulator code from ArchivedExecutionJobVertex +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5114";>FLINK-5114</a>] - PartitionState update with finished execution fails +</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-5143";>FLINK-5143</a>] - Add EXISTS to list of supported operators +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5144";>FLINK-5144</a>] - Error while applying rule AggregateJoinTransposeRule +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5147";>FLINK-5147</a>] - StreamingOperatorsITCase.testGroupedFoldOperation failed on Travis +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5149";>FLINK-5149</a>] - ContinuousEventTimeTrigger doesn't fire at the end of the window +</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-5154";>FLINK-5154</a>] - Duplicate TypeSerializer when writing RocksDB Snapshot +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5158";>FLINK-5158</a>] - Handle ZooKeeperCompletedCheckpointStore exceptions in CheckpointCoordinator +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5160";>FLINK-5160</a>] - SecurityContextTest#testCreateInsecureHadoopCtx fails on windows +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5162";>FLINK-5162</a>] - BlobRecoveryItCase#testBlobServerRecovery fails on Windows +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5164";>FLINK-5164</a>] - Hadoop-compat IOFormat tests fail on Windows +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5173";>FLINK-5173</a>] - Upgrade RocksDB dependency +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5179";>FLINK-5179</a>] - MetricRegistry life-cycle issues with HA +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5184";>FLINK-5184</a>] - Error result of compareSerialized in RowComparator class +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5193";>FLINK-5193</a>] - Recovering all jobs fails completely if a single recovery fails +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5197";>FLINK-5197</a>] - Late JobStatusChanged messages can interfere with running jobs +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5206";>FLINK-5206</a>] - Flakey PythonPlanBinderTest +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5209";>FLINK-5209</a>] - Fix TaskManager metrics +</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-5216";>FLINK-5216</a>] - CheckpointCoordinator's 'minPauseBetweenCheckpoints' refers to checkpoint start rather then checkpoint completion +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5218";>FLINK-5218</a>] - Eagerly close checkpoint streams on cancellation +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5221";>FLINK-5221</a>] - Checkpointed workless in Window Operator +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5228";>FLINK-5228</a>] - LocalInputChannel re-trigger request and release deadlock +</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-5248";>FLINK-5248</a>] - SavepointITCase doesn't catch savepoint restore failure +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5261";>FLINK-5261</a>] - ScheduledDropwizardReporter does not properly clean up metrics +</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-5274";>FLINK-5274</a>] - LocalInputChannel throws NPE if partition reader is released +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5275";>FLINK-5275</a>] - InputChanelDeploymentDescriptors throws misleading Exception if producer failed/cancelled +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5285";>FLINK-5285</a>] - CancelCheckpointMarker flood when using at least once mode +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5289";>FLINK-5289</a>] - NPE when using value state on non-keyed stream +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5292";>FLINK-5292</a>] - Make the operators for 1.1->1.2 backwards compatible. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5296";>FLINK-5296</a>] - Expose the old AlignedWindowOperators to the user through explicit commands. +</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-5307";>FLINK-5307</a>] - Log configuration for every reporter +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5320";>FLINK-5320</a>] - Fix result TypeInformation in WindowedStream.fold(ACC, FoldFunction, WindowFunction) +</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-5326";>FLINK-5326</a>] - IllegalStateException: Bug in Netty consumer logic: reader queue got notified by partition about available data, but none was available +</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-5330";>FLINK-5330</a>] - Harden KafkaConsumer08Test +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5332";>FLINK-5332</a>] - Non-thread safe FileSystem::initOutPathLocalFS() can cause lost files/directories in local execution +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5344";>FLINK-5344</a>] - docs don't build in dockerized jekyll; -p option is broken +</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-5356";>FLINK-5356</a>] - librocksdbjni*.so is not deleted from /tmp directory +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5357";>FLINK-5357</a>] - WordCountTable fails +</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-5369";>FLINK-5369</a>] - Rework jsr305 and logging dependencies +</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-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-5394";>FLINK-5394</a>] - the estimateRowCount method of DataSetCalc didn't work +</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-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-5417";>FLINK-5417</a>] - Fix the wrong config file name +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5418";>FLINK-5418</a>] - Estimated row size does not support nested types +</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-5443";>FLINK-5443</a>] - Create a path to migrate from the Rolling to the BucketingSink. +</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-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-5483";>FLINK-5483</a>] - Link to "linking modules not contained in binary distribution" broken in all connector documentations +</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-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-5549";>FLINK-5549</a>] - TypeExtractor fails with RuntimeException, but should use GenericTypeInfo +</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-5578";>FLINK-5578</a>] - Each time application is submitted to yarn, application id increases by two +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5580";>FLINK-5580</a>] - Kerberos keytabs not working for YARN deployment mode +</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-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-5617";>FLINK-5617</a>] - Check new public APIs in 1.2 release +</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-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-5660";>FLINK-5660</a>] - Not properly cleaning PendingCheckpoints up +</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-5670";>FLINK-5670</a>] - Local RocksDB directories not cleaned up +</li> +</ul> + +<h2> Improvement +</h2> +<ul> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2090";>FLINK-2090</a>] - toString of CollectionInputFormat takes long time when the collection is huge +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2765";>FLINK-2765</a>] - Upgrade hbase version for hadoop-2 to 1.2 release +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3042";>FLINK-3042</a>] - Define a way to let types create their own TypeInformation +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-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-3615";>FLINK-3615</a>] - Add support for non-native SQL types +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3670";>FLINK-3670</a>] - Kerberos: Improving long-running streaming jobs +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3677";>FLINK-3677</a>] - FileInputFormat: Allow to specify include/exclude file name patterns +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3702";>FLINK-3702</a>] - DataStream API PojoFieldAccessor doesn't support nested POJOs +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3719";>FLINK-3719</a>] - WebInterface: Moving the barrier between graph and stats +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3779";>FLINK-3779</a>] - Add support for queryable state +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3787";>FLINK-3787</a>] - Yarn client does not report unfulfillable container constraints +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3866";>FLINK-3866</a>] - StringArraySerializer claims type is immutable; shouldn't +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3869";>FLINK-3869</a>] - WindowedStream.apply with FoldFunction is too restrictive +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3899";>FLINK-3899</a>] - Document window processing with Reduce/FoldFunction + WindowFunction +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3904";>FLINK-3904</a>] - GlobalConfiguration doesn't ensure config has been loaded +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-3921";>FLINK-3921</a>] - StringParser not specifying encoding to use +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4023";>FLINK-4023</a>] - Move Kafka consumer partition discovery from constructor to open() +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4037";>FLINK-4037</a>] - Introduce ArchivedExecutionGraph without any user classes +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4068";>FLINK-4068</a>] - Move constant computations out of code-generated `flatMap` functions. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4104";>FLINK-4104</a>] - Restructure Gelly docs +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4129";>FLINK-4129</a>] - Remove the example HITSAlgorithm +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4161";>FLINK-4161</a>] - Quickstarts can exclude more flink-dist dependencies +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4179";>FLINK-4179</a>] - Update TPCHQuery3Table example +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4189";>FLINK-4189</a>] - Introduce symbols for internal use +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4190";>FLINK-4190</a>] - Generalise RollingSink to work with arbitrary buckets +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4203";>FLINK-4203</a>] - Improve Table API documentation +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4204";>FLINK-4204</a>] - Clean up gelly-examples +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4218";>FLINK-4218</a>] - Sporadic "java.lang.RuntimeException: Error triggering a checkpoint..." causes task restarting +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4222";>FLINK-4222</a>] - Allow Kinesis configuration to get credentials from AWS Metadata +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4241";>FLINK-4241</a>] - Cryptic expression parser exceptions +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4242";>FLINK-4242</a>] - Improve validation exception messages +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4245";>FLINK-4245</a>] - Metric naming improvements +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4247";>FLINK-4247</a>] - CsvTableSource.getDataSet() expects Java ExecutionEnvironment +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4248";>FLINK-4248</a>] - CsvTableSource does not support reading SqlTimeTypeInfo types +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4251";>FLINK-4251</a>] - Add possiblity for the RMQ Streaming Sink to customize the queue +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4253";>FLINK-4253</a>] - Rename "recovery.mode" config key to "high-availability" +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4260";>FLINK-4260</a>] - Allow SQL's LIKE ESCAPE +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4268";>FLINK-4268</a>] - Add a parsers for BigDecimal/BigInteger +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4281";>FLINK-4281</a>] - Wrap all Calcite Exceptions in Flink Exceptions +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4282";>FLINK-4282</a>] - Add Offset Parameter to WindowAssigners +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4299";>FLINK-4299</a>] - Show loss of job manager in Client +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4302";>FLINK-4302</a>] - Add JavaDocs to MetricConfig +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4306";>FLINK-4306</a>] - Fix Flink and Storm dependencies in flink-storm and flink-storm-examples +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4308";>FLINK-4308</a>] - Allow uploaded jar directory to be configurable +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4310";>FLINK-4310</a>] - Move BinaryCompatibility Check plugin to relevant projects +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4318";>FLINK-4318</a>] - Make master docs build target version-specific +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4322";>FLINK-4322</a>] - Unify CheckpointCoordinator and SavepointCoordinator +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4340";>FLINK-4340</a>] - Remove RocksDB Semi-Async Checkpoint Mode +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4366";>FLINK-4366</a>] - Enforce parallelism=1 For AllWindowedStream +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4369";>FLINK-4369</a>] - EvictingWindowOperator Must Actually Evict Elements +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4378";>FLINK-4378</a>] - Enable RollingSink to custom HDFS client configuration +</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-4431";>FLINK-4431</a>] - Introduce a "VisibleForTesting" annotation +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4435";>FLINK-4435</a>] - Replace Guava's VisibleForTesting annotation with Flink's annotation +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4439";>FLINK-4439</a>] - Error message KafkaConsumer08 when all 'bootstrap.servers' are invalid +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4445";>FLINK-4445</a>] - Ignore unmatched state when restoring from savepoint +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4447";>FLINK-4447</a>] - Include NettyConfig options on Configurations page +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4457";>FLINK-4457</a>] - Make the ExecutionGraph independent of Akka +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4459";>FLINK-4459</a>] - Introduce SlotProvider for Scheduler +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4478";>FLINK-4478</a>] - Implement heartbeat logic +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4495";>FLINK-4495</a>] - Running multiple jobs on yarn (without yarn-session) +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4525";>FLINK-4525</a>] - Drop the "eager split pre-assignment" code paths +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4527";>FLINK-4527</a>] - Drop the "flinkAccumulators" from the Execution +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4539";>FLINK-4539</a>] - Duplicate/inconsistent logic for physical memory size in classes "Hardware" and "EnvironmentInformation" +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4541";>FLINK-4541</a>] - Support for SQL NOT IN operator +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4543";>FLINK-4543</a>] - Race Deadlock in SpilledSubpartitionViewTest +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4549";>FLINK-4549</a>] - Test and document implicitly supported SQL functions +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4550";>FLINK-4550</a>] - Clearly define SQL operator table +</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-4560";>FLINK-4560</a>] - enforcer java version as 1.7 +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4579";>FLINK-4579</a>] - Add StateBackendFactory for RocksDB Backend +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4599";>FLINK-4599</a>] - Add 'explain()' also to StreamTableEnvironment +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4611";>FLINK-4611</a>] - Make "AUTO" credential provider as default for Kinesis Connector +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4623";>FLINK-4623</a>] - Create Physical Execution Plan of a DataStream +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4625";>FLINK-4625</a>] - Guard Flink processes against blocking shutdown hooks +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4638";>FLINK-4638</a>] - Fix exception message for MemorySegment +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4654";>FLINK-4654</a>] - clean up docs +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4662";>FLINK-4662</a>] - Bump Calcite version up to 1.9 +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4668";>FLINK-4668</a>] - Fix positive random int generation +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4669";>FLINK-4669</a>] - scala api createLocalEnvironment() function add default Configuration parameter +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4684";>FLINK-4684</a>] - Remove obsolete classloader from CheckpointCoordinator +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4704";>FLINK-4704</a>] - Move Table API to org.apache.flink.table +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4715";>FLINK-4715</a>] - TaskManager should commit suicide after cancellation failure +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4720";>FLINK-4720</a>] - Implement an archived version of the execution graph +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4723";>FLINK-4723</a>] - Unify behaviour of committed offsets to Kafka / ZK for Kafka 0.8 and 0.9 consumer +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4728";>FLINK-4728</a>] - Replace reference equality with object equality +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4729";>FLINK-4729</a>] - Use optional VertexCentric CombineFunction +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4733";>FLINK-4733</a>] - Port WebFrontend to new metric system +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4734";>FLINK-4734</a>] - Remove use of Tuple setField for fixed position +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4736";>FLINK-4736</a>] - Don't duplicate fields in Ordering +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4737";>FLINK-4737</a>] - Add more compression algorithms to FileInputFormat +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4739";>FLINK-4739</a>] - Adding packaging details for the Elasticsearch connector +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4745";>FLINK-4745</a>] - Convert KafkaTableSource test to unit tests +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4751";>FLINK-4751</a>] - Extend Flink's futures to support combining two futures +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4752";>FLINK-4752</a>] - Improve session window documentation +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4762";>FLINK-4762</a>] - Use plural in time interval units +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4764";>FLINK-4764</a>] - Introduce config options +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4771";>FLINK-4771</a>] - Compression for AvroOutputFormat +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4772";>FLINK-4772</a>] - Store metrics in MetricStore as strings +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4773";>FLINK-4773</a>] - Introduce an OperatorIOMetricGroup +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4775";>FLINK-4775</a>] - Simplify access to MetricStore +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4776";>FLINK-4776</a>] - Move ExecutionGraph initialization into a dedicated class +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4780";>FLINK-4780</a>] - Ability to use UDP protocol in metrics-graphite +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4787";>FLINK-4787</a>] - Add REST API call for cancel-with-savepoints +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4792";>FLINK-4792</a>] - Update documentation - FlinkML/QuickStart Guide +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4825";>FLINK-4825</a>] - Implement a RexExecutor that uses Flink's code generation +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4832";>FLINK-4832</a>] - Count/Sum 0 elements +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4876";>FLINK-4876</a>] - Allow web interface to be bound to a specific ip/interface/inetHost +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4881";>FLINK-4881</a>] - Docker: Remove dependency on shared volumes +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4892";>FLINK-4892</a>] - Snapshot TimerService using Key-Grouped State +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4894";>FLINK-4894</a>] - Don't block on buffer request after broadcastEvent +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4906";>FLINK-4906</a>] - Use constants for the name of system-defined metrics +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4913";>FLINK-4913</a>] - Per-job Yarn clusters: include user jar in system class loader +</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-4923";>FLINK-4923</a>] - Expose input/output buffers and bufferPool usage as a metric for a Task +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4924";>FLINK-4924</a>] - Simplify Operator Test Harness Constructors +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4925";>FLINK-4925</a>] - Integrate meters into IOMetricGroups +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4935";>FLINK-4935</a>] - Submit job with savepoint via REST API +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4936";>FLINK-4936</a>] - Operator names for Gelly inputs +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4939";>FLINK-4939</a>] - GenericWriteAheadSink: Decouple the creating from the committing subtask for a pending checkpoint +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4943";>FLINK-4943</a>] - flink-mesos/ConfigConstants: Typo: YYARN -> YARN +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4946";>FLINK-4946</a>] - Load jar files from subdirectories of lib +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4963";>FLINK-4963</a>] - Tabulate edge direction for directed VertexMetrics +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4970";>FLINK-4970</a>] - Parameterize vertex value for SSSP +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4972";>FLINK-4972</a>] - CoordinatorShutdownTest relies on race condition for success +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4975";>FLINK-4975</a>] - Add a limit for how much data may be buffered during checkpoint alignment +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4983";>FLINK-4983</a>] - Web UI: Add favicon +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4996";>FLINK-4996</a>] - Make CrossHint @Public +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5000";>FLINK-5000</a>] - Rename Methods in ManagedInitializationContext +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5003";>FLINK-5003</a>] - Provide Access to State Stores in Operator Snapshot Context +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5004";>FLINK-5004</a>] - Add task manager option to disable queryable state server +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5008";>FLINK-5008</a>] - Update quickstart documentation +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5010";>FLINK-5010</a>] - Decouple the death watch parameters from the Akka ask timeout +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5012";>FLINK-5012</a>] - Provide Timestamp in TimelyFlatMapFunction +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5020";>FLINK-5020</a>] - Make the GenericWriteAheadSink rescalable. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5021";>FLINK-5021</a>] - Makes the ContinuousFileReaderOperator rescalable. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5022";>FLINK-5022</a>] - Suppress RejectedExecutionException when the Executor is shut down +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5026";>FLINK-5026</a>] - Rename TimelyFlatMap to Process +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5034";>FLINK-5034</a>] - Don't Write StateDescriptor to RocksDB Snapshot +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5035";>FLINK-5035</a>] - Don't Write TypeSerializer to Heap State Snapshot +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5046";>FLINK-5046</a>] - Avoid redundant serialization when creating the TaskDeploymentDescriptor +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5054";>FLINK-5054</a>] - Make the BucketingSink rescalable. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5096";>FLINK-5096</a>] - Make the RollingSink rescalable. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-5110";>FLINK-5110</a>] - Remove the AbstractAlignedProcessingTimeWindowOperator. +</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/jir
<TRUNCATED>
