| |
| <!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/08/05/apache-flink-1.3.2-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 second bugfix version of the Apache Flink 1.3 series. |
| This release includes more than 60 fixes and minor improvements for Flink 1.3.1. The list below includes a detailed list of all fixes. |
| We highly recommend all users to upgrade to Flink 1.3.2. |
| Important Notice: A user reported a bug in the FlinkKafkaConsumer (FLINK-7143) that is causing incorrect partition assignment in large Kafka deployments in the presence of inconsistent broker metadata."> |
| <meta name="theme-color" content="#FFFFFF"><meta property="og:title" content="Apache Flink 1.3.2 Released" /> |
| <meta property="og:description" content="The Apache Flink community released the second bugfix version of the Apache Flink 1.3 series. |
| This release includes more than 60 fixes and minor improvements for Flink 1.3.1. The list below includes a detailed list of all fixes. |
| We highly recommend all users to upgrade to Flink 1.3.2. |
| Important Notice: A user reported a bug in the FlinkKafkaConsumer (FLINK-7143) that is causing incorrect partition assignment in large Kafka deployments in the presence of inconsistent broker metadata." /> |
| <meta property="og:type" content="article" /> |
| <meta property="og:url" content="https://flink.apache.org/2017/08/05/apache-flink-1.3.2-released/" /><meta property="article:section" content="posts" /> |
| <meta property="article:published_time" content="2017-08-05T09:00:00+00:00" /> |
| <meta property="article:modified_time" content="2017-08-05T09:00:00+00:00" /> |
| <title>Apache Flink 1.3.2 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/08/05/apache-flink-1.3.2-released/">Apache Flink 1.3.2 Released</a> |
| </h1> |
| |
| |
| |
| August 5, 2017 - |
| |
| |
| |
| |
| |
| <p><p>The Apache Flink community released the second bugfix version of the Apache Flink 1.3 series.</p> |
| <p>This release includes more than 60 fixes and minor improvements for Flink 1.3.1. The list below includes a detailed list of all fixes.</p> |
| <p>We highly recommend all users to upgrade to Flink 1.3.2.</p> |
| <div class="alert alert-warning"> |
| Important Notice: |
| <p>A user reported a bug in the FlinkKafkaConsumer |
| (<a href="https://issues.apache.org/jira/browse/FLINK-7143">FLINK-7143</a>) that is causing |
| incorrect partition assignment in large Kafka deployments in the presence of inconsistent broker |
| metadata. In that case multiple parallel instances of the FlinkKafkaConsumer may read from the |
| same topic partition, leading to data duplication. In Flink 1.3.2 this bug is fixed but incorrect |
| assignments from Flink 1.3.0 and 1.3.1 cannot be automatically fixed by upgrading to Flink 1.3.2 |
| via a savepoint because the upgraded version would resume the wrong partition assignment from the |
| savepoint. If you believe you are affected by this bug (seeing messages from some partitions |
| duplicated) please refer to the JIRA issue for an upgrade path that works around that.</p> |
| <p>Before attempting the more elaborate upgrade path, we would suggest to check if you are |
| actually affected by this bug. We did not manage to reproduce it in various testing clusters and |
| according to the reporting user, it only appeared in rare cases on their very large setup. This |
| leads us to believe that most likely only a minority of setups would be affected by this bug.</p> |
| </div> |
| <p>Notable changes:</p> |
| <ul> |
| <li>The default Kafka version for Flink Kafka Consumer 0.10 was bumped from 0.10.0.1 to 0.10.2.1.</li> |
| <li>Some default values for configurations of AWS API call behaviors in the Flink Kinesis Consumer |
| were adapted for better default consumption performance: 1) <code>SHARD_GETRECORDS_MAX</code> default changed |
| to 10,000, and 2) <code>SHARD_GETRECORDS_INTERVAL_MILLIS</code> default changed to 200ms.</li> |
| </ul> |
| <p>Updated Maven dependencies:</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.3.2<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.3.2<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.3.2<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> |
| <p>List of resolved issues:</p> |
| <h2> Sub-task |
| </h2> |
| <ul> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6665'>FLINK-6665</a>] - Pass a ScheduledExecutorService to the RestartStrategy |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6667'>FLINK-6667</a>] - Pass a callback type to the RestartStrategy, rather than the full ExecutionGraph |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6680'>FLINK-6680</a>] - App & Flink migration guide: updates for the 1.3 release |
| </li> |
| </ul> |
| <h2> Bug |
| </h2> |
| <ul> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-5488'>FLINK-5488</a>] - yarnClient should be closed in AbstractYarnClusterDescriptor for error conditions |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6376'>FLINK-6376</a>] - when deploy flink cluster on the yarn, it is lack of hdfs delegation token. |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6541'>FLINK-6541</a>] - Jar upload directory not created |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6654'>FLINK-6654</a>] - missing maven dependency on "flink-shaded-hadoop2-uber" in flink-dist |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6655'>FLINK-6655</a>] - Misleading error message when HistoryServer path is empty |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6742'>FLINK-6742</a>] - Improve error message when savepoint migration fails due to task removal |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6774'>FLINK-6774</a>] - build-helper-maven-plugin version not set |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6806'>FLINK-6806</a>] - rocksdb is not listed as state backend in doc |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6843'>FLINK-6843</a>] - ClientConnectionTest fails on travis |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6867'>FLINK-6867</a>] - Elasticsearch 1.x ITCase still instable due to embedded node instability |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6918'>FLINK-6918</a>] - Failing tests: ChainLengthDecreaseTest and ChainLengthIncreaseTest |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6945'>FLINK-6945</a>] - TaskCancelAsyncProducerConsumerITCase.testCancelAsyncProducerAndConsumer instable test case |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6964'>FLINK-6964</a>] - Fix recovery for incremental checkpoints in StandaloneCompletedCheckpointStore |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6965'>FLINK-6965</a>] - Avro is missing snappy dependency |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6987'>FLINK-6987</a>] - TextInputFormatTest fails when run in path containing spaces |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6996'>FLINK-6996</a>] - FlinkKafkaProducer010 doesn't guarantee at-least-once semantic |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7005'>FLINK-7005</a>] - Optimization steps are missing for nested registered tables |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7011'>FLINK-7011</a>] - Instable Kafka testStartFromKafkaCommitOffsets failures on Travis |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7025'>FLINK-7025</a>] - Using NullByteKeySelector for Unbounded ProcTime NonPartitioned Over |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7034'>FLINK-7034</a>] - GraphiteReporter cannot recover from lost connection |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7038'>FLINK-7038</a>] - Several misused "KeyedDataStream" term in docs and Javadocs |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7041'>FLINK-7041</a>] - Deserialize StateBackend from JobCheckpointingSettings with user classloader |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7132'>FLINK-7132</a>] - Fix BulkIteration parallelism |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7133'>FLINK-7133</a>] - Fix Elasticsearch version interference |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7137'>FLINK-7137</a>] - Flink table API defaults top level fields as nullable and all nested fields within CompositeType as non-nullable |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7143'>FLINK-7143</a>] - Partition assignment for Kafka consumer is not stable |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7154'>FLINK-7154</a>] - Missing call to build CsvTableSource example |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7158'>FLINK-7158</a>] - Wrong test jar dependency in flink-clients |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7177'>FLINK-7177</a>] - DataSetAggregateWithNullValuesRule fails creating null literal for non-nullable type |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7178'>FLINK-7178</a>] - Datadog Metric Reporter Jar is Lacking Dependencies |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7180'>FLINK-7180</a>] - CoGroupStream perform checkpoint failed |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7195'>FLINK-7195</a>] - FlinkKafkaConsumer should not respect fetched partitions to filter restored partition states |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7216'>FLINK-7216</a>] - ExecutionGraph can perform concurrent global restarts to scheduling |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7225'>FLINK-7225</a>] - Cutoff exception message in StateDescriptor |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7226'>FLINK-7226</a>] - REST responses contain invalid content-encoding header |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7231'>FLINK-7231</a>] - SlotSharingGroups are not always released in time for new restarts |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7234'>FLINK-7234</a>] - Fix CombineHint documentation |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7241'>FLINK-7241</a>] - Fix YARN high availability documentation |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7255'>FLINK-7255</a>] - ListStateDescriptor example uses wrong constructor |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7258'>FLINK-7258</a>] - IllegalArgumentException in Netty bootstrap with large memory state segment size |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7266'>FLINK-7266</a>] - Don't attempt to delete parent directory on S3 |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7268'>FLINK-7268</a>] - Zookeeper Checkpoint Store interacting with Incremental State Handles can lead to loss of handles |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7281'>FLINK-7281</a>] - Fix various issues in (Maven) release infrastructure |
| </li> |
| </ul> |
| <h2> Improvement |
| </h2> |
| <ul> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6365'>FLINK-6365</a>] - Adapt default values of the Kinesis connector |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6575'>FLINK-6575</a>] - Disable all tests on Windows that use HDFS |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6682'>FLINK-6682</a>] - Improve error message in case parallelism exceeds maxParallelism |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6789'>FLINK-6789</a>] - Remove duplicated test utility reducer in optimizer |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6874'>FLINK-6874</a>] - Static and transient fields ignored for POJOs |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6898'>FLINK-6898</a>] - Limit size of operator component in metric name |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6937'>FLINK-6937</a>] - Fix link markdown in Production Readiness Checklist doc |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6940'>FLINK-6940</a>] - Clarify the effect of configuring per-job state backend |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-6998'>FLINK-6998</a>] - Kafka connector needs to expose metrics for failed/successful offset commits in the Kafka Consumer callback |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7004'>FLINK-7004</a>] - Switch to Travis Trusty image |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7032'>FLINK-7032</a>] - Intellij is constantly changing language level of sub projects back to 1.6 |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7069'>FLINK-7069</a>] - Catch exceptions for each reporter separately |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7149'>FLINK-7149</a>] - Add checkpoint ID to 'sendValues()' in GenericWriteAheadSink |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7164'>FLINK-7164</a>] - Extend integration tests for (externalised) checkpoints, checkpoint store |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7174'>FLINK-7174</a>] - Bump dependency of Kafka 0.10.x to the latest one |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7211'>FLINK-7211</a>] - Exclude Gelly javadoc jar from release |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7224'>FLINK-7224</a>] - Incorrect Javadoc description in all Kafka consumer versions |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7228'>FLINK-7228</a>] - Harden HistoryServerStaticFileHandlerTest |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7233'>FLINK-7233</a>] - TaskManagerHeapSizeCalculationJavaBashTest failed on Travis |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7287'>FLINK-7287</a>] - test instability in Kafka010ITCase.testCommitOffsetsToKafka |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-7290'>FLINK-7290</a>] - Make release scripts modular |
| </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-08-05-release-1.3.2.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> |
| |
| |
| |
| |
| |
| |
