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 â 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 â 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: ⦠(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>
