| |
| <!DOCTYPE html> |
| <html lang="en" dir=ZgotmplZ> |
| |
| <head> |
| |
| |
| |
| <link rel="stylesheet" href="/bootstrap/css/bootstrap.min.css"> |
| <script src="/bootstrap/js/bootstrap.bundle.min.js"></script> |
| <link rel="stylesheet" type="text/css" href="/font-awesome/css/font-awesome.min.css"> |
| <script src="/js/anchor.min.js"></script> |
| <script src="/js/flink.js"></script> |
| <link rel="canonical" href="https://flink.apache.org/2017/04/26/apache-flink-1.2.1-released/"> |
| |
| <meta charset="UTF-8"> |
| <meta name="viewport" content="width=device-width, initial-scale=1.0"> |
| <meta name="description" content="The Apache Flink community released the first bugfix version of the Apache Flink 1.2 series. |
| This release includes many critical fixes for Flink 1.2.0. The list below includes a detailed list of all fixes. |
| We highly recommend all users to upgrade to Flink 1.2.1. |
| Please note that there are two unresolved major issues in Flink 1.2.1 and 1.2.0: |
| FLINK-6353 Restoring using CheckpointedRestoring does not work from 1.2 to 1.2 FLINK-6188 Some setParallelism() methods can’t cope with default parallelism <dependency> <groupId>org."> |
| <meta name="theme-color" content="#FFFFFF"><meta property="og:title" content="Apache Flink 1.2.1 Released" /> |
| <meta property="og:description" content="The Apache Flink community released the first bugfix version of the Apache Flink 1.2 series. |
| This release includes many critical fixes for Flink 1.2.0. The list below includes a detailed list of all fixes. |
| We highly recommend all users to upgrade to Flink 1.2.1. |
| Please note that there are two unresolved major issues in Flink 1.2.1 and 1.2.0: |
| FLINK-6353 Restoring using CheckpointedRestoring does not work from 1.2 to 1.2 FLINK-6188 Some setParallelism() methods can’t cope with default parallelism <dependency> <groupId>org." /> |
| <meta property="og:type" content="article" /> |
| <meta property="og:url" content="https://flink.apache.org/2017/04/26/apache-flink-1.2.1-released/" /><meta property="article:section" content="posts" /> |
| <meta property="article:published_time" content="2017-04-26T18:00:00+00:00" /> |
| <meta property="article:modified_time" content="2017-04-26T18:00:00+00:00" /> |
| <title>Apache Flink 1.2.1 Released | Apache Flink</title> |
| <link rel="manifest" href="/manifest.json"> |
| <link rel="icon" href="/favicon.png" type="image/x-icon"> |
| <link rel="stylesheet" href="/book.min.22eceb4d17baa9cdc0f57345edd6f215a40474022dfee39b63befb5fb3c596b5.css" integrity="sha256-IuzrTRe6qc3A9XNF7dbyFaQEdAIt/uObY777X7PFlrU="> |
| <script defer src="/en.search.min.2698f0d1b683dae4d6cb071668b310a55ebcf1c48d11410a015a51d90105b53e.js" integrity="sha256-Jpjw0baD2uTWywcWaLMQpV688cSNEUEKAVpR2QEFtT4="></script> |
| <!-- |
| Made with Book Theme |
| https://github.com/alex-shpak/hugo-book |
| --> |
| |
| <meta name="generator" content="Hugo 0.124.1"> |
| |
| |
| <script> |
| var _paq = window._paq = window._paq || []; |
| |
| |
| _paq.push(['disableCookies']); |
| |
| _paq.push(["setDomains", ["*.flink.apache.org","*.nightlies.apache.org/flink"]]); |
| _paq.push(['trackPageView']); |
| _paq.push(['enableLinkTracking']); |
| (function() { |
| var u="//analytics.apache.org/"; |
| _paq.push(['setTrackerUrl', u+'matomo.php']); |
| _paq.push(['setSiteId', '1']); |
| var d=document, g=d.createElement('script'), s=d.getElementsByTagName('script')[0]; |
| g.async=true; g.src=u+'matomo.js'; s.parentNode.insertBefore(g,s); |
| })(); |
| </script> |
| |
| </head> |
| |
| <body dir=ZgotmplZ> |
| |
| |
| |
| <header> |
| <nav class="navbar navbar-expand-xl"> |
| <div class="container-fluid"> |
| <a class="navbar-brand" href="/"> |
| <img src="/img/logo/png/100/flink_squirrel_100_color.png" alt="Apache Flink" height="47" width="47" class="d-inline-block align-text-middle"> |
| <span>Apache Flink</span> |
| </a> |
| <button class="navbar-toggler" type="button" data-bs-toggle="collapse" data-bs-target="#navbarSupportedContent" aria-controls="navbarSupportedContent" aria-expanded="false" aria-label="Toggle navigation"> |
| <i class="fa fa-bars navbar-toggler-icon"></i> |
| </button> |
| <div class="collapse navbar-collapse" id="navbarSupportedContent"> |
| <ul class="navbar-nav"> |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| <li class="nav-item dropdown"> |
| <a class="nav-link dropdown-toggle" href="#" role="button" data-bs-toggle="dropdown" aria-expanded="false">About</a> |
| <ul class="dropdown-menu"> |
| |
| <li> |
| |
| |
| <a class="dropdown-item" href="/what-is-flink/flink-architecture/">Architecture</a> |
| |
| |
| </li> |
| |
| <li> |
| |
| |
| <a class="dropdown-item" href="/what-is-flink/flink-applications/">Applications</a> |
| |
| |
| </li> |
| |
| <li> |
| |
| |
| <a class="dropdown-item" href="/what-is-flink/flink-operations/">Operations</a> |
| |
| |
| </li> |
| |
| <li> |
| |
| |
| <a class="dropdown-item" href="/what-is-flink/use-cases/">Use Cases</a> |
| |
| |
| </li> |
| |
| <li> |
| |
| |
| <a class="dropdown-item" href="/what-is-flink/powered-by/">Powered By</a> |
| |
| |
| </li> |
| |
| <li> |
| |
| |
| <a class="dropdown-item" href="/what-is-flink/roadmap/">Roadmap</a> |
| |
| |
| </li> |
| |
| <li> |
| |
| |
| <a class="dropdown-item" href="/what-is-flink/community/">Community & Project Info</a> |
| |
| |
| </li> |
| |
| <li> |
| |
| |
| <a class="dropdown-item" href="/what-is-flink/security/">Security</a> |
| |
| |
| </li> |
| |
| <li> |
| |
| |
| <a class="dropdown-item" href="/what-is-flink/special-thanks/">Special Thanks</a> |
| |
| |
| </li> |
| |
| </ul> |
| </li> |
| |
| |
| |
| |
| |
| <li class="nav-item dropdown"> |
| <a class="nav-link dropdown-toggle" href="#" role="button" data-bs-toggle="dropdown" aria-expanded="false">Getting Started</a> |
| <ul class="dropdown-menu"> |
| |
| <li> |
| |
| |
| <a class="dropdown-item" href="https://nightlies.apache.org/flink/flink-docs-stable/docs/try-flink/local_installation/">With Flink<i class="link fa fa-external-link title" aria-hidden="true"></i> |
| </a> |
| |
| |
| </li> |
| |
| <li> |
| |
| |
| <a class="dropdown-item" href="https://nightlies.apache.org/flink/flink-kubernetes-operator-docs-stable/docs/try-flink-kubernetes-operator/quick-start/">With Flink Kubernetes Operator<i class="link fa fa-external-link title" aria-hidden="true"></i> |
| </a> |
| |
| |
| </li> |
| |
| <li> |
| |
| |
| <a class="dropdown-item" href="https://nightlies.apache.org/flink/flink-cdc-docs-stable/docs/get-started/introduction/">With Flink CDC<i class="link fa fa-external-link title" aria-hidden="true"></i> |
| </a> |
| |
| |
| </li> |
| |
| <li> |
| |
| |
| <a class="dropdown-item" href="https://nightlies.apache.org/flink/flink-ml-docs-stable/docs/try-flink-ml/quick-start/">With Flink ML<i class="link fa fa-external-link title" aria-hidden="true"></i> |
| </a> |
| |
| |
| </li> |
| |
| <li> |
| |
| |
| <a class="dropdown-item" href="https://nightlies.apache.org/flink/flink-statefun-docs-stable/getting-started/project-setup.html">With Flink Stateful Functions<i class="link fa fa-external-link title" aria-hidden="true"></i> |
| </a> |
| |
| |
| </li> |
| |
| <li> |
| |
| |
| <a class="dropdown-item" href="https://nightlies.apache.org/flink/flink-docs-stable/docs/learn-flink/overview/">Training Course<i class="link fa fa-external-link title" aria-hidden="true"></i> |
| </a> |
| |
| |
| </li> |
| |
| </ul> |
| </li> |
| |
| |
| |
| |
| |
| <li class="nav-item dropdown"> |
| <a class="nav-link dropdown-toggle" href="#" role="button" data-bs-toggle="dropdown" aria-expanded="false">Documentation</a> |
| <ul class="dropdown-menu"> |
| |
| <li> |
| |
| |
| <a class="dropdown-item" href="https://nightlies.apache.org/flink/flink-docs-stable/">Flink 1.19 (stable)<i class="link fa fa-external-link title" aria-hidden="true"></i> |
| </a> |
| |
| |
| </li> |
| |
| <li> |
| |
| |
| <a class="dropdown-item" href="https://nightlies.apache.org/flink/flink-docs-master/">Flink Master (snapshot)<i class="link fa fa-external-link title" aria-hidden="true"></i> |
| </a> |
| |
| |
| </li> |
| |
| <li> |
| |
| |
| <a class="dropdown-item" href="https://nightlies.apache.org/flink/flink-kubernetes-operator-docs-stable/">Kubernetes Operator 1.8 (latest)<i class="link fa fa-external-link title" aria-hidden="true"></i> |
| </a> |
| |
| |
| </li> |
| |
| <li> |
| |
| |
| <a class="dropdown-item" href="https://nightlies.apache.org/flink/flink-kubernetes-operator-docs-main">Kubernetes Operator Main (snapshot)<i class="link fa fa-external-link title" aria-hidden="true"></i> |
| </a> |
| |
| |
| </li> |
| |
| <li> |
| |
| |
| <a class="dropdown-item" href="https://nightlies.apache.org/flink/flink-cdc-docs-stable">CDC 3.0 (stable)<i class="link fa fa-external-link title" aria-hidden="true"></i> |
| </a> |
| |
| |
| </li> |
| |
| <li> |
| |
| |
| <a class="dropdown-item" href="https://nightlies.apache.org/flink/flink-cdc-docs-master">CDC Master (snapshot)<i class="link fa fa-external-link title" aria-hidden="true"></i> |
| </a> |
| |
| |
| </li> |
| |
| <li> |
| |
| |
| <a class="dropdown-item" href="https://nightlies.apache.org/flink/flink-ml-docs-stable/">ML 2.3 (stable)<i class="link fa fa-external-link title" aria-hidden="true"></i> |
| </a> |
| |
| |
| </li> |
| |
| <li> |
| |
| |
| <a class="dropdown-item" href="https://nightlies.apache.org/flink/flink-ml-docs-master">ML Master (snapshot)<i class="link fa fa-external-link title" aria-hidden="true"></i> |
| </a> |
| |
| |
| </li> |
| |
| <li> |
| |
| |
| <a class="dropdown-item" href="https://nightlies.apache.org/flink/flink-statefun-docs-stable/">Stateful Functions 3.3 (stable)<i class="link fa fa-external-link title" aria-hidden="true"></i> |
| </a> |
| |
| |
| </li> |
| |
| <li> |
| |
| |
| <a class="dropdown-item" href="https://nightlies.apache.org/flink/flink-statefun-docs-master">Stateful Functions Master (snapshot)<i class="link fa fa-external-link title" aria-hidden="true"></i> |
| </a> |
| |
| |
| </li> |
| |
| </ul> |
| </li> |
| |
| |
| |
| |
| |
| <li class="nav-item dropdown"> |
| <a class="nav-link dropdown-toggle" href="#" role="button" data-bs-toggle="dropdown" aria-expanded="false">How to Contribute</a> |
| <ul class="dropdown-menu"> |
| |
| <li> |
| |
| |
| <a class="dropdown-item" href="/how-to-contribute/overview/">Overview</a> |
| |
| |
| </li> |
| |
| <li> |
| |
| |
| <a class="dropdown-item" href="/how-to-contribute/contribute-code/">Contribute Code</a> |
| |
| |
| </li> |
| |
| <li> |
| |
| |
| <a class="dropdown-item" href="/how-to-contribute/reviewing-prs/">Review Pull Requests</a> |
| |
| |
| </li> |
| |
| <li> |
| |
| |
| <a class="dropdown-item" href="/how-to-contribute/code-style-and-quality-preamble/">Code Style and Quality Guide</a> |
| |
| |
| </li> |
| |
| <li> |
| |
| |
| <a class="dropdown-item" href="/how-to-contribute/contribute-documentation/">Contribute Documentation</a> |
| |
| |
| </li> |
| |
| <li> |
| |
| |
| <a class="dropdown-item" href="/how-to-contribute/documentation-style-guide/">Documentation Style Guide</a> |
| |
| |
| </li> |
| |
| <li> |
| |
| |
| <a class="dropdown-item" href="/how-to-contribute/improve-website/">Contribute to the Website</a> |
| |
| |
| </li> |
| |
| <li> |
| |
| |
| <a class="dropdown-item" href="/how-to-contribute/getting-help/">Getting Help</a> |
| |
| |
| </li> |
| |
| </ul> |
| </li> |
| |
| |
| |
| |
| |
| |
| |
| |
| <li class="nav-item"> |
| |
| |
| <a class="nav-link" href="/posts/">Flink Blog</a> |
| |
| |
| </li> |
| |
| |
| |
| |
| |
| <li class="nav-item"> |
| |
| |
| <a class="nav-link" href="/downloads/">Downloads</a> |
| |
| |
| </li> |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| </ul> |
| <div class="book-search"> |
| <div class="book-search-spinner hidden"> |
| <i class="fa fa-refresh fa-spin"></i> |
| </div> |
| <form class="search-bar d-flex" onsubmit="return false;"su> |
| <input type="text" id="book-search-input" placeholder="Search" aria-label="Search" maxlength="64" data-hotkeys="s/"> |
| <i class="fa fa-search search"></i> |
| <i class="fa fa-circle-o-notch fa-spin spinner"></i> |
| </form> |
| <div class="book-search-spinner hidden"></div> |
| <ul id="book-search-results"></ul> |
| </div> |
| </div> |
| </div> |
| </nav> |
| <div class="navbar-clearfix"></div> |
| </header> |
| |
| |
| <main class="flex"> |
| <section class="container book-page"> |
| |
| <article class="markdown"> |
| <h1> |
| <a href="/2017/04/26/apache-flink-1.2.1-released/">Apache Flink 1.2.1 Released</a> |
| </h1> |
| |
| |
| |
| April 26, 2017 - |
| |
| |
| |
| |
| |
| <p><p>The Apache Flink community released the first bugfix version of the Apache Flink 1.2 series.</p> |
| <p>This release includes many critical fixes for Flink 1.2.0. The list below includes a detailed list of all fixes.</p> |
| <p>We highly recommend all users to upgrade to Flink 1.2.1.</p> |
| <p>Please note that there are two unresolved major issues in Flink 1.2.1 and 1.2.0:</p> |
| <ul> |
| <li><a href="https://issues.apache.org/jira/browse/FLINK-6353">FLINK-6353</a> Restoring using CheckpointedRestoring does not work from 1.2 to 1.2</li> |
| <li><a href="https://issues.apache.org/jira/browse/FLINK-6188">FLINK-6188</a> Some setParallelism() methods can’t cope with default parallelism</li> |
| </ul> |
| <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-xml" data-lang="xml"><span class="line"><span class="cl"><span class="nt"><dependency></span> |
| </span></span><span class="line"><span class="cl"> <span class="nt"><groupId></span>org.apache.flink<span class="nt"></groupId></span> |
| </span></span><span class="line"><span class="cl"> <span class="nt"><artifactId></span>flink-java<span class="nt"></artifactId></span> |
| </span></span><span class="line"><span class="cl"> <span class="nt"><version></span>1.2.1<span class="nt"></version></span> |
| </span></span><span class="line"><span class="cl"><span class="nt"></dependency></span> |
| </span></span><span class="line"><span class="cl"><span class="nt"><dependency></span> |
| </span></span><span class="line"><span class="cl"> <span class="nt"><groupId></span>org.apache.flink<span class="nt"></groupId></span> |
| </span></span><span class="line"><span class="cl"> <span class="nt"><artifactId></span>flink-streaming-java_2.10<span class="nt"></artifactId></span> |
| </span></span><span class="line"><span class="cl"> <span class="nt"><version></span>1.2.1<span class="nt"></version></span> |
| </span></span><span class="line"><span class="cl"><span class="nt"></dependency></span> |
| </span></span><span class="line"><span class="cl"><span class="nt"><dependency></span> |
| </span></span><span class="line"><span class="cl"> <span class="nt"><groupId></span>org.apache.flink<span class="nt"></groupId></span> |
| </span></span><span class="line"><span class="cl"> <span class="nt"><artifactId></span>flink-clients_2.10<span class="nt"></artifactId></span> |
| </span></span><span class="line"><span class="cl"> <span class="nt"><version></span>1.2.1<span class="nt"></version></span> |
| </span></span><span class="line"><span class="cl"><span class="nt"></dependency></span> |
| </span></span></code></pre></div><p>You can find the binaries on the updated <a href="http://flink.apache.org/downloads.html">Downloads page</a>.</p> |
| <h2>Release Notes - Flink - Version 1.2.1</h2> |
| <h3> Sub-task |
| </h3> |
| <ul> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5546'>FLINK-5546</a>] - java.io.tmpdir setted as project build directory in surefire plugin |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5640'>FLINK-5640</a>] - configure the explicit Unit Test file suffix |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5723'>FLINK-5723</a>] - Use "Used" instead of "Initial" to make taskmanager tag more readable |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5825'>FLINK-5825</a>] - In yarn mode, a small pic can not be loaded |
| </li> |
| </ul> |
| <h3> Bug |
| </h3> |
| <ul> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-4813'>FLINK-4813</a>] - Having flink-test-utils as a dependency outside Flink fails the build |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-4848'>FLINK-4848</a>] - keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5628'>FLINK-5628</a>] - CheckpointStatsTracker implements Serializable but isn't |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5644'>FLINK-5644</a>] - Task#lastCheckpointSize metric broken |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5650'>FLINK-5650</a>] - Flink-python tests executing cost too long time |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5652'>FLINK-5652</a>] - Memory leak in AsyncDataStream |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5669'>FLINK-5669</a>] - flink-streaming-contrib DataStreamUtils.collect in local environment mode fails when offline |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5678'>FLINK-5678</a>] - User-defined TableFunctions do not support all types of parameters |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5699'>FLINK-5699</a>] - Cancel with savepoint fails with a NPE if savepoint target directory not set |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5701'>FLINK-5701</a>] - FlinkKafkaProducer should check asyncException on checkpoints |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5708'>FLINK-5708</a>] - we should remove duplicated configuration options |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5732'>FLINK-5732</a>] - Java quick start mvn command line is incorrect |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5749'>FLINK-5749</a>] - unset HADOOP_HOME and HADOOP_CONF_DIR to avoid env in build machine failing the UT and IT |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5751'>FLINK-5751</a>] - 404 in documentation |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5771'>FLINK-5771</a>] - DelimitedInputFormat does not correctly handle multi-byte delimiters |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5773'>FLINK-5773</a>] - Cannot cast scala.util.Failure to org.apache.flink.runtime.messages.Acknowledge |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5806'>FLINK-5806</a>] - TaskExecutionState toString format have wrong key |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5814'>FLINK-5814</a>] - flink-dist creates wrong symlink when not used with cleaned before |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5817'>FLINK-5817</a>] - Fix test concurrent execution failure by test dir conflicts. |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5828'>FLINK-5828</a>] - BlobServer create cache dir has concurrency safety problem |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5885'>FLINK-5885</a>] - Java code snippet instead of scala in documentation |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5907'>FLINK-5907</a>] - RowCsvInputFormat bug on parsing tsv |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5934'>FLINK-5934</a>] - Scheduler in ExecutionGraph null if failure happens in ExecutionGraph.restoreLatestCheckpointedState |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5940'>FLINK-5940</a>] - ZooKeeperCompletedCheckpointStore cannot handle broken state handles |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5942'>FLINK-5942</a>] - Harden ZooKeeperStateHandleStore to deal with corrupted data |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5945'>FLINK-5945</a>] - Close function in OuterJoinOperatorBase#executeOnCollections |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5949'>FLINK-5949</a>] - Flink on YARN checks for Kerberos credentials for non-Kerberos authentication methods |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5962'>FLINK-5962</a>] - Cancel checkpoint canceller tasks in CheckpointCoordinator |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5965'>FLINK-5965</a>] - Typo on DropWizard wrappers |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5972'>FLINK-5972</a>] - Don't allow shrinking merging windows |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5985'>FLINK-5985</a>] - Flink treats every task as stateful (making topology changes impossible) |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6000'>FLINK-6000</a>] - Can not start HA cluster with start-cluster.sh |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6001'>FLINK-6001</a>] - NPE on TumblingEventTimeWindows with ContinuousEventTimeTrigger and allowedLateness |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6002'>FLINK-6002</a>] - Documentation: 'MacOS X' under 'Download and Start Flink' in Quickstart page is not rendered correctly |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6006'>FLINK-6006</a>] - Kafka Consumer can lose state if queried partition list is incomplete on restore |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6025'>FLINK-6025</a>] - User code ClassLoader not used when KryoSerializer fallbacks to serialization for copying |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6051'>FLINK-6051</a>] - Wrong metric scope names in documentation |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6084'>FLINK-6084</a>] - Cassandra connector does not declare all dependencies |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6133'>FLINK-6133</a>] - fix build status in README.md |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6170'>FLINK-6170</a>] - Some checkpoint metrics rely on latest stat snapshot |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6181'>FLINK-6181</a>] - Zookeeper scripts use invalid regex |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6182'>FLINK-6182</a>] - Fix possible NPE in SourceStreamTask |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6183'>FLINK-6183</a>] - TaskMetricGroup may not be cleanup when Task.run() is never called or exits early |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6184'>FLINK-6184</a>] - Buffer metrics can cause NPE |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6203'>FLINK-6203</a>] - DataSet Transformations |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6207'>FLINK-6207</a>] - Duplicate type serializers for async snapshots of CopyOnWriteStateTable |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6308'>FLINK-6308</a>] - Task managers are not attaching to job manager on macos |
| </li> |
| </ul> |
| <h3> Improvement |
| </h3> |
| <ul> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-4326'>FLINK-4326</a>] - Flink start-up scripts should optionally start services on the foreground |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5217'>FLINK-5217</a>] - Deprecated interface Checkpointed make clear suggestion |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5331'>FLINK-5331</a>] - PythonPlanBinderTest idling extremely long |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5581'>FLINK-5581</a>] - Improve Kerberos security related documentation |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5639'>FLINK-5639</a>] - Clarify License implications of RabbitMQ Connector |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5680'>FLINK-5680</a>] - Document env.ssh.opts |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5681'>FLINK-5681</a>] - Make ReaperThread for SafetyNetCloseableRegistry a singleton |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5702'>FLINK-5702</a>] - Kafka Producer docs should warn if using setLogFailuresOnly, at-least-once is compromised |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5705'>FLINK-5705</a>] - webmonitor's request/response use UTF-8 explicitly |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5713'>FLINK-5713</a>] - Protect against NPE in WindowOperator window cleanup |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5721'>FLINK-5721</a>] - Add FoldingState to State Documentation |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5800'>FLINK-5800</a>] - Make sure that the CheckpointStreamFactory is instantiated once per operator only |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5805'>FLINK-5805</a>] - improve docs for ProcessFunction |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5807'>FLINK-5807</a>] - improved wording for doc home page |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5837'>FLINK-5837</a>] - improve readability of the queryable state docs |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5876'>FLINK-5876</a>] - Mention Scala type fallacies for queryable state client serializers |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5877'>FLINK-5877</a>] - Fix Scala snippet in Async I/O API doc |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5894'>FLINK-5894</a>] - HA docs are misleading re: state backends |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5895'>FLINK-5895</a>] - Reduce logging aggressiveness of FileSystemSafetyNet |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5938'>FLINK-5938</a>] - Replace ExecutionContext by Executor in Scheduler |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6212'>FLINK-6212</a>] - Missing reference to flink-avro dependency |
| </li> |
| </ul> |
| <h3> New Feature |
| </h3> |
| <ul> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6139'>FLINK-6139</a>] - Documentation for building / preparing Flink for MapR |
| </li> |
| </ul> |
| <h3> Task |
| </h3> |
| <ul> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-2883'>FLINK-2883</a>] - Add documentation to forbid key-modifying ReduceFunction |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-3903'>FLINK-3903</a>] - Homebrew Installation |
| </li> |
| </ul> |
| </p> |
| </article> |
| |
| |
| |
| |
| |
| |
| |
| <div class="edit-this-page"> |
| <p> |
| <a href="https://cwiki.apache.org/confluence/display/FLINK/Flink+Translation+Specifications">Want to contribute translation?</a> |
| </p> |
| <p> |
| <a href="//github.com/apache/flink-web/edit/asf-site/docs/content/posts/2017-04-26-release-1.2.1.md"> |
| Edit This Page<i class="fa fa-edit fa-fw"></i> |
| </a> |
| </p> |
| </div> |
| |
| </section> |
| |
| <aside class="book-toc"> |
| |
| |
| |
| <nav id="TableOfContents"><h3>On This Page <a href="javascript:void(0)" class="toc" onclick="collapseToc()"><i class="fa fa-times" aria-hidden="true"></i></a></h3></nav> |
| |
| |
| </aside> |
| <aside class="expand-toc hidden"> |
| <a class="toc" onclick="expandToc()" href="javascript:void(0)"> |
| <i class="fa fa-bars" aria-hidden="true"></i> |
| </a> |
| </aside> |
| |
| </main> |
| |
| <footer> |
| |
| |
| |
| <div class="separator"></div> |
| <div class="panels"> |
| <div class="wrapper"> |
| <div class="panel"> |
| <ul> |
| <li> |
| <a href="https://flink-packages.org/">flink-packages.org</a> |
| </li> |
| <li> |
| <a href="https://www.apache.org/">Apache Software Foundation</a> |
| </li> |
| <li> |
| <a href="https://www.apache.org/licenses/">License</a> |
| </li> |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| <li> |
| <a href="/zh/"> |
| <i class="fa fa-globe" aria-hidden="true"></i> 中文版 |
| </a> |
| </li> |
| |
| |
| |
| </ul> |
| </div> |
| <div class="panel"> |
| <ul> |
| <li> |
| <a href="/what-is-flink/security">Security</a--> |
| </li> |
| <li> |
| <a href="https://www.apache.org/foundation/sponsorship.html">Donate</a> |
| </li> |
| <li> |
| <a href="https://www.apache.org/foundation/thanks.html">Thanks</a> |
| </li> |
| </ul> |
| </div> |
| <div class="panel icons"> |
| <div> |
| <a href="/posts"> |
| <div class="icon flink-blog-icon"></div> |
| <span>Flink blog</span> |
| </a> |
| </div> |
| <div> |
| <a href="https://github.com/apache/flink"> |
| <div class="icon flink-github-icon"></div> |
| <span>Github</span> |
| </a> |
| </div> |
| <div> |
| <a href="https://twitter.com/apacheflink"> |
| <div class="icon flink-twitter-icon"></div> |
| <span>Twitter</span> |
| </a> |
| </div> |
| </div> |
| </div> |
| </div> |
| |
| <hr/> |
| |
| <div class="container disclaimer"> |
| <p>The contents of this website are © 2024 Apache Software Foundation under the terms of the Apache License v2. Apache Flink, Flink, and the Flink logo are either registered trademarks or trademarks of The Apache Software Foundation in the United States and other countries.</p> |
| </div> |
| |
| |
| |
| </footer> |
| |
| </body> |
| </html> |
| |
| |
| |
| |
| |
| |
