| |
| <!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/2016/12/21/apache-flink-1.1.4-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 next bugfix version of the Apache Flink 1.1 series. |
| This release includes major robustness improvements for checkpoint cleanup on failures and consumption of intermediate streams. We highly recommend all users to upgrade to Flink 1.1.4. |
| <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-java</artifactId> <version>1.1.4</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-streaming-java_2.10</artifactId> <version>1.1.4</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-clients_2.10</artifactId> <version>1.1.4</version> </dependency> You can find the binaries on the updated Downloads page. |
| Note for RocksDB Backend Users # We updated Flink’s RocksDB dependency version from 4."> |
| <meta name="theme-color" content="#FFFFFF"><meta property="og:title" content="Apache Flink 1.1.4 Released" /> |
| <meta property="og:description" content="The Apache Flink community released the next bugfix version of the Apache Flink 1.1 series. |
| This release includes major robustness improvements for checkpoint cleanup on failures and consumption of intermediate streams. We highly recommend all users to upgrade to Flink 1.1.4. |
| <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-java</artifactId> <version>1.1.4</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-streaming-java_2.10</artifactId> <version>1.1.4</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-clients_2.10</artifactId> <version>1.1.4</version> </dependency> You can find the binaries on the updated Downloads page. |
| Note for RocksDB Backend Users # We updated Flink’s RocksDB dependency version from 4." /> |
| <meta property="og:type" content="article" /> |
| <meta property="og:url" content="https://flink.apache.org/2016/12/21/apache-flink-1.1.4-released/" /><meta property="article:section" content="posts" /> |
| <meta property="article:published_time" content="2016-12-21T09:00:00+00:00" /> |
| <meta property="article:modified_time" content="2016-12-21T09:00:00+00:00" /> |
| <title>Apache Flink 1.1.4 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="/2016/12/21/apache-flink-1.1.4-released/">Apache Flink 1.1.4 Released</a> |
| </h1> |
| |
| |
| |
| December 21, 2016 - |
| |
| |
| |
| |
| |
| <p><p>The Apache Flink community released the next bugfix version of the Apache Flink 1.1 series.</p> |
| <p>This release includes major robustness improvements for checkpoint cleanup on failures and consumption of intermediate streams. We highly recommend all users to upgrade to Flink 1.1.4.</p> |
| <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.1.4<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.1.4<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.1.4<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 id="note-for-rocksdb-backend-users"> |
| Note for RocksDB Backend Users |
| <a class="anchor" href="#note-for-rocksdb-backend-users">#</a> |
| </h2> |
| <p>We updated Flink’s RocksDB dependency version from <code>4.5.1</code> to <code>4.11.2</code>. Between these versions some of RocksDB’s internal configuration defaults changed that would affect the memory footprint of running Flink with RocksDB. Therefore, we manually reset them to the previous defaults. If you want to run with the new Rocks 4.11.2 defaults, you can do this via:</p> |
| <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-java" data-lang="java"><span class="line"><span class="cl"><span class="n">RocksDBStateBackend</span><span class="w"> </span><span class="n">backend</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="k">new</span><span class="w"> </span><span class="n">RocksDBStateBackend</span><span class="p">(</span><span class="s">"..."</span><span class="p">);</span><span class="w"> |
| </span></span></span><span class="line"><span class="cl"><span class="w"></span><span class="c1">// Use the new default options. Otherwise, the default for RocksDB 4.5.1</span><span class="w"> |
| </span></span></span><span class="line"><span class="cl"><span class="w"></span><span class="c1">// `PredefinedOptions.DEFAULT_ROCKS_4_5_1` will be used.</span><span class="w"> |
| </span></span></span><span class="line"><span class="cl"><span class="w"></span><span class="n">backend</span><span class="p">.</span><span class="na">setPredefinedOptions</span><span class="p">(</span><span class="n">PredefinedOptions</span><span class="p">.</span><span class="na">DEFAULT</span><span class="p">);</span><span class="w"> |
| </span></span></span></code></pre></div><h2 id="release-notes---flink---version-114"> |
| Release Notes - Flink - Version 1.1.4 |
| <a class="anchor" href="#release-notes---flink---version-114">#</a> |
| </h2> |
| <h3 id="sub-task"> |
| Sub-task |
| <a class="anchor" href="#sub-task">#</a> |
| </h3> |
| <ul> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-4510'>FLINK-4510</a>] - Always create CheckpointCoordinator |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-4984'>FLINK-4984</a>] - Add Cancellation Barriers to BarrierTracker and BarrierBuffer |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-4985'>FLINK-4985</a>] - Report Declined/Canceled Checkpoints to Checkpoint Coordinator |
| </li> |
| </ul> |
| <h3 id="bug"> |
| Bug |
| <a class="anchor" href="#bug">#</a> |
| </h3> |
| <ul> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-2662'>FLINK-2662</a>] - CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators." |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-3680'>FLINK-3680</a>] - Remove or improve (not set) text in the Job Plan UI |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-3813'>FLINK-3813</a>] - YARNSessionFIFOITCase.testDetachedMode failed on Travis |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-4108'>FLINK-4108</a>] - NPE in Row.productArity |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-4506'>FLINK-4506</a>] - CsvOutputFormat defaults allowNullValues to false, even though doc and declaration says true |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-4581'>FLINK-4581</a>] - Table API throws "No suitable driver found for jdbc:calcite" |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-4586'>FLINK-4586</a>] - NumberSequenceIterator and Accumulator threading issue |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-4619'>FLINK-4619</a>] - JobManager does not answer to client when restore from savepoint fails |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-4727'>FLINK-4727</a>] - Kafka 0.9 Consumer should also checkpoint auto retrieved offsets even when no data is read |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-4862'>FLINK-4862</a>] - NPE on EventTimeSessionWindows with ContinuousEventTimeTrigger |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-4932'>FLINK-4932</a>] - Don't let ExecutionGraph fail when in state Restarting |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-4933'>FLINK-4933</a>] - ExecutionGraph.scheduleOrUpdateConsumers can fail the ExecutionGraph |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-4977'>FLINK-4977</a>] - Enum serialization does not work in all cases |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-4991'>FLINK-4991</a>] - TestTask hangs in testWatchDogInterruptsTask |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-4998'>FLINK-4998</a>] - ResourceManager fails when num task slots > Yarn vcores |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5013'>FLINK-5013</a>] - Flink Kinesis connector doesn't work on old EMR versions |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5028'>FLINK-5028</a>] - Stream Tasks must not go through clean shutdown logic on cancellation |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5038'>FLINK-5038</a>] - Errors in the "cancelTask" method prevent closeables from being closed early |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5039'>FLINK-5039</a>] - Avro GenericRecord support is broken |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5040'>FLINK-5040</a>] - Set correct input channel types with eager scheduling |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5050'>FLINK-5050</a>] - JSON.org license is CatX |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5057'>FLINK-5057</a>] - Cancellation timeouts are picked from wrong config |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5058'>FLINK-5058</a>] - taskManagerMemory attribute set wrong value in FlinkShell |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5063'>FLINK-5063</a>] - State handles are not properly cleaned up for declined or expired checkpoints |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5073'>FLINK-5073</a>] - ZooKeeperCompleteCheckpointStore executes blocking delete operation in ZooKeeper client thread |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5075'>FLINK-5075</a>] - Kinesis consumer incorrectly determines shards as newly discovered when tested against Kinesalite |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5082'>FLINK-5082</a>] - Pull ExecutionService lifecycle management out of the JobManager |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5085'>FLINK-5085</a>] - Execute CheckpointCoodinator's state discard calls asynchronously |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5114'>FLINK-5114</a>] - PartitionState update with finished execution fails |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5142'>FLINK-5142</a>] - Resource leak in CheckpointCoordinator |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5149'>FLINK-5149</a>] - ContinuousEventTimeTrigger doesn't fire at the end of the window |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5154'>FLINK-5154</a>] - Duplicate TypeSerializer when writing RocksDB Snapshot |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5158'>FLINK-5158</a>] - Handle ZooKeeperCompletedCheckpointStore exceptions in CheckpointCoordinator |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5172'>FLINK-5172</a>] - In RocksDBStateBackend, set flink-core and flink-streaming-java to "provided" |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5173'>FLINK-5173</a>] - Upgrade RocksDB dependency |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5184'>FLINK-5184</a>] - Error result of compareSerialized in RowComparator class |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5193'>FLINK-5193</a>] - Recovering all jobs fails completely if a single recovery fails |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5197'>FLINK-5197</a>] - Late JobStatusChanged messages can interfere with running jobs |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5214'>FLINK-5214</a>] - Clean up checkpoint files when failing checkpoint operation on TM |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5215'>FLINK-5215</a>] - Close checkpoint streams upon cancellation |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5216'>FLINK-5216</a>] - CheckpointCoordinator's 'minPauseBetweenCheckpoints' refers to checkpoint start rather then checkpoint completion |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5218'>FLINK-5218</a>] - Eagerly close checkpoint streams on cancellation |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5228'>FLINK-5228</a>] - LocalInputChannel re-trigger request and release deadlock |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5229'>FLINK-5229</a>] - Cleanup StreamTaskStates if a checkpoint operation of a subsequent operator fails |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5246'>FLINK-5246</a>] - Don't discard unknown checkpoint messages in the CheckpointCoordinator |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5248'>FLINK-5248</a>] - SavepointITCase doesn't catch savepoint restore failure |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5274'>FLINK-5274</a>] - LocalInputChannel throws NPE if partition reader is released |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5275'>FLINK-5275</a>] - InputChanelDeploymentDescriptors throws misleading Exception if producer failed/cancelled |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5276'>FLINK-5276</a>] - ExecutionVertex archiving can throw NPE with many previous attempts |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5285'>FLINK-5285</a>] - CancelCheckpointMarker flood when using at least once mode |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5326'>FLINK-5326</a>] - IllegalStateException: Bug in Netty consumer logic: reader queue got notified by partition about available data, but none was available |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5352'>FLINK-5352</a>] - Restore RocksDB 1.1.3 memory behavior |
| </li> |
| </ul> |
| <h3 id="improvement"> |
| Improvement |
| <a class="anchor" href="#improvement">#</a> |
| </h3> |
| <ul> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-3347'>FLINK-3347</a>] - TaskManager (or its ActorSystem) need to restart in case they notice quarantine |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-3787'>FLINK-3787</a>] - Yarn client does not report unfulfillable container constraints |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-4445'>FLINK-4445</a>] - Ignore unmatched state when restoring from savepoint |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-4715'>FLINK-4715</a>] - TaskManager should commit suicide after cancellation failure |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-4894'>FLINK-4894</a>] - Don't block on buffer request after broadcastEvent |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-4975'>FLINK-4975</a>] - Add a limit for how much data may be buffered during checkpoint alignment |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-4996'>FLINK-4996</a>] - Make CrossHint @Public |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5046'>FLINK-5046</a>] - Avoid redundant serialization when creating the TaskDeploymentDescriptor |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5123'>FLINK-5123</a>] - Add description how to do proper shading to Flink docs. |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5169'>FLINK-5169</a>] - Make consumption of input channels fair |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5192'>FLINK-5192</a>] - Provide better log config templates |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5194'>FLINK-5194</a>] - Log heartbeats on TRACE level |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5196'>FLINK-5196</a>] - Don't log InputChannelDescriptor |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5198'>FLINK-5198</a>] - Overwrite TaskState toString |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5199'>FLINK-5199</a>] - Improve logging of submitted job graph actions in HA case |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5201'>FLINK-5201</a>] - Promote loaded config properties to INFO |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5207'>FLINK-5207</a>] - Decrease HadoopFileSystem logging |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5249'>FLINK-5249</a>] - description of datastream rescaling doesn't match the figure |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5259'>FLINK-5259</a>] - wrong execution environment in retry delays example |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5278'>FLINK-5278</a>] - Improve Task and checkpoint logging |
| </li> |
| </ul> |
| <h3 id="new-feature"> |
| New Feature |
| <a class="anchor" href="#new-feature">#</a> |
| </h3> |
| <ul> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-4976'>FLINK-4976</a>] - Add a way to abort in flight checkpoints |
| </li> |
| </ul> |
| <h3 id="task"> |
| Task |
| <a class="anchor" href="#task">#</a> |
| </h3> |
| <ul> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-4778'>FLINK-4778</a>] - Update program example in /docs/setup/cli.md due to the change in FLINK-2021 |
| </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/2016-12-21-release-1.1.4.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> |
| <ul> |
| <li> |
| <ul> |
| <li><a href="#note-for-rocksdb-backend-users">Note for RocksDB Backend Users</a></li> |
| <li><a href="#release-notes---flink---version-114">Release Notes - Flink - Version 1.1.4</a> |
| <ul> |
| <li><a href="#sub-task">Sub-task</a></li> |
| <li><a href="#bug">Bug</a></li> |
| <li><a href="#improvement">Improvement</a></li> |
| <li><a href="#new-feature">New Feature</a></li> |
| <li><a href="#task">Task</a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </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> |
| |
| |
| |
| |
| |
| |
