You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by rm...@apache.org on 2017/01/18 14:10:42 UTC
[35/78] [abbrv] flink-web git commit: Revert "Rebuild website"
http://git-wip-us.apache.org/repos/asf/flink-web/blob/16a92b0c/content/blog/release_1.1.0-changelog.html
----------------------------------------------------------------------
diff --git a/content/blog/release_1.1.0-changelog.html b/content/blog/release_1.1.0-changelog.html
deleted file mode 100644
index 15d6ddc..0000000
--- a/content/blog/release_1.1.0-changelog.html
+++ /dev/null
@@ -1,689 +0,0 @@
-<!DOCTYPE html>
-<html lang="en">
- <head>
- <meta charset="utf-8">
- <meta http-equiv="X-UA-Compatible" content="IE=edge">
- <meta name="viewport" content="width=device-width, initial-scale=1">
- <!-- The above 3 meta tags *must* come first in the head; any other head content must come *after* these tags -->
- <title>Apache Flink: Release 1.1.0 \u2013 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.1.0 \u2013 Changelog</h1>
-
- <ul id="markdown-toc">
- <li><a href="#changelog" id="markdown-toc-changelog">Changelog</a> <ul>
- <li><a href="#sub-task" id="markdown-toc-sub-task">Sub-task</a></li>
- <li><a href="#bug" id="markdown-toc-bug">Bug</a></li>
- <li><a href="#improvement" id="markdown-toc-improvement">Improvement</a></li>
- <li><a href="#new-feature" id="markdown-toc-new-feature">New Feature</a></li>
- <li><a href="#task" id="markdown-toc-task">Task</a></li>
- <li><a href="#test" id="markdown-toc-test">Test</a></li>
- <li><a href="#wish" id="markdown-toc-wish">Wish</a></li>
- </ul>
- </li>
-</ul>
-
-<h2 id="changelog">Changelog</h2>
-
-<p>The 1.1.0 release <a href="https://issues.apache.org/jira/issues/?jql=project+%3D+FLINK+AND+fixVersion+%3D+1.1.0">resolved 457 JIRA issues</a> in total.</p>
-
-<h3 id="sub-task">Sub-task</h3>
-
-<ul>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-1502">FLINK-1502</a>: Expose metrics to graphite, ganglia and JMX.</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-1550">FLINK-1550</a>: Show JVM Metrics for JobManager</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3129">FLINK-3129</a>: Add tooling to ensure interface stability</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3141">FLINK-3141</a>: Design of NULL values handling in operation</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3223">FLINK-3223</a>: Translate Table API query into logical relational plans for Apache Calcite</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3225">FLINK-3225</a>: Optimize logical Table API plans in Calcite</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3226">FLINK-3226</a>: Translate optimized logical Table API plans into physical plans representing DataSet programs</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3229">FLINK-3229</a>: Kinesis streaming consumer with integration of Flink's checkpointing mechanics</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3230">FLINK-3230</a>: Kinesis streaming producer</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3231">FLINK-3231</a>: Handle Kinesis-side resharding in Kinesis streaming consumer</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3327">FLINK-3327</a>: Attach the ExecutionConfig to the JobGraph and make it accessible to the AbstractInvocable.</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3489">FLINK-3489</a>: Refactor Table API before merging into master</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3544">FLINK-3544</a>: ResourceManager runtime components</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3545">FLINK-3545</a>: ResourceManager: YARN integration</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3547">FLINK-3547</a>: Add support for streaming projection, selection, and union</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3550">FLINK-3550</a>: Rework stream join example</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3552">FLINK-3552</a>: Change socket WordCount to be properly windowed</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3573">FLINK-3573</a>: Implement more String functions for Table API</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3574">FLINK-3574</a>: Implement math functions for Table API</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3586">FLINK-3586</a>: Risk of data overflow while use sum/count to calculate AVG value</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3612">FLINK-3612</a>: Fix/adjust Table API examples</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3714">FLINK-3714</a>: Add Support for "Allowed Lateness"</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3727">FLINK-3727</a>: Add support for embedded streaming SQL (projection, filter, union)</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3748">FLINK-3748</a>: Add CASE function to Table API</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3756">FLINK-3756</a>: Introduce state hierarchy in CheckpointCoordinator</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3837">FLINK-3837</a>: Create FLOOR/CEIL function</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3923">FLINK-3923</a>: Unify configuration conventions of the Kinesis producer to the same as the consumer</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3949">FLINK-3949</a>: Collect Metrics in Runtime Operators</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3951">FLINK-3951</a>: Add Histogram Metric Type</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4018">FLINK-4018</a>: Configurable idle time between getRecords requests to Kinesis shards</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4019">FLINK-4019</a>: Expose approximateArrivalTimestamp through the KinesisDeserializationSchema interface</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4020">FLINK-4020</a>: Remove shard list querying from Kinesis consumer constructor</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4033">FLINK-4033</a>: Missing Scala example snippets for the Kinesis Connector documentation</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4057">FLINK-4057</a>: Expose JobManager Metrics</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4062">FLINK-4062</a>: Update Windowing Documentation</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4080">FLINK-4080</a>: Kinesis consumer not exactly-once if stopped in the middle of processing aggregated records</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4085">FLINK-4085</a>: Set Kinesis Consumer Agent to Flink</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4191">FLINK-4191</a>: Expose shard information in KinesisDeserializationSchema</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4239">FLINK-4239</a>: Set Default Allowed Lateness to Zero and Make Triggers Non-Purging</li>
-</ul>
-
-<h3 id="bug">Bug</h3>
-
-<ul>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-1159">FLINK-1159</a>: Case style anonymous functions not supported by Scala API</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-1964">FLINK-1964</a>: Rework TwitterSource to use a Properties object instead of a file path</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-2392">FLINK-2392</a>: Instable test in flink-yarn-tests</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-2544">FLINK-2544</a>: Some test cases using PowerMock fail with Java 8u20</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-2832">FLINK-2832</a>: Failing test: RandomSamplerTest.testReservoirSamplerWithReplacement</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-2915">FLINK-2915</a>: JobManagerProcessFailureBatchRecoveryITCase</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3086">FLINK-3086</a>: ExpressionParser does not support concatenation of suffix operations</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3105">FLINK-3105</a>: Submission in per job YARN cluster mode reuses properties file of long-lived session</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3126">FLINK-3126</a>: Remove accumulator type from "value" in web frontend</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3179">FLINK-3179</a>: Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3333">FLINK-3333</a>: Documentation about object reuse should be improved</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3380">FLINK-3380</a>: Unstable Test: JobSubmissionFailsITCase</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3396">FLINK-3396</a>: Job submission Savepoint restore logic flawed</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3411">FLINK-3411</a>: Failed recovery can lead to removal of HA state</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3444">FLINK-3444</a>: env.fromElements relies on the first input element for determining the DataSet/DataStream type</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3466">FLINK-3466</a>: Job might get stuck in restoreState() from HDFS due to interrupt</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3471">FLINK-3471</a>: JDBCInputFormat cannot handle null fields of certain types</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3472">FLINK-3472</a>: JDBCInputFormat.nextRecord(..) has misleading message on NPE</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3488">FLINK-3488</a>: Kafka08ITCase.testBigRecordJob fails on Travis</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3491">FLINK-3491</a>: HDFSCopyUtilitiesTest fails on Windows</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3495">FLINK-3495</a>: RocksDB Tests can't run on Windows</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3505">FLINK-3505</a>: JoinUnionTransposeRule fails to push Join past Union.</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3519">FLINK-3519</a>: Subclasses of Tuples don't work if the declared type of a DataSet is not the descendant</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3530">FLINK-3530</a>: Kafka09ITCase.testBigRecordJob fails on Travis</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3533">FLINK-3533</a>: Update the Gelly docs wrt examples and cluster execution</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3534">FLINK-3534</a>: Cancelling a running job can lead to restart instead of stopping</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3540">FLINK-3540</a>: Hadoop 2.6.3 build contains /com/google/common (guava) classes in flink-dist.jar</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3556">FLINK-3556</a>: Unneeded check in HA blob store configuration</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3561">FLINK-3561</a>: ExecutionConfig's timestampsEnabled is unused</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3562">FLINK-3562</a>: Update docs in the course of EventTimeSourceFunction removal</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3563">FLINK-3563</a>: .returns() doesn't compile when using .map() with a custom MapFunction</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3565">FLINK-3565</a>: FlinkKafkaConsumer does not work with Scala 2.11</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3566">FLINK-3566</a>: Input type validation often fails on custom TypeInfo implementations</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3567">FLINK-3567</a>: Rework selection when grouping in Table API</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3569">FLINK-3569</a>: Test cases fail due to Maven Shade plugin</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3577">FLINK-3577</a>: Display anchor links when hovering over headers.</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3578">FLINK-3578</a>: Scala DataStream API does not support Rich Window Functions</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3579">FLINK-3579</a>: Improve String concatenation</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3583">FLINK-3583</a>: Configuration not visible in gui when job is running</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3585">FLINK-3585</a>: Deploy scripts don't support spaces in paths</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3593">FLINK-3593</a>: DistinctITCase is failing</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3595">FLINK-3595</a>: Kafka09 consumer thread does not interrupt when stuck in record emission</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3601">FLINK-3601</a>: JobManagerTest times out on StopSignal test</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3602">FLINK-3602</a>: Recursive Types are not supported / crash TypeExtractor</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3608">FLINK-3608</a>: ImmutableSettings error in ElasticsearchSink</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3611">FLINK-3611</a>: Wrong link in CONTRIBUTING.md</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3619">FLINK-3619</a>: SavepointCoordinator test failure</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3621">FLINK-3621</a>: Misleading documentation of memory configuration parameters</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3622">FLINK-3622</a>: Improve error messages for invalid joins</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3630">FLINK-3630</a>: Little mistake in documentation</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3631">FLINK-3631</a>: CodeGenerator does not check type compatibility for equality expressions</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3633">FLINK-3633</a>: Job submission silently fails when using user code types</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3635">FLINK-3635</a>: Potential null deference in TwitterExample#SelectEnglishAndTokenizeFlatMap#flatMap</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3636">FLINK-3636</a>: NoClassDefFoundError while running WindowJoin example</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3638">FLINK-3638</a>: Invalid default ports in documentation</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3644">FLINK-3644</a>: WebRuntimMonitor set java.io.tmpdir does not work for change upload dir.</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3645">FLINK-3645</a>: HDFSCopyUtilitiesTest fails in a Hadoop cluster</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3651">FLINK-3651</a>: Fix faulty RollingSink Restore</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3653">FLINK-3653</a>: recovery.zookeeper.storageDir is not documented on the configuration page</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3663">FLINK-3663</a>: FlinkKafkaConsumerBase.logPartitionInfo is missing a log marker</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3669">FLINK-3669</a>: WindowOperator registers a lot of timers at StreamTask</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3675">FLINK-3675</a>: YARN ship folder incosistent behavior</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3676">FLINK-3676</a>: WebClient hasn't been removed from the docs</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3681">FLINK-3681</a>: CEP library does not support Java 8 lambdas as select function</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3682">FLINK-3682</a>: CEP operator does not set the processing timestamp correctly</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3684">FLINK-3684</a>: CEP operator does not forward watermarks properly</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3689">FLINK-3689</a>: JobManager blocks cluster shutdown when not connected to ResourceManager</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3693">FLINK-3693</a>: JobManagerHAJobGraphRecoveryITCase.testClientNonDetachedListeningBehaviour is unstable</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3696">FLINK-3696</a>: Some Union tests fail for TableConfigMode.EFFICIENT</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3697">FLINK-3697</a>: keyBy() with nested POJO computes invalid field position indexes</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3701">FLINK-3701</a>: Cant call execute after first execution</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3712">FLINK-3712</a>: YARN client dynamic properties are not passed correctly to the leader election service on the client</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3713">FLINK-3713</a>: DisposeSavepoint message uses system classloader to discard state</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3716">FLINK-3716</a>: Kafka08ITCase.testFailOnNoBroker() timing out before it has a chance to pass</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3718">FLINK-3718</a>: Add Option For Completely Async Backup in RocksDB State Backend</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3725">FLINK-3725</a>: Exception in thread "main" scala.MatchError: \u2026 (of class scala.Tuple4)</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3728">FLINK-3728</a>: Throw meaningful exceptions for unsupported SQL features</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3729">FLINK-3729</a>: Several SQL tests fail on Windows OS</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3730">FLINK-3730</a>: Fix RocksDB Local Directory Initialization</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3731">FLINK-3731</a>: Embedded SQL outer joins should fail during translation</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3732">FLINK-3732</a>: Potential null deference in ExecutionConfig#equals()</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3735">FLINK-3735</a>: Embedded SQL union should fail during translation</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3737">FLINK-3737</a>: WikipediaEditsSourceTest.testWikipediaEditsSource() fails locally</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3745">FLINK-3745</a>: TimestampITCase testWatermarkPropagationNoFinalWatermarkOnStop failing intermittently</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3757">FLINK-3757</a>: addAccumulator does not throw Exception on duplicate accumulator name</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3759">FLINK-3759</a>: Table API should throw exception is null value is encountered in non-null mode.</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3762">FLINK-3762</a>: Kryo StackOverflowError due to disabled Kryo Reference tracking</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3773">FLINK-3773</a>: Scanners are left unclosed in SqlExplainTest</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3774">FLINK-3774</a>: Flink configuration is not correctly forwarded to PlanExecutor in ScalaShellRemoteEnvironment</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3781">FLINK-3781</a>: BlobClient may be left unclosed in BlobCache#deleteGlobal()</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3790">FLINK-3790</a>: Rolling File sink does not pick up hadoop configuration</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3792">FLINK-3792</a>: RowTypeInfo equality should not depend on field names</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3793">FLINK-3793</a>: Re-organize the Table API and SQL docs</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3796">FLINK-3796</a>: FileSourceFunction doesn't respect InputFormat's life cycle methods</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3803">FLINK-3803</a>: Checkpoint Stats Tracker Reads from Wrong Configuration</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3824">FLINK-3824</a>: ResourceManager may repeatedly connect to outdated JobManager in HA mode</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3826">FLINK-3826</a>: Broken test: StreamCheckpointingITCase</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3835">FLINK-3835</a>: JSON execution plan not helpful to debug plans with KeySelectors</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3838">FLINK-3838</a>: CLI parameter parser is munging application params</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3840">FLINK-3840</a>: RocksDB local parent dir is polluted with empty folders with random names</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3842">FLINK-3842</a>: Fix handling null record/row in generated code</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3845">FLINK-3845</a>: Gelly allows duplicate vertices in Graph.addVertices</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3846">FLINK-3846</a>: Graph.removeEdges also removes duplicate edges</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3860">FLINK-3860</a>: WikipediaEditsSourceTest.testWikipediaEditsSource times out</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3863">FLINK-3863</a>: Yarn Cluster shutdown may fail if leader changed recently</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3864">FLINK-3864</a>: Yarn tests don't check for prohibited strings in log output</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3877">FLINK-3877</a>: Create TranslateFunction interface for Graph translators</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3878">FLINK-3878</a>: File cache doesn't support multiple duplicate temp directories</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3882">FLINK-3882</a>: Errors in sample Java code for the Elasticsearch 2.x sink</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3890">FLINK-3890</a>: Deprecate streaming mode flag from Yarn CLI</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3892">FLINK-3892</a>: ConnectionUtils may die with NullPointerException</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3893">FLINK-3893</a>: LeaderChangeStateCleanupTest times out</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3908">FLINK-3908</a>: FieldParsers error state is not reset correctly to NONE</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3909">FLINK-3909</a>: Maven Failsafe plugin may report SUCCESS on failed tests</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3914">FLINK-3914</a>: BlobServer.createTemporaryFilename() has concurrency safety problem</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3922">FLINK-3922</a>: Infinite recursion on TypeExtractor</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3926">FLINK-3926</a>: Incorrect implementation of getFieldIndex in TupleTypeInfo</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3927">FLINK-3927</a>: TaskManager registration may fail if Yarn versions don't match</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3928">FLINK-3928</a>: Potential overflow due to 32-bit int arithmetic</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3933">FLINK-3933</a>: Add an auto-type-extracting DeserializationSchema</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3934">FLINK-3934</a>: Prevent translation of non-equi joins in DataSetJoinRule</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3935">FLINK-3935</a>: Invalid check of key and ordering fields in PartitionNode</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3938">FLINK-3938</a>: Yarn tests don't run on the current master</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3939">FLINK-3939</a>: Prevent distinct aggregates and grouping sets from being translated</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3944">FLINK-3944</a>: Add optimization rules to reorder Cartesian products and joins</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3948">FLINK-3948</a>: EventTimeWindowCheckpointingITCase Fails with Core Dump</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3953">FLINK-3953</a>: Surefire plugin executes unit tests twice</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3956">FLINK-3956</a>: Make FileInputFormats independent from Configuration</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3960">FLINK-3960</a>: Disable, fix and re-enable EventTimeWindowCheckpointingITCase</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3962">FLINK-3962</a>: JMXReporter doesn't properly register/deregister metrics</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3963">FLINK-3963</a>: AbstractReporter uses shaded dependency</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3971">FLINK-3971</a>: Aggregates handle null values incorrectly.</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3972">FLINK-3972</a>: Subclasses of ResourceID may not to be serializable</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3973">FLINK-3973</a>: Table API documentation is "hidden" in Programming Guide menu list</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3974">FLINK-3974</a>: enableObjectReuse fails when an operator chains to multiple downstream operators</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3975">FLINK-3975</a>: Override baseurl when serving docs locally</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3977">FLINK-3977</a>: Subclasses of InternalWindowFunction must support OutputTypeConfigurable</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3981">FLINK-3981</a>: Don't log duplicate TaskManager registrations as exceptions</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3982">FLINK-3982</a>: Multiple ResourceManagers register at JobManager in standalone HA mode</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3994">FLINK-3994</a>: Instable KNNITSuite</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3995">FLINK-3995</a>: Properly Structure Test Utils and Dependencies</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4000">FLINK-4000</a>: Exception: Could not restore checkpointed state to operators and functions; during Job Restart (Job restart is triggered due to one of the task manager failure)</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4002">FLINK-4002</a>: [py] Improve testing infraestructure</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4009">FLINK-4009</a>: Scala Shell fails to find library for inclusion in test</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4011">FLINK-4011</a>: Unable to access completed job in web frontend</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4012">FLINK-4012</a>: Docs: Links to "Iterations" are broken (404)</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4016">FLINK-4016</a>: FoldApplyWindowFunction is not properly initialized</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4024">FLINK-4024</a>: FileSourceFunction not adjusted to new IF lifecycle</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4027">FLINK-4027</a>: FlinkKafkaProducer09 sink can lose messages</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4028">FLINK-4028</a>: AbstractAlignedProcessingTimeWindowOperator creates wrong TimeWindow</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4030">FLINK-4030</a>: ScalaShellITCase gets stuck</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4031">FLINK-4031</a>: Nightly Jenkins job doesn't deploy sources</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4038">FLINK-4038</a>: Impossible to set more than 1 JVM argument in env.java.opts</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4040">FLINK-4040</a>: Same env.java.opts is applied for TM , JM and ZK</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4041">FLINK-4041</a>: Failure while asking ResourceManager for RegisterResource</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4046">FLINK-4046</a>: Failing a restarting job can get stuck in JobStatus.FAILING</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4052">FLINK-4052</a>: Unstable test ConnectionUtilsTest</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4053">FLINK-4053</a>: Return value from Connection should be checked against null</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4056">FLINK-4056</a>: SavepointITCase.testCheckpointHasBeenRemoved failed on Travis</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4076">FLINK-4076</a>: BoltWrapper#dispose() should call AbstractStreamOperator#dispose()</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4077">FLINK-4077</a>: Register Pojo DataSet/DataStream as Table requires alias expression.</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4078">FLINK-4078</a>: Use ClosureCleaner for CoGroup where</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4079">FLINK-4079</a>: YARN properties file used for per-job cluster</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4083">FLINK-4083</a>: Use ClosureCleaner for Join where and equalTo</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4089">FLINK-4089</a>: Ineffective null check in YarnClusterClient#getApplicationStatus()</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4090">FLINK-4090</a>: Close of OutputStream should be in finally clause in FlinkYarnSessionCli#writeYarnProperties()</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4097">FLINK-4097</a>: Cassandra Sink throws NPE on closing if server is not available</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4099">FLINK-4099</a>: CliFrontendYarnAddressConfigurationTest fails</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4111">FLINK-4111</a>: Flink Table & SQL doesn't work in very simple example</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4113">FLINK-4113</a>: Always copy first value in ChainedAllReduceDriver</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4115">FLINK-4115</a>: FsStateBackend filesystem verification can cause classpath exceptions</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4122">FLINK-4122</a>: Cassandra jar contains 2 guava versions</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4123">FLINK-4123</a>: CassandraWriteAheadSink can hang on cassandra failure</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4125">FLINK-4125</a>: Yarn CLI incorrectly calculates slotsPerTM when parallelism < task manager count</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4130">FLINK-4130</a>: CallGenerator could generate illegal code when taking no operands</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4132">FLINK-4132</a>: Fix boxed comparison in CommunityDetection algorithm</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4133">FLINK-4133</a>: Reflect streaming file source changes in documentation</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4134">FLINK-4134</a>: EventTimeSessionWindows trigger for empty windows when dropping late events</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4139">FLINK-4139</a>: Yarn: Adjust parallelism and task slots correctly</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4141">FLINK-4141</a>: TaskManager failures not always recover when killed during an ApplicationMaster failure in HA mode on Yarn</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4142">FLINK-4142</a>: Recovery problem in HA on Hadoop Yarn 2.4.1</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4144">FLINK-4144</a>: Yarn properties file: replace hostname/port with Yarn application id</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4145">FLINK-4145</a>: JmxReporterTest fails due to port conflicts</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4146">FLINK-4146</a>: CliFrontendYarnAddressConfigurationTest picks wrong IP address on Travis</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4149">FLINK-4149</a>: Fix Serialization of NFA in AbstractKeyedCEPPatternOperator</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4150">FLINK-4150</a>: Problem with Blobstore in Yarn HA setting on recovery after cluster shutdown</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4152">FLINK-4152</a>: TaskManager registration exponential backoff doesn't work</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4154">FLINK-4154</a>: Correction of murmur hash breaks backwards compatibility</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4156">FLINK-4156</a>: Job with -m yarn-cluster registers TaskManagers to another running Yarn session</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4157">FLINK-4157</a>: FlinkKafkaMetrics cause TaskManager shutdown during cancellation</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4158">FLINK-4158</a>: Scala QuickStart StreamingJob fails to compile</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4159">FLINK-4159</a>: Quickstart poms exclude unused dependencies</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4160">FLINK-4160</a>: YARN session doesn't show input validation errors</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4166">FLINK-4166</a>: Generate automatic different namespaces in Zookeeper for Flink applications</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4167">FLINK-4167</a>: TaskMetricGroup does not close IOMetricGroup</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4168">FLINK-4168</a>: ForkableFlinkMiniCluster not available in Kinesis connector tests</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4171">FLINK-4171</a>: StatsD does not accept metrics whose name contains ":"</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4172">FLINK-4172</a>: Don't proxy a ProxiedObject</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4176">FLINK-4176</a>: Travis build fails at flink-connector-kinesis for JDK: openjdk7</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4184">FLINK-4184</a>: Ganglia and GraphiteReporter report metric names with invalid characters</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4196">FLINK-4196</a>: Remove "recoveryTimestamp"</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4199">FLINK-4199</a>: Misleading messages by CLI upon job submission</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4201">FLINK-4201</a>: Checkpoints for jobs in non-terminal state (e.g. suspended) get deleted</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4214">FLINK-4214</a>: JobExceptionsHandler will return all exceptions</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4216">FLINK-4216</a>: WordWithCount example with Java has wrong generics type</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4232">FLINK-4232</a>: Flink executable does not return correct pid</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4235">FLINK-4235</a>: ClassLoaderITCase.testDisposeSavepointWithCustomKvState timed out on Travis</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4238">FLINK-4238</a>: Only allow/require query for Tuple Stream in CassandraSink</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4258">FLINK-4258</a>: Potential null pointer dereference in SavepointCoordinator#onFullyAcknowledgedCheckpoint</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4261">FLINK-4261</a>: Setup atomic deployment of snapshots</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4277">FLINK-4277</a>: TaskManagerConfigurationTest fails</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4284">FLINK-4284</a>: DataSet/CEP link to non-existant "Linking with Flink" section</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-4307">FLINK-4307</a>: Broken user-facing API for ListState</li>
-</ul>
-
-<h3 id="improvement">Improvement</h3>
-
-<ul>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-1827">FLINK-1827</a>: Move test classes in test folders and fix scope of test dependencies</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-1991">FLINK-1991</a>: Return Table as DataSet<Tuple></li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-1996">FLINK-1996</a>: Add output methods to Table API</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-2227">FLINK-2227</a>: .yarn-properties file is not cleaned up</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-2522">FLINK-2522</a>: Integrate Streaming Api into Flink-scala-shell</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-2788">FLINK-2788</a>: Add type hint with TypeExtactor call on Hint Type</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-2829">FLINK-2829</a>: Confusing error message when Flink cannot create enough task threads</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-2929">FLINK-2929</a>: Recovery of jobs on cluster restarts</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-2935">FLINK-2935</a>: Allow scala shell to read yarn properties</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-2985">FLINK-2985</a>: Allow different field names for unionAll() in Table API</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3115">FLINK-3115</a>: Update Elasticsearch connector to 2.X</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3152">FLINK-3152</a>: Support all comparisons for Date type</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3153">FLINK-3153</a>: Support all comparisons for String type</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3174">FLINK-3174</a>: Add merging WindowAssigner</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3272">FLINK-3272</a>: Generalize vertex value type in ConnectedComponents</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3323">FLINK-3323</a>: Add documentation for NiFi connector</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3332">FLINK-3332</a>: Provide an exactly-once Cassandra connector</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3375">FLINK-3375</a>: Allow Watermark Generation in the Kafka Source</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3383">FLINK-3383</a>: Separate Maven deployment from CI testing</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3405">FLINK-3405</a>: Extend NiFiSource with interface StoppableFunction</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3407">FLINK-3407</a>: Extend TwitterSource with interface StoppableFunction</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3428">FLINK-3428</a>: Add fixed time trailing timestamp/watermark extractor</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3461">FLINK-3461</a>: Remove duplicate condition check in ZooKeeperLeaderElectionService</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3467">FLINK-3467</a>: Remove superfluous objects from DataSourceTask.invoke</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3469">FLINK-3469</a>: Improve documentation for grouping keys</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3487">FLINK-3487</a>: FilterAggregateTransposeRule does not transform logical plan as desired.</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3503">FLINK-3503</a>: ProjectJoinTransposeRule fails to push down project.</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3506">FLINK-3506</a>: ReduceExpressionsRule does not remove duplicate expression in Filter</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3507">FLINK-3507</a>: PruneEmptyRules does not prune empty node as expected.</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3524">FLINK-3524</a>: Provide a JSONDeserialisationSchema in the kafka connector package</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3535">FLINK-3535</a>: Decrease logging verbosity of StackTraceSampleCoordinator</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3541">FLINK-3541</a>: Clean up workaround in FlinkKafkaConsumer09</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3559">FLINK-3559</a>: Don't print pid file check if no active PID</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3560">FLINK-3560</a>: Examples shouldn't always print usage statement</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3570">FLINK-3570</a>: Replace random NIC selection heuristic by InetAddress.getLocalHost</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3575">FLINK-3575</a>: Update Working With State Section in Doc</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3589">FLINK-3589</a>: Allow setting Operator parallelism to default value</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3590">FLINK-3590</a>: JDBC Format tests don't hide derby logs</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3591">FLINK-3591</a>: Replace Quickstart K-Means Example by Streaming Example</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3596">FLINK-3596</a>: DataSet RelNode refactoring</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3597">FLINK-3597</a>: Table API operator names should reflect relational expression</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3603">FLINK-3603</a>: Re-enable Table API explain</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3604">FLINK-3604</a>: Enable ignored Table API tests</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3607">FLINK-3607</a>: Decrease default forkCount for tests</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3614">FLINK-3614</a>: Remove Non-Keyed Window Operator</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3618">FLINK-3618</a>: Rename abstract UDF classes in Scatter-Gather implementation</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3623">FLINK-3623</a>: Adjust MurmurHash algorithm</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3632">FLINK-3632</a>: Clean up Table API exceptions</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3634">FLINK-3634</a>: Fix documentation for DataSetUtils.zipWithUniqueId()</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3637">FLINK-3637</a>: Change RollingSink Writer interface to allow wider range of outputs</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3641">FLINK-3641</a>: Document registerCachedFile API call</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3649">FLINK-3649</a>: Document stable API methods maxBy/minBy</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3650">FLINK-3650</a>: Add maxBy/minBy to Scala DataSet API</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3654">FLINK-3654</a>: Disable Write-Ahead-Log in RocksDB State</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3657">FLINK-3657</a>: Change access of DataSetUtils.countElements() to 'public'</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3658">FLINK-3658</a>: Allow the FlinkKafkaProducer to send data to multiple topics</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3664">FLINK-3664</a>: Create a method to easily Summarize a DataSet</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3665">FLINK-3665</a>: Range partitioning lacks support to define sort orders</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3666">FLINK-3666</a>: Remove Nephele references</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3667">FLINK-3667</a>: Generalize client<->cluster communication</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3678">FLINK-3678</a>: Make Flink logs directory configurable</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3691">FLINK-3691</a>: Extend AvroInputFormat to support Avro GenericRecord</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3700">FLINK-3700</a>: Replace Guava Preconditions class with Flink Preconditions</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3736">FLINK-3736</a>: Move toRexNode and toAggCall logic into Expressions</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3739">FLINK-3739</a>: Add a null literal to Table API</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3747">FLINK-3747</a>: Consolidate TimestampAssigner Methods in Kafka Consumer</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3750">FLINK-3750</a>: Make JDBCInputFormat a parallel source</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3752">FLINK-3752</a>: Add Per-Kafka-Partition Watermark Generation to the docs</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3754">FLINK-3754</a>: Add a validation phase before construct RelNode using TableAPI</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3763">FLINK-3763</a>: RabbitMQ Source/Sink standardize connection parameters</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3770">FLINK-3770</a>: Fix TriangleEnumerator performance</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3776">FLINK-3776</a>: Flink Scala shell does not allow to set configuration for local execution</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3794">FLINK-3794</a>: Add checks for unsupported operations in streaming table API</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3799">FLINK-3799</a>: Graph checksum should execute single job</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3804">FLINK-3804</a>: Update YARN documentation</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3806">FLINK-3806</a>: Revert use of DataSet.count() in Gelly</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3811">FLINK-3811</a>: Refactor ExecutionEnvironment in TableEnvironment</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3815">FLINK-3815</a>: Replace Guava Preconditions usage in flink-gelly</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3816">FLINK-3816</a>: Replace Guava Preconditions usage in flink-clients</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3817">FLINK-3817</a>: Remove unused Guava dependency from RocksDB StateBackend</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3818">FLINK-3818</a>: Remove Guava dependency from flink-gelly-examples</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3819">FLINK-3819</a>: Replace Guava Preconditions usage in flink-gelly-scala</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3821">FLINK-3821</a>: Reduce Guava usage in flink-java</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3853">FLINK-3853</a>: Reduce object creation in Gelly utility mappers</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3854">FLINK-3854</a>: Support Avro key-value rolling sink writer</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3855">FLINK-3855</a>: Upgrade Jackson version</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3868">FLINK-3868</a>: Specialized CopyableValue serializers and comparators</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3876">FLINK-3876</a>: Improve documentation of Scala Shell</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3880">FLINK-3880</a>: Improve performance of Accumulator map</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3886">FLINK-3886</a>: Give a better error when the application Main class is not public.</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3887">FLINK-3887</a>: Improve dependency management for building docs</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3891">FLINK-3891</a>: Add a class containing all supported Table API types</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3900">FLINK-3900</a>: Set nullCheck=true as default in TableConfig</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3901">FLINK-3901</a>: Create a RowCsvInputFormat to use as default CSV IF in Table API</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3912">FLINK-3912</a>: Typos in Batch Scala API Documentation</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3913">FLINK-3913</a>: Clean up documentation typos</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3916">FLINK-3916</a>: Allow generic types passing the Table API</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3936">FLINK-3936</a>: Add MIN / MAX aggregations function for BOOLEAN types</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3937">FLINK-3937</a>: Make flink cli list, savepoint, cancel and stop work on Flink-on-YARN clusters</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3945">FLINK-3945</a>: Degree annotation for directed graphs</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3955">FLINK-3955</a>: Change Table.toSink() to Table.writeToSink()</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3978">FLINK-3978</a>: Add hasBroadcastVariable method to RuntimeContext</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3979">FLINK-3979</a>: [documentation]add missed import classes in run_example_quickstart</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3980">FLINK-3980</a>: Remove ExecutionConfig.PARALLELISM_UNKNOWN</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3993">FLINK-3993</a>: [py] Add generateSequence() support to Python API</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4003">FLINK-4003</a>: Use intrinsics for MathUtils logarithms</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4017">FLINK-4017</a>: [py] Add Aggregation support to Python API</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4025">FLINK-4025</a>: Add possiblity for the RMQ Streaming Source to customize the queue</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4026">FLINK-4026</a>: Fix code, grammar, and link issues in the Streaming documentation</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4032">FLINK-4032</a>: Replace all usage of Guava Preconditions</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4049">FLINK-4049</a>: Mark RichInputFormat.openInputFormat and closeInputFormat as @PublicEvolving</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4054">FLINK-4054</a>: Inconsistent Reporter synchronization within report()</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4063">FLINK-4063</a>: Add Metrics Support for Triggers</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4066">FLINK-4066</a>: RabbitMQ source, customize queue arguments</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4067">FLINK-4067</a>: Add version header to savepoints</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4070">FLINK-4070</a>: Support literals on left side of binary expressions</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4074">FLINK-4074</a>: Reporter can block TaskManager shutdown</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4082">FLINK-4082</a>: Add Setting for LargeRecordHandler</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4086">FLINK-4086</a>: Hide internal Expression methods from Table API</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4087">FLINK-4087</a>: JMXReporter can't handle port conflicts</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4093">FLINK-4093</a>: Expose metric interfaces</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4095">FLINK-4095</a>: Add configDir argument to shell scripts</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4103">FLINK-4103</a>: Modify CsvTableSource to implement StreamTableSource</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4105">FLINK-4105</a>: Restructure Gelly docs</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4106">FLINK-4106</a>: Restructure Gelly docs</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4107">FLINK-4107</a>: Restructure Gelly docs</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4109">FLINK-4109</a>: Change the name of ternary condition operator 'eval' to '?'</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4116">FLINK-4116</a>: Document metrics</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4118">FLINK-4118</a>: The docker-flink image is outdated (1.0.2) and can be slimmed down</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4119">FLINK-4119</a>: Null checks in close() for Cassandra Input/Output Formats, checking arguments via Flink Preconditions</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4121">FLINK-4121</a>: Add timeunit (ms) to docs for timestamps and watermarks</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4127">FLINK-4127</a>: Clean up configuration and check breaking API changes</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4135">FLINK-4135</a>: Replace ChecksumHashCode as GraphAnalytic</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4170">FLINK-4170</a>: Remove <code>CONFIG_</code> prefix from KinesisConfigConstants variables</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4183">FLINK-4183</a>: Move checking for StreamTableEnvironment into validation layer</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4185">FLINK-4185</a>: Reflecting rename from Tachyon to Alluxio</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4186">FLINK-4186</a>: Expose Kafka metrics through Flink metrics</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4192">FLINK-4192</a>: Move Metrics API to separate module</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4197">FLINK-4197</a>: Allow Kinesis Endpoint to be Overridden via Config</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4202">FLINK-4202</a>: Add JM metric which shows the restart duration</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4206">FLINK-4206</a>: Metric names should allow special characters</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4209">FLINK-4209</a>: Fix issue on docker with multiple NICs and remove supervisord dependency</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4210">FLINK-4210</a>: Move close()/isClosed() out of MetricGroup interface</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4229">FLINK-4229</a>: Do not start Metrics Reporter by default</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4244">FLINK-4244</a>: Field names for union operator do not have to be equal</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4246">FLINK-4246</a>: Allow Specifying Multiple Metrics Reporters</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4269">FLINK-4269</a>: Decrease log level in RuntimeMonitorHandler</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4279">FLINK-4279</a>: [py] Set flink dependencies to provided</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4299">FLINK-4299</a>: Show loss of job manager in Client</li>
-</ul>
-
-<h3 id="new-feature">New Feature</h3>
-
-<ul>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-1745">FLINK-1745</a>: Add exact k-nearest-neighbours algorithm to machine learning library</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-2044">FLINK-2044</a>: Implementation of Gelly HITS Algorithm</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-2099">FLINK-2099</a>: Add a SQL API</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-2166">FLINK-2166</a>: Add fromCsvFile() to TableEnvironment</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-2828">FLINK-2828</a>: Add interfaces for Table API input formats</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-2909">FLINK-2909</a>: Gelly Graph Generators</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-2946">FLINK-2946</a>: Add orderBy() to Table API</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-2971">FLINK-2971</a>: Add outer joins to the Table API</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-2997">FLINK-2997</a>: Support range partition with user customized data distribution.</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-2998">FLINK-2998</a>: Support range partition comparison for multi input nodes.</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3034">FLINK-3034</a>: Redis SInk Connector</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3068">FLINK-3068</a>: Add a Table API configuration to TableEnvironment</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3207">FLINK-3207</a>: Add a Pregel iteration abstraction to Gelly</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3311">FLINK-3311</a>: Add a connector for streaming data into Cassandra</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3543">FLINK-3543</a>: Introduce ResourceManager component</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3546">FLINK-3546</a>: Streaming Table API</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3564">FLINK-3564</a>: Implement distinct() for Table API</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3626">FLINK-3626</a>: zipWithIndex in Python API</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3639">FLINK-3639</a>: Add methods and utilities to register DataSets and Tables in the TableEnvironment</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3640">FLINK-3640</a>: Add support for SQL queries in DataSet programs</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3721">FLINK-3721</a>: Min and max accumulators</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3768">FLINK-3768</a>: Clustering Coefficient</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3771">FLINK-3771</a>: Methods for translating Graphs</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3772">FLINK-3772</a>: Graph algorithms for vertex and edge degree</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3780">FLINK-3780</a>: Jaccard Similarity</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3786">FLINK-3786</a>: Add BigDecimal and BigInteger as Basic types</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3856">FLINK-3856</a>: Create types for java.sql.Date/Time/Timestamp</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3859">FLINK-3859</a>: Add BigDecimal/BigInteger support to Table API</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3872">FLINK-3872</a>: Add Kafka TableSource with JSON serialization</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3879">FLINK-3879</a>: Native implementation of HITS algorithm</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3898">FLINK-3898</a>: Adamic-Adar Similarity</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3906">FLINK-3906</a>: Global Clustering Coefficient</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3907">FLINK-3907</a>: Directed Clustering Coefficient</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3919">FLINK-3919</a>: Distributed Linear Algebra: row-based matrix</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3925">FLINK-3925</a>: GraphAlgorithm to filter by maximum degree</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3941">FLINK-3941</a>: Add support for UNION (with duplicate elimination)</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3942">FLINK-3942</a>: Add support for INTERSECT</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3943">FLINK-3943</a>: Add support for EXCEPT (set minus)</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3965">FLINK-3965</a>: Delegating GraphAlgorithm</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4013">FLINK-4013</a>: GraphAlgorithms to simplify directed and undirected graphs</li>
-</ul>
-
-<h3 id="task">Task</h3>
-
-<ul>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3139">FLINK-3139</a>: NULL values handling in Table API</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3221">FLINK-3221</a>: Move Table API on top of Apache Calcite</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3609">FLINK-3609</a>: Revisit selection of Calcite rules</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3738">FLINK-3738</a>: Refactor TableEnvironment and TranslationContext</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3743">FLINK-3743</a>: Upgrade breeze from 0.11.2 to 0.12</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3847">FLINK-3847</a>: Reorganize package structure of flink-table</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3852">FLINK-3852</a>: Use a StreamExecutionEnvironment in the quickstart job skeleton</li>
-</ul>
-
-<h3 id="test">Test</h3>
-
-<ul>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-2100">FLINK-2100</a>: Add ITCases for all Table API examples</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-2444">FLINK-2444</a>: Add tests for HadoopInputFormats</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-2445">FLINK-2445</a>: Add tests for HadoopOutputFormats</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3517">FLINK-3517</a>: Number of job and task managers not checked in scripts</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-3782">FLINK-3782</a>: ByteArrayOutputStream and ObjectOutputStream should close</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4010">FLINK-4010</a>: Scala Shell tests may fail because of a locked STDIN</li>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-4230">FLINK-4230</a>: Session Windowing IT Case</li>
-</ul>
-
-<h3 id="wish">Wish</h3>
-
-<ul>
- <li><a href="https://issues.apache.org/jira/browse/FLINK-2673">FLINK-2673</a>: Scala API does not support Option type as key</li>
-</ul>
-
-
- </div>
-</div>
-
- </div>
- </div>
-
- <hr />
-
- <div class="row">
- <div class="footer text-center col-sm-12">
- <p>Copyright � 2014-2016 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
- <p>Apache Flink, Apache, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation.</p>
- <p><a href="/privacy-policy.html">Privacy Policy</a> · <a href="/blog/feed.xml">RSS feed</a></p>
- </div>
- </div>
- </div><!-- /.container -->
-
- <!-- Include all compiled plugins (below), or include individual files as needed -->
- <script src="https://maxcdn.bootstrapcdn.com/bootstrap/3.3.4/js/bootstrap.min.js"></script>
- <script src="/js/codetabs.js"></script>
- <script src="/js/stickysidebar.js"></script>
-
-
- <!-- Google Analytics -->
- <script>
- (function(i,s,o,g,r,a,m){i['GoogleAnalyticsObject']=r;i[r]=i[r]||function(){
- (i[r].q=i[r].q||[]).push(arguments)},i[r].l=1*new Date();a=s.createElement(o),
- m=s.getElementsByTagName(o)[0];a.async=1;a.src=g;m.parentNode.insertBefore(a,m)
- })(window,document,'script','//www.google-analytics.com/analytics.js','ga');
-
- ga('create', 'UA-52545728-1', 'auto');
- ga('send', 'pageview');
- </script>
- </body>
-</html>