This is an automated email from the ASF dual-hosted git repository.
martijnvisser 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 71a615a56 Flink 1.16.1. This closes #603
71a615a56 is described below
commit 71a615a56b96a350523747ce5c7293d5b559994d
Author: MartijnVisser <[email protected]>
AuthorDate: Mon Jan 30 16:01:42 2023 +0100
Flink 1.16.1. This closes #603
* Flink 1.16.1
Co-authored-by: Matthias Pohl <[email protected]>
Co-authored-by: Dawid Wysakowicz <[email protected]>
Co-authored-by: Hong Liang Teoh <[email protected]>
---
_config.yml | 33 ++---
_posts/2023-01-26-release-1.16.1.md | 234 ++++++++++++++++++++++++++++++++++++
q/gradle-quickstart.sh | 6 +-
q/quickstart-scala.sh | 2 +-
q/quickstart.sh | 2 +-
q/sbt-quickstart.sh | 6 +-
6 files changed, 260 insertions(+), 23 deletions(-)
diff --git a/_config.yml b/_config.yml
index 6d3582b66..09e91b239 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.16.0
+FLINK_VERSION_STABLE: 1.16.1
FLINK_VERSION_STABLE_SHORT: "1.16"
FLINK_ISSUES_URL: https://issues.apache.org/jira/browse/FLINK
@@ -75,18 +75,18 @@ FLINK_TABLE_STORE_GITHUB_REPO_NAME: flink-table-store
flink_releases:
- version_short: "1.16"
binary_release:
- name: "Apache Flink 1.16.0"
+ name: "Apache Flink 1.16.1"
scala_212:
- id: "1160-download_212"
- url:
"https://www.apache.org/dyn/closer.lua/flink/flink-1.16.0/flink-1.16.0-bin-scala_2.12.tgz";
- asc_url:
"https://downloads.apache.org/flink/flink-1.16.0/flink-1.16.0-bin-scala_2.12.tgz.asc";
- sha512_url:
"https://downloads.apache.org/flink/flink-1.16.0/flink-1.16.0-bin-scala_2.12.tgz.sha512";
+ id: "1161-download_212"
+ url:
"https://www.apache.org/dyn/closer.lua/flink/flink-1.16.1/flink-1.16.1-bin-scala_2.12.tgz";
+ asc_url:
"https://downloads.apache.org/flink/flink-1.16.1/flink-1.16.1-bin-scala_2.12.tgz.asc";
+ sha512_url:
"https://downloads.apache.org/flink/flink-1.16.1/flink-1.16.1-bin-scala_2.12.tgz.sha512";
source_release:
- name: "Apache Flink 1.16.0"
- id: "1160-download-source"
- url:
"https://www.apache.org/dyn/closer.lua/flink/flink-1.16.0/flink-1.16.0-src.tgz";
- asc_url:
"https://downloads.apache.org/flink/flink-1.16.0/flink-1.16.0-src.tgz.asc";
- sha512_url:
"https://downloads.apache.org/flink/flink-1.16.0/flink-1.16.0-src.tgz.sha512";
+ name: "Apache Flink 1.16.1"
+ id: "1161-download-source"
+ url:
"https://www.apache.org/dyn/closer.lua/flink/flink-1.16.1/flink-1.16.1-src.tgz";
+ asc_url:
"https://downloads.apache.org/flink/flink-1.16.1/flink-1.16.1-src.tgz.asc";
+ sha512_url:
"https://downloads.apache.org/flink/flink-1.16.1/flink-1.16.1-src.tgz.sha512";
release_notes_url:
"https://nightlies.apache.org/flink/flink-docs-release-1.16/release-notes/flink-1.16";
- version_short: "1.15"
@@ -222,14 +222,14 @@ flink_kubernetes_operator_releases:
source_release:
name: "Apache Flink Kubernetes Operator 1.3.1"
id: "130-kubernetes-operator-download-source"
- flink_version: "1.16.0, 1.15.3, 1.14.6, 1.13.6"
+ flink_version: "1.16.1, 1.15.3, 1.14.6, 1.13.6"
url:
"https://www.apache.org/dyn/closer.lua/flink/flink-kubernetes-operator-1.3.1/flink-kubernetes-operator-1.3.1-src.tgz";
asc_url:
"https://downloads.apache.org/flink/flink-kubernetes-operator-1.3.1/flink-kubernetes-operator-1.3.1-src.tgz.asc";
sha512_url:
"https://downloads.apache.org/flink/flink-kubernetes-operator-1.3.1/flink-kubernetes-operator-1.3.1-src.tgz.sha512";
helm_release:
name: "Apache Flink Kubernetes Operator Helm Chart 1.3.1"
id: "130-kubernetes-operator-download-helm"
- flink_version: "1.16.0, 1.15.3, 1.14.6, 1.13.6"
+ flink_version: "1.16.1, 1.15.3, 1.14.6, 1.13.6"
url:
"https://www.apache.org/dyn/closer.lua/flink/flink-kubernetes-operator-1.3.1/flink-kubernetes-operator-1.3.1-helm.tgz";
asc_url:
"https://downloads.apache.org/flink/flink-kubernetes-operator-1.3.1/flink-kubernetes-operator-1.3.1-helm.tgz.asc";
sha512_url:
"https://downloads.apache.org/flink/flink-kubernetes-operator-1.3.1/flink-kubernetes-operator-1.3.1-helm.tgz.sha512";
@@ -256,14 +256,14 @@ flink_table_store_releases:
source_release:
name: "Apache Flink Table Store 0.3.0"
id: "030-table-store-download-source"
- flink_version: "1.16.0"
+ flink_version: "1.16.1"
url:
"https://www.apache.org/dyn/closer.lua/flink/flink-table-store-0.3.0/flink-table-store-0.3.0-src.tgz";
asc_url:
"https://downloads.apache.org/flink/flink-table-store-0.3.0/flink-table-store-0.3.0-src.tgz.asc";
sha512_url:
"https://downloads.apache.org/flink/flink-table-store-0.3.0/flink-table-store-0.3.0-src.tgz.sha512";
binaries_release:
name: "Apache Flink Table Store Binaries 0.3.0"
id: "030-table-store-download-binaries"
- flink_version: "1.16.0"
+ flink_version: "1.16.1"
url:
"https://www.apache.org/dyn/closer.lua/flink/flink-table-store-0.3.0/flink-table-store-dist-0.3.0.jar";
asc_url:
"https://downloads.apache.org/flink/flink-table-store-0.3.0/flink-table-store-dist-0.3.0.jar.asc";
sha512_url:
"https://downloads.apache.org/flink/flink-table-store-0.3.0/flink-table-store-dist-0.3.0.jar.sha512";
@@ -335,6 +335,9 @@ component_releases:
release_archive:
flink:
+ - version_short: "1.16"
+ version_long: 1.16.1
+ release_date: 2023-01-26
-
version_short: "1.16"
version_long: 1.16.0
diff --git a/_posts/2023-01-26-release-1.16.1.md
b/_posts/2023-01-26-release-1.16.1.md
new file mode 100644
index 000000000..56af837cb
--- /dev/null
+++ b/_posts/2023-01-26-release-1.16.1.md
@@ -0,0 +1,234 @@
+---
+layout: post
+title: "Apache Flink 1.16.1 Release Announcement"
+date: 2023-01-30T16:00:00.000Z
+categories: news
+authors:
+- MartijnVisser:
+ name: "Martijn Visser"
+ twitter: "martijnvisser82"
+
+excerpt: The Apache Flink Community is pleased to announce a bug fix release
for Flink 1.16.
+
+---
+
+The Apache Flink Community is pleased to announce the first bug fix release of
the Flink 1.16 series.
+
+This release includes 84 bug fixes, vulnerability fixes, and minor
improvements for Flink 1.16.
+Below you will find a list of all bugfixes and improvements (excluding
improvements to the build infrastructure and build stability). For a complete
list of all changes see:
+[JIRA](https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12352344).
+
+We highly recommend all users upgrade to Flink 1.16.1.
+
+# Release Artifacts
+
+## Maven Dependencies
+
+```xml
+<dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-java</artifactId>
+ <version>1.16.1</version>
+</dependency>
+<dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-streaming-java</artifactId>
+ <version>1.16.1</version>
+</dependency>
+<dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-clients</artifactId>
+ <version>1.16.1</version>
+</dependency>
+```
+
+## Binaries
+
+You can find the binaries on the updated [Downloads page]({{ site.baseurl
}}/downloads.html).
+
+## Docker Images
+
+* [library/flink](https://hub.docker.com/_/flink?tab=tags&page=1&name=1.16.1)
(official images)
+*
[apache/flink](https://hub.docker.com/r/apache/flink/tags?page=1&name=1.16.1)
(ASF repository)
+
+## PyPi
+
+* [apache-flink==1.16.1](https://pypi.org/project/apache-flink/1.16.1/)
+
+# Upgrade Notes
+
+[FLINK-28988 - Incorrect result for filter after temporal
join](https://issues.apache.org/jira/browse/FLINK-28988)
+The filter will not be pushed down into both inputs of the event time temporal
join.
+This may cause incompatible plan changes compared to Flink 1.16.0, e.g., when
the left input is an upsert source
+(like upsert-kafka connector), the query plan will remove the
ChangelogNormalize node in Flink 1.16.1, while it
+did appear in 1.16.0.
+
+[FLINK-29849 - Event time temporal join on an upsert source may produce
incorrect execution plan](https://issues.apache.org/jira/browse/FLINK-29849)
+This resolves the correctness issue when doing an event time temporal join
with a versioned table backed by an upsert source.
+When the right input of the join is an upsert source, it no longer generates a
ChangelogNormalize node for it.
+This is an incompatible plan change compared to 1.16.0
+
+[FLINK-30383 - UseLogicalIdentifier makes datadog consider metric as
custom](https://issues.apache.org/jira/browse/FLINK-30383)
+The Datadog reporter now adds a "flink." prefix to metric identifiers if
"useLogicalIdentifier" is enabled.
+This is required for these metrics to be recognized as Flink metrics, not
custom ones.
+
+# Release Notes
+
+<h2> Bug
+</h2>
+<ul>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-16582'>FLINK-16582</a>] -
NettyBufferPoolTest may have warns on NettyBuffer leak
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-26037'>FLINK-26037</a>] -
TaskManagerRunner may crash during shutdown sequence
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-26890'>FLINK-26890</a>] -
DynamoDB consumer error consuming partitions close to retention
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-27341'>FLINK-27341</a>] -
TaskManager running together with JobManager are bind to 127.0.0.1
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-27944'>FLINK-27944</a>] -
IO metrics collision happens if a task has union inputs
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-28102'>FLINK-28102</a>] -
Flink AkkaRpcSystemLoader fails when temporary directory is a symlink
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-28526'>FLINK-28526</a>] -
Fail to lateral join with UDTF from Table with timstamp column
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-28695'>FLINK-28695</a>] -
Fail to send partition request to restarted taskmanager
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-28742'>FLINK-28742</a>] -
Table.to_pandas fails with lit("xxx")
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-28786'>FLINK-28786</a>] -
Cannot run PyFlink 1.16 on MacOS with M1 chip
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-28863'>FLINK-28863</a>] -
Snapshot result of RocksDB native savepoint should have empty shared-state
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-28960'>FLINK-28960</a>] -
Pulsar throws java.lang.NoClassDefFoundError:
javax/xml/bind/annotation/XmlElement
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-28988'>FLINK-28988</a>] -
Incorrect result for filter after temporal join
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-29231'>FLINK-29231</a>] -
PyFlink UDAF produces different results in the same sliding window
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-29234'>FLINK-29234</a>] -
Dead lock in DefaultLeaderElectionService
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-29298'>FLINK-29298</a>] -
LocalBufferPool request buffer from NetworkBufferPool hanging
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-29479'>FLINK-29479</a>] -
Support whether using system PythonPath for PyFlink jobs
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-29539'>FLINK-29539</a>] -
dnsPolicy in FlinkPod is not overridable
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-29615'>FLINK-29615</a>] -
MetricStore does not remove metrics of nonexistent subtasks when adaptive
scheduler lowers job parallelism
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-29627'>FLINK-29627</a>] -
Sink - Duplicate key exception during recover more than 1 committable.
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-29677'>FLINK-29677</a>] -
Prevent dropping the current catalog
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-29728'>FLINK-29728</a>] -
TablePlanner prevents Flink from starting is working directory is a
symbolic link
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-29749'>FLINK-29749</a>] -
flink info command support dynamic properties
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-29781'>FLINK-29781</a>] -
ChangelogNormalize uses wrong keys after transformation by
WatermarkAssignerChangelogNormalizeTransposeRule
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-29803'>FLINK-29803</a>] -
Table API Scala APIs lack proper source jars
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-29817'>FLINK-29817</a>] -
Published metadata for apache-flink in pypi are inconsistent and causes
poetry to fail
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-29827'>FLINK-29827</a>] -
[Connector][AsyncSinkWriter] Checkpointed states block writer from sending
records
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-29839'>FLINK-29839</a>] -
HiveServer2 endpoint doesn't support TGetInfoType value
'CLI_ODBC_KEYWORDS'
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-29849'>FLINK-29849</a>] -
Event time temporal join on an upsert source may produce incorrect
execution plan
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-29857'>FLINK-29857</a>] -
Fix failure to connect to 'HiveServer2Endpoint' when using hive3
beeline
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-29899'>FLINK-29899</a>] -
Stacktrace printing in DefaultExecutionGraphCacheTest is confusing maven
test log output
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-29923'>FLINK-29923</a>] -
Hybrid Shuffle may face deadlock when running a task need to execute big
size data
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-29927'>FLINK-29927</a>] -
AkkaUtils#getAddress may cause memory leak
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-30030'>FLINK-30030</a>] -
Unexpected behavior for overwrite in Hive dialect
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-30133'>FLINK-30133</a>] -
HadoopModuleFactory creates error if the security module cannot be loaded
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-30168'>FLINK-30168</a>] -
PyFlink Deserialization Error with Object Array
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-30189'>FLINK-30189</a>] -
HsSubpartitionFileReader may load data that has been consumed from memory
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-30239'>FLINK-30239</a>] -
The flame graph doesn't work due to groupExecutionsByLocation has bug
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-30304'>FLINK-30304</a>] -
Possible Deadlock in Kinesis/Firehose/DynamoDB Connector
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-30308'>FLINK-30308</a>] -
ClassCastException: class java.io.ObjectStreamClass$Caches$1 cannot be cast
to class java.util.Map is showing in the logging when the job shutdown
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-30334'>FLINK-30334</a>] -
SourceCoordinator error splitRequest check cause HybridSource loss of data
and hang
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-30359'>FLINK-30359</a>] -
Encountered NoClassDefFoundError when using
flink-sql-connector-elasticsearch6
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-30366'>FLINK-30366</a>] -
Python Group Agg failed in cleaning the idle state
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-30525'>FLINK-30525</a>] -
Cannot open jobmanager configuration web page
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-30558'>FLINK-30558</a>] -
The metric 'numRestarts' reported in SchedulerBase will be
overridden by metric 'fullRestarts'
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-30637'>FLINK-30637</a>] -
In linux-aarch64 environment, using “is” judgment to match the window type
of overwindow have returned incorrect matching results
+</li>
+</ul>
+
+<h2> Improvement
+</h2>
+<ul>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-27327'>FLINK-27327</a>] -
Add description about changing max parallelism explicitly leads to state
incompatibility
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-29134'>FLINK-29134</a>] -
fetch metrics may cause oom(ThreadPool task pile up)
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-29155'>FLINK-29155</a>] -
Improve default config of grpcServer in Process Mode
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-29244'>FLINK-29244</a>] -
Add metric lastMaterializationDuration to
ChangelogMaterializationMetricGroup
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-29458'>FLINK-29458</a>] -
When two tables have the same field, do not specify the table
name,Exception will be thrown：SqlValidatorException :Column 'currency'
is ambiguous
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-29639'>FLINK-29639</a>] -
Add ResourceId in TransportException for debugging
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-29693'>FLINK-29693</a>] -
MiniClusterExtension should respect DEFAULT_PARALLELISM if set
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-29834'>FLINK-29834</a>] -
Clear static Jackson TypeFactory cache on CL release
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-29966'>FLINK-29966</a>] -
Replace and redesign the Python api documentation base
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-30016'>FLINK-30016</a>] -
Update Flink 1.16 release notes about updated oshi-core
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-30116'>FLINK-30116</a>] -
Don't Show Env Vars in Web UI
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-30183'>FLINK-30183</a>] -
We should add a proper error message in case the deprecated
reflection-based instantiation of a reporter is triggered
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-30357'>FLINK-30357</a>] -
Wrong link in connector/jdbc doc.
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-30436'>FLINK-30436</a>] -
Integrate Opensearch connector docs into Flink docs v1.16
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-30592'>FLINK-30592</a>] -
The unsupported hive version is not deleted on the hive overview document
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-30633'>FLINK-30633</a>] -
Update AWS SDKv2 to v2.19.14
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-30724'>FLINK-30724</a>] -
Update doc of kafka per-partition watermark to FLIP-27 source
+</li>
+</ul>
+
+<h2> Technical Debt
+</h2>
+<ul>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-27731'>FLINK-27731</a>] -
Remove Hugo Modules integration
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-29157'>FLINK-29157</a>] -
Clarify the contract between CompletedCheckpointStore and
SharedStateRegistry
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-29957'>FLINK-29957</a>] -
Rework connector docs integration
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-29958'>FLINK-29958</a>] -
Add new connector_artifact shortcode
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-29972'>FLINK-29972</a>] -
Pin Flink docs to Elasticsearch Connector 3.0.0
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-29973'>FLINK-29973</a>] -
connector_artifact should append Flink minor version
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-30291'>FLINK-30291</a>] -
Integrate flink-connector-aws into Flink docs
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-30382'>FLINK-30382</a>] -
Flink 1.16 to integrate KDS/KDF docs from flink-connector-aws
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-30383'>FLINK-30383</a>] -
UseLogicalIdentifier makes datadog consider metric as custom
+</li>
+</ul>
\ No newline at end of file
diff --git a/q/gradle-quickstart.sh b/q/gradle-quickstart.sh
index b6e2f6502..253313ffb 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.16.0}"
+defaultFlinkVersion="${1:-1.16.1}"
# flink-docs-master/docs/dev/datastream/project-configuration/#gradle
# passes the scala version prefixed with a _, e.g.: _2.12
scalaBinaryVersionFromCmdArg="${2/_/}"
@@ -114,9 +114,9 @@ ext {
javaVersion = '1.8'
flinkVersion = '${flinkVersion}'
scalaBinaryVersion = '${scalaBinaryVersion}'
- slf4jVersion = '1.7.32'
+ slf4jVersion = '1.7.36'
log4jVersion = '2.17.1'
- flinkVersionNew = flinkVersion.toString().replace("-SNAPSHOT", "") >=
"1.15"
+ flinkVersionNew = flinkVersion.toString().replace("-SNAPSHOT", "") >=
"1.16"
}
// artifact properties
diff --git a/q/quickstart-scala.sh b/q/quickstart-scala.sh
index 924fdf2df..3f501f02f 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.16.0}
\
+ -DarchetypeVersion=${1:-1.16.1}
\
-DgroupId=org.myorg.quickstart \
-DartifactId=$PACKAGE
\
-Dversion=0.1
\
diff --git a/q/quickstart.sh b/q/quickstart.sh
index 8a4abe060..e9d2bbe4e 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.16.0}
\
+ -DarchetypeVersion=${1:-1.16.1}
\
-DgroupId=org.myorg.quickstart \
-DartifactId=$PACKAGE
\
-Dversion=0.1
\
diff --git a/q/sbt-quickstart.sh b/q/sbt-quickstart.sh
index b9e8a1013..40a3bf013 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.16.0"
+defaultFlinkVersion="1.16.1"
echo "This script creates a Flink project using Scala and SBT."
@@ -103,9 +103,9 @@ version := \"0.1-SNAPSHOT\"
organization := \"org.example\"
-ThisBuild / scalaVersion := \"2.11.12\"
+ThisBuild / scalaVersion := \"2.12.7\"
-val flinkVersion = \"1.14.0\"
+val flinkVersion = \"1.16.1\"
val flinkDependencies = Seq(
\"org.apache.flink\" %% \"flink-scala\" % flinkVersion % \"provided\",
