This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/flink-web.git
The following commit(s) were added to refs/heads/asf-site by this push: new c9d07f1 Add Flink release 1.14.3 c9d07f1 is described below commit c9d07f112643f7670f65550818e0785e07c52024 Author: martijnvisser <mart...@2symbols.com> AuthorDate: Wed Jan 12 19:44:49 2022 +0100 Add Flink release 1.14.3 --- _config.yml | 28 +-- _posts/2022-01-17-release-1.14.3.md | 331 ++++++++++++++++++++++++++++++++++++ q/gradle-quickstart.sh | 2 +- q/quickstart-scala.sh | 2 +- q/quickstart.sh | 2 +- q/sbt-quickstart.sh | 2 +- 6 files changed, 351 insertions(+), 16 deletions(-) diff --git a/_config.yml b/_config.yml index 96224b6..41464de 100644 --- a/_config.yml +++ b/_config.yml @@ -9,7 +9,7 @@ url: https://flink.apache.org DOCS_BASE_URL: https://nightlies.apache.org/flink/ -FLINK_VERSION_STABLE: 1.14.2 +FLINK_VERSION_STABLE: 1.14.3 FLINK_VERSION_STABLE_SHORT: "1.14" FLINK_ISSUES_URL: https://issues.apache.org/jira/browse/FLINK @@ -64,23 +64,23 @@ flink_releases: - version_short: "1.14" binary_release: - name: "Apache Flink 1.14.2" + name: "Apache Flink 1.14.3" scala_211: id: "1142-download_211" - url: "https://www.apache.org/dyn/closer.lua/flink/flink-1.14.2/flink-1.14.2-bin-scala_2.11.tgz" - asc_url: "https://downloads.apache.org/flink/flink-1.14.2/flink-1.14.2-bin-scala_2.11.tgz.asc" - sha512_url: "https://downloads.apache.org/flink/flink-1.14.2/flink-1.14.2-bin-scala_2.11.tgz.sha512" + url: "https://www.apache.org/dyn/closer.lua/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.11.tgz" + asc_url: "https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.11.tgz.asc" + sha512_url: "https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.11.tgz.sha512" scala_212: id: "1142-download_212" - url: "https://www.apache.org/dyn/closer.lua/flink/flink-1.14.2/flink-1.14.2-bin-scala_2.12.tgz" - asc_url: "https://downloads.apache.org/flink/flink-1.14.2/flink-1.14.2-bin-scala_2.12.tgz.asc" - sha512_url: "https://downloads.apache.org/flink/flink-1.14.2/flink-1.14.2-bin-scala_2.12.tgz.sha512" + url: "https://www.apache.org/dyn/closer.lua/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.12.tgz" + asc_url: "https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.12.tgz.asc" + sha512_url: "https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.12.tgz.sha512" source_release: - name: "Apache Flink 1.14.2" + name: "Apache Flink 1.14.3" id: "1142-download-source" - url: "https://www.apache.org/dyn/closer.lua/flink/flink-1.14.2/flink-1.14.2-src.tgz" - asc_url: "https://downloads.apache.org/flink/flink-1.14.2/flink-1.14.2-src.tgz.asc" - sha512_url: "https://downloads.apache.org/flink/flink-1.14.2/flink-1.14.2-src.tgz.sha512" + url: "https://www.apache.org/dyn/closer.lua/flink/flink-1.14.3/flink-1.14.3-src.tgz" + asc_url: "https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-src.tgz.asc" + sha512_url: "https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-src.tgz.sha512" release_notes_url: "https://nightlies.apache.org/flink/flink-docs-release-1.14/release-notes/flink-1.14" - version_short: "1.13" @@ -205,6 +205,10 @@ release_archive: flink: - version_short: "1.14" + version_long: 1.14.3 + release_date: 2022-01-17 + - + version_short: "1.14" version_long: 1.14.2 release_date: 2021-12-16 - diff --git a/_posts/2022-01-17-release-1.14.3.md b/_posts/2022-01-17-release-1.14.3.md new file mode 100644 index 0000000..09bcb76 --- /dev/null +++ b/_posts/2022-01-17-release-1.14.3.md @@ -0,0 +1,331 @@ +--- +layout: post +title: "Apache Flink 1.14.3 Release Announcement" +date: 2022-01-17T08:00:00.000Z +categories: news +authors: +- tweise: + name: "Thomas Weise" +- MartijnVisser: + name: "Martijn Visser" + twitter: "martijnvisser82" + +The Apache Flink community released the second bugfix version of the Apache Flink 1.14 series. + +--- + +The Apache Flink community released the second bugfix version of the Apache Flink 1.14 series. +The first bugfix release was 1.14.2, being an emergency release due to an Apache Log4j Zero Day (CVE-2021-44228). Flink 1.14.1 was abandoned. +That means that this Flink release is the first bugfix release of the Flink 1.14 series which contains bugfixes not related to the mentioned CVE. + +This release includes 164 fixes and minor improvements for Flink 1.14.0. The list below includes bugfixes and improvements. For a complete list of all changes see: +[JIRA](https://issues.apache.org/jira/secure/ReleaseNote.jspa?version=12351075&projectId=12315522). + +We highly recommend all users to upgrade to Flink 1.14.3. + +Updated Maven dependencies: + +```xml +<dependency> + <groupId>org.apache.flink</groupId> + <artifactId>flink-java</artifactId> + <version>1.14.3</version> +</dependency> +<dependency> + <groupId>org.apache.flink</groupId> + <artifactId>flink-streaming-java_2.11</artifactId> + <version>1.14.3</version> +</dependency> +<dependency> + <groupId>org.apache.flink</groupId> + <artifactId>flink-clients_2.11</artifactId> + <version>1.14.3</version> +</dependency> +``` + +You can find the binaries on the updated [Downloads page]({{ site.baseurl }}/downloads.html). + + + + + + Release Notes - Flink - Version 1.14.3 + +<h2> Sub-task +</h2> +<ul> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24355'>FLINK-24355</a>] - Expose the flag for enabling checkpoints after tasks finish in the Web UI +</li> +</ul> + +<h2> Bug +</h2> +<ul> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-15987'>FLINK-15987</a>] - SELECT 1.0e0 / 0.0e0 throws NumberFormatException +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-17914'>FLINK-17914</a>] - HistoryServer deletes cached archives if archive listing fails +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-19142'>FLINK-19142</a>] - Local recovery can be broken if slot hijacking happened during a full restart +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20195'>FLINK-20195</a>] - Jobs endpoint returns duplicated jobs +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20370'>FLINK-20370</a>] - Result is wrong when sink primary key is not the same with query +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21289'>FLINK-21289</a>] - Application mode ignores the pipeline.classpaths configuration +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21345'>FLINK-21345</a>] - NullPointerException LogicalCorrelateToJoinFromTemporalTableFunctionRule.scala:157 +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-22113'>FLINK-22113</a>] - UniqueKey constraint is lost with multiple sources join in SQL +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-22954'>FLINK-22954</a>] - Don't support consuming update and delete changes when use table function that does not contain table field +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-23614'>FLINK-23614</a>] - The resulting scale of TRUNCATE(DECIMAL, ...) is not correct +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-23704'>FLINK-23704</a>] - FLIP-27 sources are not generating LatencyMarkers +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-23827'>FLINK-23827</a>] - Fix ModifiedMonotonicity inference for some node +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-23919'>FLINK-23919</a>] - PullUpWindowTableFunctionIntoWindowAggregateRule generates invalid Calc for Window TVF +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24156'>FLINK-24156</a>] - BlobServer crashes due to SocketTimeoutException in Java 11 +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24232'>FLINK-24232</a>] - Archiving of suspended jobs prevents breaks subsequent archive attempts +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24291'>FLINK-24291</a>] - Decimal precision is lost when deserializing in test cases +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24310'>FLINK-24310</a>] - A bug in the BufferingSink example in the doc +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24315'>FLINK-24315</a>] - Cannot rebuild watcher thread while the K8S API server is unavailable +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24318'>FLINK-24318</a>] - Casting a number to boolean has different results between 'select' fields and 'where' condition +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24331'>FLINK-24331</a>] - PartiallyFinishedSourcesITCase fails with "No downstream received 0 from xxx;" +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24336'>FLINK-24336</a>] - PyFlink TableEnvironment executes the SQL randomly MalformedURLException with the configuration for 'pipeline.classpaths' +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24344'>FLINK-24344</a>] - Handling of IOExceptions when triggering checkpoints doesn't cause job failover +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24353'>FLINK-24353</a>] - Bash scripts do not respect dynamic configurations when calculating memory sizes +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24366'>FLINK-24366</a>] - Unnecessary/misleading error message about failing restores when tasks are already canceled. +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24371'>FLINK-24371</a>] - Support SinkWriter preCommit without the need of a committer +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24377'>FLINK-24377</a>] - TM resource may not be properly released after heartbeat timeout +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24380'>FLINK-24380</a>] - Flink should handle the state transition of the pod from Pending to Failed +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24381'>FLINK-24381</a>] - Table API exceptions may leak sensitive configuration values +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24401'>FLINK-24401</a>] - TM cannot exit after Metaspace OOM +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24407'>FLINK-24407</a>] - Pulsar connector chinese document link to Pulsar document location incorrectly. +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24408'>FLINK-24408</a>] - org.codehaus.janino.InternalCompilerException: Compiling "StreamExecValues$200": Code of method "nextRecord(Ljava/lang/Object;)Ljava/lang/Object;" of class "StreamExecValues$200" grows beyond 64 KB +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24409'>FLINK-24409</a>] - Kafka topics with periods in their names generate a constant stream of errors +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24431'>FLINK-24431</a>] - [Kinesis][EFO] EAGER registration strategy does not work when job fails over +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24432'>FLINK-24432</a>] - RocksIteratorWrapper.seekToLast() calls the wrong RocksIterator method +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24465'>FLINK-24465</a>] - Wrong javadoc and documentation for buffer timeout +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24467'>FLINK-24467</a>] - Set min and max buffer size even if the difference less than threshold +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24468'>FLINK-24468</a>] - NPE when notifyNewBufferSize +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24469'>FLINK-24469</a>] - Incorrect calcualtion of the buffer size in case of channel data skew +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24480'>FLINK-24480</a>] - EqualiserCodeGeneratorTest fails on azure +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24488'>FLINK-24488</a>] - KafkaRecordSerializationSchemaBuilder does not forward timestamp +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24492'>FLINK-24492</a>] - incorrect implicit type conversion between numeric and (var)char +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24506'>FLINK-24506</a>] - checkpoint directory is not configurable through the Flink configuration passed into the StreamExecutionEnvironment +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24540'>FLINK-24540</a>] - Fix Resource leak due to Files.list +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24543'>FLINK-24543</a>] - Zookeeper connection issue causes inconsistent state in Flink +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24550'>FLINK-24550</a>] - Can not access job information from a standby jobmanager UI +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24551'>FLINK-24551</a>] - BUFFER_DEBLOAT_SAMPLES property is taken from the wrong configuration +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24552'>FLINK-24552</a>] - Ineffective buffer debloat configuration in randomized tests +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24563'>FLINK-24563</a>] - Comparing timstamp_ltz with random string throws NullPointerException +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24596'>FLINK-24596</a>] - Bugs in sink.buffer-flush before upsert-kafka +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24597'>FLINK-24597</a>] - RocksdbStateBackend getKeysAndNamespaces would return duplicate data when using MapState +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24600'>FLINK-24600</a>] - Duplicate 99th percentile displayed in checkpoint summary +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24608'>FLINK-24608</a>] - Sinks built with the unified sink framework do not receive timestamps when used in Table API +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24613'>FLINK-24613</a>] - Documentation on orc supported data types is outdated +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24647'>FLINK-24647</a>] - ClusterUncaughtExceptionHandler does not log the exception +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24654'>FLINK-24654</a>] - NPE on RetractableTopNFunction when some records were cleared by state ttl +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24662'>FLINK-24662</a>] - PyFlink sphinx check failed with "node class 'meta' is already registered, its visitors will be overridden" +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24667'>FLINK-24667</a>] - Channel state writer would fail the task directly if meeting exception previously +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24676'>FLINK-24676</a>] - Schema does not match if explain insert statement with partial column +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24678'>FLINK-24678</a>] - Correct the metric name of map state contains latency +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24691'>FLINK-24691</a>] - FLINK SQL SUM() causes a precision error +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24704'>FLINK-24704</a>] - Exception occurs when the input record loses monotonicity on the sort key field of UpdatableTopNFunction +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24706'>FLINK-24706</a>] - AkkaInvocationHandler silently ignores deserialization errors +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24708'>FLINK-24708</a>] - `ConvertToNotInOrInRule` has a bug which leads to wrong result +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24728'>FLINK-24728</a>] - Batch SQL file sink forgets to close the output stream +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24733'>FLINK-24733</a>] - Data loss in pulsar source when using shared mode +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24738'>FLINK-24738</a>] - Fail during announcing buffer size to released local channel +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24761'>FLINK-24761</a>] - Fix PartitionPruner code gen compile fail +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24773'>FLINK-24773</a>] - KafkaCommitter should fail on unknown Exception +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24777'>FLINK-24777</a>] - Processed (persisted) in-flight data description miss on Monitoring Checkpointing page +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24789'>FLINK-24789</a>] - IllegalStateException with CheckpointCleaner being closed already +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24792'>FLINK-24792</a>] - OperatorCoordinatorSchedulerTest crashed JVM on AZP +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24835'>FLINK-24835</a>] - "group by" in the interval join will throw a exception +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24846'>FLINK-24846</a>] - AsyncWaitOperator fails during stop-with-savepoint +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24858'>FLINK-24858</a>] - TypeSerializer version mismatch during eagerly restore +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24874'>FLINK-24874</a>] - Dropdown menu is not properly shown in UI +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24885'>FLINK-24885</a>] - ProcessElement Interface parameter Collector : java.lang.NullPointerException +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24919'>FLINK-24919</a>] - UnalignedCheckpointITCase hangs on Azure +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24922'>FLINK-24922</a>] - Fix spelling errors in the word "parallism" +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24937'>FLINK-24937</a>] - "kubernetes application HA test" hangs on azure +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24938'>FLINK-24938</a>] - Checkpoint cleaner is closed before checkpoints are discarded +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25022'>FLINK-25022</a>] - ClassLoader leak with ThreadLocals on the JM when submitting a job through the REST API +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25067'>FLINK-25067</a>] - Correct the description of RocksDB's background threads +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25084'>FLINK-25084</a>] - Field names must be unique. Found duplicates +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25091'>FLINK-25091</a>] - Official website document FileSink orc compression attribute reference error +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25096'>FLINK-25096</a>] - Issue in exceptions API(/jobs/:jobid/exceptions) in flink 1.13.2 +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25126'>FLINK-25126</a>] - FlinkKafkaInternalProducer state is not reset if transaction finalization fails +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25132'>FLINK-25132</a>] - KafkaSource cannot work with object-reusing DeserializationSchema +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25134'>FLINK-25134</a>] - Unused RetryRule in KafkaConsumerTestBase swallows retries +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25222'>FLINK-25222</a>] - Remove NetworkFailureProxy used for Kafka connector tests +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25271'>FLINK-25271</a>] - ApplicationDispatcherBootstrapITCase. testDispatcherRecoversAfterLosingAndRegainingLeadership failed on azure +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25294'>FLINK-25294</a>] - Incorrect cloudpickle import +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25375'>FLINK-25375</a>] - Update Log4j to 2.17.0 +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25418'>FLINK-25418</a>] - The dir_cache is specified in the flink task. When there is no network, you will still download the python third-party library +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25446'>FLINK-25446</a>] - Avoid sanity check on read bytes on DataInputStream#read(byte[]) +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25468'>FLINK-25468</a>] - Local recovery fails if local state storage and RocksDB working directory are not on the same volume +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25477'>FLINK-25477</a>] - The directory structure of the State Backends document is not standardized +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25513'>FLINK-25513</a>] - CoFlatMapFunction requires both two flat_maps to yield something +</li> +</ul> + +<h2> Improvement +</h2> +<ul> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-20443'>FLINK-20443</a>] - ContinuousProcessingTimeTrigger doesn't fire at the end of the window +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-21467'>FLINK-21467</a>] - Document possible recommended usage of Bounded{One/Multi}Input.endInput and emphasize that they could be called multiple times +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-23519'>FLINK-23519</a>] - Aggregate State Backend Latency by State Level +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-23798'>FLINK-23798</a>] - Avoid using reflection to get filter when partition filter is enabled +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-23842'>FLINK-23842</a>] - Add log messages for reader registrations and split requests. +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-23914'>FLINK-23914</a>] - Make connector testing framework more verbose on test failure +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24117'>FLINK-24117</a>] - Remove unHandledErrorListener in ZooKeeperLeaderElectionDriver and ZooKeeperLeaderRetrievalDriver +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24148'>FLINK-24148</a>] - Add bloom filter policy option in RocksDBConfiguredOptions +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24382'>FLINK-24382</a>] - RecordsOut metric for sinks is inaccurate +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24437'>FLINK-24437</a>] - Remove unhandled exception handler from CuratorFramework before closing it +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24460'>FLINK-24460</a>] - Rocksdb Iterator Error Handling Improvement +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24481'>FLINK-24481</a>] - Translate buffer debloat documenation to chinese +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24529'>FLINK-24529</a>] - flink sql job cannot use custom job name +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24631'>FLINK-24631</a>] - Avoiding directly use the labels as selector for deployment and service +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24670'>FLINK-24670</a>] - Restructure unaligned checkpoints documentation page to "Checkpointing under back pressure" +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24690'>FLINK-24690</a>] - Clarification of buffer size threshold calculation in BufferDebloater +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24695'>FLINK-24695</a>] - Update how to configure unaligned checkpoints in the documentation +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24739'>FLINK-24739</a>] - State requirements for Flink's application mode in the documentation +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24813'>FLINK-24813</a>] - Improve ImplicitTypeConversionITCase +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24880'>FLINK-24880</a>] - Error messages "OverflowError: timeout value is too large" shown when executing PyFlink jobs +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24958'>FLINK-24958</a>] - correct the example and link for temporal table function documentation +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24987'>FLINK-24987</a>] - Enhance ExternalizedCheckpointCleanup enum +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25092'>FLINK-25092</a>] - Implement artifact cacher for Bash based Elasticsearch test +</li> +</ul> + +<h2> Technical Debt +</h2> +<ul> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24367'>FLINK-24367</a>] - Add a fallback AkkaRpcSystemLoader for tests in the IDE +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24445'>FLINK-24445</a>] - Move RPC System packaging to package phase +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24455'>FLINK-24455</a>] - FallbackAkkaRpcSystemLoader should check for maven errors +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24513'>FLINK-24513</a>] - AkkaRpcSystemLoader must be an ITCase +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24559'>FLINK-24559</a>] - flink-rpc-akka-loader does not bundle flink-rpc-akka +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24609'>FLINK-24609</a>] - flink-rpc-akka uses wrong Scala version property for parser-combinators +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-24859'>FLINK-24859</a>] - Document new File formats +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-25472'>FLINK-25472</a>] - Update to Log4j 2.17.1 +</li> +</ul> + \ No newline at end of file diff --git a/q/gradle-quickstart.sh b/q/gradle-quickstart.sh index baa6315..68f61f0 100755 --- a/q/gradle-quickstart.sh +++ b/q/gradle-quickstart.sh @@ -41,7 +41,7 @@ function mkPackage() { defaultProjectName="quickstart" defaultOrganization="org.myorg.quickstart" defaultVersion="0.1-SNAPSHOT" -defaultFlinkVersion="${1:-1.14.2}" +defaultFlinkVersion="${1:-1.14.3}" defaultScalaBinaryVersion="${2:-2.11}" echo "This script creates a Flink project using Java and Gradle." diff --git a/q/quickstart-scala.sh b/q/quickstart-scala.sh index e66bd81..bd618b1 100755 --- a/q/quickstart-scala.sh +++ b/q/quickstart-scala.sh @@ -24,7 +24,7 @@ PACKAGE=quickstart mvn archetype:generate \ -DarchetypeGroupId=org.apache.flink \ -DarchetypeArtifactId=flink-quickstart-scala \ - -DarchetypeVersion=${1:-1.14.2} \ + -DarchetypeVersion=${1:-1.14.3} \ -DgroupId=org.myorg.quickstart \ -DartifactId=$PACKAGE \ -Dversion=0.1 \ diff --git a/q/quickstart.sh b/q/quickstart.sh index 7121e2f..14e5379 100755 --- a/q/quickstart.sh +++ b/q/quickstart.sh @@ -24,7 +24,7 @@ PACKAGE=quickstart mvn archetype:generate \ -DarchetypeGroupId=org.apache.flink \ -DarchetypeArtifactId=flink-quickstart-java \ - -DarchetypeVersion=${1:-1.14.2} \ + -DarchetypeVersion=${1:-1.14.3} \ -DgroupId=org.myorg.quickstart \ -DartifactId=$PACKAGE \ -Dversion=0.1 \ diff --git a/q/sbt-quickstart.sh b/q/sbt-quickstart.sh index 12751a5..1c5d849 100755 --- a/q/sbt-quickstart.sh +++ b/q/sbt-quickstart.sh @@ -42,7 +42,7 @@ defaultProjectName="Flink Project" defaultOrganization="org.example" defaultVersion="0.1-SNAPSHOT" defaultScalaVersion="2.12.7" -defaultFlinkVersion="1.14.2" +defaultFlinkVersion="1.14.3" echo "This script creates a Flink project using Scala and SBT."