from:"knaufk"

[flink-web] 01/02: add announcement blog post for Flink 1.18

2023-10-26 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git

commit 4ed5d4caf7c089145384157915b3ee071e424a47
Author: Konstantin Knauf 
AuthorDate: Fri Oct 6 13:59:05 2023 +0200

add announcement blog post for Flink 1.18
---
 docs/content/posts/2023-10-24-release-1.18.0.md| 597 +
 .../backpressure_monitor.png   | Bin 0 -> 166226 bytes
 .../rescaling_performance.png  | Bin 0 -> 63024 bytes
 .../2023-10-24-release-1.18.0/tpc-ds-benchmark.png | Bin 0 -> 1299594 bytes
 4 files changed, 597 insertions(+)

diff --git a/docs/content/posts/2023-10-24-release-1.18.0.md 
b/docs/content/posts/2023-10-24-release-1.18.0.md
new file mode 100644
index 0..4a13d53a3
--- /dev/null
+++ b/docs/content/posts/2023-10-24-release-1.18.0.md
@@ -0,0 +1,597 @@
+---
+authors:
+- JingGe:
+  name: "Jing Ge"
+  twitter: jingengineer
+- KonstantinKnauf:
+  name: "Konstantin Knauf"
+  twitter: snntrable
+- SergeyNuyanzin:
+  name: "Sergey Nuyanzin"
+  twitter: uckamello
+- QingshengRen:
+  name: "Qingsheng Ren"
+  twitter: renqstuite
+date: "2023-10-24T22:00:00Z"
+subtitle: ""
+title: Announcing the Release of Apache Flink 1.18
+aliases:
+- /news/2023/10/10/release-1.18.0.html
+---
+
+The Apache Flink PMC is pleased to announce the release of Apache Flink 
1.18.0. As usual, we are looking at a packed 
+release with a wide variety of improvements and new features. Overall, 174 
people contributed to this release completing 
+18 FLIPS and 700+ issues. Thank you!
+
+Let's dive into the highlights.
+
+# Towards a Streaming Lakehouse
+
+## Flink SQL Improvements
+
+### Introduce Flink JDBC Driver For SQL Gateway 
+
+Flink 1.18 comes with a JDBC Driver for the Flink SQL Gateway. So, you can now 
use any SQL Client that supports JDBC to 
+interact with your tables via Flink SQL. Here is an example using 
[SQLLine](https://julianhyde.github.io/sqlline/manual.html). 
+
+```shell
+sqlline> !connect jdbc:flink://localhost:8083
+```
+
+```shell
+sqlline version 1.12.0
+sqlline> !connect jdbc:flink://localhost:8083
+Enter username for jdbc:flink://localhost:8083:
+Enter password for jdbc:flink://localhost:8083:
+0: jdbc:flink://localhost:8083> CREATE TABLE T(
+. . . . . . . . . . . . . . .)>  a INT,
+. . . . . . . . . . . . . . .)>  b VARCHAR(10)
+. . . . . . . . . . . . . . .)>  ) WITH (
+. . . . . . . . . . . . . . .)>  'connector' = 'filesystem',
+. . . . . . . . . . . . . . .)>  'path' = 'file:///tmp/T.csv',
+. . . . . . . . . . . . . . .)>  'format' = 'csv'
+. . . . . . . . . . . . . . .)>  );
+No rows affected (0.122 seconds)
+0: jdbc:flink://localhost:8083> INSERT INTO T VALUES (1, 'Hi'), (2, 'Hello');
++--+
+|  job id  |
++--+
+| fbade1ab4450fc57ebd5269fdf60dcfd |
++--+
+1 row selected (1.282 seconds)
+0: jdbc:flink://localhost:8083> SELECT * FROM T;
++---+---+
+| a |   b   |
++---+---+
+| 1 | Hi|
+| 2 | Hello |
++---+---+
+2 rows selected (1.955 seconds)
+0: jdbc:flink://localhost:8083>
+```
+
+**More Information**
+* 
[Documentation](https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/dev/table/jdbcdriver/)
 
+* [FLIP-293: Introduce Flink Jdbc Driver For SQL 
Gateway](https://cwiki.apache.org/confluence/display/FLINK/FLIP-293%3A+Introduce+Flink+Jdbc+Driver+For+Sql+Gateway)
+
+
+### Stored Procedure Support for Flink Connectors
+
+Stored procedures have been an indispensable tool in traditional databases,
+offering a convenient way to encapsulate complex logic for data manipulation
+and administrative tasks. They also offer the potential for enhanced
+performance, since they can trigger the handling of data operations directly
+within an external database. Other popular data systems like Trino and Iceberg
+automate and simplify common maintenance tasks into small sets of procedures,
+which greatly reduces users' administrative burden.
+
+This new update primarily targets developers of Flink connectors, who can now
+predefine custom stored procedures into connectors via the Catalog interface.
+The primary benefit to users is that connector-specific tasks that previously
+may have required writing custom Flink code can now be replaced with simple
+calls that encapsulate, standardize, and potentially optimize the underlying
+operations. Users can execute procedures using the familiar `CALL` syntax, and
+discover a connector's available procedures with `SHOW PROCEDURES`. Stored
+procedures within connectors improves the extensibility of Flink's SQL and
+Table APIs, and should unlock smoother data access and management for users.
+
+Users can use `CALL` to directly call built-in

[flink-web] branch asf-site updated (8e169ad6e -> f976446f3)

2023-10-26 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a change to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git


from 8e169ad6e [FLINK-33350] Update website for release 1.18.0
 new 4ed5d4caf add announcement blog post for Flink 1.18
 new f976446f3 bump flink version to 1.18.0

The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 docs/config.toml   |   4 +-
 docs/content/posts/2023-10-24-release-1.18.0.md| 597 +
 .../backpressure_monitor.png   | Bin 0 -> 166226 bytes
 .../rescaling_performance.png  | Bin 0 -> 63024 bytes
 .../2023-10-24-release-1.18.0/tpc-ds-benchmark.png | Bin 0 -> 1299594 bytes
 5 files changed, 599 insertions(+), 2 deletions(-)
 create mode 100644 docs/content/posts/2023-10-24-release-1.18.0.md
 create mode 100644 
docs/static/img/blog/2023-10-24-release-1.18.0/backpressure_monitor.png
 create mode 100644 
docs/static/img/blog/2023-10-24-release-1.18.0/rescaling_performance.png
 create mode 100644 
docs/static/img/blog/2023-10-24-release-1.18.0/tpc-ds-benchmark.png

[flink-web] 02/02: bump flink version to 1.18.0

2023-10-26 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git

commit f976446f38e883e8e19c888d5fa314a6c4c9bf08
Author: Konstantin Knauf 
AuthorDate: Fri Oct 20 18:38:27 2023 +0200

bump flink version to 1.18.0
---
 docs/config.toml | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/docs/config.toml b/docs/config.toml
index 8bcc45550..65e4337aa 100644
--- a/docs/config.toml
+++ b/docs/config.toml
@@ -33,8 +33,8 @@ posts = "/:year/:month/:day/:title/"
   # The link to Flink's Jira issues
   FlinkIssuesUrl = "https://issues.apache.org/jira/projects/FLINK/issues/;
 
-  FlinkStableVersion = "1.17.0"
-  FlinkStableShortVersion = "1.17"
+  FlinkStableVersion = "1.18.0"
+  FlinkStableShortVersion = "1.18"
   StateFunStableVersion = "3.3.0"
   StateFunStableShortVersion = "3.3"
   FlinkMLStableVersion = "2.3.0"

[flink-statefun] branch master updated: [hotfix] Update config-map.yaml to helm chart (#313)

2022-07-03 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git


The following commit(s) were added to refs/heads/master by this push:
 new ef8995d0 [hotfix] Update config-map.yaml to helm chart (#313)
ef8995d0 is described below

commit ef8995d0168bc75499137d8fb864884ddf6109d2
Author: Asher Liu 
AuthorDate: Mon Jul 4 03:18:22 2022 +0800

[hotfix] Update config-map.yaml to helm chart (#313)
---
 tools/k8s/templates/config-map.yaml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/tools/k8s/templates/config-map.yaml 
b/tools/k8s/templates/config-map.yaml
index c96e1c54..0165934d 100644
--- a/tools/k8s/templates/config-map.yaml
+++ b/tools/k8s/templates/config-map.yaml
@@ -43,7 +43,7 @@ data:
 execution.savepoint.ignore-unclaimed-state: true
 kubernetes.cluster-id: {{ .Values.ha.id }}
 high-availability: 
org.apache.flink.kubernetes.highavailability.KubernetesHaServicesFactory
-high-availability.storageDir: {{ .Values.ha.dir }
+high-availability.storageDir: {{ .Values.ha.dir }}
 
   log4j-console.properties: |+
 rootLogger.level = INFO

[flink] branch release-1.13 updated: [hotfix] [docs] set Flink version to 1.13.6 in docs

2022-03-15 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.13 by this push:
 new 7315265  [hotfix] [docs] set Flink version to 1.13.6 in docs
7315265 is described below

commit 73152653dcab765f00064a194c74fa98bf87175e
Author: Konstantin Knauf 
AuthorDate: Tue Mar 15 12:50:41 2022 +0100

[hotfix] [docs] set Flink version to 1.13.6 in docs
---
 docs/config.toml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/docs/config.toml b/docs/config.toml
index 12400f3..bc5d8f4 100644
--- a/docs/config.toml
+++ b/docs/config.toml
@@ -34,7 +34,7 @@ pygmentsUseClasses = true
   # we change the version for the complete docs when forking of a release 
branch
   # etc.
   # The full version string as referenced in Maven (e.g. 1.2.1)
-  Version = "1.13.5"
+  Version = "1.13.6"
 
   # For stable releases, leave the bugfix version out (e.g. 1.2). For snapshot
   # release this should be the same as the regular version

[flink] branch release-1.14 updated: [hotfix] set Flink version to 1.14.4 in docs

2022-03-15 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.14 by this push:
 new 132bed9  [hotfix] set Flink version to 1.14.4 in docs
132bed9 is described below

commit 132bed9620d87f63b741f09531383d0ab3ced0da
Author: Konstantin Knauf 
AuthorDate: Tue Mar 15 12:49:23 2022 +0100

[hotfix] set Flink version to 1.14.4 in docs
---
 docs/config.toml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/docs/config.toml b/docs/config.toml
index 6203ccd..964ae06 100644
--- a/docs/config.toml
+++ b/docs/config.toml
@@ -34,7 +34,7 @@ pygmentsUseClasses = true
   # we change the version for the complete docs when forking of a release 
branch
   # etc.
   # The full version string as referenced in Maven (e.g. 1.2.1)
-  Version = "1.14.3"
+  Version = "1.14.4"
 
   # For stable releases, leave the bugfix version out (e.g. 1.2). For snapshot
   # release this should be the same as the regular version

svn commit: r53094 - /release/flink/flink-1.14.3/

2022-03-15 Thread knaufk

Author: knaufk
Date: Tue Mar 15 11:44:47 2022
New Revision: 53094

Log:
Remove Flink 1.14.3

Removed:
release/flink/flink-1.14.3/

[flink-web] branch asf-site updated: Rebuild Website

2022-03-15 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk 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 387bf1f  Rebuild Website
387bf1f is described below

commit 387bf1f3cfbfac4a11f913dc37d43fb44acd1511
Author: Konstantin Knauf 
AuthorDate: Tue Mar 15 12:40:47 2022 +0100

Rebuild Website
---
 content/blog/feed.xml  | 451 -
 content/blog/index.html|  46 ++-
 content/blog/page10/index.html |  44 +-
 content/blog/page11/index.html |  48 ++-
 content/blog/page12/index.html |  44 +-
 content/blog/page13/index.html |  42 +-
 content/blog/page14/index.html |  42 +-
 content/blog/page15/index.html |  42 +-
 content/blog/page16/index.html |  42 +-
 content/blog/page17/index.html |  42 +-
 content/blog/page18/index.html |  27 +-
 content/blog/page2/index.html  |  49 +--
 content/blog/page3/index.html  |  51 ++-
 content/blog/page4/index.html  |  44 +-
 content/blog/page5/index.html  |  42 +-
 content/blog/page6/index.html  |  47 ++-
 content/blog/page7/index.html  |  45 +-
 content/blog/page8/index.html  |  38 +-
 content/blog/page9/index.html  |  38 +-
 content/downloads.html |  33 +-
 content/index.html |   8 +-
 .../news/2022/02/{09 => 18}/release-1.13.6.html|   2 +-
 .../11/release-1.14.4.html}| 164 +++-
 content/q/gradle-quickstart.sh |   2 +-
 content/q/quickstart-scala.sh  |   2 +-
 content/q/quickstart.sh|   2 +-
 content/q/sbt-quickstart.sh|   2 +-
 content/zh/downloads.html  |  37 +-
 content/zh/index.html  |   8 +-
 29 files changed, 776 insertions(+), 708 deletions(-)

diff --git a/content/blog/feed.xml b/content/blog/feed.xml
index 6e7ccc6..c8b120f 100644
--- a/content/blog/feed.xml
+++ b/content/blog/feed.xml
@@ -7,6 +7,171 @@
 https://flink.apache.org/blog/feed.xml; rel="self" 
type="application/rss+xml" />
 
 
+Apache Flink 1.14.4 Release Announcement
+pThe Apache Flink Community is pleased to announce 
another bug fix release for Flink 1.14./p
+
+pThis release includes 51 bug and vulnerability fixes and minor 
improvements for Flink 1.14.
+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:
+a 
href=https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522amp;version=12351074JIRA/a./p;
+
+pWe highly recommend all users to upgrade to Flink 1.14.4./p
+
+h1 id=release-artifactsRelease Artifacts/h1
+
+h2 id=maven-dependenciesMaven Dependencies/h2
+
+div class=highlightprecode 
class=language-xmlspan 
class=ntlt;dependencygt;/span
+  span 
class=ntlt;groupIdgt;/spanorg.apache.flinkspan
 class=ntlt;/groupIdgt;/span
+  span 
class=ntlt;artifactIdgt;/spanflink-javaspan
 class=ntlt;/artifactIdgt;/span
+  span 
class=ntlt;versiongt;/span1.14.4span 
class=ntlt;/versiongt;/span
+span class=ntlt;/dependencygt;/span
+span class=ntlt;dependencygt;/span
+  span 
class=ntlt;groupIdgt;/spanorg.apache.flinkspan
 class=ntlt;/groupIdgt;/span
+  span 
class=ntlt;artifactIdgt;/spanflink-streaming-java_2.11span
 class=ntlt;/artifactIdgt;/span
+  span 
class=ntlt;versiongt;/span1.14.4span 
class=ntlt;/versiongt;/span
+span class=ntlt;/dependencygt;/span
+span class=ntlt;dependencygt;/span
+  span 
class=ntlt;groupIdgt;/spanorg.apache.flinkspan
 class=ntlt;/groupIdgt;/span
+  span 
class=ntlt;artifactIdgt;/spanflink-clients_2.11span
 class=ntlt;/artifactIdgt;/span
+  span 
class=ntlt;versiongt;/span1.14.4span 
class=ntlt;/versiongt;/span
+span 
class=ntlt;/dependencygt;/span/code/pre/div
+
+h2 id=binariesBinaries/h2
+
+pYou can find the binaries on the updated a 
href=/downloads.htmlDownloads page/a./p
+
+h2 id=docker-imagesDocker Images/h2
+
+ul
+  lia 
href=https://hub.docker.com/_/flink?tab=tagsamp;page=1amp;name=1.14.4library/flink/a;
 (official images)/li
+  lia 
href=https://hub.docker.com/r/apache/flink/tags?page=1amp;name=1.14.4apache/flink/a;
 (ASF repository)/li
+/ul
+
+h2 id=pypiPyPi/h2
+
+ul
+  lia 
href=https://pypi.org/project/apache-flink/1.14.4/apache-flink==1.14.4/a/li;
+/ul
+
+h1 id=release-notesRelease Notes/h1
+
+h2Sub-task
+/h2
+ul
+li[a 
href=https://issues.apache.org/jira/browse/FLINK-21788FLINK-21788/a;]
 - Throw

[flink-web] 04/04: add 1.14.4 release blog post

2022-03-15 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git

commit 4d2fc04e50cdcbecfb427effbd03d9443dfcd33c
Author: Konstantin Knauf 
AuthorDate: Fri Feb 25 13:26:05 2022 +0100

add 1.14.4 release blog post
---
 _posts/2022-03-11-release-1.14.4.md | 169 
 1 file changed, 169 insertions(+)

diff --git a/_posts/2022-03-11-release-1.14.4.md 
b/_posts/2022-03-11-release-1.14.4.md
new file mode 100644
index 000..339a22f
--- /dev/null
+++ b/_posts/2022-03-11-release-1.14.4.md
@@ -0,0 +1,169 @@
+---
+layout: post
+title:  "Apache Flink 1.14.4 Release Announcement"
+date: 2022-03-11T08:00:00.000Z
+categories: news
+authors:
+- knaufk:
+  name: "Konstantin Knauf"
+  twitter: "snntrable"
+
+excerpt: The Apache Flink Community is please to announce another bug fix 
release for Flink 1.14.
+
+---
+
+The Apache Flink Community is pleased to announce another bug fix release for 
Flink 1.14.
+
+This release includes 51 bug and vulnerability fixes and minor improvements 
for Flink 1.14.
+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=12351074).
+
+We highly recommend all users to upgrade to Flink 1.14.4.
+
+# Release Artifacts
+
+## Maven Dependencies
+
+```xml
+
+  org.apache.flink
+  flink-java
+  1.14.4
+
+
+  org.apache.flink
+  flink-streaming-java_2.11
+  1.14.4
+
+
+  org.apache.flink
+  flink-clients_2.11
+  1.14.4
+
+```
+
+## 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=1=1.14.4) 
(official images)
+* 
[apache/flink](https://hub.docker.com/r/apache/flink/tags?page=1=1.14.4) 
(ASF repository)
+
+## PyPi
+
+* [apache-flink==1.14.4](https://pypi.org/project/apache-flink/1.14.4/)
+
+# Release Notes
+
+Sub-task
+
+
+[FLINK-21788] - 
Throw PartitionNotFoundException if the partition file has been lost for 
blocking shuffle
+
+[FLINK-24954] - 
Reset read buffer request timeout on buffer recycling for sort-shuffle
+
+[FLINK-25653] - 
Move buffer recycle in SortMergeSubpartitionReader out of lock to avoid 
deadlock
+
+[FLINK-25654] - 
Remove the redundant lock in SortMergeResultPartition
+
+[FLINK-25879] - 
Track used search terms in Matomo
+
+[FLINK-25880] - 
Implement Matomo in Flink documentation
+
+
+
+Bug
+
+
+[FLINK-21752] - 
NullPointerException on restore in PojoSerializer
+
+[FLINK-23946] - 
Application mode fails fatally when being shut down
+
+[FLINK-24334] - 
Configuration kubernetes.flink.log.dir not working
+
+[FLINK-24407] - 
Pulsar connector chinese document link to Pulsar document location 
incorrectly.
+
+[FLINK-24607] - 
SourceCoordinator may miss to close SplitEnumerator when failover frequently
+
+[FLINK-25171] - 
When the DDL statement was executed, the column names of the Derived 
Columns were not validated
+
+[FLINK-25199] - 
StreamEdges are not unique in self-union, which blocks propagation of 
watermarks
+
+[FLINK-25362] - 
Incorrect dependencies in Table Confluent/Avro docs
+
+[FLINK-25407] - 
Network stack deadlock when cancellation happens during initialisation
+
+[FLINK-25466] - 
TTL configuration could parse in StateTtlConfig#DISABLED
+
+[FLINK-25486] - 
Perjob can not recover from checkpoint when zookeeper leader changes
+
+[FLINK-25494] - 
Duplicate element serializer during 
DefaultOperatorStateBackendSnapshotStrategy#syncPrepareResources
+
+[FLINK-25678] - 
TaskExecutorStateChangelogStoragesManager.shutdown is not thread-safe
+
+[FLINK-25683] - 
wrong result if table transfrom to DataStream then window process in batch 
mode
+
+[FLINK-25728] - 
Potential memory leaks in StreamMultipleInputProcessor
+
+[FLINK-25732] - 
Dispatcher#requestMultipleJobDetails returns non-serialiable collection
+
+[FLINK-25827] - 
Potential memory leaks in SourceOperator
+
+[FLINK-25856] - 
Fix use of UserDefinedType in from_elements
+
+[FLINK-25883] - 
The value of DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S is too 
large 
+
+[FLINK-25893] - 
ResourceManagerServiceImpls lifecycle can lead to exceptions
+
+[FLINK-25952] - 
Savepoint on S3 are not relocatable even if entropy injection is not enabled
+
+[FLINK-26039] - 
Incorrect value getter in map unnest table function
+
+[FLINK-26159] - 
Pulsar Connector: should add description MAX_FETCH_RECORD in doc to explain 
slow consumption
+
+[FLINK-26160] - 
Pulsar Con

[flink-web] 03/04: [hotfix] fix release date of Flink 1.13.6

2022-03-15 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git

commit 72b187448a1cbb90afebb5e4f1c966e0fa3fc3ad
Author: Konstantin Knauf 
AuthorDate: Fri Feb 25 12:30:26 2022 +0100

[hotfix] fix release date of Flink 1.13.6
---
 _config.yml | 2 +-
 _posts/2022-02-18-release-1.13.6.md | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/_config.yml b/_config.yml
index ad04f89..7ba6b8b 100644
--- a/_config.yml
+++ b/_config.yml
@@ -221,7 +221,7 @@ release_archive:
   -
 version_short: "1.13"
 version_long: 1.13.6
-release_date: 2022-02-09
+release_date: 2022-02-18
   -
 version_short: "1.13"
 version_long: 1.13.5
diff --git a/_posts/2022-02-18-release-1.13.6.md 
b/_posts/2022-02-18-release-1.13.6.md
index d01b0f5..ca8b994 100644
--- a/_posts/2022-02-18-release-1.13.6.md
+++ b/_posts/2022-02-18-release-1.13.6.md
@@ -1,7 +1,7 @@
 ---
 layout: post
 title:  "Apache Flink 1.13.6 Release Announcement"
-date: 2022-02-09T08:00:00.000Z
+date: 2022-02-18T08:00:00.000Z
 categories: news
 authors:
 - knaufk:

[flink-web] 01/04: update quickstarts for Flink 1.14.4

2022-03-15 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git

commit 7e863cdd90b0acf7eab4e9c3d91cb5940629846e
Author: Konstantin Knauf 
AuthorDate: Fri Feb 25 12:28:56 2022 +0100

update quickstarts for Flink 1.14.4
---
 q/gradle-quickstart.sh | 2 +-
 q/quickstart-scala.sh  | 2 +-
 q/quickstart.sh| 2 +-
 q/sbt-quickstart.sh| 2 +-
 4 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/q/gradle-quickstart.sh b/q/gradle-quickstart.sh
index 68f61f0..b977c69 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.3}"
+defaultFlinkVersion="${1:-1.14.4}"
 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 bd618b1..f9868ff 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.3}  
\
+  -DarchetypeVersion=${1:-1.14.4}  
\
   -DgroupId=org.myorg.quickstart   \
   -DartifactId=$PACKAGE
\
   -Dversion=0.1
\
diff --git a/q/quickstart.sh b/q/quickstart.sh
index 14e5379..0b1a988 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.3}  
\
+  -DarchetypeVersion=${1:-1.14.4}  
\
   -DgroupId=org.myorg.quickstart   \
   -DartifactId=$PACKAGE
\
   -Dversion=0.1
\
diff --git a/q/sbt-quickstart.sh b/q/sbt-quickstart.sh
index 1c5d849..9669b7b 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.3"
+defaultFlinkVersion="1.14.4"
 
 echo "This script creates a Flink project using Scala and SBT."

[flink-web] 02/04: update config.yaml for Flink 1.14.4

2022-03-15 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git

commit 6bcff3df5fd7a311ca508d3bf30ad38ad83ca061
Author: Konstantin Knauf 
AuthorDate: Fri Feb 25 12:29:38 2022 +0100

update config.yaml for Flink 1.14.4
---
 _config.yml | 33 ++---
 1 file changed, 18 insertions(+), 15 deletions(-)

diff --git a/_config.yml b/_config.yml
index 303db11..ad04f89 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.3
+FLINK_VERSION_STABLE: 1.14.4
 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.3"
+  name: "Apache Flink 1.14.4"
   scala_211:
-id: "1142-download_211"
-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;
+id: "1144-download_211"
+url: 
"https://www.apache.org/dyn/closer.lua/flink/flink-1.14.4/flink-1.14.4-bin-scala_2.11.tgz;
+asc_url: 
"https://downloads.apache.org/flink/flink-1.14.4/flink-1.14.4-bin-scala_2.11.tgz.asc;
+sha512_url: 
"https://downloads.apache.org/flink/flink-1.14.4/flink-1.14.4-bin-scala_2.11.tgz.sha512;
   scala_212:
-id: "1142-download_212"
-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;
+id: "1144-download_212"
+url: 
"https://www.apache.org/dyn/closer.lua/flink/flink-1.14.4/flink-1.14.4-bin-scala_2.12.tgz;
+asc_url: 
"https://downloads.apache.org/flink/flink-1.14.4/flink-1.14.4-bin-scala_2.12.tgz.asc;
+sha512_url: 
"https://downloads.apache.org/flink/flink-1.14.4/flink-1.14.4-bin-scala_2.12.tgz.sha512;
 source_release:
-  name: "Apache Flink 1.14.3"
-  id: "1142-download-source"
-  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;
+  name: "Apache Flink 1.14.4"
+  id: "1144-download-source"
+  url: 
"https://www.apache.org/dyn/closer.lua/flink/flink-1.14.4/flink-1.14.4-src.tgz;
+  asc_url: 
"https://downloads.apache.org/flink/flink-1.14.4/flink-1.14.4-src.tgz.asc;
+  sha512_url: 
"https://downloads.apache.org/flink/flink-1.14.4/flink-1.14.4-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"
@@ -203,6 +203,9 @@ component_releases:
 
 release_archive:
 flink:
+  - version_short: "1.14"
+version_long: 1.14.4
+release_date: 2022-03-02
   -
 version_short: "1.14"
 version_long: 1.14.3

[flink-web] branch asf-site updated (775ff53 -> 4d2fc04)

2022-03-15 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a change to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git.


from 775ff53  Rebuild website
 new 7e863cd  update quickstarts for Flink 1.14.4
 new 6bcff3d  update config.yaml for Flink 1.14.4
 new 72b1874  [hotfix] fix release date of Flink 1.13.6
 new 4d2fc04  add 1.14.4 release blog post

The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 _config.yml |  35 
 _posts/2022-02-18-release-1.13.6.md |   2 +-
 _posts/2022-03-11-release-1.14.4.md | 169 
 q/gradle-quickstart.sh  |   2 +-
 q/quickstart-scala.sh   |   2 +-
 q/quickstart.sh |   2 +-
 q/sbt-quickstart.sh |   2 +-
 7 files changed, 193 insertions(+), 21 deletions(-)
 create mode 100644 _posts/2022-03-11-release-1.14.4.md

[flink-docker] branch dev-1.14 updated: Add GPG key for 1.14.4 release (#108)

2022-03-11 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch dev-1.14
in repository https://gitbox.apache.org/repos/asf/flink-docker.git


The following commit(s) were added to refs/heads/dev-1.14 by this push:
 new e26a46b  Add GPG key for 1.14.4 release (#108)
e26a46b is described below

commit e26a46baae76eae5cf9d9fe3ca8b90e3d60fc4eb
Author: Konstantin Knauf 
AuthorDate: Fri Mar 11 11:45:43 2022 +0100

Add GPG key for 1.14.4 release (#108)
---
 add-version.sh | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/add-version.sh b/add-version.sh
index 61365f3..765ef66 100755
--- a/add-version.sh
+++ b/add-version.sh
@@ -100,6 +100,8 @@ elif [ "$flink_version" = "1.14.2" ]; then
 gpg_key="19F2195E1B4816D765A2C324C2EED7B111D464BA"
 elif [ "$flink_version" = "1.14.3" ]; then
 gpg_key="10409A66C7C2F297C8581C2A12DEE3E4D920A98C"
+elif [ "$flink_version" = "1.14.4" ]; then
+gpg_key="CCFA852FD039380AB3EC36D08C3FB007FE60DEFA"
 else
 error "Missing GPG key ID for this release"
 fi

[flink-docker] branch master updated: Update Dockerfiles for 1.14.4 release (#109)

2022-03-11 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-docker.git


The following commit(s) were added to refs/heads/master by this push:
 new 5f88136  Update Dockerfiles for 1.14.4 release (#109)
5f88136 is described below

commit 5f88136a8cebd45d28d89e2a8d272b233ae98a1c
Author: Konstantin Knauf 
AuthorDate: Fri Mar 11 11:20:39 2022 +0100

Update Dockerfiles for 1.14.4 release (#109)
---
 1.14/scala_2.11-java11-debian/Dockerfile   | 6 +++---
 1.14/scala_2.11-java11-debian/release.metadata | 2 +-
 1.14/scala_2.11-java8-debian/Dockerfile| 6 +++---
 1.14/scala_2.11-java8-debian/release.metadata  | 2 +-
 1.14/scala_2.12-java11-debian/Dockerfile   | 6 +++---
 1.14/scala_2.12-java11-debian/release.metadata | 2 +-
 1.14/scala_2.12-java8-debian/Dockerfile| 6 +++---
 1.14/scala_2.12-java8-debian/release.metadata  | 2 +-
 8 files changed, 16 insertions(+), 16 deletions(-)

diff --git a/1.14/scala_2.11-java11-debian/Dockerfile 
b/1.14/scala_2.11-java11-debian/Dockerfile
index b5228a2..1dc9ea1 100644
--- a/1.14/scala_2.11-java11-debian/Dockerfile
+++ b/1.14/scala_2.11-java11-debian/Dockerfile
@@ -44,9 +44,9 @@ RUN set -ex; \
   gosu nobody true
 
 # Configure Flink version
-ENV 
FLINK_TGZ_URL=https://www.apache.org/dyn/closer.cgi?action=download=flink/flink-1.14.3/flink-1.14.3-bin-scala_2.11.tgz
 \
-
FLINK_ASC_URL=https://www.apache.org/dist/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.11.tgz.asc
 \
-GPG_KEY=10409A66C7C2F297C8581C2A12DEE3E4D920A98C \
+ENV 
FLINK_TGZ_URL=https://www.apache.org/dyn/closer.cgi?action=download=flink/flink-1.14.4/flink-1.14.4-bin-scala_2.11.tgz
 \
+
FLINK_ASC_URL=https://www.apache.org/dist/flink/flink-1.14.4/flink-1.14.4-bin-scala_2.11.tgz.asc
 \
+GPG_KEY=CCFA852FD039380AB3EC36D08C3FB007FE60DEFA \
 CHECK_GPG=true
 
 # Prepare environment
diff --git a/1.14/scala_2.11-java11-debian/release.metadata 
b/1.14/scala_2.11-java11-debian/release.metadata
index 2874668..a8e3b3d 100644
--- a/1.14/scala_2.11-java11-debian/release.metadata
+++ b/1.14/scala_2.11-java11-debian/release.metadata
@@ -1,2 +1,2 @@
-Tags: 1.14.3-scala_2.11-java11, 1.14-scala_2.11-java11, scala_2.11-java11
+Tags: 1.14.4-scala_2.11-java11, 1.14-scala_2.11-java11, scala_2.11-java11
 Architectures: amd64,arm64v8
diff --git a/1.14/scala_2.11-java8-debian/Dockerfile 
b/1.14/scala_2.11-java8-debian/Dockerfile
index 6aff4df..38ed6d0 100644
--- a/1.14/scala_2.11-java8-debian/Dockerfile
+++ b/1.14/scala_2.11-java8-debian/Dockerfile
@@ -44,9 +44,9 @@ RUN set -ex; \
   gosu nobody true
 
 # Configure Flink version
-ENV 
FLINK_TGZ_URL=https://www.apache.org/dyn/closer.cgi?action=download=flink/flink-1.14.3/flink-1.14.3-bin-scala_2.11.tgz
 \
-
FLINK_ASC_URL=https://www.apache.org/dist/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.11.tgz.asc
 \
-GPG_KEY=10409A66C7C2F297C8581C2A12DEE3E4D920A98C \
+ENV 
FLINK_TGZ_URL=https://www.apache.org/dyn/closer.cgi?action=download=flink/flink-1.14.4/flink-1.14.4-bin-scala_2.11.tgz
 \
+
FLINK_ASC_URL=https://www.apache.org/dist/flink/flink-1.14.4/flink-1.14.4-bin-scala_2.11.tgz.asc
 \
+GPG_KEY=CCFA852FD039380AB3EC36D08C3FB007FE60DEFA \
 CHECK_GPG=true
 
 # Prepare environment
diff --git a/1.14/scala_2.11-java8-debian/release.metadata 
b/1.14/scala_2.11-java8-debian/release.metadata
index 6b529bf..83b4a71 100644
--- a/1.14/scala_2.11-java8-debian/release.metadata
+++ b/1.14/scala_2.11-java8-debian/release.metadata
@@ -1,2 +1,2 @@
-Tags: 1.14.3-scala_2.11-java8, 1.14-scala_2.11-java8, scala_2.11-java8, 
1.14.3-scala_2.11, 1.14-scala_2.11, scala_2.11
+Tags: 1.14.4-scala_2.11-java8, 1.14-scala_2.11-java8, scala_2.11-java8, 
1.14.4-scala_2.11, 1.14-scala_2.11, scala_2.11
 Architectures: amd64,arm64v8
diff --git a/1.14/scala_2.12-java11-debian/Dockerfile 
b/1.14/scala_2.12-java11-debian/Dockerfile
index 1bb36d3..56bea5e 100644
--- a/1.14/scala_2.12-java11-debian/Dockerfile
+++ b/1.14/scala_2.12-java11-debian/Dockerfile
@@ -44,9 +44,9 @@ RUN set -ex; \
   gosu nobody true
 
 # Configure Flink version
-ENV 
FLINK_TGZ_URL=https://www.apache.org/dyn/closer.cgi?action=download=flink/flink-1.14.3/flink-1.14.3-bin-scala_2.12.tgz
 \
-
FLINK_ASC_URL=https://www.apache.org/dist/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.12.tgz.asc
 \
-GPG_KEY=10409A66C7C2F297C8581C2A12DEE3E4D920A98C \
+ENV 
FLINK_TGZ_URL=https://www.apache.org/dyn/closer.cgi?action=download=flink/flink-1.14.4/flink-1.14.4-bin-scala_2.12.tgz
 \
+
FLINK_ASC_URL=https://www.apache.org/dist/flink/flink-1.14.4/flink-1.14.4-bin-scala_2.12.tgz.asc
 \
+GPG_KEY=CCFA852FD039380AB3EC36D08C3FB007FE60DEFA \
 CHECK_GPG=true
 
 # Prepare environment
diff --git a/1.14/scala_2.12-java11-debian/release.metadata 
b/1.14/scala_2.12-java11-debian/release.metadata
index ac3e5bc..abf4dd1 100644
--- a/1.14/scala_2.12-java11-debian/release.metadata
+++ b/1.14/scala_2.12-java11

[flink] annotated tag release-1.14.4 updated (895c609 -> c028828)

2022-03-11 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a change to annotated tag release-1.14.4
in repository https://gitbox.apache.org/repos/asf/flink.git.


*** WARNING: tag release-1.14.4 was modified! ***

from 895c609  (commit)
  to c028828  (tag)
 tagging 895c60940a8a7c95bef1ebe9f92c0baf168be145 (commit)
 replaces pre-apache-rename
  by Konstantin Knauf
  on Fri Mar 11 10:08:53 2022 +0100

- Log -
Release Flink 1.14.4
-BEGIN PGP SIGNATURE-

iQIzBAABCAAdFiEEzPqFL9A5OAqz7DbQjD+wB/5g3voFAmIrEaUACgkQjD+wB/5g
3vo+ow//bDUfIIbor2qqcBKC2Ih3LMUqd/T8kU0ridDYPaa/LvDNPqNgsKwsYrn1
VvYaS6BN0ykj4aAsEjQwD/UnOZWKmfl5Q3YcML15gTd+Li1NtayhzoqAz22B2gy2
DmTy323ewegGamp/MfqT/xzHkHHIGZ9JgeGFmkdTgjTdRFTAwgpyfr314F179jbW
x7LS85bRUpZK3VQf4spSL65+2G8Oy8yMBpuU9yAyypr9I/0IKPjWMDUwYX+b4DQ4
NTSf1L5Wvn9f7Mj4WVSuIHRg0KaIDFT+gVyIqxK5AEqRujQDqnNYsjGsX8HQ089L
cX6L5XVLLDfvQIZxrxpbtbi2pts6A6nxz6o2rcPP77grin6Wv4nxm0K6fTvrq9ka
hyxvrkVJ0WgHKLeP/HzYihfIFOlIAZBBx/RHywMSsdPbYewLY+KEkAspAw3rlLqr
tCyPqdyZQk+i56bOaVTe45CksTXW6kWkbtb7gCgfrsMrxBF31GEyP7qeDNqv0/2l
6zqCPliMmyKAJKao70a9O8ecVDM7feFPhke+hyd1XehgnSKS7pzggMEBjQDtMIyi
cb5aI7qbz5OzaZ6sW9XMR3y+f/dQUQVlkAaaMjIT59ejm0/IBa5vdglEO9fAaGXL
nqUhCarwKLGzZQLefjoKhV+wbcPQh2wAjWIe5W3xxhAhfHsP7WM=
=0I+S
-END PGP SIGNATURE-
---


No new revisions were added by this update.

Summary of changes:

svn commit: r52977 - /dev/flink/flink-1.14.4-rc1/ /release/flink/flink-1.14.4/

2022-03-11 Thread knaufk

Author: knaufk
Date: Fri Mar 11 09:07:01 2022
New Revision: 52977

Log:
Release Flink 1.14.4

Added:
release/flink/flink-1.14.4/
  - copied from r52976, dev/flink/flink-1.14.4-rc1/
Removed:
dev/flink/flink-1.14.4-rc1/

[flink] branch master updated (7faf8d8 -> 1bb8f9f)

2022-03-02 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


from 7faf8d8  [hotfix][Pattern Recognition][docs] Fixed an issue that the 
example of “Time constraint” omits a comma.
 add 1bb8f9f  [hotfix] improvements to savepoint docs (#18909)

No new revisions were added by this update.

Summary of changes:
 docs/content/docs/ops/state/savepoints.md | 99 ---
 1 file changed, 39 insertions(+), 60 deletions(-)

[flink] branch master updated (1947fb1 -> 176aaed)

2022-03-01 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


from 1947fb1  [hotfix][docs][table] Fix docs for SHA1
 add 176aaed  [hotfix] Fix deprecated method call in the docs (#18939)

No new revisions were added by this update.

Summary of changes:
 docs/content.zh/docs/dev/datastream/fault-tolerance/checkpointing.md | 4 ++--
 docs/content.zh/docs/ops/state/checkpoints.md| 2 +-
 docs/content/docs/dev/datastream/fault-tolerance/checkpointing.md| 4 ++--
 docs/content/docs/ops/state/checkpoints.md   | 2 +-
 4 files changed, 6 insertions(+), 6 deletions(-)

[flink] branch release-1.14 updated: [Hotfix][doc] Fix typo in java code demo of ES stream connector page for release-1.14 (#18934)

2022-03-01 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.14 by this push:
 new dc78e66  [Hotfix][doc] Fix typo in java code demo of ES stream 
connector page for release-1.14 (#18934)
dc78e66 is described below

commit dc78e662f6e456fa86f5c0b946c9be7ade0e976b
Author: Roc Marshal 
AuthorDate: Tue Mar 1 16:56:03 2022 +0800

[Hotfix][doc] Fix typo in java code demo of ES stream connector page for 
release-1.14 (#18934)
---
 docs/content.zh/docs/connectors/datastream/elasticsearch.md | 8 
 docs/content/docs/connectors/datastream/elasticsearch.md| 8 
 2 files changed, 8 insertions(+), 8 deletions(-)

diff --git a/docs/content.zh/docs/connectors/datastream/elasticsearch.md 
b/docs/content.zh/docs/connectors/datastream/elasticsearch.md
index 0638573..26090b2 100644
--- a/docs/content.zh/docs/connectors/datastream/elasticsearch.md
+++ b/docs/content.zh/docs/connectors/datastream/elasticsearch.md
@@ -166,10 +166,10 @@ esSinkBuilder.setBulkFlushMaxActions(1);
 // 为内部创建的 REST 客户端提供一个自定义配置信息的 RestClientFactory
 esSinkBuilder.setRestClientFactory(
   restClientBuilder -> {
-restClientBuilder.setDefaultHeaders(...)
-restClientBuilder.setMaxRetryTimeoutMillis(...)
-restClientBuilder.setPathPrefix(...)
-restClientBuilder.setHttpClientConfigCallback(...)
+restClientBuilder.setDefaultHeaders(...);
+restClientBuilder.setMaxRetryTimeoutMillis(...);
+restClientBuilder.setPathPrefix(...);
+restClientBuilder.setHttpClientConfigCallback(...);
   }
 );
 
diff --git a/docs/content/docs/connectors/datastream/elasticsearch.md 
b/docs/content/docs/connectors/datastream/elasticsearch.md
index 30ffd8a..767d0bf 100644
--- a/docs/content/docs/connectors/datastream/elasticsearch.md
+++ b/docs/content/docs/connectors/datastream/elasticsearch.md
@@ -172,10 +172,10 @@ esSinkBuilder.setBulkFlushMaxActions(1);
 // provide a RestClientFactory for custom configuration on the internally 
created REST client
 esSinkBuilder.setRestClientFactory(
   restClientBuilder -> {
-restClientBuilder.setDefaultHeaders(...)
-restClientBuilder.setMaxRetryTimeoutMillis(...)
-restClientBuilder.setPathPrefix(...)
-restClientBuilder.setHttpClientConfigCallback(...)
+restClientBuilder.setDefaultHeaders(...);
+restClientBuilder.setMaxRetryTimeoutMillis(...);
+restClientBuilder.setPathPrefix(...);
+restClientBuilder.setHttpClientConfigCallback(...);
   }
 );

[flink] branch master updated: [hotfix] [docs] Typo in filesystem.md (#18788)

2022-02-28 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
 new 145099b  [hotfix] [docs] Typo in filesystem.md (#18788)
145099b is described below

commit 145099b9446d9b749747c2413923823748369415
Author: oogetyboogety 
AuthorDate: Mon Feb 28 01:47:19 2022 -0700

[hotfix] [docs] Typo in filesystem.md (#18788)

with AvroParquetWriters from ParquetAvroWriters rename
---
 docs/content/docs/connectors/datastream/filesystem.md | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/docs/content/docs/connectors/datastream/filesystem.md 
b/docs/content/docs/connectors/datastream/filesystem.md
index 85224c1..4fce324 100644
--- a/docs/content/docs/connectors/datastream/filesystem.md
+++ b/docs/content/docs/connectors/datastream/filesystem.md
@@ -405,7 +405,7 @@ Schema schema = ...;
 DataStream input = ...;
 
 final FileSink sink = FileSink
-   .forBulkFormat(outputBasePath, 
ParquetAvroWriters.forGenericRecord(schema))
+   .forBulkFormat(outputBasePath, 
AvroParquetWriters.forGenericRecord(schema))
.build();
 
 input.sinkTo(sink);

[flink] branch master updated: [hotfix]fix method name typos (#18904)

2022-02-27 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
 new 1ed9ea2  [hotfix]fix method name typos (#18904)
1ed9ea2 is described below

commit 1ed9ea2815ec34365525f23a66edb27227b3da01
Author: zhangmang 
AuthorDate: Mon Feb 28 02:50:04 2022 +0800

[hotfix]fix method name typos (#18904)
---
 .../apache/flink/table/planner/expressions/TemporalTypesTest.scala| 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/expressions/TemporalTypesTest.scala
 
b/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/expressions/TemporalTypesTest.scala
index 6d46f7c..1029c9f 100644
--- 
a/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/expressions/TemporalTypesTest.scala
+++ 
b/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/expressions/TemporalTypesTest.scala
@@ -283,7 +283,7 @@ class TemporalTypesTest extends ExpressionTestBase {
   }
 
   @Test
-  def tesInvalidCastBetweenNumericAndTimestampLtz(): Unit = {
+  def testInvalidCastBetweenNumericAndTimestampLtz(): Unit = {
 val castFromTimestampLtzExceptionMsg = "The cast from TIMESTAMP_LTZ type 
to" +
   " NUMERIC type is not allowed."
 
@@ -363,7 +363,7 @@ class TemporalTypesTest extends ExpressionTestBase {
   }
 
   @Test
-  def tesInvalidCastBetweenNumericAndTimestamp(): Unit = {
+  def testInvalidCastBetweenNumericAndTimestamp(): Unit = {
 val castFromTimestampExceptionMsg = "The cast from TIMESTAMP type to 
NUMERIC type" +
   " is not allowed. It's recommended to use" +
   " UNIX_TIMESTAMP(CAST(timestamp_col AS STRING)) instead."

[flink] branch master updated: [hotfix][sqlclient][docs] Improved sql client docs (#18855)

2022-02-27 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
 new 538b5d4  [hotfix][sqlclient][docs] Improved sql client docs (#18855)
538b5d4 is described below

commit 538b5d4567976f8744e6155942697ebb37709da7
Author: mans2singh 
AuthorDate: Sun Feb 27 13:48:39 2022 -0500

[hotfix][sqlclient][docs] Improved sql client docs (#18855)
---
 docs/content.zh/docs/dev/table/sqlClient.md | 12 ++--
 docs/content/docs/dev/table/sqlClient.md| 12 ++--
 2 files changed, 12 insertions(+), 12 deletions(-)

diff --git a/docs/content.zh/docs/dev/table/sqlClient.md 
b/docs/content.zh/docs/dev/table/sqlClient.md
index 4f5bf76..2239121 100644
--- a/docs/content.zh/docs/dev/table/sqlClient.md
+++ b/docs/content.zh/docs/dev/table/sqlClient.md
@@ -364,7 +364,7 @@ When using `-i ` option to initialize SQL Client 
session, the followin
 
 When execute queries or insert statements, please enter the interactive mode 
or use the -f option to submit the SQL statements.
 
-Attention If SQL Client meets errors 
in initialization, SQL Client will exit with error messages.
+Attention If SQL Client receives 
errors during initialization, SQL Client will exit with error messages.
 
 ### Dependencies
 
@@ -388,7 +388,7 @@ In both modes, SQL Client supports to parse and execute all 
types of the Flink s
 
 ### Interactive Command Line
 
-In interactive Command Line, the SQL Client reads user inputs and executes the 
statement when getting semicolon (`;`).
+In interactive Command Line, the SQL Client reads user inputs and executes the 
statement terminated by semicolon (`;`).
 
 SQL Client will print success message if the statement is executed 
successfully. When getting errors, SQL Client will also print error messages.
 By default, the error message only contains the error cause. In order to print 
the full exception stack for debugging, please set the
@@ -398,7 +398,7 @@ By default, the error message only contains the error 
cause. In order to print t
 
 SQL Client supports to execute a SQL script file with the `-f` option. SQL 
Client will execute
 statements one by one in the SQL script file and print execution messages for 
each executed statements.
-Once a statement is failed, the SQL Client will exist and all the remaining 
statements will not be executed.
+Once a statement fails, the SQL Client will exit and all the remaining 
statements will not be executed.
 
 An example of such a file is presented below.
 
@@ -445,7 +445,7 @@ This configuration:
 - set the savepoint path,
 - submit a sql job that load the savepoint from the specified savepoint path.
 
-Attention Comparing to interactive 
mode, SQL Client will stop execution and exits when meets errors.
+Attention Compared to the interactive 
mode, SQL Client will stop execution and exit when there are errors.
 
 ### Execute a set of SQL statements
 
@@ -594,9 +594,9 @@ Job ID: 6f922fe5cba87406ff23ae4a7bb79044
 
 Attention The SQL Client does not 
track the status of the running Flink job after submission. The CLI process can 
be shutdown after the submission without affecting the detached query. Flink's 
`restart strategy` takes care of the fault-tolerance. A query can be cancelled 
using Flink's web interface, command-line, or REST API.
 
-However, for batch users, it's more common that the next DML statement 
requires to wait util the
+However, for batch users, it's more common that the next DML statement 
requires waiting until the
 previous DML statement finishes. In order to execute DML statements 
synchronously, you can set
-`table.dml-sync` option true in SQL Client.
+`table.dml-sync` option `true` in SQL Client.
 
 ```sql
 Flink SQL> SET 'table.dml-sync' = 'true';
diff --git a/docs/content/docs/dev/table/sqlClient.md 
b/docs/content/docs/dev/table/sqlClient.md
index 113413a..e9446c5 100644
--- a/docs/content/docs/dev/table/sqlClient.md
+++ b/docs/content/docs/dev/table/sqlClient.md
@@ -410,7 +410,7 @@ When using `-i ` option to initialize SQL Client 
session, the followin
 
 When execute queries or insert statements, please enter the interactive mode 
or use the -f option to submit the SQL statements.
 
-Attention If SQL Client meets errors 
in initialization, SQL Client will exit with error messages.
+Attention If SQL Client receives 
errors during initialization, SQL Client will exit with error messages.
 
 ### Dependencies
 
@@ -437,7 +437,7 @@ In both modes, SQL Client supports to parse and execute all 
types of the Flink s
 
 ### Interactive Command Line
 
-In interactive Command Line, the SQL Client reads user inputs and executes the 
statement when getting semicolon (`;`).
+In interactive Command Line, the SQL Client reads user inputs and executes the 
statement terminated by a semicolon (`;`).
 
 SQL Client will print success message if the statem

svn commit: r52746 - in /dev/flink/flink-1.14.4-rc1: ./ python/

2022-02-25 Thread knaufk

Author: knaufk
Date: Fri Feb 25 13:29:00 2022
New Revision: 52746

Log:
Add flink-1.14.4-rc1

Added:
dev/flink/flink-1.14.4-rc1/
dev/flink/flink-1.14.4-rc1/flink-1.14.4-bin-scala_2.11.tgz   (with props)
dev/flink/flink-1.14.4-rc1/flink-1.14.4-bin-scala_2.11.tgz.asc   (with 
props)
dev/flink/flink-1.14.4-rc1/flink-1.14.4-bin-scala_2.11.tgz.sha512
dev/flink/flink-1.14.4-rc1/flink-1.14.4-bin-scala_2.12.tgz   (with props)
dev/flink/flink-1.14.4-rc1/flink-1.14.4-bin-scala_2.12.tgz.asc   (with 
props)
dev/flink/flink-1.14.4-rc1/flink-1.14.4-bin-scala_2.12.tgz.sha512
dev/flink/flink-1.14.4-rc1/flink-1.14.4-src.tgz   (with props)
dev/flink/flink-1.14.4-rc1/flink-1.14.4-src.tgz.asc   (with props)
dev/flink/flink-1.14.4-rc1/flink-1.14.4-src.tgz.sha512
dev/flink/flink-1.14.4-rc1/python/
dev/flink/flink-1.14.4-rc1/python/apache-flink-1.14.4.tar.gz   (with props)
dev/flink/flink-1.14.4-rc1/python/apache-flink-1.14.4.tar.gz.asc   (with 
props)
dev/flink/flink-1.14.4-rc1/python/apache-flink-1.14.4.tar.gz.sha512
dev/flink/flink-1.14.4-rc1/python/apache-flink-libraries-1.14.4.tar.gz   
(with props)
dev/flink/flink-1.14.4-rc1/python/apache-flink-libraries-1.14.4.tar.gz.asc  
 (with props)

dev/flink/flink-1.14.4-rc1/python/apache-flink-libraries-1.14.4.tar.gz.sha512

dev/flink/flink-1.14.4-rc1/python/apache_flink-1.14.4-cp36-cp36m-macosx_10_9_x86_64.whl
   (with props)

dev/flink/flink-1.14.4-rc1/python/apache_flink-1.14.4-cp36-cp36m-macosx_10_9_x86_64.whl.asc
   (with props)

dev/flink/flink-1.14.4-rc1/python/apache_flink-1.14.4-cp36-cp36m-macosx_10_9_x86_64.whl.sha512

dev/flink/flink-1.14.4-rc1/python/apache_flink-1.14.4-cp36-cp36m-manylinux1_x86_64.whl
   (with props)

dev/flink/flink-1.14.4-rc1/python/apache_flink-1.14.4-cp36-cp36m-manylinux1_x86_64.whl.asc
   (with props)

dev/flink/flink-1.14.4-rc1/python/apache_flink-1.14.4-cp36-cp36m-manylinux1_x86_64.whl.sha512

dev/flink/flink-1.14.4-rc1/python/apache_flink-1.14.4-cp37-cp37m-macosx_10_9_x86_64.whl
   (with props)

dev/flink/flink-1.14.4-rc1/python/apache_flink-1.14.4-cp37-cp37m-macosx_10_9_x86_64.whl.asc
   (with props)

dev/flink/flink-1.14.4-rc1/python/apache_flink-1.14.4-cp37-cp37m-macosx_10_9_x86_64.whl.sha512

dev/flink/flink-1.14.4-rc1/python/apache_flink-1.14.4-cp37-cp37m-manylinux1_x86_64.whl
   (with props)

dev/flink/flink-1.14.4-rc1/python/apache_flink-1.14.4-cp37-cp37m-manylinux1_x86_64.whl.asc
   (with props)

dev/flink/flink-1.14.4-rc1/python/apache_flink-1.14.4-cp37-cp37m-manylinux1_x86_64.whl.sha512

dev/flink/flink-1.14.4-rc1/python/apache_flink-1.14.4-cp38-cp38-macosx_10_9_x86_64.whl
   (with props)

dev/flink/flink-1.14.4-rc1/python/apache_flink-1.14.4-cp38-cp38-macosx_10_9_x86_64.whl.asc
   (with props)

dev/flink/flink-1.14.4-rc1/python/apache_flink-1.14.4-cp38-cp38-macosx_10_9_x86_64.whl.sha512

dev/flink/flink-1.14.4-rc1/python/apache_flink-1.14.4-cp38-cp38-manylinux1_x86_64.whl
   (with props)

dev/flink/flink-1.14.4-rc1/python/apache_flink-1.14.4-cp38-cp38-manylinux1_x86_64.whl.asc
   (with props)

dev/flink/flink-1.14.4-rc1/python/apache_flink-1.14.4-cp38-cp38-manylinux1_x86_64.whl.sha512

Added: dev/flink/flink-1.14.4-rc1/flink-1.14.4-bin-scala_2.11.tgz
==
Binary file - no diff available.

Propchange: dev/flink/flink-1.14.4-rc1/flink-1.14.4-bin-scala_2.11.tgz
--
svn:mime-type = application/gzip

Added: dev/flink/flink-1.14.4-rc1/flink-1.14.4-bin-scala_2.11.tgz.asc
==
Binary file - no diff available.

Propchange: dev/flink/flink-1.14.4-rc1/flink-1.14.4-bin-scala_2.11.tgz.asc
--
svn:mime-type = application/pgp-signature

Added: dev/flink/flink-1.14.4-rc1/flink-1.14.4-bin-scala_2.11.tgz.sha512
==
--- dev/flink/flink-1.14.4-rc1/flink-1.14.4-bin-scala_2.11.tgz.sha512 (added)
+++ dev/flink/flink-1.14.4-rc1/flink-1.14.4-bin-scala_2.11.tgz.sha512 Fri Feb 
25 13:29:00 2022
@@ -0,0 +1 @@
+923f2d08d58d91809940f7d458b797b7099ce566ed635c5456a0e36c3ba5b1a200dd595113ffcdd972304a691baf6222b48f2fe7807c9b6286ff60c930a1df5f
  flink-1.14.4-bin-scala_2.11.tgz

Added: dev/flink/flink-1.14.4-rc1/flink-1.14.4-bin-scala_2.12.tgz
==
Binary file - no diff available.

Propchange: dev/flink/flink-1.14.4-rc1/flink-1.14.4-bin-scala_2.12.tgz
--
svn:mime-type = application/gzip

Added: dev/flink/flink-1.14.4-rc1/flink-1.14.4-bin-scala_2.12.tgz.asc

[flink] annotated tag release-1.14.4-rc1 updated (895c609 -> d3db692)

2022-02-25 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a change to annotated tag release-1.14.4-rc1
in repository https://gitbox.apache.org/repos/asf/flink.git.


*** WARNING: tag release-1.14.4-rc1 was modified! ***

from 895c609  (commit)
  to d3db692  (tag)
 tagging 895c60940a8a7c95bef1ebe9f92c0baf168be145 (commit)
 replaces pre-apache-rename
  by Konstantin Knauf
  on Fri Feb 25 11:58:38 2022 +0100

- Log -
release-1.14.4-rc1
-BEGIN PGP SIGNATURE-

iQIzBAABCAAdFiEEzPqFL9A5OAqz7DbQjD+wB/5g3voFAmIYtl4ACgkQjD+wB/5g
3vrs8g/+NtgVefzyRW8Tx/+9lQy1BGhpcmkvT69WN0iz021ttTZYw2OAfcG00PyW
2tiqca1D0lC1OTJLCn/E+W3fBVnlSUyDGBv+JIB/inCQj9VtUpczbaUd1sDLfvQx
R9vT1JD6PffneYhs+ScES12G8wjsEtPVcfI10NeF09ZOe/f7MmFsYHebqLTrWNEY
YWcWgI/vmBakuuDIEstAylTUF3E8PiIuhFgUvjp8U2glTLJLnfyoHpynwIWfjpqG
dl/KvAN6pKNwYBBfekgdiZHSCTMI/wIC8k3MkK+Nwq+5EwQKI8KNNS1+K84mvVMs
2EKlPMZsXf/KP3QYNSKfqZElQB7zKc5Q+TD8ln6JRy2xbqv2HCJLUK9XMusaRIWq
6OQ/1vGtAQ0ePmV3zFjA5cIq+dUiwsNfoxw8LkTevnQ8o+v+Y5u1z4Q1F7joTrNg
kO4TUelRsiY5M1mKpB8Cs+2Xw8FReSmGRm13wF7xWCVkzYIgEc9KMseFWC+AeB+a
lX62vZ7yX7ClyiyUxZ2kC7nPFy9SXF9s78POzVOGB32hX89v8qufao1Aww4iBjsU
Lo2V368qa9WLNXCda416tSKz87gwvMf++guXQHrSRSFBPh97tm0VRAMLNmztOgYd
BmJ32y6cfAhEyqfq2TgylGU0vaSKn7gJK3RLeqou2cXdvRN2jto=
=FSLj
-END PGP SIGNATURE-
---


No new revisions were added by this update.

Summary of changes:

[flink] branch release-1.13 updated: Update japicmp configuration for 1.13.6

2022-02-18 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.13 by this push:
 new 3d22d95  Update japicmp configuration for 1.13.6
3d22d95 is described below

commit 3d22d95007af0a40d96a1355b2c71edb26eeea91
Author: Konstantin Knauf 
AuthorDate: Fri Feb 18 14:17:19 2022 +0100

Update japicmp configuration for 1.13.6
---
 pom.xml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pom.xml b/pom.xml
index b06edf0..af10c87 100644
--- a/pom.xml
+++ b/pom.xml
@@ -154,7 +154,7 @@ under the License.
For Hadoop 2.7, the minor Hadoop version supported for 
flink-shaded-hadoop-2-uber is 2.7.5
-->

2.7.5
-   1.13.3
+   1.13.6
tools/japicmp-output
2.4.2

[flink-web] branch asf-site updated: Rebuild Website

2022-02-18 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk 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 e25edec  Rebuild Website
e25edec is described below

commit e25edece13009c3a5bb5cba0b382ed27a76ff53a
Author: Konstantin Knauf 
AuthorDate: Fri Feb 18 14:15:05 2022 +0100

Rebuild Website
---
 content/blog/feed.xml   | 247 ---
 content/blog/index.html |  36 ++-
 content/blog/page10/index.html  |  36 ++-
 content/blog/page11/index.html  |  38 ++-
 content/blog/page12/index.html  |  38 ++-
 content/blog/page13/index.html  |  38 ++-
 content/blog/page14/index.html  |  40 ++-
 content/blog/page15/index.html  |  40 ++-
 content/blog/page16/index.html  |  40 ++-
 content/blog/page17/index.html  |  40 ++-
 content/blog/page18/index.html  |  25 ++
 content/blog/page2/index.html   |  38 ++-
 content/blog/page3/index.html   |  40 ++-
 content/blog/page4/index.html   |  38 ++-
 content/blog/page5/index.html   |  38 ++-
 content/blog/page6/index.html   |  41 ++-
 content/blog/page7/index.html   |  39 ++-
 content/blog/page8/index.html   |  36 ++-
 content/blog/page9/index.html   |  36 ++-
 content/downloads.html  |  23 +-
 content/index.html  |   6 +-
 content/news/2022/02/09/release-1.13.6.html | 453 
 content/zh/downloads.html   |  27 +-
 content/zh/index.html   |   6 +-
 24 files changed, 1127 insertions(+), 312 deletions(-)

diff --git a/content/blog/feed.xml b/content/blog/feed.xml
index e85205d..f6928c7 100644
--- a/content/blog/feed.xml
+++ b/content/blog/feed.xml
@@ -7,6 +7,203 @@
 https://flink.apache.org/blog/feed.xml; rel="self" 
type="application/rss+xml" />
 
 
+Apache Flink 1.13.6 Release Announcement
+pThe Apache Flink Community is pleased to announce 
another bug fix release for Flink 1.13./p
+
+pThis release includes 99 bug and vulnerability fixes and minor 
improvements for Flink 1.13 including another upgrade of Apache Log4j (to 
2.17.1).
+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:
+a 
href=https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522amp;version=12351074JIRA/a./p;
+
+pWe highly recommend all users to upgrade to Flink 1.13.6./p
+
+h1 id=release-artifactsRelease Artifacts/h1
+
+h2 id=maven-dependenciesMaven Dependencies/h2
+
+div class=highlightprecode 
class=language-xmlspan 
class=ntlt;dependencygt;/span
+  span 
class=ntlt;groupIdgt;/spanorg.apache.flinkspan
 class=ntlt;/groupIdgt;/span
+  span 
class=ntlt;artifactIdgt;/spanflink-javaspan
 class=ntlt;/artifactIdgt;/span
+  span 
class=ntlt;versiongt;/span1.13.6span 
class=ntlt;/versiongt;/span
+span class=ntlt;/dependencygt;/span
+span class=ntlt;dependencygt;/span
+  span 
class=ntlt;groupIdgt;/spanorg.apache.flinkspan
 class=ntlt;/groupIdgt;/span
+  span 
class=ntlt;artifactIdgt;/spanflink-streaming-java_2.11span
 class=ntlt;/artifactIdgt;/span
+  span 
class=ntlt;versiongt;/span1.13.6span 
class=ntlt;/versiongt;/span
+span class=ntlt;/dependencygt;/span
+span class=ntlt;dependencygt;/span
+  span 
class=ntlt;groupIdgt;/spanorg.apache.flinkspan
 class=ntlt;/groupIdgt;/span
+  span 
class=ntlt;artifactIdgt;/spanflink-clients_2.11span
 class=ntlt;/artifactIdgt;/span
+  span 
class=ntlt;versiongt;/span1.13.6span 
class=ntlt;/versiongt;/span
+span 
class=ntlt;/dependencygt;/span/code/pre/div
+
+h2 id=binariesBinaries/h2
+
+pYou can find the binaries on the updated a 
href=/downloads.htmlDownloads page/a./p
+
+h2 id=docker-imagesDocker Images/h2
+
+ul
+  lia 
href=https://hub.docker.com/_/flink?tab=tagsamp;page=1amp;name=1.13.6library/flink/a;
 (official images)/li
+  lia 
href=https://hub.docker.com/r/apache/flink/tags?page=1amp;name=1.13.6apache/flink/a;
 (ASF repository)/li
+/ul
+
+h2 id=pypiPyPi/h2
+
+ul
+  lia 
href=https://pypi.org/project/apache-flink/1.13.6/apache-flink==1.13.6/a/li;
+/ul
+
+h1 id=release-notesRelease Notes/h1
+
+h2 Bug
+/h2
+ul
+li[a 
href=https://issues.apache.org/jira/browse/FLINK-15987FLINK-15987/a;]
 - SELECT 1.0e0 / 0.0e0 throws NumberFormatException
+/li
+li[a 
href=https://issues.apache.org/jira/browse/FLINK-17914FLINK-17914/a;]
 - HistoryServer deletes cached archives if archive listing fails
+/li
+li[a 
href=https://issues.apache.org/jira/browse/FLINK-20195FLINK-20195/a;]
 - Jobs endpoint returns duplicated jobs
+/li
+li[a 
href=https://issues.apache.org/jira/browse/FLINK-20370FLINK-20370/a;]
 -

svn commit: r52622 - /release/flink/flink-1.13.5/

2022-02-18 Thread knaufk

Author: knaufk
Date: Fri Feb 18 13:20:37 2022
New Revision: 52622

Log:
Remove Flink 1.13.5

Removed:
release/flink/flink-1.13.5/

[flink-web] 01/02: update config.yaml for Flink 1.13.6 release

2022-02-18 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git

commit 393f732d8a53105357bceb221d7493356c07799e
Author: Konstantin Knauf 
AuthorDate: Thu Feb 3 20:35:50 2022 +0100

update config.yaml for Flink 1.13.6 release
---
 _config.yml | 30 +-
 1 file changed, 17 insertions(+), 13 deletions(-)

diff --git a/_config.yml b/_config.yml
index e9f2ac6..de83681 100644
--- a/_config.yml
+++ b/_config.yml
@@ -85,23 +85,23 @@ flink_releases:
   -
 version_short: "1.13"
 binary_release:
-  name: "Apache Flink 1.13.5"
+  name: "Apache Flink 1.13.6"
   scala_211:
-id: "1135-download_211"
-url: 
"https://www.apache.org/dyn/closer.lua/flink/flink-1.13.5/flink-1.13.5-bin-scala_2.11.tgz;
-asc_url: 
"https://downloads.apache.org/flink/flink-1.13.5/flink-1.13.5-bin-scala_2.11.tgz.asc;
-sha512_url: 
"https://downloads.apache.org/flink/flink-1.13.5/flink-1.13.5-bin-scala_2.11.tgz.sha512;
+id: "1136-download_211"
+url: 
"https://www.apache.org/dyn/closer.lua/flink/flink-1.13.6/flink-1.13.6-bin-scala_2.11.tgz;
+asc_url: 
"https://downloads.apache.org/flink/flink-1.13.6/flink-1.13.6-bin-scala_2.11.tgz.asc;
+sha512_url: 
"https://downloads.apache.org/flink/flink-1.13.6/flink-1.13.6-bin-scala_2.11.tgz.sha512;
   scala_212:
-id: "1135-download_212"
-url: 
"https://www.apache.org/dyn/closer.lua/flink/flink-1.13.5/flink-1.13.5-bin-scala_2.12.tgz;
-asc_url: 
"https://downloads.apache.org/flink/flink-1.13.5/flink-1.13.5-bin-scala_2.12.tgz.asc;
-sha512_url: 
"https://downloads.apache.org/flink/flink-1.13.5/flink-1.13.5-bin-scala_2.12.tgz.sha512;
+id: "1136-download_212"
+url: 
"https://www.apache.org/dyn/closer.lua/flink/flink-1.13.6/flink-1.13.6-bin-scala_2.12.tgz;
+asc_url: 
"https://downloads.apache.org/flink/flink-1.13.6/flink-1.13.6-bin-scala_2.12.tgz.asc;
+sha512_url: 
"https://downloads.apache.org/flink/flink-1.13.6/flink-1.13.6-bin-scala_2.12.tgz.sha512;
 source_release:
-  name: "Apache Flink 1.13.5"
+  name: "Apache Flink 1.13.6"
   id: "1135-download-source"
-  url: 
"https://www.apache.org/dyn/closer.lua/flink/flink-1.13.5/flink-1.13.5-src.tgz;
-  asc_url: 
"https://downloads.apache.org/flink/flink-1.13.5/flink-1.13.5-src.tgz.asc;
-  sha512_url: 
"https://downloads.apache.org/flink/flink-1.13.5/flink-1.13.5-src.tgz.sha512;
+  url: 
"https://www.apache.org/dyn/closer.lua/flink/flink-1.13.6/flink-1.13.6-src.tgz;
+  asc_url: 
"https://downloads.apache.org/flink/flink-1.13.6/flink-1.13.6-src.tgz.asc;
+  sha512_url: 
"https://downloads.apache.org/flink/flink-1.13.6/flink-1.13.6-src.tgz.sha512;
 release_notes_url: 
"https://nightlies.apache.org/flink/flink-docs-release-1.13/release-notes/flink-1.13;
   -
 version_short: "1.12"
@@ -217,6 +217,10 @@ release_archive:
 release_date: 2021-09-29
   -
 version_short: "1.13"
+version_long: 1.13.6
+release_date: 2022-02-09
+  -
+version_short: "1.13"
 version_long: 1.13.5
 release_date: 2021-12-16
   -

[flink-web] branch asf-site updated (0cb4b0b -> eec77c0)

2022-02-18 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a change to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git.


from 0cb4b0b  rebuild site
 new 393f732  update config.yaml for Flink 1.13.6 release
 new eec77c0  add 1.13.6 release announcement

The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 _config.yml |  30 +++---
 _posts/2022-02-18-release-1.13.6.md | 201 
 2 files changed, 218 insertions(+), 13 deletions(-)
 create mode 100644 _posts/2022-02-18-release-1.13.6.md

[flink-web] 02/02: add 1.13.6 release announcement

2022-02-18 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git

commit eec77c0fe2fb22bbc0cfc7df10ffb3b88076c67b
Author: Konstantin Knauf 
AuthorDate: Thu Feb 3 20:59:13 2022 +0100

add 1.13.6 release announcement
---
 _posts/2022-02-18-release-1.13.6.md | 201 
 1 file changed, 201 insertions(+)

diff --git a/_posts/2022-02-18-release-1.13.6.md 
b/_posts/2022-02-18-release-1.13.6.md
new file mode 100644
index 000..d01b0f5
--- /dev/null
+++ b/_posts/2022-02-18-release-1.13.6.md
@@ -0,0 +1,201 @@
+---
+layout: post
+title:  "Apache Flink 1.13.6 Release Announcement"
+date: 2022-02-09T08:00:00.000Z
+categories: news
+authors:
+- knaufk:
+  name: "Konstantin Knauf"
+  twitter: "snntrable"
+
+excerpt: The Apache Flink Community is please to announce another bug fix 
release for Flink 1.13.
+
+---
+
+The Apache Flink Community is pleased to announce another bug fix release for 
Flink 1.13.
+
+This release includes 99 bug and vulnerability fixes and minor improvements 
for Flink 1.13 including another upgrade of Apache Log4j (to 2.17.1).
+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=12351074).
+
+We highly recommend all users to upgrade to Flink 1.13.6.
+
+# Release Artifacts
+
+## Maven Dependencies
+
+```xml
+
+  org.apache.flink
+  flink-java
+  1.13.6
+
+
+  org.apache.flink
+  flink-streaming-java_2.11
+  1.13.6
+
+
+  org.apache.flink
+  flink-clients_2.11
+  1.13.6
+
+```
+
+## 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=1=1.13.6) 
(official images)
+* 
[apache/flink](https://hub.docker.com/r/apache/flink/tags?page=1=1.13.6) 
(ASF repository)
+
+## PyPi
+
+* [apache-flink==1.13.6](https://pypi.org/project/apache-flink/1.13.6/)
+
+# Release Notes
+
+ Bug
+
+
+[FLINK-15987] - 
SELECT 1.0e0 / 0.0e0 throws NumberFormatException
+
+[FLINK-17914] - 
HistoryServer deletes cached archives if archive listing fails
+
+[FLINK-20195] - 
Jobs endpoint returns duplicated jobs
+
+[FLINK-20370] - 
Result is wrong when sink primary key is not the same with query
+
+[FLINK-21289] - 
Application mode ignores the pipeline.classpaths configuration
+
+[FLINK-23919] - 
PullUpWindowTableFunctionIntoWindowAggregateRule generates invalid Calc for 
Window TVF
+
+[FLINK-24232] - 
Archiving of suspended jobs prevents breaks subsequent archive attempts
+
+[FLINK-24255] - 
Test Environment / Mini Cluster do not forward configuration.
+
+[FLINK-24310] - 
A bug in the BufferingSink example in the doc
+
+[FLINK-24318] - 
Casting a number to boolean has different results between select 
fields and where condition
+
+[FLINK-24334] - 
Configuration kubernetes.flink.log.dir not working
+
+[FLINK-24366] - 
Unnecessary/misleading error message about failing restores when tasks are 
already canceled.
+
+[FLINK-24401] - 
TM cannot exit after Metaspace OOM
+
+[FLINK-24465] - 
Wrong javadoc and documentation for buffer timeout
+
+[FLINK-24492] - 
incorrect implicit type conversion between numeric and (var)char
+
+[FLINK-24506] - 
checkpoint directory is not configurable through the Flink configuration 
passed into the StreamExecutionEnvironment
+
+[FLINK-24509] - 
FlinkKafkaProducer example is not compiling due to incorrect constructer 
signature used
+
+[FLINK-24540] - 
Fix Resource leak due to Files.list 
+
+[FLINK-24543] - 
Zookeeper connection issue causes inconsistent state in Flink
+
+[FLINK-24563] - 
Comparing timstamp_ltz with random string throws NullPointerException
+
+[FLINK-24597] - 
RocksdbStateBackend getKeysAndNamespaces would return duplicate data when 
using MapState 
+
+[FLINK-24621] - 
JobManager fails to recover 1.13.1 checkpoint due to 
InflightDataRescalingDescriptor
+
+[FLINK-24662] - 
PyFlink sphinx check failed with node class meta is already 
registered, its visitors will be overridden
+
+[FLINK-24667] - 
Channel state writer would fail the task directly if meeting exception 
previously
+
+[FLINK-24676] - 
Schema does not match if explain insert statement with partial column
+
+[FLINK-24678] - 
Correct the metric name of map state contains latency
+
+[FLINK-24708] - 
`ConvertToNotInOrInRule` has a bug which leads to wrong result
+
+[FLINK-24728] - 
Batch SQL file sink forgets to close the output stream
+
+[FLINK-24761] - 
Fix PartitionPruner code ge

[flink-docker] branch dev-1.13 updated: Add GPG key for 1.13.6 release (#104)

2022-02-16 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch dev-1.13
in repository https://gitbox.apache.org/repos/asf/flink-docker.git


The following commit(s) were added to refs/heads/dev-1.13 by this push:
 new 68c0fb9  Add GPG key for 1.13.6 release (#104)
68c0fb9 is described below

commit 68c0fb9bc11a808b363361020b5dca520fbde28f
Author: Konstantin Knauf 
AuthorDate: Thu Feb 17 08:31:23 2022 +0100

Add GPG key for 1.13.6 release (#104)
---
 add-version.sh | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/add-version.sh b/add-version.sh
index e98e4cc..03cdee3 100755
--- a/add-version.sh
+++ b/add-version.sh
@@ -102,6 +102,8 @@ elif [ "$flink_version" = "1.13.4" ]; then
 gpg_key="19F2195E1B4816D765A2C324C2EED7B111D464BA"
 elif [ "$flink_version" = "1.13.5" ]; then
 gpg_key="19F2195E1B4816D765A2C324C2EED7B111D464BA"
+elif [ "$flink_version" = "1.13.6" ]; then
+gpg_key="CCFA852FD039380AB3EC36D08C3FB007FE60DEFA"
 else
 error "Missing GPG key ID for this release"
 fi

[flink-docker] branch master updated: Update Dockerfiles for 1.13.6 release (#105)

2022-02-16 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-docker.git


The following commit(s) were added to refs/heads/master by this push:
 new 3dd2ef7  Update Dockerfiles for 1.13.6 release (#105)
3dd2ef7 is described below

commit 3dd2ef7d59ff91800fc82be1f0f04b01db9080bf
Author: Konstantin Knauf 
AuthorDate: Wed Feb 16 20:39:55 2022 +0100

Update Dockerfiles for 1.13.6 release (#105)
---
 1.13/scala_2.11-java11-debian/Dockerfile   | 6 +++---
 1.13/scala_2.11-java11-debian/release.metadata | 2 +-
 1.13/scala_2.11-java8-debian/Dockerfile| 6 +++---
 1.13/scala_2.11-java8-debian/release.metadata  | 2 +-
 1.13/scala_2.12-java11-debian/Dockerfile   | 6 +++---
 1.13/scala_2.12-java11-debian/release.metadata | 2 +-
 1.13/scala_2.12-java8-debian/Dockerfile| 6 +++---
 1.13/scala_2.12-java8-debian/release.metadata  | 2 +-
 8 files changed, 16 insertions(+), 16 deletions(-)

diff --git a/1.13/scala_2.11-java11-debian/Dockerfile 
b/1.13/scala_2.11-java11-debian/Dockerfile
index 8112da2..f7fad32 100644
--- a/1.13/scala_2.11-java11-debian/Dockerfile
+++ b/1.13/scala_2.11-java11-debian/Dockerfile
@@ -44,9 +44,9 @@ RUN set -ex; \
   gosu nobody true
 
 # Configure Flink version
-ENV 
FLINK_TGZ_URL=https://www.apache.org/dyn/closer.cgi?action=download=flink/flink-1.13.5/flink-1.13.5-bin-scala_2.11.tgz
 \
-
FLINK_ASC_URL=https://www.apache.org/dist/flink/flink-1.13.5/flink-1.13.5-bin-scala_2.11.tgz.asc
 \
-GPG_KEY=19F2195E1B4816D765A2C324C2EED7B111D464BA \
+ENV 
FLINK_TGZ_URL=https://www.apache.org/dyn/closer.cgi?action=download=flink/flink-1.13.6/flink-1.13.6-bin-scala_2.11.tgz
 \
+
FLINK_ASC_URL=https://www.apache.org/dist/flink/flink-1.13.6/flink-1.13.6-bin-scala_2.11.tgz.asc
 \
+GPG_KEY=CCFA852FD039380AB3EC36D08C3FB007FE60DEFA \
 CHECK_GPG=true
 
 # Prepare environment
diff --git a/1.13/scala_2.11-java11-debian/release.metadata 
b/1.13/scala_2.11-java11-debian/release.metadata
index 15e97bb..9c08cc8 100644
--- a/1.13/scala_2.11-java11-debian/release.metadata
+++ b/1.13/scala_2.11-java11-debian/release.metadata
@@ -1,2 +1,2 @@
-Tags: 1.13.5-scala_2.11-java11, 1.13-scala_2.11-java11, scala_2.11-java11
+Tags: 1.13.6-scala_2.11-java11, 1.13-scala_2.11-java11, scala_2.11-java11
 Architectures: amd64
diff --git a/1.13/scala_2.11-java8-debian/Dockerfile 
b/1.13/scala_2.11-java8-debian/Dockerfile
index 3d6aa7b..ace4b73 100644
--- a/1.13/scala_2.11-java8-debian/Dockerfile
+++ b/1.13/scala_2.11-java8-debian/Dockerfile
@@ -44,9 +44,9 @@ RUN set -ex; \
   gosu nobody true
 
 # Configure Flink version
-ENV 
FLINK_TGZ_URL=https://www.apache.org/dyn/closer.cgi?action=download=flink/flink-1.13.5/flink-1.13.5-bin-scala_2.11.tgz
 \
-
FLINK_ASC_URL=https://www.apache.org/dist/flink/flink-1.13.5/flink-1.13.5-bin-scala_2.11.tgz.asc
 \
-GPG_KEY=19F2195E1B4816D765A2C324C2EED7B111D464BA \
+ENV 
FLINK_TGZ_URL=https://www.apache.org/dyn/closer.cgi?action=download=flink/flink-1.13.6/flink-1.13.6-bin-scala_2.11.tgz
 \
+
FLINK_ASC_URL=https://www.apache.org/dist/flink/flink-1.13.6/flink-1.13.6-bin-scala_2.11.tgz.asc
 \
+GPG_KEY=CCFA852FD039380AB3EC36D08C3FB007FE60DEFA \
 CHECK_GPG=true
 
 # Prepare environment
diff --git a/1.13/scala_2.11-java8-debian/release.metadata 
b/1.13/scala_2.11-java8-debian/release.metadata
index ae4190e..0798f06 100644
--- a/1.13/scala_2.11-java8-debian/release.metadata
+++ b/1.13/scala_2.11-java8-debian/release.metadata
@@ -1,2 +1,2 @@
-Tags: 1.13.5-scala_2.11-java8, 1.13-scala_2.11-java8, scala_2.11-java8, 
1.13.5-scala_2.11, 1.13-scala_2.11, scala_2.11
+Tags: 1.13.6-scala_2.11-java8, 1.13-scala_2.11-java8, scala_2.11-java8, 
1.13.6-scala_2.11, 1.13-scala_2.11, scala_2.11
 Architectures: amd64
diff --git a/1.13/scala_2.12-java11-debian/Dockerfile 
b/1.13/scala_2.12-java11-debian/Dockerfile
index f1b1e29..180d048 100644
--- a/1.13/scala_2.12-java11-debian/Dockerfile
+++ b/1.13/scala_2.12-java11-debian/Dockerfile
@@ -44,9 +44,9 @@ RUN set -ex; \
   gosu nobody true
 
 # Configure Flink version
-ENV 
FLINK_TGZ_URL=https://www.apache.org/dyn/closer.cgi?action=download=flink/flink-1.13.5/flink-1.13.5-bin-scala_2.12.tgz
 \
-
FLINK_ASC_URL=https://www.apache.org/dist/flink/flink-1.13.5/flink-1.13.5-bin-scala_2.12.tgz.asc
 \
-GPG_KEY=19F2195E1B4816D765A2C324C2EED7B111D464BA \
+ENV 
FLINK_TGZ_URL=https://www.apache.org/dyn/closer.cgi?action=download=flink/flink-1.13.6/flink-1.13.6-bin-scala_2.12.tgz
 \
+
FLINK_ASC_URL=https://www.apache.org/dist/flink/flink-1.13.6/flink-1.13.6-bin-scala_2.12.tgz.asc
 \
+GPG_KEY=CCFA852FD039380AB3EC36D08C3FB007FE60DEFA \
 CHECK_GPG=true
 
 # Prepare environment
diff --git a/1.13/scala_2.12-java11-debian/release.metadata 
b/1.13/scala_2.12-java11-debian/release.metadata
index 0d5d203..ce57c6a 100644
--- a/1.13/scala_2.12-java11-debian/release.metadata
+++ b/1.13/scala_2.12-java11-debian

[flink-docker] branch master updated (d232f51 -> 6b00930)

2022-02-16 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink-docker.git.


from d232f51  [FLINK-25679] Add support for arm64v8
 add 6b00930  [hotfix] replace example for pull request to 
docker-library/official-images (#106)

No new revisions were added by this update.

Summary of changes:
 README.md | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

svn commit: r52581 - /dev/flink/flink-1.13.6-rc1/ /release/flink/flink-1.13.6/

2022-02-16 Thread knaufk

Author: knaufk
Date: Wed Feb 16 18:11:21 2022
New Revision: 52581

Log:
Release Flink 1.13.6

Added:
release/flink/flink-1.13.6/
  - copied from r52580, dev/flink/flink-1.13.6-rc1/
Removed:
dev/flink/flink-1.13.6-rc1/

[flink] branch master updated (ebfc7c8 -> 2c792d0)

2022-02-16 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


from ebfc7c8  [FLINK-25980][datastream] remove unnecessary condition
 add 2c792d0  [FLINK-25532] Improve Documentation of Flink Docker-Compose 
(#18725)

No new revisions were added by this update.

Summary of changes:
 .../resource-providers/standalone/docker.md| 485 ++---
 1 file changed, 221 insertions(+), 264 deletions(-)

svn commit: r52412 - /dev/flink/flink-1.13.6-rc1/python/

2022-02-05 Thread knaufk

Author: knaufk
Date: Sat Feb  5 20:04:32 2022
New Revision: 52412

Log:
Add flink-1.13.6-rc1 python binaries

Added:
dev/flink/flink-1.13.6-rc1/python/apache-flink-1.13.6.tar.gz   (with props)
dev/flink/flink-1.13.6-rc1/python/apache-flink-1.13.6.tar.gz.asc   (with 
props)
dev/flink/flink-1.13.6-rc1/python/apache-flink-1.13.6.tar.gz.sha512
dev/flink/flink-1.13.6-rc1/python/apache-flink-libraries-1.13.6.tar.gz   
(with props)
dev/flink/flink-1.13.6-rc1/python/apache-flink-libraries-1.13.6.tar.gz.asc  
 (with props)

dev/flink/flink-1.13.6-rc1/python/apache-flink-libraries-1.13.6.tar.gz.sha512

dev/flink/flink-1.13.6-rc1/python/apache_flink-1.13.6-cp36-cp36m-macosx_10_9_x86_64.whl
   (with props)

dev/flink/flink-1.13.6-rc1/python/apache_flink-1.13.6-cp36-cp36m-macosx_10_9_x86_64.whl.asc
   (with props)

dev/flink/flink-1.13.6-rc1/python/apache_flink-1.13.6-cp36-cp36m-macosx_10_9_x86_64.whl.sha512

dev/flink/flink-1.13.6-rc1/python/apache_flink-1.13.6-cp36-cp36m-manylinux1_x86_64.whl
   (with props)

dev/flink/flink-1.13.6-rc1/python/apache_flink-1.13.6-cp36-cp36m-manylinux1_x86_64.whl.asc
   (with props)

dev/flink/flink-1.13.6-rc1/python/apache_flink-1.13.6-cp36-cp36m-manylinux1_x86_64.whl.sha512

dev/flink/flink-1.13.6-rc1/python/apache_flink-1.13.6-cp37-cp37m-macosx_10_9_x86_64.whl
   (with props)

dev/flink/flink-1.13.6-rc1/python/apache_flink-1.13.6-cp37-cp37m-macosx_10_9_x86_64.whl.asc
   (with props)

dev/flink/flink-1.13.6-rc1/python/apache_flink-1.13.6-cp37-cp37m-macosx_10_9_x86_64.whl.sha512

dev/flink/flink-1.13.6-rc1/python/apache_flink-1.13.6-cp37-cp37m-manylinux1_x86_64.whl
   (with props)

dev/flink/flink-1.13.6-rc1/python/apache_flink-1.13.6-cp37-cp37m-manylinux1_x86_64.whl.asc
   (with props)

dev/flink/flink-1.13.6-rc1/python/apache_flink-1.13.6-cp37-cp37m-manylinux1_x86_64.whl.sha512

dev/flink/flink-1.13.6-rc1/python/apache_flink-1.13.6-cp38-cp38-macosx_10_9_x86_64.whl
   (with props)

dev/flink/flink-1.13.6-rc1/python/apache_flink-1.13.6-cp38-cp38-macosx_10_9_x86_64.whl.asc
   (with props)

dev/flink/flink-1.13.6-rc1/python/apache_flink-1.13.6-cp38-cp38-macosx_10_9_x86_64.whl.sha512

dev/flink/flink-1.13.6-rc1/python/apache_flink-1.13.6-cp38-cp38-manylinux1_x86_64.whl
   (with props)

dev/flink/flink-1.13.6-rc1/python/apache_flink-1.13.6-cp38-cp38-manylinux1_x86_64.whl.asc
   (with props)

dev/flink/flink-1.13.6-rc1/python/apache_flink-1.13.6-cp38-cp38-manylinux1_x86_64.whl.sha512

Added: dev/flink/flink-1.13.6-rc1/python/apache-flink-1.13.6.tar.gz
==
Binary file - no diff available.

Propchange: dev/flink/flink-1.13.6-rc1/python/apache-flink-1.13.6.tar.gz
--
svn:mime-type = application/gzip

Added: dev/flink/flink-1.13.6-rc1/python/apache-flink-1.13.6.tar.gz.asc
==
Binary file - no diff available.

Propchange: dev/flink/flink-1.13.6-rc1/python/apache-flink-1.13.6.tar.gz.asc
--
svn:mime-type = application/pgp-signature

Added: dev/flink/flink-1.13.6-rc1/python/apache-flink-1.13.6.tar.gz.sha512
==
--- dev/flink/flink-1.13.6-rc1/python/apache-flink-1.13.6.tar.gz.sha512 (added)
+++ dev/flink/flink-1.13.6-rc1/python/apache-flink-1.13.6.tar.gz.sha512 Sat Feb 
 5 20:04:32 2022
@@ -0,0 +1 @@
+dc75d4f430c0113f7574b98fab9c827f1079af16fa858dc7983db1979a6926406530b7a8c18d5da49766ab8ccd3febb715f06f59d5bd45732d18306c263aef11
  apache-flink-1.13.6.tar.gz

Added: dev/flink/flink-1.13.6-rc1/python/apache-flink-libraries-1.13.6.tar.gz
==
Binary file - no diff available.

Propchange: 
dev/flink/flink-1.13.6-rc1/python/apache-flink-libraries-1.13.6.tar.gz
--
svn:mime-type = application/gzip

Added: 
dev/flink/flink-1.13.6-rc1/python/apache-flink-libraries-1.13.6.tar.gz.asc
==
Binary file - no diff available.

Propchange: 
dev/flink/flink-1.13.6-rc1/python/apache-flink-libraries-1.13.6.tar.gz.asc
--
svn:mime-type = application/pgp-signature

Added: 
dev/flink/flink-1.13.6-rc1/python/apache-flink-libraries-1.13.6.tar.gz.sha512
==
--- 
dev/flink/flink-1.13.6-rc1/python/apache-flink-libraries-1.13.6.tar.gz.sha512 
(added)
+++ 
dev/flink/flink-1.13.6-rc1/python/apache-flink-libraries-1.13.6.tar.gz.sha512 
Sat Feb  5 20:04:32 2022
@@ -0,0 +1

svn commit: r52401 - in /dev/flink/flink-1.13.6-rc1: ./ python/

2022-02-04 Thread knaufk

Author: knaufk
Date: Fri Feb  4 13:03:03 2022
New Revision: 52401

Log:
Add flink-1.13.6-rc1

Added:
dev/flink/flink-1.13.6-rc1/
dev/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.11.tgz   (with props)
dev/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.11.tgz.asc   (with 
props)
dev/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.11.tgz.sha512
dev/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.12.tgz   (with props)
dev/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.12.tgz.asc   (with 
props)
dev/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.12.tgz.sha512
dev/flink/flink-1.13.6-rc1/flink-1.13.6-src.tgz   (with props)
dev/flink/flink-1.13.6-rc1/flink-1.13.6-src.tgz.asc   (with props)
dev/flink/flink-1.13.6-rc1/flink-1.13.6-src.tgz.sha512
dev/flink/flink-1.13.6-rc1/python/

Added: dev/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.11.tgz
==
Binary file - no diff available.

Propchange: dev/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.11.tgz
--
svn:mime-type = application/gzip

Added: dev/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.11.tgz.asc
==
Binary file - no diff available.

Propchange: dev/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.11.tgz.asc
--
svn:mime-type = application/pgp-signature

Added: dev/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.11.tgz.sha512
==
--- dev/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.11.tgz.sha512 (added)
+++ dev/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.11.tgz.sha512 Fri Feb  
4 13:03:03 2022
@@ -0,0 +1 @@
+ba943e9beb50ab2bbd9ba831eddccb824ee9bab18245a9ef3367312c7aa193ad063b7470744c4c90fdce5330a4692278844a275972afea366163f6bdd366a911
  flink-1.13.6-bin-scala_2.11.tgz

Added: dev/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.12.tgz
==
Binary file - no diff available.

Propchange: dev/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.12.tgz
--
svn:mime-type = application/gzip

Added: dev/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.12.tgz.asc
==
Binary file - no diff available.

Propchange: dev/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.12.tgz.asc
--
svn:mime-type = application/pgp-signature

Added: dev/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.12.tgz.sha512
==
--- dev/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.12.tgz.sha512 (added)
+++ dev/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.12.tgz.sha512 Fri Feb  
4 13:03:03 2022
@@ -0,0 +1 @@
+281a63b6a3278bbcf988c623c4bf95854bdb473a17b0cee99a0544fd3a60d28f4c23cf079ade3176a956d2572cea528cd2e76cfdd81707a7a90e4c42aa1609e9
  flink-1.13.6-bin-scala_2.12.tgz

Added: dev/flink/flink-1.13.6-rc1/flink-1.13.6-src.tgz
==
Binary file - no diff available.

Propchange: dev/flink/flink-1.13.6-rc1/flink-1.13.6-src.tgz
--
svn:mime-type = application/gzip

Added: dev/flink/flink-1.13.6-rc1/flink-1.13.6-src.tgz.asc
==
Binary file - no diff available.

Propchange: dev/flink/flink-1.13.6-rc1/flink-1.13.6-src.tgz.asc
--
svn:mime-type = application/pgp-signature

Added: dev/flink/flink-1.13.6-rc1/flink-1.13.6-src.tgz.sha512
==
--- dev/flink/flink-1.13.6-rc1/flink-1.13.6-src.tgz.sha512 (added)
+++ dev/flink/flink-1.13.6-rc1/flink-1.13.6-src.tgz.sha512 Fri Feb  4 13:03:03 
2022
@@ -0,0 +1 @@
+fea6e47399614d1b73cbcb8bf25bf933dfb689564c2facf8f0662258b26d57d4157520a6924be59749625359e1589af6ff259e13d377da23f439a3f2a275cb9f
  flink-1.13.6-src.tgz

svn commit: r52400 - /release/flink/flink-1.13.6-rc1/

2022-02-04 Thread knaufk

Author: knaufk
Date: Fri Feb  4 12:45:52 2022
New Revision: 52400

Log:
Remove 1.13.6 RC 1 from release repository

Removed:
release/flink/flink-1.13.6-rc1/

svn commit: r52398 - /release/flink/flink-1.13.6-rc1/

2022-02-04 Thread knaufk

Author: knaufk
Date: Fri Feb  4 12:16:53 2022
New Revision: 52398

Log:
Updated artifacts for Flink 1.13.6 RC1

Modified:
release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.11.tgz
release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.11.tgz.asc
release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.11.tgz.sha512
release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.12.tgz
release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.12.tgz.asc
release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.12.tgz.sha512
release/flink/flink-1.13.6-rc1/flink-1.13.6-src.tgz
release/flink/flink-1.13.6-rc1/flink-1.13.6-src.tgz.asc
release/flink/flink-1.13.6-rc1/flink-1.13.6-src.tgz.sha512

Modified: release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.11.tgz
==
Binary files - no diff available.

Modified: release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.11.tgz.asc
==
Binary files - no diff available.

Modified: release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.11.tgz.sha512
==
--- release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.11.tgz.sha512 
(original)
+++ release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.11.tgz.sha512 Fri 
Feb  4 12:16:53 2022
@@ -1 +1 @@
-5b18c15e48f45124ce70df15e971fe137c00fabeed95e9f2550884920feb08b78e818ef5da2cb18b92419409b8907d51e4b0043fbbef8ba2df2489ddbc584806
  flink-1.13.6-bin-scala_2.11.tgz
+ba943e9beb50ab2bbd9ba831eddccb824ee9bab18245a9ef3367312c7aa193ad063b7470744c4c90fdce5330a4692278844a275972afea366163f6bdd366a911
  flink-1.13.6-bin-scala_2.11.tgz

Modified: release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.12.tgz
==
Binary files - no diff available.

Modified: release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.12.tgz.asc
==
Binary files - no diff available.

Modified: release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.12.tgz.sha512
==
--- release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.12.tgz.sha512 
(original)
+++ release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.12.tgz.sha512 Fri 
Feb  4 12:16:53 2022
@@ -1 +1 @@
-9a1f7dac05fe8faf62d49b1e361018e9cc1d5dfabf4768839406107a93347ce5bd0766a610b475c20129fa25350d5dec3a700ff9bab8d199a5bddd66d00ee578
  flink-1.13.6-bin-scala_2.12.tgz
+281a63b6a3278bbcf988c623c4bf95854bdb473a17b0cee99a0544fd3a60d28f4c23cf079ade3176a956d2572cea528cd2e76cfdd81707a7a90e4c42aa1609e9
  flink-1.13.6-bin-scala_2.12.tgz

Modified: release/flink/flink-1.13.6-rc1/flink-1.13.6-src.tgz
==
Binary files - no diff available.

Modified: release/flink/flink-1.13.6-rc1/flink-1.13.6-src.tgz.asc
==
Binary files - no diff available.

Modified: release/flink/flink-1.13.6-rc1/flink-1.13.6-src.tgz.sha512
==
--- release/flink/flink-1.13.6-rc1/flink-1.13.6-src.tgz.sha512 (original)
+++ release/flink/flink-1.13.6-rc1/flink-1.13.6-src.tgz.sha512 Fri Feb  4 
12:16:53 2022
@@ -1 +1 @@
-b9038fd6b9953141b584689e387b504bcd87ee452db0bf8617a5e9bacd91cb2a7535f30b028f1d4fa11a2238245be3310e89a7cce9f9bfca5f044591b5e9a4f8
  flink-1.13.6-src.tgz
+fea6e47399614d1b73cbcb8bf25bf933dfb689564c2facf8f0662258b26d57d4157520a6924be59749625359e1589af6ff259e13d377da23f439a3f2a275cb9f
  flink-1.13.6-src.tgz

[flink] annotated tag release-1.13.6-rc1 updated (b2ca390 -> b3452a9)

2022-02-04 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a change to annotated tag release-1.13.6-rc1
in repository https://gitbox.apache.org/repos/asf/flink.git.


*** WARNING: tag release-1.13.6-rc1 was modified! ***

from b2ca390  (commit)
  to b3452a9  (tag)
 tagging b2ca390d478aa855eb0f2028d0ed965803a98af1 (commit)
 replaces pre-apache-rename
  by Konstantin Knauf
  on Thu Feb 3 14:55:04 2022 +0100

- Log -
release-1.13.6-rc1
-BEGIN PGP SIGNATURE-

iQIzBAABCAAdFiEEzPqFL9A5OAqz7DbQjD+wB/5g3voFAmH73rgACgkQjD+wB/5g
3vrjZw//TyClw11FIKBM+SjAetpi2r9wks7CeBpzMGf2toYiu4VAzQgsh2SFn2X6
I6O9MCHB+GOYRMi/q21kgtBrRgDj0CAtlM8hevRTn+LVKrxy/cJzznPkTGOfm83g
OuY/i28Hl1EPtocJm27clZaofAOaN0iVWppmr8mKKVp0GDcDtkRWHwkxd10OmV/E
bpiWXQPxI2aNbzad9EqbuF5Wr5HSZ8czDStOZuFEQcltRoB+dsewy0ukrzdI7hBi
pDq38IFpd5OIXBMN99K2KY13vRJRVd05FBdDrceN1hr4H4CbxYUPk0XRTwf1vjCs
mGurMuLrj3NN/1ztgzn/QNJXKuCEYq708R86lg/yWiX4v0ODOk617cR2tiJ1fi8K
mnJxx6bv0ZoYyvQcRfn8w4ranURQD5yMSVGTGWZbsQs6NUNRTt4xmSmjMP4WFXIu
VNfCT/95Z50c/+mBs6KE5+xd3RQwEw3NxkoV8VPK9UQrM2nNJhg+T3HDdqas5BRU
v5T2GrOfrlR0PNJEFp1atD0j29IQRtSNJk6mGVGllrlV5iHvbkC2vM61dSwN6HsH
bfpSdnaff8XEpxSW9FnijuFTBTHn6t2c9dzuDbIAizTEhV6W+Zx21hs/8bXB+HXq
CsB9F9SSSwe+AFsAvmie/erm1VrXnc280YigWaox7WbHi1nxibQ=
=ufFM
-END PGP SIGNATURE-
---


No new revisions were added by this update.

Summary of changes:

svn commit: r52395 - in /release/flink/flink-1.13.6-rc1: ./ python/

2022-02-03 Thread knaufk

Author: knaufk
Date: Fri Feb  4 07:59:14 2022
New Revision: 52395

Log:
Add flink-1.13.6-rc1

Added:
release/flink/flink-1.13.6-rc1/
release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.11.tgz   (with 
props)
release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.11.tgz.asc   (with 
props)
release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.11.tgz.sha512
release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.12.tgz   (with 
props)
release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.12.tgz.asc   (with 
props)
release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.12.tgz.sha512
release/flink/flink-1.13.6-rc1/flink-1.13.6-src.tgz   (with props)
release/flink/flink-1.13.6-rc1/flink-1.13.6-src.tgz.asc   (with props)
release/flink/flink-1.13.6-rc1/flink-1.13.6-src.tgz.sha512
release/flink/flink-1.13.6-rc1/python/

Added: release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.11.tgz
==
Binary file - no diff available.

Propchange: release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.11.tgz
--
svn:mime-type = application/gzip

Added: release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.11.tgz.asc
==
Binary file - no diff available.

Propchange: release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.11.tgz.asc
--
svn:mime-type = application/pgp-signature

Added: release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.11.tgz.sha512
==
--- release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.11.tgz.sha512 
(added)
+++ release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.11.tgz.sha512 Fri 
Feb  4 07:59:14 2022
@@ -0,0 +1 @@
+5b18c15e48f45124ce70df15e971fe137c00fabeed95e9f2550884920feb08b78e818ef5da2cb18b92419409b8907d51e4b0043fbbef8ba2df2489ddbc584806
  flink-1.13.6-bin-scala_2.11.tgz

Added: release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.12.tgz
==
Binary file - no diff available.

Propchange: release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.12.tgz
--
svn:mime-type = application/gzip

Added: release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.12.tgz.asc
==
Binary file - no diff available.

Propchange: release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.12.tgz.asc
--
svn:mime-type = application/pgp-signature

Added: release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.12.tgz.sha512
==
--- release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.12.tgz.sha512 
(added)
+++ release/flink/flink-1.13.6-rc1/flink-1.13.6-bin-scala_2.12.tgz.sha512 Fri 
Feb  4 07:59:14 2022
@@ -0,0 +1 @@
+9a1f7dac05fe8faf62d49b1e361018e9cc1d5dfabf4768839406107a93347ce5bd0766a610b475c20129fa25350d5dec3a700ff9bab8d199a5bddd66d00ee578
  flink-1.13.6-bin-scala_2.12.tgz

Added: release/flink/flink-1.13.6-rc1/flink-1.13.6-src.tgz
==
Binary file - no diff available.

Propchange: release/flink/flink-1.13.6-rc1/flink-1.13.6-src.tgz
--
svn:mime-type = application/gzip

Added: release/flink/flink-1.13.6-rc1/flink-1.13.6-src.tgz.asc
==
Binary file - no diff available.

Propchange: release/flink/flink-1.13.6-rc1/flink-1.13.6-src.tgz.asc
--
svn:mime-type = application/pgp-signature

Added: release/flink/flink-1.13.6-rc1/flink-1.13.6-src.tgz.sha512
==
--- release/flink/flink-1.13.6-rc1/flink-1.13.6-src.tgz.sha512 (added)
+++ release/flink/flink-1.13.6-rc1/flink-1.13.6-src.tgz.sha512 Fri Feb  4 
07:59:14 2022
@@ -0,0 +1 @@
+b9038fd6b9953141b584689e387b504bcd87ee452db0bf8617a5e9bacd91cb2a7535f30b028f1d4fa11a2238245be3310e89a7cce9f9bfca5f044591b5e9a4f8
  flink-1.13.6-src.tgz

[flink] branch master updated (18db2f2 -> e55a42b)

2022-02-02 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


from 18db2f2  [FLINK-25564][tests] Leave cleanup to rule
 add e55a42b  [FLINK-25880][Docs] Implement Matomo in Flink documentation 
(#18577)

No new revisions were added by this update.

Summary of changes:
 docs/layouts/_default/baseof.html | 30 +++---
 1 file changed, 19 insertions(+), 11 deletions(-)

[flink-web] 01/03: [FLINK-25881] Measure visits on flink.apache.org and nightlies.apache.org/flink as the same visit

2022-02-02 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git

commit f78d10f24016698138350abe774bd71a45348722
Author: martijnvisser 
AuthorDate: Tue Feb 1 12:07:08 2022 +0100

[FLINK-25881] Measure visits on flink.apache.org and 
nightlies.apache.org/flink as the same visit
---
 _layouts/base.html | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/_layouts/base.html b/_layouts/base.html
index 1979f8c..69c8566 100755
--- a/_layouts/base.html
+++ b/_layouts/base.html
@@ -33,6 +33,8 @@
   /* tracker methods like "setCustomDimension" should be called before 
"trackPageView" */
   /* We explicitly disable cookie tracking to avoid privacy issues */
   _paq.push(['disableCookies']);
+  /* Measure a visit to flink.apache.org and nightlies.apache.org/flink as 
the same visit */
+  _paq.push(["setDomains", 
["*.flink.apache.org","*.nightlies.apache.org/flink"]]);
   _paq.push(['trackPageView']);
   _paq.push(['enableLinkTracking']);
   (function() {

[flink-web] branch asf-site updated (8df3ed1 -> b88d1c6)

2022-02-02 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a change to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git.


from 8df3ed1  Rebuild website
 new f78d10f  [FLINK-25881] Measure visits on flink.apache.org and 
nightlies.apache.org/flink as the same visit
 new 1b54141  [FLINK-25878] Update privacy policy to reflect change from 
Google Analytics to Matomo
 new b88d1c6  Rebuild website

The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 _layouts/base.html |  2 +
 content/2019/05/03/pulsar-flink.html   |  2 +
 content/2019/05/14/temporal-tables.html|  2 +
 content/2019/05/19/state-ttl.html  |  2 +
 content/2019/06/05/flink-network-stack.html|  2 +
 content/2019/06/26/broadcast-state.html|  2 +
 content/2019/07/23/flink-network-stack-2.html  |  2 +
 content/2020/04/09/pyflink-udf-support-flink.html  |  2 +
 content/2020/07/23/catalogs.html   |  2 +
 ...ql-demo-building-e2e-streaming-application.html |  2 +
 .../08/04/pyflink-pandas-udf-support-flink.html|  2 +
 content/2020/08/19/statefun.html   |  2 +
 .../flink-1.11-memory-management-improvements.html |  2 +
 ...om-aligned-to-unaligned-checkpoints-part-1.html |  2 +
 content/2020/12/15/pipelined-region-sheduling.html |  2 +
 content/2021/01/07/pulsar-flink-connector-270.html |  2 +
 content/2021/01/18/rocksdb.html|  2 +
 content/2021/02/10/native-k8s-with-ha.html |  2 +
 content/2021/03/11/batch-execution-mode.html   |  2 +
 content/2021/05/06/reactive-mode.html  |  2 +
 content/2021/07/07/backpressure.html   |  2 +
 .../2021/09/07/connector-table-sql-api-part1.html  |  2 +
 .../2021/09/07/connector-table-sql-api-part2.html  |  2 +
 content/2021/10/26/sort-shuffle-part1.html |  2 +
 content/2021/10/26/sort-shuffle-part2.html |  2 +
 content/2021/11/03/flink-backward.html |  2 +
 content/2021/12/10/log4j-cve.html  |  2 +
 .../2022/01/04/scheduler-performance-part-one.html |  2 +
 .../2022/01/04/scheduler-performance-part-two.html |  2 +
 content/2022/01/20/pravega-connector-101.html  |  2 +
 content/blog/index.html|  2 +
 content/blog/page10/index.html |  2 +
 content/blog/page11/index.html |  2 +
 content/blog/page12/index.html |  2 +
 content/blog/page13/index.html |  2 +
 content/blog/page14/index.html |  2 +
 content/blog/page15/index.html |  2 +
 content/blog/page16/index.html |  2 +
 content/blog/page17/index.html |  2 +
 content/blog/page18/index.html |  2 +
 content/blog/page2/index.html  |  2 +
 content/blog/page3/index.html  |  2 +
 content/blog/page4/index.html  |  2 +
 content/blog/page5/index.html  |  2 +
 content/blog/page6/index.html  |  2 +
 content/blog/page7/index.html  |  2 +
 content/blog/page8/index.html  |  2 +
 content/blog/page9/index.html  |  2 +
 .../blog/release_1.0.0-changelog_known_issues.html |  2 +
 content/blog/release_1.1.0-changelog.html  |  2 +
 content/blog/release_1.2.0-changelog.html  |  2 +
 content/blog/release_1.3.0-changelog.html  |  2 +
 content/community.html |  2 +
 .../code-style-and-quality-common.html |  2 +
 .../code-style-and-quality-components.html |  2 +
 .../code-style-and-quality-formatting.html |  2 +
 .../contributing/code-style-and-quality-java.html  |  2 +
 .../code-style-and-quality-preamble.html   |  2 +
 .../code-style-and-quality-pull-requests.html  |  2 +
 .../contributing/code-style-and-quality-scala.html |  2 +
 content/contributing/contribute-code.html  |  2 +
 content/contributing/contribute-documentation.html |  2 +
 content/contributing/docs-style.html   |  2 +
 content/contributing/how-to-contribute.html|  2 +
 content/contributing/improve-website.html  |  2 +
 content/contributing/reviewing-prs.html|  2 +
 content/documentation.html |  2 +
 content/downloads.html |  2 +
 content/ecosystem.html |  2 +
 .../apache-beam-how-beam-runs-on-top-of-flink.html |  2 +
 .../2020/06/23/flink-on-zeppelin-part2.html|  2 +
 .../feature/2019/09/13/state-processor-api.html|  2 +

[flink-web] 02/03: [FLINK-25878] Update privacy policy to reflect change from Google Analytics to Matomo

2022-02-02 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git

commit 1b541416811019de2c9ad926db4898a356e12e91
Author: martijnvisser 
AuthorDate: Tue Feb 1 12:07:59 2022 +0100

[FLINK-25878] Update privacy policy to reflect change from Google Analytics 
to Matomo
---
 privacy-policy.md| 46 +-
 privacy-policy.zh.md | 39 +++
 2 files changed, 68 insertions(+), 17 deletions(-)

diff --git a/privacy-policy.md b/privacy-policy.md
index 00867c5..4711813 100644
--- a/privacy-policy.md
+++ b/privacy-policy.md
@@ -2,26 +2,38 @@
 title: "Privacy Policy"
 ---
 
-Information about your use of this website is collected using server access
-logs and a tracking cookie. The collected information consists of the
-following:
+Information about your use of this website is collected using server access 
logs.
+We do this to understand what parts of the website are important to our users, 
+what features are most frequently read up on, where users get lost in the 
documentation, etc. 
+This data allows us to better understand how users use the system, the 
website, and the docs 
+and where to focus improvements next.
+
+The collected information consists of the following:
 
 1. The IP address from which you access the website;
 2. The type of browser and operating system you use to access our site;
 3. The date and time you access our site;
-4. The pages you visit; and
-5. The addresses of pages from where you followed a link to our site.
-
-Part of this information is gathered using a tracking cookie set by the
-[Google Analytics](http://www.google.com/analytics/) service and handled by
-Google as described in their [privacy 
policy](http://www.google.com/privacy.html).
-See your browser documentation for instructions on how to disable the cookie
-if you prefer not to share this data with Google.
-
-We use the gathered information to help us make our site more useful to
-visitors and to better understand how and when our site is used. We do not
-track or collect personally identifiable information or associate gathered
+4. The pages you visit;
+5. If you click on any of the file download links on our website;
+6. The addresses of pages from where you followed a link to our site;
+7. The addresses of pages to where you go to from our site; and
+8. The search terms you use on the website.
+
+This information is gathered and stored using the open source software 
[Matomo](https://matomo.org/).
+We don't use any cookies to collect this information. An IP address is 
anonymized by removing 
+the last two octets from the IP address. That means that if you're IP is 
192.168.100.50, we store it as
+192.168.0.0. 
+
+We do not track or collect personally identifiable information or associate 
gathered
 data with any personally identifying information from other sources.
 
-By using this website, you consent to the collection of this data in the
-manner and for the purpose described above.
\ No newline at end of file
+Matomo is self-hosted on a virtual machine, provided by the Apache Software 
Foundation. 
+It can only be accessed by Flink PMC members and members of the Apache Privacy 
committee. 
+The data can be viewed by anyone by visiting 
[https://matomo.privacy.apache.org/](https://matomo.privacy.apache.org/).
+
+Matomo respects any Do Not Track setting in your browser. You can also opt-out 
from all Matomo tracking below.
+
+https://matomo.privacy.apache.org/index.php?module=CoreAdminHome=optOut=en===14px=%22Helvetica%20Neue%22%2CHelvetica%2CArial%2Csans-serif;
+>
diff --git a/privacy-policy.zh.md b/privacy-policy.zh.md
new file mode 100644
index 000..5ed99d5
--- /dev/null
+++ b/privacy-policy.zh.md
@@ -0,0 +1,39 @@
+---
+title: "Privacy Policy"
+---
+
+Information about your use of this website is collected using server access 
logs.
+We do this to understand what parts of the website are important to our users,
+what features are most frequently read up on, where users get lost in the 
documentation, etc.
+This data allows us to better understand how users use the system, the 
website, and the docs
+and where to focus improvements next.
+
+The collected information consists of the following:
+
+1. The IP address from which you access the website;
+2. The type of browser and operating system you use to access our site;
+3. The date and time you access our site;
+4. The pages you visit;
+5. If you click on any of the file download links on our website;
+6. The addresses of pages from where you followed a link to our site;
+7. The addresses of pages to where you go to from our site; and
+8. The search terms you use on the website.
+
+This information is gathered and stored using the open source software 
[Matomo](https://matomo.org/).
+We don't use any cookies to collect this information. An IP address is

[flink-web] 01/03: [FLINK-25864] Remove Google Analytics implementation

2022-01-28 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git

commit a8bbe1200482c60f90912ff00e989b38d47438c2
Author: martijnvisser 
AuthorDate: Fri Jan 28 11:07:20 2022 +0100

[FLINK-25864] Remove Google Analytics implementation
---
 _layouts/base.html | 11 ---
 downloads.md   | 34 +++---
 downloads.zh.md| 34 +++---
 3 files changed, 22 insertions(+), 57 deletions(-)

diff --git a/_layouts/base.html b/_layouts/base.html
index 551ef03..6b40b87 100755
--- a/_layouts/base.html
+++ b/_layouts/base.html
@@ -63,16 +63,5 @@
 
 
 
-
-
-
-  
(function(i,s,o,g,r,a,m){i['GoogleAnalyticsObject']=r;i[r]=i[r]||function(){
-  (i[r].q=i[r].q||[]).push(arguments)},i[r].l=1*new 
Date();a=s.createElement(o),
-  
m=s.getElementsByTagName(o)[0];a.async=1;a.src=g;m.parentNode.insertBefore(a,m)
-  
})(window,document,'script','//www.google-analytics.com/analytics.js','ga');
-
-  ga('create', 'UA-52545728-1', 'auto');
-  ga('send', 'pageview');
-
   
 
diff --git a/downloads.md b/downloads.md
index 956830c..15a5e19 100644
--- a/downloads.md
+++ b/downloads.md
@@ -4,18 +4,6 @@ title: "Downloads"
 
 
 
-
-$( document ).ready(function() {
-  // Handler for .ready() called.
-  $('.ga-track').click( function () {
-console.log("tracking " + $(this).attr('id'))
-// we just use the element id for tracking with google analytics
-ga('send', 'event', 'button', 'click', $(this).attr('id'));
-  });
-
-});
-
-
 {% toc %}
 
 Apache Flink® {{ site.FLINK_VERSION_STABLE }} is our latest stable release.
@@ -27,7 +15,7 @@ Apache Flink® {{ site.FLINK_VERSION_STABLE }} is our latest 
stable release.
 {% if flink_release.binary_release.scala_211 %}
 
 
-{{ 
flink_release.binary_release.name }} for Scala 2.11 (asc, sha512)
+{{ 
flink_release.binary_release.name }} for Scala 2.11 (asc, sha512)
 
 
 {% endif %}
@@ -35,14 +23,14 @@ Apache Flink® {{ site.FLINK_VERSION_STABLE }} is our latest 
stable release.
 {% if flink_release.binary_release.scala_212 %}
 
 
-{{ 
flink_release.binary_release.name }} for Scala 2.12 (asc, sha512)
+{{ 
flink_release.binary_release.name }} for Scala 2.12 (asc, sha512)
 
 
 {% endif %}
 
 {% if flink_release.source_release %}
 
-{{ flink_release.source_release.name }} 
Source Release
+{{ flink_release.source_release.name }} 
Source Release
 (asc, sha512)
 
 {% endif %}
@@ -59,19 +47,19 @@ Apache Flink® {{ site.FLINK_VERSION_STABLE }} is our latest 
stable release.
 
 {% if component.scala_211 %}
 
-{{ component.name }} for Scala 2.11 (asc, sha1)
+{{ 
component.name }} for Scala 2.11 (asc, sha1)
 
 {% endif %}
 
 {% if component.scala_212 %}
 
-{{ component.name }} for Scala 2.12 (asc, sha1)
+{{ 
component.name }} for Scala 2.12 (asc, sha1)
 
 {% endif %}
 
 {% else %}
 
-{{ 
component.name }} (asc, sha1)
+{{ component.name }} 
(asc, sha1)
 
 {% endif %}
 
@@ -94,7 +82,7 @@ Apache Flink® {{ site.FLINK_VERSION_STABLE }} is our latest 
stable release.
 {% if alternative.scala_211 %}
 
 
-{{ alternative.name }} for Scala 2.11 (asc, sha512)
+{{ alternative.name }} for Scala 2.11 (asc, sha512)
 
 
 {% endif %}
@@ -102,7 +90,7 @@ Apache Flink® {{ site.FLINK_VERSION_STABLE }} is our latest 
stable release.
 {% if alternative.scala_212 %}
 
 
-{{ alternative.name }} for Scala 2.12 (asc, sha512)
+{{ alternative.name }} for Scala 2.12 (asc, sha512)
 
 
 {% endif %}
@@ -126,7 +114,7 @@ Apache Flink® Stateful Functions {{ 
site.FLINK_STATEFUN_VERSION_STABLE }} is th
 ## {{ flink_statefun_release.source_release.name }}
 
 
-{{ 
flink_statefun_release.source_release.name }} Source Release
+{{ 
flink_statefun_release.source_release.name }} Source Release
 (asc, sha512)
 
 
@@ -143,7 +131,7 @@ Apache Flink® ML {{ site.FLINK_ML_VERSION_STABLE }} is the 
latest stable releas
 ## {{ flink_ml_release.source_release.name }}
 
 
-{{ flink_ml_release.source_release.name 
}} Source Release
+{{ flink_ml_release.source_release.name 
}} Source Release
 (asc, sha512)
 
 
@@ -161,7 +149,7 @@ main Flink release:
 {% for additional_component in site.component_releases %}
 
 
-{{ additional_component.name }}
+{{ 
additional_component.name }}
 (asc, {% if 
additional_component.sha512_url %}sha512 {% else %} sha1{% endif %})
 
 
diff --git a/downloads.zh.md b/downloads.zh.md
index c83de2e..32d1225 100644
--- a/downloads.zh.md
+++ b/downloads.zh.md
@@ -4,18 +4,6 @@ title: "下载"
 
 
 
-
-$( document ).ready(function() {
-  // Handler for .ready() called.
-  $('.ga-track').click( function () {
-console.log("tracking " + $(this).attr('id'))
-// we just use the element id for tracking with google analytics
-ga('send', 'event', 'button', 'click', $(this).attr('id'));
-  });
-
-});
-
-
 {% toc %}
 
 Apache Flink® {{ site.FLINK_VERSION_STABLE }} 是我

[flink-web] 02/03: [FLINK-25864] Add Matomo tracking code to base layout

2022-01-28 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git

commit 124c10b1d03e0adf659e11bf4cc17d21cda88bb6
Author: martijnvisser 
AuthorDate: Fri Jan 28 11:12:39 2022 +0100

[FLINK-25864] Add Matomo tracking code to base layout
---
 _layouts/base.html | 17 +
 1 file changed, 17 insertions(+)

diff --git a/_layouts/base.html b/_layouts/base.html
index 6b40b87..a153c5d 100755
--- a/_layouts/base.html
+++ b/_layouts/base.html
@@ -27,6 +27,23 @@
   https://oss.maxcdn.com/html5shiv/3.7.2/html5shiv.min.js&quot</a>;>
   https://oss.maxcdn.com/respond/1.4.2/respond.min.js&quot</a>;>

[flink-web] branch asf-site updated (9f3e4ee -> 52db297)

2022-01-28 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a change to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git.


from 9f3e4ee  Add libenchao to the committer list
 new a8bbe12  [FLINK-25864] Remove Google Analytics implementation
 new 124c10b  [FLINK-25864] Add Matomo tracking code to base layout
 new 52db297  [hotfix] Add 2022 to copyright notice

The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 _layouts/base.html | 30 ++
 downloads.md   | 34 +++---
 downloads.zh.md| 34 +++---
 3 files changed, 40 insertions(+), 58 deletions(-)

[flink-web] 03/03: [hotfix] Add 2022 to copyright notice

2022-01-28 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git

commit 52db297da2769a30776542533835fbdd2fe11e03
Author: martijnvisser 
AuthorDate: Fri Jan 28 11:12:53 2022 +0100

[hotfix] Add 2022 to copyright notice
---
 _layouts/base.html | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/_layouts/base.html b/_layouts/base.html
index a153c5d..1979f8c 100755
--- a/_layouts/base.html
+++ b/_layouts/base.html
@@ -68,7 +68,7 @@
 
 
   
-Copyright © 2014-2021 http://apache.org;>The Apache 
Software Foundation. All Rights Reserved.
+Copyright © 2014-2022 http://apache.org;>The Apache 
Software Foundation. All Rights Reserved.
 Apache Flink, Flink®, Apache®, the squirrel logo, and the Apache 
feather logo are either registered trademarks or trademarks of The Apache 
Software Foundation.
 Privacy Policy 
 RSS feed

svn commit: r52270 - /release/flink/KEYS

2022-01-25 Thread knaufk

Author: knaufk
Date: Tue Jan 25 21:40:52 2022
New Revision: 52270

Log:
Add knaufk's signging key to Apache Flink's KEYS file

Modified:
release/flink/KEYS

Modified: release/flink/KEYS
==
--- release/flink/KEYS (original)
+++ release/flink/KEYS Tue Jan 25 21:40:52 2022
@@ -2530,3 +2530,62 @@ f5hnC+DqlvCuLrAAVjXutdVt9A/yNMkgQkrQ9iYJ
 tYcvi9ykRdAT6B6ydkNAeT/EBDrPeSBgnKXOTv8C1jL8lM/EP28w6Aq8XyReIM0=
 =mAWr
 -END PGP PUBLIC KEY BLOCK-
+pub   rsa4096 2022-01-24 [SC]
+  CCFA852FD039380AB3EC36D08C3FB007FE60DEFA
+uid   [ultimate] Konstantin Knauf (CODE SIGNING KEY) 

+sig 38C3FB007FE60DEFA 2022-01-24  Konstantin Knauf (CODE SIGNING KEY) 

+sub   rsa4096 2022-01-24 [E]
+sig  8C3FB007FE60DEFA 2022-01-24  Konstantin Knauf (CODE SIGNING KEY) 

+
+-BEGIN PGP PUBLIC KEY BLOCK-
+
+mQINBGHusUoBEACuFZ+IvB/k6TZYcU0C1rETPkwewXurb4FJEWL8qm4Q7WmWu4E5
+WyHedtSIAgHpk0qSOJ3l5yh1g5uABiup/XcxopSCNTELh49hvIo/73igFzbbdYYf
+HhT04xvqpb4sb9ErYv0ZWhI4GPrTopAZSIdjAxa5ye3zRQEsWfninDH19xWlFEwi
+q1fGqZwuH2BdzMKAPOrg8CtcND5UyLopmyIOHhrcCstdLeglL6KTEAdpLcbIl9k8
+ZbQVMvI2VY0opcBUFGDWFoSm7yJD3kPapeuR8F27Jz6USV4vf1YV48rsU423N6mW
+qKAH5Z50Pc5pfsWlyIhWzdHpoYTlgrnsYASRXQuofIklnqzjPYRI1gVyCxPKlew3
+ONHyTHJhkWNEkMHOcUfIPA/GDtwB5X4YE9xS7U+yj8fvZFPfHkvtKZCpjq7RL5Bv
+rBRAl564ch95W+e66o1uqVGPMbLhtNUHXNZ6CcDhDrumLiubFXb+OppSug3dil8K
+fqWGaW7cDPEfcTfb6bnST4EsGCZvJbU82N3386jMsPcZzwJFQtlUmuEPfzzEDUgX
+wqoxkzqZcpLLM97e+4xM43Ilgad8R1NX2Qfus0SwtiED1KtZy0JKCwa8rK/q65pX
+8wFKu62QKiGEoYTI7GHWp8Sl9uC1xm6QOuYAejp8qwxbH+ThGv6H8MKuiQARAQAB
+tDdLb25zdGFudGluIEtuYXVmIChDT0RFIFNJR05JTkcgS0VZKSA8a25hdWZrQGFw
+YWNoZS5vcmc+iQJOBBMBCAA4FiEEzPqFL9A5OAqz7DbQjD+wB/5g3voFAmHusUoC
+GwMFCwkIBwIGFQoJCAsCBBYCAwECHgECF4AACgkQjD+wB/5g3vr+eBAAg5UtOn4p
+ier9cKiZSNJSvAg5fJEurfXiJtEqZZNkpFENruuAif6RjnYfNMdy1kf1mrOyn7lS
+Kv3G/fXJlL2fw4oCMpkn99FJppzbFawmqJr3wQuoZ0/h++dJZB9Gu6v2hF4JvHOM
+FGfF9rS7u1M35PSp+Ulott/T60NOq92PJBuM4hzRkHCcYJF1/IOuzEyXaMQmlU7i
+ZeaEwfjTSiiQN89JYNxUz3wsFX2E1xhQhzf0cM/annu0jG1Bd2ydCRepBHOFXcS+
+aTou2leXIeLBNvU9/8rhEzRyWDsIzJK5pn0UDIFN08P9at/fzZV5GaB+iGh/wVYF
+nO+BFoh42FlD8oah8YpG3Xx3lB2XZltUehYdh5thl0JKoRsnv3M5MDRJF3AjDD2L
+kanY8HICnTX0czfwf7WpKn3O9nEXO40yRAEVRV+5zlgex2YkZmG3wrIKwJYMYvCH
+Wf5oaNgsai6iqVaCvVoYZMh+kZyeu/zLceu4xP/KrZij/PIQuOqUGtpCAVhguyOb
+Lvf9n/nR0unU+sOn5tJEu0FUhVeiwIr7o+/+puGvDv7Bbi1qoVDi93ePmOIZ3n+j
+nEPIY8ITgiEENYc5kl+0vHCnhDAIkLqhuwJsW303fGvYkGkNNsBYpEQo4dBklFsa
+rUwI5qorZ3ynmQWFK+dUdOpZjpw4MEnguwm5Ag0EYe6xSgEQAP1hMceScMQWtMoz
+7nIe9AJOr3VrTBm+LDJW/LVXbDq/Co+v3S4GPmqnkfKIOd1iDiqnCAjL8REK4N8S
+ad0Vkk1BFr0q+bl5/yBNioGswlMKNV32b9nqQK14gqC17S+BItbTMPuQQMkk1TE7
+VLsWy9yz0X1Id3RFAi0JaKD+Jtjho8sSZIIpFkJ8x1k3cWrk2jmcGcHm1w2uCYWg
+eEcmleApqeLLpVxEW9DQ9SPZgcUkZuNcLrP78J2eIwig668ysZB3GZYdskGFS0/P
+RJkE52NTB4pPI6F+KzDn3CeYaMZAtpTTROSJof5cR/NcdfPFCJ+bwF7/+wCZ7hr3
+39HfBweD4WyJHBrhgIw+QufUaAm8hKEanNVf+iSQ3czJHv/iDYIAzSMQvvR/G8a1
+wSX0xE5xBXbdey5AB97cQJsP6rPbJ7CXhuf0B4afDq/F/Z0wJDoC0/mG65g3P4N1
+NbwQvXIjwLhBHA0VMnF+IFpQZNH51KE7YvxC09kd/jF2v1wcQ7AxAcHlOjaM2NAh
+xy3ngASCldnJpaFsDiV1mkZLX3Kwl5+TzJqLPR7fNZdD/v/cZRLx6nhQvlOgj7t0
+JyU/yq9MqaJB3/3c6ZtLx8kx6XdTOu2s+gEspZSbBO+L1cXn06oNAvDjdfksN299
+dfwhGeZUZEfseql6LYWuCXkyLi9HABEBAAGJAjYEGAEIACAWIQTM+oUv0Dk4CrPs
+NtCMP7AH/mDe+gUCYe6xSgIbDAAKCRCMP7AH/mDe+tHKEACBf6bdlSuheNqvFA+1
+EAq5mw0VpMQm9R/iJTXp3/8qPXy2sG0J0SLgdw4mF886GOXlSSB2LwRjvqnm6VTY
+Fu9GRm4Ckunk2by8HPKrnoxzAkvYouA/W5y8PC+hsv0asITaMIGq4ouRpYTwwVOq
+os2vcFtJ0pKO9941qAKN/Djwyr0Dn7rNlsuvIF2RSfOdrg+GXGCMx4oni9O6dumi
+OH8uiE5l65yQCRJdlUUIi7aNUnYzhMJ7zE7w9BImTHPHSDi7+MHicsWyYCz7n78w
+rI+iJUXeGNNd4d28LjomCXLtQQn5b9YVzkZdjHg76SNN2dRWp6I9XdY03Tsr17Cs
+6YnM0jdROYdXmwO8+g3LPFWtU6RM3r8ZO/lDi6mOX0mgdDhO7GXclQ0QN1VBsC3j
+jZiApw1NSi3+eYF/fN8O1XZvIZVPGGxZhOBn5zOOGS9n/neYJeOzvLl+mAR8mHMP
+aqiAE1p6Awe4pE3ci0XNI0efld9ih3viTqfdgFEx2XkUN9tcoqjGj+MwfGlRlUIn
+SDy+CiMvakm6JpwZmaNcQo8gZEFbnbZXFer0eRvTd+GwJpIingYEe3gwDtNlPgUc
+yqLDKueNnlzzybSLll20sjps1k2UAiLGCPdqX9NPduB4oxONuBhH+vhiodbBqFAl
+ylriNSVnTevZXjp2uOOo86BeOg==
+=3UZf
+-END PGP PUBLIC KEY BLOCK-

[flink-web] 02/03: [FLINK-25748] tidy up source code section on community page

2022-01-21 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git

commit d63695a8efaaed7df85b7b969c1b7fb8679ff1f8
Author: Konstantin Knauf 
AuthorDate: Fri Jan 21 14:33:30 2022 +0100

[FLINK-25748] tidy up source code section on community page
---
 community.md| 48 ++--
 community.zh.md | 40 
 2 files changed, 38 insertions(+), 50 deletions(-)

diff --git a/community.md b/community.md
index e7b6303..af5af0a 100644
--- a/community.md
+++ b/community.md
@@ -167,41 +167,31 @@ There are plenty of meetups on 
[meetup.com](http://www.meetup.com/topics/apache-
 
 ## Source Code
 
-### Flink core repository
+### Main Repositories
 
-- **ASF repository**: 
[https://gitbox.apache.org/repos/asf/flink.git](https://gitbox.apache.org/repos/asf/flink.git)
-- **GitHub mirror**: 
[https://github.com/apache/flink.git](https://github.com/apache/flink.git)
+* **Flink Core Repository**
+* ASF repository: 
[https://gitbox.apache.org/repos/asf/flink.git](https://gitbox.apache.org/repos/asf/flink.git)
+* GitHub mirror: 
[https://github.com/apache/flink.git](https://github.com/apache/flink.git)
 
-### Flink docker repository
+* **Flink Docker Repository**
+* ASF repository: 
[https://gitbox.apache.org/repos/asf/flink-docker.git](https://gitbox.apache.org/repos/asf/flink-docker.git)
+* GitHub mirror: 
[https://github.com/apache/flink-docker.git](https://github.com/apache/flink-docker.git)
 
-- **ASF repository**: 
[https://gitbox.apache.org/repos/asf/flink-docker.git](https://gitbox.apache.org/repos/asf/flink-docker.git)
-- **GitHub mirror**: 
[https://github.com/apache/flink-docker.git](https://github.com/apache/flink-docker.git)
+* **Flink Stateful Functions Repository**
+   * ASF repository: 
[https://gitbox.apache.org/repos/asf/flink-statefun.git](https://gitbox.apache.org/repos/asf/flink-statefun.git)
+   * GitHub mirror: 
[https://github.com/apache/flink-statefun](https://github.com/apache/flink-statefun)
 
-### Flink Stateful Functions repository
+* **Flink Stateful Functions Docker Repository**
+   * ASF repository: 
[https://gitbox.apache.org/repos/asf/flink-statefun-docker.git](https://gitbox.apache.org/repos/asf/flink-statefun-docker.git)
+   * GitHub mirror: 
[https://github.com/apache/flink-statefun-docker](https://github.com/apache/flink-statefun-docker)
 
-- **ASF repository**: 
[https://gitbox.apache.org/repos/asf/flink-statefun.git](https://gitbox.apache.org/repos/asf/flink-statefun.git)
-- **GitHub mirror**: 
[https://github.com/apache/flink-statefun](https://github.com/apache/flink-statefun)
+* **Flink Website Repository**
+   * ASF repository: 
[https://gitbox.apache.org/repos/asf/flink-web.git](https://gitbox.apache.org/repos/asf/flink-web.git)
+   * GitHub mirror:  
[https://github.com/apache/flink-web.git](https://github.com/apache/flink-web.git)
 
-### Flink Stateful Functions Docker repository
-
-- **ASF repository**: 
[https://gitbox.apache.org/repos/asf/flink-statefun-docker.git](https://gitbox.apache.org/repos/asf/flink-statefun-docker.git)
-- **GitHub mirror**: 
[https://github.com/apache/flink-statefun-docker](https://github.com/apache/flink-statefun-docker)
-
-### Flink-shaded repositories (shaded dependency libraries)
-
-- **ASF repository**: 
[https://gitbox.apache.org/repos/asf/flink-shaded.git](https://gitbox.apache.org/repos/asf/flink-shaded.git)
-- **GitHub mirror**:  
[https://github.com/apache/flink-shaded.git](https://github.com/apache/flink-shaded.git)
-
-### Flink Website repositories
-
-- **ASF repository**: 
[https://gitbox.apache.org/repos/asf/flink-web.git](https://gitbox.apache.org/repos/asf/flink-web.git)
-- **GitHub mirror**:  
[https://github.com/apache/flink-web.git](https://github.com/apache/flink-web.git)
-
-### Bahir Flink repositories (additional connectors)
-
-- **ASF repository**: 
[https://git-wip-us.apache.org/repos/asf/bahir-flink.git](https://git-wip-us.apache.org/repos/asf/bahir-flink.git)
-- **GitHub mirror**:  
[https://github.com/apache/bahir-flink.git](https://github.com/apache/bahir-flink.git)
+### Complete List of Repositories
 
+The complete list of repositories of Apache Flink can be found under 
https://gitbox.apache.org/repos/asf#flink. 
 
 ## Training
 
@@ -215,8 +205,6 @@ The Apache Flink https://cwiki.apache.org/confluence/display/FLINK/Apac
 
 Flink Forward is a conference happening yearly in different locations around 
the world. Up to date information about the conference is available on https://www.flink-forward.org/;>Flink-Forward.org.
 
-
-
 # People
 
 
diff --git a/community.zh.md b/community.zh.md
index 1e10ee1..e563079 100644
--- a/community.zh.md
+++ b/community.zh.md
@@ -165,35 +165,35 @@ Committer 们会关注 [Stack 
Overflow](http://stackoverflow.com/questions/tagge
 
 ## 源代码
 
-### 主仓库
+### Main Repositories
 
-- **ASF 仓库**: 
[ht

[flink-web] 01/03: [hotfix] add Konstantin Knauf as PMC member

2022-01-21 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git

commit 8567da8e6ef3610832d57644392299e3f31d24e6
Author: Konstantin Knauf 
AuthorDate: Fri Jan 21 14:10:46 2022 +0100

[hotfix] add Konstantin Knauf as PMC member
---
 community.md| 2 +-
 community.zh.md | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/community.md b/community.md
index 1d1ff2c..e7b6303 100644
--- a/community.md
+++ b/community.md
@@ -337,7 +337,7 @@ Flink Forward is a conference happening yearly in different 
locations around the
   
 https://avatars0.githubusercontent.com/u/11538663?v=3=50; 
class="committer-avatar">
 Konstantin Knauf
-Committer
+PMC, Committer
 knaufk
   
   
diff --git a/community.zh.md b/community.zh.md
index 020cd9b..1e10ee1 100644
--- a/community.zh.md
+++ b/community.zh.md
@@ -322,7 +322,7 @@ Flink Forward 大会每年都会在世界的不同地方举办。关于大会最
   
 https://avatars0.githubusercontent.com/u/11538663?v=3=50; 
class="committer-avatar">
 Konstantin Knauf
-Committer
+PMC, Committer
 knaufk

[flink-web] branch asf-site updated (104f831 -> 37b6c84)

2022-01-21 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a change to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git.


from 104f831  Rebuild website
 new 8567da8  [hotfix] add Konstantin Knauf as PMC member
 new d63695a  [FLINK-25748] tidy up source code section on community page
 new 37b6c84  rebuild website

The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 community.md  | 50 +++
 community.zh.md   | 42 +++
 content/community.html| 87 ---
 content/zh/community.html | 81 +--
 4 files changed, 117 insertions(+), 143 deletions(-)

[flink-web] 03/03: rebuild website

2022-01-21 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git

commit 37b6c8401d21d729be6c1dfb13f6fe68ff21eb23
Author: Konstantin Knauf 
AuthorDate: Fri Jan 21 17:30:43 2022 +0100

rebuild website
---
 content/community.html| 87 ---
 content/zh/community.html | 81 +--
 2 files changed, 77 insertions(+), 91 deletions(-)

diff --git a/content/community.html b/content/community.html
index 1e73d36..96ce03e 100644
--- a/content/community.html
+++ b/content/community.html
@@ -210,13 +210,8 @@
   Reporting Security Issues
   Meetups
   Source Code

-  Flink core repository
-  Flink docker repository
-  Flink Stateful Functions 
repository
-  Flink Stateful 
Functions Docker repository
-  Flink-shaded
 repositories (shaded dependency libraries)
-  Flink Website repositories
-  Bahir Flink 
repositories (additional connectors)
+  Main Repositories
+  Complete List of 
Repositories
 
   
   Training
@@ -393,54 +388,44 @@
 
 Source Code
 
-Flink core repository
+Main Repositories
 
 
-  ASF repository: https://gitbox.apache.org/repos/asf/flink.git;>https://gitbox.apache.org/repos/asf/flink.git
-  GitHub mirror: https://github.com/apache/flink.git;>https://github.com/apache/flink.git
-
-
-Flink docker repository
-
-
-  ASF repository: https://gitbox.apache.org/repos/asf/flink-docker.git;>https://gitbox.apache.org/repos/asf/flink-docker.git
-  GitHub mirror: https://github.com/apache/flink-docker.git;>https://github.com/apache/flink-docker.git
-
-
-Flink Stateful Functions 
repository
-
-
-  ASF repository: https://gitbox.apache.org/repos/asf/flink-statefun.git;>https://gitbox.apache.org/repos/asf/flink-statefun.git
-  GitHub mirror: https://github.com/apache/flink-statefun;>https://github.com/apache/flink-statefun
-
-
-Flink Stateful Functions 
Docker repository
-
-
-  ASF repository: https://gitbox.apache.org/repos/asf/flink-statefun-docker.git;>https://gitbox.apache.org/repos/asf/flink-statefun-docker.git
-  GitHub mirror: https://github.com/apache/flink-statefun-docker;>https://github.com/apache/flink-statefun-docker
-
-
-Flink-shaded 
repositories (shaded dependency libraries)
-
-
-  ASF repository: https://gitbox.apache.org/repos/asf/flink-shaded.git;>https://gitbox.apache.org/repos/asf/flink-shaded.git
-  GitHub mirror:  https://github.com/apache/flink-shaded.git;>https://github.com/apache/flink-shaded.git
-
-
-Flink Website repositories
-
-
-  ASF repository: https://gitbox.apache.org/repos/asf/flink-web.git;>https://gitbox.apache.org/repos/asf/flink-web.git
-  GitHub mirror:  https://github.com/apache/flink-web.git;>https://github.com/apache/flink-web.git
+  Flink Core Repository
+
+  ASF repository: https://gitbox.apache.org/repos/asf/flink.git;>https://gitbox.apache.org/repos/asf/flink.git
+  GitHub mirror: https://github.com/apache/flink.git;>https://github.com/apache/flink.git
+
+  
+  Flink Docker Repository
+
+  ASF repository: https://gitbox.apache.org/repos/asf/flink-docker.git;>https://gitbox.apache.org/repos/asf/flink-docker.git
+  GitHub mirror: https://github.com/apache/flink-docker.git;>https://github.com/apache/flink-docker.git
+
+  
+  Flink Stateful Functions Repository
+
+  ASF repository: https://gitbox.apache.org/repos/asf/flink-statefun.git;>https://gitbox.apache.org/repos/asf/flink-statefun.git
+  GitHub mirror: https://github.com/apache/flink-statefun;>https://github.com/apache/flink-statefun
+
+  
+  Flink Stateful Functions Docker Repository
+
+  ASF repository: https://gitbox.apache.org/repos/asf/flink-statefun-docker.git;>https://gitbox.apache.org/repos/asf/flink-statefun-docker.git
+  GitHub mirror: https://github.com/apache/flink-statefun-docker;>https://github.com/apache/flink-statefun-docker
+
+  
+  Flink Website Repository
+
+  ASF repository: https://gitbox.apache.org/repos/asf/flink-web.git;>https://gitbox.apache.org/repos/asf/flink-web.git
+  GitHub mirror:  https://github.com/apache/flink-web.git;>https://github.com/apache/flink-web.git
+
+  
 
 
-Bahir Flink 
repositories (additional connectors)
+Complete List of Repositories
 
-
-  ASF repository: https://git-wip-us.apache.org/repos/asf/bahir-flink.git;>https://git-wip-us.apache.org/repos/asf/bahir-flink.git
-  GitHub mirror:  https://github.com/apache/bahir-flink.git;>https://github.com/apache/bahir-flink.git
-
+The complete list of repositories of Apache Flink can be found under 
https://gitbox.apache.org/repos/asf#flink.
 
 Training
 
@@ -574,7 +559,7 @@
   
 https://avatars0.githubusercontent.com/u/11538663?v=3s=50; 
class="committer-avatar" />
 Konstantin Knauf
-Committer
+PMC, Committer
 kn

[flink] branch release-1.14 updated: [FLINK-25375] Update log4j2 dependency to 2.17.0 to address (#18167)

2021-12-25 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.14 by this push:
 new 49971b8  [FLINK-25375] Update log4j2 dependency to 2.17.0 to address 
(#18167)
49971b8 is described below

commit 49971b8a527b81b5e00169d5b187e21a274184e2
Author: Konstantin Knauf 
AuthorDate: Sun Dec 26 08:41:52 2021 +0100

[FLINK-25375] Update log4j2 dependency to 2.17.0 to address (#18167)

CVE-2021-45105

Co-authored-by: Bernard Joseph Jean Bruno 
---
 docs/content.zh/docs/dev/datastream/project-configuration.md | 2 +-
 docs/content/docs/dev/datastream/project-configuration.md| 2 +-
 pom.xml  | 2 +-
 tools/releasing/NOTICE-binary_PREAMBLE.txt   | 8 
 4 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/docs/content.zh/docs/dev/datastream/project-configuration.md 
b/docs/content.zh/docs/dev/datastream/project-configuration.md
index ac1100f..fa8f9ac 100644
--- a/docs/content.zh/docs/dev/datastream/project-configuration.md
+++ b/docs/content.zh/docs/dev/datastream/project-configuration.md
@@ -331,7 +331,7 @@ ext {
 flinkVersion = '1.13-SNAPSHOT'
 scalaBinaryVersion = '2.11'
 slf4jVersion = '1.7.15'
-log4jVersion = '2.16.0'
+log4jVersion = '2.17.0'
 }
 
 
diff --git a/docs/content/docs/dev/datastream/project-configuration.md 
b/docs/content/docs/dev/datastream/project-configuration.md
index 06a822e..a3cd119 100644
--- a/docs/content/docs/dev/datastream/project-configuration.md
+++ b/docs/content/docs/dev/datastream/project-configuration.md
@@ -330,7 +330,7 @@ ext {
 flinkVersion = '1.13-SNAPSHOT'
 scalaBinaryVersion = '2.11'
 slf4jVersion = '1.7.15'
-log4jVersion = '2.16.0'
+log4jVersion = '2.17.0'
 }
 
 
diff --git a/pom.xml b/pom.xml
index c1959d5..ae65b81 100644
--- a/pom.xml
+++ b/pom.xml
@@ -106,7 +106,7 @@ under the License.
18.0
1.8
1.7.15
-   2.16.0
+   2.17.0

diff --git a/tools/releasing/NOTICE-binary_PREAMBLE.txt 
b/tools/releasing/NOTICE-binary_PREAMBLE.txt
index 257fcc70..4613ecc 100644
--- a/tools/releasing/NOTICE-binary_PREAMBLE.txt
+++ b/tools/releasing/NOTICE-binary_PREAMBLE.txt
@@ -8,10 +8,10 @@ Copyright 2014-2021 The Apache Software Foundation
 
 This project bundles the following dependencies under the Apache Software 
License 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt)
 
-- org.apache.logging.log4j:log4j-api:2.16.0
-- org.apache.logging.log4j:log4j-core:2.16.0
-- org.apache.logging.log4j:log4j-slf4j-impl:2.16.0
-- org.apache.logging.log4j:log4j-1.2-api:2.16.0
+- org.apache.logging.log4j:log4j-api:2.17.0
+- org.apache.logging.log4j:log4j-core:2.17.0
+- org.apache.logging.log4j:log4j-slf4j-impl:2.17.0
+- org.apache.logging.log4j:log4j-1.2-api:2.17.0
 
 This project bundles the following dependencies under the BSD license.
 See bundled license files for details.

[flink] branch release-1.12 updated: [FLINK-25375] Update log4j2 dependency to 2.17.0 to address (#18166)

2021-12-25 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch release-1.12
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.12 by this push:
 new 1561f0f  [FLINK-25375] Update log4j2 dependency to 2.17.0 to address 
(#18166)
1561f0f is described below

commit 1561f0f908a96b8efa83e79d44cfe579cb7d29ef
Author: Konstantin Knauf 
AuthorDate: Sun Dec 26 08:41:50 2021 +0100

[FLINK-25375] Update log4j2 dependency to 2.17.0 to address (#18166)

CVE-2021-45105

Co-authored-by: Bernard Joseph Jean Bruno 
---
 docs/dev/project-configuration.md  | 2 +-
 docs/dev/project-configuration.zh.md   | 2 +-
 pom.xml| 2 +-
 tools/releasing/NOTICE-binary_PREAMBLE.txt | 8 
 4 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/docs/dev/project-configuration.md 
b/docs/dev/project-configuration.md
index 36d4610..28172e0 100644
--- a/docs/dev/project-configuration.md
+++ b/docs/dev/project-configuration.md
@@ -326,7 +326,7 @@ ext {
 flinkVersion = '{{ site.version }}'
 scalaBinaryVersion = '{{ site.scala_version }}'
 slf4jVersion = '1.7.15'
-log4jVersion = '2.16.0'
+log4jVersion = '2.17.0'
 }
 
 
diff --git a/docs/dev/project-configuration.zh.md 
b/docs/dev/project-configuration.zh.md
index 3f48dce..dee703c 100644
--- a/docs/dev/project-configuration.zh.md
+++ b/docs/dev/project-configuration.zh.md
@@ -326,7 +326,7 @@ ext {
 flinkVersion = '{{ site.version }}'
 scalaBinaryVersion = '{{ site.scala_version }}'
 slf4jVersion = '1.7.15'
-log4jVersion = '2.16.0'
+log4jVersion = '2.17.0'
 }
 
 
diff --git a/pom.xml b/pom.xml
index cfed76b..b5fcb08 100644
--- a/pom.xml
+++ b/pom.xml
@@ -108,7 +108,7 @@ under the License.
2.5.21
1.8
1.7.15
-   2.12.1
+   2.17.0

diff --git a/tools/releasing/NOTICE-binary_PREAMBLE.txt 
b/tools/releasing/NOTICE-binary_PREAMBLE.txt
index fba3eb0..4613ecc 100644
--- a/tools/releasing/NOTICE-binary_PREAMBLE.txt
+++ b/tools/releasing/NOTICE-binary_PREAMBLE.txt
@@ -8,10 +8,10 @@ Copyright 2014-2021 The Apache Software Foundation
 
 This project bundles the following dependencies under the Apache Software 
License 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt)
 
-- org.apache.logging.log4j:log4j-api:2.12.1
-- org.apache.logging.log4j:log4j-core:2.12.1
-- org.apache.logging.log4j:log4j-slf4j-impl:2.12.1
-- org.apache.logging.log4j:log4j-1.2-api:2.12.1
+- org.apache.logging.log4j:log4j-api:2.17.0
+- org.apache.logging.log4j:log4j-core:2.17.0
+- org.apache.logging.log4j:log4j-slf4j-impl:2.17.0
+- org.apache.logging.log4j:log4j-1.2-api:2.17.0
 
 This project bundles the following dependencies under the BSD license.
 See bundled license files for details.

[flink] branch release-1.13 updated: [FLINK-25375] Update log4j2 dependency to 2.17.0 to address (#18168)

2021-12-25 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.13 by this push:
 new d903739  [FLINK-25375] Update log4j2 dependency to 2.17.0 to address 
(#18168)
d903739 is described below

commit d903739d6cf95bcac4be46eedafe016d6dd02446
Author: Konstantin Knauf 
AuthorDate: Sun Dec 26 08:41:14 2021 +0100

[FLINK-25375] Update log4j2 dependency to 2.17.0 to address (#18168)

CVE-2021-45105

Co-authored-by: Bernard Joseph Jean Bruno 
---
 docs/content.zh/docs/dev/datastream/project-configuration.md | 2 +-
 docs/content/docs/dev/datastream/project-configuration.md| 2 +-
 pom.xml  | 2 +-
 tools/releasing/NOTICE-binary_PREAMBLE.txt   | 8 
 4 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/docs/content.zh/docs/dev/datastream/project-configuration.md 
b/docs/content.zh/docs/dev/datastream/project-configuration.md
index ac1100f..fa8f9ac 100644
--- a/docs/content.zh/docs/dev/datastream/project-configuration.md
+++ b/docs/content.zh/docs/dev/datastream/project-configuration.md
@@ -331,7 +331,7 @@ ext {
 flinkVersion = '1.13-SNAPSHOT'
 scalaBinaryVersion = '2.11'
 slf4jVersion = '1.7.15'
-log4jVersion = '2.16.0'
+log4jVersion = '2.17.0'
 }
 
 
diff --git a/docs/content/docs/dev/datastream/project-configuration.md 
b/docs/content/docs/dev/datastream/project-configuration.md
index 06a822e..a3cd119 100644
--- a/docs/content/docs/dev/datastream/project-configuration.md
+++ b/docs/content/docs/dev/datastream/project-configuration.md
@@ -330,7 +330,7 @@ ext {
 flinkVersion = '1.13-SNAPSHOT'
 scalaBinaryVersion = '2.11'
 slf4jVersion = '1.7.15'
-log4jVersion = '2.16.0'
+log4jVersion = '2.17.0'
 }
 
 
diff --git a/pom.xml b/pom.xml
index 916afef..9562459 100644
--- a/pom.xml
+++ b/pom.xml
@@ -107,7 +107,7 @@ under the License.
2.5.21
1.8
1.7.15
-   2.16.0
+   2.17.0

diff --git a/tools/releasing/NOTICE-binary_PREAMBLE.txt 
b/tools/releasing/NOTICE-binary_PREAMBLE.txt
index 257fcc70..4613ecc 100644
--- a/tools/releasing/NOTICE-binary_PREAMBLE.txt
+++ b/tools/releasing/NOTICE-binary_PREAMBLE.txt
@@ -8,10 +8,10 @@ Copyright 2014-2021 The Apache Software Foundation
 
 This project bundles the following dependencies under the Apache Software 
License 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt)
 
-- org.apache.logging.log4j:log4j-api:2.16.0
-- org.apache.logging.log4j:log4j-core:2.16.0
-- org.apache.logging.log4j:log4j-slf4j-impl:2.16.0
-- org.apache.logging.log4j:log4j-1.2-api:2.16.0
+- org.apache.logging.log4j:log4j-api:2.17.0
+- org.apache.logging.log4j:log4j-core:2.17.0
+- org.apache.logging.log4j:log4j-slf4j-impl:2.17.0
+- org.apache.logging.log4j:log4j-1.2-api:2.17.0
 
 This project bundles the following dependencies under the BSD license.
 See bundled license files for details.

[flink] 01/01: [FLINK-25375] Update log4j2 dependency to 2.17.0 to address CVE-2021-45105

2021-12-21 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch FLINK-25375-112
in repository https://gitbox.apache.org/repos/asf/flink.git

commit f1a79f4e4f24d76d7068d482d64866ca28ad9986
Author: Bernard Joseph Jean Bruno 
AuthorDate: Sun Dec 19 14:27:32 2021 +0400

[FLINK-25375] Update log4j2 dependency to 2.17.0 to address
CVE-2021-45105
---
 docs/dev/project-configuration.md  | 2 +-
 docs/dev/project-configuration.zh.md   | 2 +-
 pom.xml| 2 +-
 tools/releasing/NOTICE-binary_PREAMBLE.txt | 8 
 4 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/docs/dev/project-configuration.md 
b/docs/dev/project-configuration.md
index 36d4610..28172e0 100644
--- a/docs/dev/project-configuration.md
+++ b/docs/dev/project-configuration.md
@@ -326,7 +326,7 @@ ext {
 flinkVersion = '{{ site.version }}'
 scalaBinaryVersion = '{{ site.scala_version }}'
 slf4jVersion = '1.7.15'
-log4jVersion = '2.16.0'
+log4jVersion = '2.17.0'
 }
 
 
diff --git a/docs/dev/project-configuration.zh.md 
b/docs/dev/project-configuration.zh.md
index 3f48dce..dee703c 100644
--- a/docs/dev/project-configuration.zh.md
+++ b/docs/dev/project-configuration.zh.md
@@ -326,7 +326,7 @@ ext {
 flinkVersion = '{{ site.version }}'
 scalaBinaryVersion = '{{ site.scala_version }}'
 slf4jVersion = '1.7.15'
-log4jVersion = '2.16.0'
+log4jVersion = '2.17.0'
 }
 
 
diff --git a/pom.xml b/pom.xml
index cfed76b..b5fcb08 100644
--- a/pom.xml
+++ b/pom.xml
@@ -108,7 +108,7 @@ under the License.
2.5.21
1.8
1.7.15
-   2.12.1
+   2.17.0

diff --git a/tools/releasing/NOTICE-binary_PREAMBLE.txt 
b/tools/releasing/NOTICE-binary_PREAMBLE.txt
index fba3eb0..4613ecc 100644
--- a/tools/releasing/NOTICE-binary_PREAMBLE.txt
+++ b/tools/releasing/NOTICE-binary_PREAMBLE.txt
@@ -8,10 +8,10 @@ Copyright 2014-2021 The Apache Software Foundation
 
 This project bundles the following dependencies under the Apache Software 
License 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt)
 
-- org.apache.logging.log4j:log4j-api:2.12.1
-- org.apache.logging.log4j:log4j-core:2.12.1
-- org.apache.logging.log4j:log4j-slf4j-impl:2.12.1
-- org.apache.logging.log4j:log4j-1.2-api:2.12.1
+- org.apache.logging.log4j:log4j-api:2.17.0
+- org.apache.logging.log4j:log4j-core:2.17.0
+- org.apache.logging.log4j:log4j-slf4j-impl:2.17.0
+- org.apache.logging.log4j:log4j-1.2-api:2.17.0
 
 This project bundles the following dependencies under the BSD license.
 See bundled license files for details.

[flink] branch FLINK-25375-112 created (now f1a79f4)

2021-12-21 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a change to branch FLINK-25375-112
in repository https://gitbox.apache.org/repos/asf/flink.git.


  at f1a79f4  [FLINK-25375] Update log4j2 dependency to 2.17.0 to address 
CVE-2021-45105

This branch includes the following new commits:

 new f1a79f4  [FLINK-25375] Update log4j2 dependency to 2.17.0 to address 
CVE-2021-45105

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

[flink] branch master updated (6a96044 -> fef7f46)

2021-12-21 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


from 6a96044  [FLINK-25363][python][table] Refactor shared group window 
classes for Python
 add fef7f46  [FLINK-25375] Update log4j2 dependency to 2.17.0 to address 
CVE-2021-45105

No new revisions were added by this update.

Summary of changes:
 docs/content.zh/docs/dev/datastream/project-configuration.md | 2 +-
 docs/content/docs/dev/datastream/project-configuration.md| 2 +-
 pom.xml  | 2 +-
 tools/releasing/NOTICE-binary_PREAMBLE.txt   | 8 
 4 files changed, 7 insertions(+), 7 deletions(-)

[flink-web] branch asf-site updated (c69db27 -> f00f0e8)

2021-12-10 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a change to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git.


from c69db27  rebuild website
 new b17c8c5  [hotfix] fix yptos in Log4j CVE blog post
 new f00f0e8  rebuild website

The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 _posts/2021-12-10-log4j-cve.md| 6 +++---
 content/2021/12/10/log4j-cve.html | 4 ++--
 content/blog/feed.xml | 4 ++--
 content/blog/index.html   | 2 +-
 content/index.html| 2 +-
 content/zh/index.html | 2 +-
 6 files changed, 10 insertions(+), 10 deletions(-)

[flink-web] 02/02: rebuild website

2021-12-10 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git

commit f00f0e87be5cb9bfe1935611667da7ba42e616ce
Author: Konstantin Knauf 
AuthorDate: Fri Dec 10 17:37:00 2021 +0100

rebuild website
---
 content/2021/12/10/log4j-cve.html | 4 ++--
 content/blog/feed.xml | 4 ++--
 content/blog/index.html   | 2 +-
 content/index.html| 2 +-
 content/zh/index.html | 2 +-
 5 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/content/2021/12/10/log4j-cve.html 
b/content/2021/12/10/log4j-cve.html
index bf61d5e..e7f27e9 100644
--- a/content/2021/12/10/log4j-cve.html
+++ b/content/2021/12/10/log4j-cve.html
@@ -204,8 +204,8 @@
 Yesterday, a new Zero Day for Apache Log4j was https://www.cyberkendra.com/2021/12/apache-log4j-vulnerability-details-and.html;>reported.
 
 It is by now tracked under https://nvd.nist.gov/vuln/detail/CVE-2021-44228;>CVE-2021-44228.
 
-Apache Flink is bundling a version of Log4j that is affeced by this 
vulnerability. 
-We recommend users to follow the https://logging.apache.org/log4j/2.x/security.html;>adivsory of the 
Apache Log4j Community. 
+Apache Flink is bundling a version of Log4j that is affected by this 
vulnerability. 
+We recommend users to follow the https://logging.apache.org/log4j/2.x/security.html;>advisory of the 
Apache Log4j Community. 
 For Apache Flink this currently translates to “setting system property 
log4j2.formatMsgNoLookups to true” until Log4j has 
been upgraded to 2.15.0 in Apache Flink.
 
 This effort is tracked in https://issues.apache.org/jira/browse/FLINK-25240;>FLINK-25240. 
diff --git a/content/blog/feed.xml b/content/blog/feed.xml
index 56e5931..daa45f3 100644
--- a/content/blog/feed.xml
+++ b/content/blog/feed.xml
@@ -11,8 +11,8 @@
 pYesterday, a new Zero Day for Apache Log4j was a 
href=https://www.cyberkendra.com/2021/12/apache-log4j-vulnerability-details-and.htmlreported/a;.
 
 It is by now tracked under a 
href=https://nvd.nist.gov/vuln/detail/CVE-2021-44228CVE-2021-44228/a./p;
 
-pApache Flink is bundling a version of Log4j that is affeced by this 
vulnerability. 
-We recommend users to follow the a 
href=https://logging.apache.org/log4j/2.x/security.htmladivsory/a;
 of the Apache Log4j Community. 
+pApache Flink is bundling a version of Log4j that is affected by this 
vulnerability. 
+We recommend users to follow the a 
href=https://logging.apache.org/log4j/2.x/security.htmladvisory/a;
 of the Apache Log4j Community. 
 For Apache Flink this currently translates to “setting system property 
codelog4j2.formatMsgNoLookups/code to 
codetrue/code” until Log4j has been upgraded to 2.15.0 in 
Apache Flink./p
 
 pThis effort is tracked in a 
href=https://issues.apache.org/jira/browse/FLINK-25240FLINK-25240/a;.
 
diff --git a/content/blog/index.html b/content/blog/index.html
index a47d95c..f7c959d 100644
--- a/content/blog/index.html
+++ b/content/blog/index.html
@@ -206,7 +206,7 @@
   10 Dec 2021
Konstantin Knauf 
 
-  Advise on Apache Log4j Zero Day (CVE-2021-44228)
+  Apache Flink is affected by an Apache Log4j Zero Day 
(CVE-2021-44228). This blog post contains advise for users on how to address 
this.
 
   Continue reading 
 
diff --git a/content/index.html b/content/index.html
index fcc6015..a6ee695 100644
--- a/content/index.html
+++ b/content/index.html
@@ -366,7 +366,7 @@
   
   
  Advise on Apache Log4j Zero 
Day (CVE-2021-44228)
-Advise on Apache Log4j Zero Day (CVE-2021-44228)
+Apache Flink is affected by an Apache Log4j Zero Day 
(CVE-2021-44228). This blog post contains advise for users on how to address 
this.
   
  Flink Backward - The 
Apache Flink Retrospective
 A look back at the development cycle for Flink 1.14
diff --git a/content/zh/index.html b/content/zh/index.html
index 1007408..655d399 100644
--- a/content/zh/index.html
+++ b/content/zh/index.html
@@ -363,7 +363,7 @@
   
   
  Advise on Apache Log4j Zero 
Day (CVE-2021-44228)
-Advise on Apache Log4j Zero Day (CVE-2021-44228)
+Apache Flink is affected by an Apache Log4j Zero Day 
(CVE-2021-44228). This blog post contains advise for users on how to address 
this.
   
  Flink Backward - The 
Apache Flink Retrospective
 A look back at the development cycle for Flink 1.14

[flink-web] 01/02: [hotfix] fix yptos in Log4j CVE blog post

2021-12-10 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git

commit b17c8c568053ef2c2731beec9e46fc6b1ca9e71f
Author: Konstantin Knauf 
AuthorDate: Fri Dec 10 17:36:01 2021 +0100

[hotfix] fix yptos in Log4j CVE blog post
---
 _posts/2021-12-10-log4j-cve.md | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/_posts/2021-12-10-log4j-cve.md b/_posts/2021-12-10-log4j-cve.md
index 574ec66..deaafe0 100644
--- a/_posts/2021-12-10-log4j-cve.md
+++ b/_posts/2021-12-10-log4j-cve.md
@@ -5,14 +5,14 @@ date: 2021-12-10 00:00:00
 authors:
 - knaufk:
   name: "Konstantin Knauf"
-excerpt: "Advise on Apache Log4j Zero Day (CVE-2021-44228)"
+excerpt: "Apache Flink is affected by an Apache Log4j Zero Day 
(CVE-2021-44228). This blog post contains advise for users on how to address 
this."
 ---
 
 Yesterday, a new Zero Day for Apache Log4j was 
[reported](https://www.cyberkendra.com/2021/12/apache-log4j-vulnerability-details-and.html).
 
 It is by now tracked under 
[CVE-2021-44228](https://nvd.nist.gov/vuln/detail/CVE-2021-44228). 
 
-Apache Flink is bundling a version of Log4j that is affeced by this 
vulnerability. 
-We recommend users to follow the 
[adivsory](https://logging.apache.org/log4j/2.x/security.html) of the Apache 
Log4j Community. 
+Apache Flink is bundling a version of Log4j that is affected by this 
vulnerability. 
+We recommend users to follow the 
[advisory](https://logging.apache.org/log4j/2.x/security.html) of the Apache 
Log4j Community. 
 For Apache Flink this currently translates to "setting system property 
`log4j2.formatMsgNoLookups` to `true`" until Log4j has been upgraded to 2.15.0 
in Apache Flink. 
 
 This effort is tracked in 
[FLINK-25240](https://issues.apache.org/jira/browse/FLINK-25240).

[flink-web] branch asf-site updated: rebuild website

2021-12-10 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk 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 c69db27  rebuild website
c69db27 is described below

commit c69db27156fdbec781bb01c5275a7aa0b5e121c3
Author: Konstantin Knauf 
AuthorDate: Fri Dec 10 17:25:45 2021 +0100

rebuild website
---
 content/{index.html => 2021/12/10/log4j-cve.html} | 276 +++---
 content/blog/feed.xml | 153 ++--
 content/blog/index.html   |  38 +--
 content/blog/page10/index.html|  38 +--
 content/blog/page11/index.html|  40 ++--
 content/blog/page12/index.html|  40 ++--
 content/blog/page13/index.html|  40 ++--
 content/blog/page14/index.html|  40 ++--
 content/blog/page15/index.html|  43 ++--
 content/blog/page16/index.html|  43 ++--
 content/blog/page17/index.html|  25 ++
 content/blog/page2/index.html |  38 ++-
 content/blog/page3/index.html |  36 ++-
 content/blog/page4/index.html |  36 ++-
 content/blog/page5/index.html |  36 ++-
 content/blog/page6/index.html |  36 ++-
 content/blog/page7/index.html |  38 +--
 content/blog/page8/index.html |  41 ++--
 content/blog/page9/index.html |  39 ++-
 content/index.html|   6 +-
 content/zh/index.html |   6 +-
 21 files changed, 471 insertions(+), 617 deletions(-)

diff --git a/content/index.html b/content/2021/12/10/log4j-cve.html
similarity index 54%
copy from content/index.html
copy to content/2021/12/10/log4j-cve.html
index b169a83..bf61d5e 100644
--- a/content/index.html
+++ b/content/2021/12/10/log4j-cve.html
@@ -5,7 +5,7 @@
 
 
 
-Apache Flink: Stateful Computations over Data Streams
+Apache Flink: Advise on Apache Log4j Zero Day 
(CVE-2021-44228)
 
 
 
@@ -145,7 +145,7 @@
 
   
 
-  中文版
+  中文版
 
   
 
@@ -193,259 +193,45 @@
   
   
   
-
   
-
-  Apache Flink® — Stateful Computations over Data 
Streams
-
-  
+
+  Advise on Apache Log4j Zero Day (CVE-2021-44228)
+  
 
-
-  
-
+  
+10 Dec 2021 Konstantin Knauf 
 
-
+Yesterday, a new Zero Day for Apache Log4j was https://www.cyberkendra.com/2021/12/apache-log4j-vulnerability-details-and.html;>reported.
 
+It is by now tracked under https://nvd.nist.gov/vuln/detail/CVE-2021-44228;>CVE-2021-44228.
 
-
+Apache Flink is bundling a version of Log4j that is affeced by this 
vulnerability. 
+We recommend users to follow the https://logging.apache.org/log4j/2.x/security.html;>adivsory of the 
Apache Log4j Community. 
+For Apache Flink this currently translates to “setting system property 
log4j2.formatMsgNoLookups to true” until Log4j has 
been upgraded to 2.15.0 in Apache Flink.
 
-
-  
-  
-
-
-
+This effort is tracked in https://issues.apache.org/jira/browse/FLINK-25240;>FLINK-25240. 
+It will be included in Flink 1.15.0, Flink 1.14.1 and Flink 1.13.3.
+We expect Flink 1.14.1 to be released in the next 1-2 weeks.
+The other releases will follow in their regular cadence.
 
-
-
-  
-
-  
- All streaming use 
cases
-  
-  
-
-  Event-driven Applications
-  Stream  Batch Analytics
-  Data Pipelines  ETL
-
-Learn more
-  
-
-  
-  
-
-  
- Guaranteed 
correctness
-  
-  
-
-  Exactly-once state consistency
-  Event-time processing
-  Sophisticated late data handling
-
-Learn
 more
-  
+  
 
-  
-  
-
-  
- 
Layered APIs
-  
-  
-
-  SQL on Stream  Batch Data
-  DataStream API  DataSet API
-  ProcessFunction (Time  State)
-
-Learn more
-  
-
-  
-
-
-  
-
-  
- Operational 
Focus
-  
-  
-
-  Flexible deployment
-  High-availability setup
-  Savepoints
-
-Learn more
-  
-
-  
-  
-
-  
- Scales to any 
use case
-  
-  
-
-  Scale-out architecture
-  Support for very large state
-  Incremental checkpointing
-
-Learn 
more
-  
-
-  
-  
-
-  
- Excellent 
Performance
-  
-  
-
-  Low latency
-  High throughput
-  In-Memory computing
-
-

[flink-web] branch asf-site updated: Add blog post about Log4j Zero Day

2021-12-10 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk 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 4c7ca4b  Add blog post about Log4j Zero Day
4c7ca4b is described below

commit 4c7ca4b1c1a28d70501ee5c25d314a5cde713ce1
Author: Konstantin Knauf 
AuthorDate: Fri Dec 10 16:15:34 2021 +0100

Add blog post about Log4j Zero Day
---
 _posts/2021-12-10-log4j-cve.md | 21 +
 1 file changed, 21 insertions(+)

diff --git a/_posts/2021-12-10-log4j-cve.md b/_posts/2021-12-10-log4j-cve.md
new file mode 100644
index 000..574ec66
--- /dev/null
+++ b/_posts/2021-12-10-log4j-cve.md
@@ -0,0 +1,21 @@
+---
+layout: post
+title: "Advise on Apache Log4j Zero Day (CVE-2021-44228)"
+date: 2021-12-10 00:00:00
+authors:
+- knaufk:
+  name: "Konstantin Knauf"
+excerpt: "Advise on Apache Log4j Zero Day (CVE-2021-44228)"
+---
+
+Yesterday, a new Zero Day for Apache Log4j was 
[reported](https://www.cyberkendra.com/2021/12/apache-log4j-vulnerability-details-and.html).
 
+It is by now tracked under 
[CVE-2021-44228](https://nvd.nist.gov/vuln/detail/CVE-2021-44228). 
+
+Apache Flink is bundling a version of Log4j that is affeced by this 
vulnerability. 
+We recommend users to follow the 
[adivsory](https://logging.apache.org/log4j/2.x/security.html) of the Apache 
Log4j Community. 
+For Apache Flink this currently translates to "setting system property 
`log4j2.formatMsgNoLookups` to `true`" until Log4j has been upgraded to 2.15.0 
in Apache Flink. 
+
+This effort is tracked in 
[FLINK-25240](https://issues.apache.org/jira/browse/FLINK-25240). 
+It will be included in Flink 1.15.0, Flink 1.14.1 and Flink 1.13.3.
+We expect Flink 1.14.1 to be released in the next 1-2 weeks.
+The other releases will follow in their regular cadence.

[flink-jira-bot] branch master updated: [FLINK-23206] Minor tickets are moved to Not a Priority instead of closing

2021-07-29 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git


The following commit(s) were added to refs/heads/master by this push:
 new d06a472  [FLINK-23206] Minor tickets are moved to Not a Priority 
instead of closing
 new 96764c4  Merge pull request #23 from knaufk/FLINK-23206
d06a472 is described below

commit d06a4724d4a448005e1e1c49c86beac978ca64de
Author: Konstantin Knauf 
AuthorDate: Wed Jul 28 15:48:46 2021 +0200

[FLINK-23206] Minor tickets are moved to Not a Priority instead of closing
---
 README.md  |  8 +--
 config.yaml|  6 +--
 flink_jira_bot.py  | 13 ++---
 stale_assigned_rule.py |  2 -
 stale_minor_rule.py| 63 --
 ...or_or_above_rule.py => stale_unassigned_rule.py | 11 ++--
 6 files changed, 17 insertions(+), 86 deletions(-)

diff --git a/README.md b/README.md
index 855d2fb..95bb38c 100644
--- a/README.md
+++ b/README.md
@@ -40,9 +40,9 @@ The configuration of the rules can be found in 
[config.yaml](config.yaml).
 
 ## About the Rules
 
-### Rule 1 Major+ Need Assignee or Discussion
+### Rule 1 Tickets Need an Assignee or Discussion Eventually
 
-Tickets major and above need an assignee, or an update within 
{stale_.stale_days}, otherwise the priority will be 
reduced after a warning period of {stale_.warning_days} 
days.
+Any ticket (except ones with priority "Not a Priority") needs an assignee, or 
an update within {stale_.stale_days}, otherwise 
the priority will be reduced after a warning period of 
{stale_.warning_days} days.
 An update of a Sub-Task counts as an update to the ticket. 
 Before this happens the assignee/reporter/watchers are notified that the 
ticket is about to become stale and will be deprioritized. 
 The time periods before warning differ based on the priority: 
@@ -51,10 +51,6 @@ The time periods before warning differ based on the priority:
 
 Assigned tickets without an update for {stale_assigned.stale_days} days are 
marked stale. The assignee is notified and asked for an update on the status of 
her contribution.
 
-### Rule 3: Close Stale Minor Tickets
-
-An unresolved Minor ticket without an update for {stale_minor.stale_days} is 
closed after a warning period of {stale_minor.warning_days} with a comment that 
encourages users to watch, comment and simply reopen with a higher priority if 
the problem insists.
-
 ## About Apache Flink
 
 Apache Flink is an open source project of The Apache Software Foundation (ASF).
diff --git a/config.yaml b/config.yaml
index 7ea46e4..1b00ddc 100644
--- a/config.yaml
+++ b/config.yaml
@@ -35,12 +35,12 @@ stale_minor:
 stale_days: 180
 warning_days: 7
 warning_label: "stale-minor"
-done_label: "auto-closed"
+done_label: "auto-deprioritized-minor"
 warning_comment: |
-I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] 
and I help the community manage its development. I noticed that neither this 
issue nor its subtasks had updates for {stale_days} days, so I labeled it 
"{warning_label}".  If you are still affected by this bug or are still 
interested in this issue, please update and remove the label.
+I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] 
and I help the community manage its development. I see this issues has been 
marked as Minor but is unassigned and neither itself nor its Sub-Tasks have 
been updated for {stale_days} days. I have gone ahead and marked it 
"{warning_label}". If this ticket is still Minor, please either assign yourself 
or give an update. Afterwards, please remove the label or in {warning_days} 
days the issue will be deprioritized.
 
 done_comment: |
-This issue was labeled "{warning_label}" {warning_days} days ago and 
has not received any updates so I have gone ahead and closed it.  If you are 
still affected by this or would like to raise the priority of this ticket 
please re-open, removing the label "{done_label}" and raise the ticket priority 
accordingly.
+This issue was labeled "{warning_label}" {warning_days} days ago and 
has not received any updates so it is being deprioritized. If this ticket is 
actually Minor, please raise the priority and ask a committer to assign you the 
issue or revive the public discussion.
 
 stale_blocker:
 ticket_limit: 5
diff --git a/flink_jira_bot.py b/flink_jira_bot.py
index 36f8ca0..76dce7a 100644
--- a/flink_jira_bot.py
+++ b/flink_jira_bot.py
@@ -24,8 +24,7 @@ from argparse import ArgumentParser
 from pathlib import Path
 
 from stale_assigned_rule import StaleAssignedRule
-from stale_major_or_above_rule import StaleMajorOrAboveRule
-from

[flink-jira-bot] branch master updated: [hotfix] dont warn on tickets that already have the warning label

2021-07-09 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git


The following commit(s) were added to refs/heads/master by this push:
 new bc37608  [hotfix] dont warn on tickets that already have the warning 
label
 new ee516a3  Merge pull request #22 from knaufk/hotfix-blocker-issues
bc37608 is described below

commit bc376084c6c76a4d0fd578e526d2930977461e54
Author: Konstantin Knauf 
AuthorDate: Fri Jul 9 12:26:05 2021 +0200

[hotfix] dont warn on tickets that already have the warning label
---
 stale_assigned_rule.py   | 2 +-
 stale_major_or_above_rule.py | 3 ++-
 stale_minor_rule.py  | 3 ++-
 3 files changed, 5 insertions(+), 3 deletions(-)

diff --git a/stale_assigned_rule.py b/stale_assigned_rule.py
index dd87598..ecbc3d3 100644
--- a/stale_assigned_rule.py
+++ b/stale_assigned_rule.py
@@ -37,7 +37,7 @@ class StaleAssignedRule(FlinkJiraRule):
 )
 self.mark_stale_tickets_stale(
 f"project = FLINK AND resolution = Unresolved AND assignee is not 
EMPTY "
-f"AND updated < startOfDay(-{self.stale_days}d)"
+f'AND updated < startOfDay(-{self.stale_days}d) AND NOT labels in 
("{self.warning_label}")'
 )
 
 def handle_stale_ticket(self, key, warning_label, done_label, comment):
diff --git a/stale_major_or_above_rule.py b/stale_major_or_above_rule.py
index c309f17..c0f8123 100644
--- a/stale_major_or_above_rule.py
+++ b/stale_major_or_above_rule.py
@@ -43,7 +43,8 @@ class StaleMajorOrAboveRule(FlinkJiraRule):
 )
 self.mark_stale_tickets_stale(
 f'project=FLINK AND type != "Sub-Task" AND priority = 
{self.priority} AND resolution = Unresolved '
-f"AND assignee is empty AND updated < 
startOfDay(-{self.stale_days}d) AND fixVersion = null"
+f'AND assignee is empty AND updated < 
startOfDay(-{self.stale_days}d) AND fixVersion = null AND NOT labels '
+f'in ("{self.warning_label}")'
 )
 
 def handle_stale_ticket(self, key, warning_label, done_label, comment):
diff --git a/stale_minor_rule.py b/stale_minor_rule.py
index 4056219..35e9c49 100644
--- a/stale_minor_rule.py
+++ b/stale_minor_rule.py
@@ -39,7 +39,8 @@ class StaleMinorRule(FlinkJiraRule):
 )
 self.mark_stale_tickets_stale(
 f'project = FLINK AND type != "Sub-Task" AND Priority = Minor AND 
resolution = Unresolved '
-f"AND updated < startOfDay(-{self.stale_days}d) AND fixVersion = 
null"
+f'AND updated < startOfDay(-{self.stale_days}d) AND fixVersion = 
null AND NOT labels in '
+f'("{self.warning_label}")'
 )
 
 def handle_stale_ticket(self, key, warning_label, done_label, comment):

[flink-jira-bot] branch master updated (bd377c0 -> 614cd74)

2021-07-05 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git.


from bd377c0  Merge pull request #19 from knaufk/FLINK-23205
 new a1d140f  [hotfix] fix formatting in flink_jra_rule.py
 new fdb9917  [FLINK-23250] dont unassign people automatically
 new 8567f87  [hotfix] fix space in log message
 new 614cd74  Merge pull request #21 from knaufk/FLINK-23250

The 62 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 README.md  |  2 +-
 config.yaml|  4 ++--
 flink_jira_rule.py |  8 +---
 stale_assigned_rule.py | 26 ++
 4 files changed, 10 insertions(+), 30 deletions(-)

[flink-jira-bot] branch master updated (feec74f -> bd377c0)

2021-07-05 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git.


from feec74f  Merge pull request #18 from apache/NicoK-patch-1
 new 4072576  [FLINK-23205] relax time intervals of Jira Bot
 new 1f645fd  [FLINK-23205] only mark tickets stale that dont have a 
fixVersion set
 new bd377c0  Merge pull request #19 from knaufk/FLINK-23205

The 58 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 config.yaml  | 6 +++---
 stale_major_or_above_rule.py | 6 +++---
 stale_minor_rule.py  | 4 ++--
 3 files changed, 8 insertions(+), 8 deletions(-)

[flink-jira-bot] 01/01: Merge pull request #18 from apache/NicoK-patch-1

2021-06-22 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git

commit feec74f47d4a9e6afb6d98a7064ad1fa89a3e345
Merge: f6e7e9c 1f593d9
Author: Konstantin Knauf 
AuthorDate: Wed Jun 23 07:48:31 2021 +0200

Merge pull request #18 from apache/NicoK-patch-1

[hotfix] add missing "days" after number of days

 config.yaml | 12 ++--
 1 file changed, 6 insertions(+), 6 deletions(-)

[flink-jira-bot] branch master updated (f6e7e9c -> feec74f)

2021-06-22 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git.


from f6e7e9c  Merge pull request #17 from knaufk/FLINK-22783
 add 1f593d9  [hotfix] add missing "days" after number of days
 new feec74f  Merge pull request #18 from apache/NicoK-patch-1

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 config.yaml | 12 ++--
 1 file changed, 6 insertions(+), 6 deletions(-)

[flink-jira-bot] branch master updated: [FLINK-22783] do not count tickets with updated subtasks against ticket limit

2021-05-26 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git


The following commit(s) were added to refs/heads/master by this push:
 new 7740c78  [FLINK-22783] do not count tickets with updated subtasks 
against ticket limit
 new f6e7e9c  Merge pull request #17 from knaufk/FLINK-22783
7740c78 is described below

commit 7740c782e3c92893fe901ffc4454dcdb28e7f3d1
Author: Konstantin Knauf 
AuthorDate: Wed May 26 14:22:52 2021 +0200

[FLINK-22783] do not count tickets with updated subtasks against ticket 
limit
---
 flink_jira_rule.py | 12 +---
 1 file changed, 9 insertions(+), 3 deletions(-)

diff --git a/flink_jira_rule.py b/flink_jira_rule.py
index 0ded937..91c45ca 100644
--- a/flink_jira_rule.py
+++ b/flink_jira_rule.py
@@ -34,7 +34,7 @@ class FlinkJiraRule:
 self.warning_comment = config["warning_comment"].get()
 self.ticket_limit = config["ticket_limit"].get()
 
-def get_issues(self, jql_query, limit):
+def get_issues(self, jql_query, limit=1):
 """Queries the JIRA PI for all issues that match the given JQL Query
 
 This method is necessary as requests tend to time out if the number of 
results reaches a certain number.
@@ -82,9 +82,12 @@ class FlinkJiraRule:
 def mark_stale_tickets_stale(self, jql_query):
 
 logging.info(f"Looking for stale tickets.")
-issues = self.get_issues(jql_query, self.ticket_limit)
+issues = self.get_issues(jql_query)
 
-for issue in issues:
+updated_issues_counter = 0
+i = 0
+while i < len(issues) and updated_issues_counter <= self.ticket_limit:
+issue = issues[i]
 key = issue["key"]
 
 if not self.has_recently_updated_subtask(key, self.stale_days):
@@ -99,11 +102,14 @@ class FlinkJiraRule:
 
 self.add_label_with_comment(key, self.warning_label, 
formatted_comment)
 
+updated_issues_counter += 1
+
 else:
 logging.info(
 f"Found https://issues.apache.org/jira/browse/{key}, but 
is has recently updated Subtasks."
 f"Ignoring for now."
 )
+i += 1
 
 def handle_tickets_marked_stale(self, jql_query):
 logging.info(f"Looking for ticket previously marked as 
{self.warning_label}.")

[flink-jira-bot] branch master updated (dcb4a44 -> b95a7a0)

2021-05-19 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git.


from dcb4a44  Merge pull request #15 from knaufk/FLINK-22569
 new db7888a  [hotfix] add missing parameter in docstring
 new 748b2dd  [hotfix] fix signature of handle_stale_ticket
 new 1631057  [hotfix] remove unused code
 new b95a7a0  Merge pull request #16 from knaufk/hotfix-signature

The 51 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 flink_jira_rule.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

[flink-jira-bot] 47/47: Merge pull request #15 from knaufk/FLINK-22569

2021-05-19 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git

commit dcb4a4476e5d332cc62c96786c31a7eebc0cf070
Merge: a43b94f 59c16f5
Author: Konstantin Knauf 
AuthorDate: Wed May 19 10:09:15 2021 +0200

Merge pull request #15 from knaufk/FLINK-22569

[FLINK-22569] limit number of tickets touched by the bot per run to 100

 config.yaml|  7 ++-
 flink_jira_rule.py | 17 +
 2 files changed, 15 insertions(+), 9 deletions(-)

[flink-jira-bot] 19/47: [FLINK-22033] add rule 2, which unassign stale assigned tickets after some time

2021-05-19 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git

commit a38d571a76c617d222e3fab5488c0ffe6d44119f
Author: Konstantin Knauf 
AuthorDate: Fri Apr 16 10:57:55 2021 +0200

[FLINK-22033] add rule 2, which unassign stale assigned tickets after some 
time
---
 README.md |   8 ++--
 config.yaml   |   8 
 flink_jira_bot.py | 116 ++
 3 files changed, 121 insertions(+), 11 deletions(-)

diff --git a/README.md b/README.md
index befa400..503a762 100644
--- a/README.md
+++ b/README.md
@@ -42,11 +42,13 @@ The configuration of the rules can be found in 
[config.yaml](config.yaml).
 
 ### Rule 1 (not implemented yet)
 
-### Rule 2 (not implemented yet)
+### Rule 2: Unassign Stale Assigned Tickets
 
-### Rule 3
+Assigned tickets without an update for {stale_assigned.stale_days} are 
unassigned after a warning period of {stale_assigned.warning_days}. Before this 
happens the assignee is notified that this is about to happen and asked for an 
update on the status of her contribution.
 
-An unresolved Minor ticket without an update for {stale.minor.stale_days} is 
closed after a warning period of {stale.minor.warning_days} with a comment that 
encourages users to watch, comment and simply reopen with a higher priority if 
the problem insists.
+### Rule 3: Close Stale Minor Tickets
+
+An unresolved Minor ticket without an update for {stale_minor.stale_days} is 
closed after a warning period of {stale_minor.warning_days} with a comment that 
encourages users to watch, comment and simply reopen with a higher priority if 
the problem insists.
 
 ## About Apache Flink
 
diff --git a/config.yaml b/config.yaml
index 1afae72..d1cb3bb 100644
--- a/config.yaml
+++ b/config.yaml
@@ -16,6 +16,14 @@
 # limitations under the License.
 

 
+stale_assigned:
+stale_days: 7
+warning_days: 7
+warning_label: "stale-assigned"
+warning_comment: 'This issue is assigned but has not received an update in 
{stale_days} days so it has been labeled "{warning_label}". If you are still 
working on the issue, please give an update and remove the label. If you are no 
longer working on the issue, please unassign so someone else may work on it. In 
{warning_days} days the issue will be automatically unassigned.'
+done_label: "auto-unassigned"
+done_comment: 'This issue was marked "{warning_label}" and has not 
received an update in {warning_days} days. It is now automatically unassigned. 
If you are still working on it, you can assign it to yourself again. Please 
also give an update about the status of the work.'
+
 stale_minor:
 stale_days: 180
 warning_days: 7
diff --git a/flink_jira_bot.py b/flink_jira_bot.py
index f67e57e..e1cdc28 100644
--- a/flink_jira_bot.py
+++ b/flink_jira_bot.py
@@ -33,12 +33,32 @@ class FlinkJiraRule:
 self.config = config
 self.is_dry_run = is_dry_run
 
+def get_issues(self, jql_query):
+"""Queries the JIRA PI for all issues that match the given JQL Query
+
+This method is necessary as requests tend to time out if the number of 
results reaches a certain number.
+So, this method requests the results in multiple queries and returns a 
final list of all issues.
+:param jql_query: the search query
+:return: a list of issues matching the query
+"""
+limit = 200
+current = 0
+total = 1
+issues = []
+while current < total:
+response = self.jira_client.jql(jql_query, limit=limit, 
start=current)
+total = response["total"]
+issues = issues + response["issues"]
+current = len(issues)
+logging.info(f'"{jql_query}" returned {len(issues)} issues')
+return issues
+
 def has_recently_updated_subtask(self, parent, updated_within_days):
 find_subtasks_updated_within = (
 f"parent = {parent}  AND updated > 
startOfDay(-{updated_within_days}d)"
 )
-issues = self.jira_client.jql(find_subtasks_updated_within, limit=1)
-return issues["total"] > 0
+issues = self.get_issues(find_subtasks_updated_within)
+return len(issues) > 0
 
 def add_label(self, issue, label):
 labels = issue["fields"]["labels"] + [label]
@@ -75,6 +95,12 @@ class FlinkJiraRule:
 else:
 logging.info(f"DRY_RUN (({key})): Closing.")
 
+def unassign(self, key):
+if not self.is_dry_run:
+self.jira_client.assign_issue(key, None)
+else:
+logging.info(f"DRY_RUN (({key})): Unassigning.")
+

[flink-jira-bot] 42/47: [FLINK-22576] Set status to 'Open' when unassigning

2021-05-19 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git

commit f185d8654881b1a14ac11f112848aa2b7be75de7
Author: Chesnay Schepler 
AuthorDate: Mon May 10 16:39:25 2021 +0200

[FLINK-22576] Set status to 'Open' when unassigning
---
 flink_jira_rule.py | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/flink_jira_rule.py b/flink_jira_rule.py
index f11f275..a98ca71 100644
--- a/flink_jira_rule.py
+++ b/flink_jira_rule.py
@@ -99,6 +99,9 @@ class FlinkJiraRule:
 
 def unassign(self, key):
 if not self.is_dry_run:
+if self.jira_client.get_issue_status(key) == "In Progress":
+self.jira_client.assign_issue(key, self.jira_client.username)
+self.jira_client.set_issue_status(key, "Open")
 self.jira_client.assign_issue(key, None)
 else:
 logging.info(f"DRY_RUN (({key})): Unassigning.")

[flink-jira-bot] 30/47: [FLINK-22034] get rid of LOWER_PRIORITIES constant

2021-05-19 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git

commit 3fcb3fff062c80d08c22c816836d600155e009af
Author: Konstantin Knauf 
AuthorDate: Thu Apr 22 10:54:11 2021 +0200

[FLINK-22034] get rid of LOWER_PRIORITIES constant
---
 flink_jira_bot.py| 6 +++---
 stale_major_or_above_rule.py | 9 +++--
 2 files changed, 6 insertions(+), 9 deletions(-)

diff --git a/flink_jira_bot.py b/flink_jira_bot.py
index aa1befa..36f8ca0 100644
--- a/flink_jira_bot.py
+++ b/flink_jira_bot.py
@@ -67,13 +67,13 @@ if __name__ == "__main__":
 )
 stale_minor_rule = StaleMinorRule(jira, jira_bot_config["stale_minor"], 
args.dryrun)
 stale_major_rule = StaleMajorOrAboveRule(
-jira, jira_bot_config["stale_major"], args.dryrun, "Major"
+jira, jira_bot_config["stale_major"], args.dryrun, "Major", "Minor"
 )
 stale_critical_rule = StaleMajorOrAboveRule(
-jira, jira_bot_config["stale_critical"], args.dryrun, "Critical"
+jira, jira_bot_config["stale_critical"], args.dryrun, "Critical", 
"Major"
 )
 stale_blocker_rule = StaleMajorOrAboveRule(
-jira, jira_bot_config["stale_blocker"], args.dryrun, "Blocker"
+jira, jira_bot_config["stale_blocker"], args.dryrun, "Blocker", 
"Critical"
 )
 stale_assigned_rule.run()
 stale_minor_rule.run()
diff --git a/stale_major_or_above_rule.py b/stale_major_or_above_rule.py
index d5e5663..c5509a0 100644
--- a/stale_major_or_above_rule.py
+++ b/stale_major_or_above_rule.py
@@ -16,8 +16,6 @@
 # limitations under the License.
 

 
-import logging
-
 from flink_jira_rule import FlinkJiraRule
 
 
@@ -31,12 +29,11 @@ class StaleMajorOrAboveRule(FlinkJiraRule):
 The time periods before warning differ based on the priority:
 """
 
-def __init__(self, jira_client, config, is_dry_run, priority):
+def __init__(self, jira_client, config, is_dry_run, priority, 
lower_priority):
 super().__init__(jira_client, config, is_dry_run)
+self.lower_priority = lower_priority
 self.priority = priority
 
-LOWER_PRIORITIES = {"Blocker": "Critical", "Critical": "Major", "Major": 
"Minor"}
-
 def run(self):
 self.handle_tickets_marked_stale(
 f"project=FLINK AND Priority = {self.priority} AND resolution = 
Unresolved "
@@ -49,4 +46,4 @@ class StaleMajorOrAboveRule(FlinkJiraRule):
 )
 
 def handle_stale_ticket(self, key):
-self.set_priority(key, self.LOWER_PRIORITIES[self.priority])
+self.set_priority(key, self.lower_priority)

[flink-jira-bot] 36/47: Merge pull request #10 from knaufk/FLINK-22429

2021-05-19 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git

commit 673419a672b02d6f83b2c13e9aded14f153eebd0
Merge: dfb2fd8 0b403ff
Author: Konstantin Knauf 
AuthorDate: Fri Apr 23 15:52:54 2021 +0200

Merge pull request #10 from knaufk/FLINK-22429

[FLINK-22429] exclude Sub-Tasks form stale-major+ and stale-minor rule

 stale_major_or_above_rule.py | 4 ++--
 stale_minor_rule.py  | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

[flink-jira-bot] 32/47: [FLINK-22036] clarify relationship between README and Confluence page

2021-05-19 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git

commit c41f7fd44fc860743b5f1b4459724e70bbeb7e46
Author: Konstantin Knauf 
AuthorDate: Thu Apr 22 11:47:29 2021 +0200

[FLINK-22036] clarify relationship between README and Confluence page
---
 README.md | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/README.md b/README.md
index a91e616..eb3c7b6 100644
--- a/README.md
+++ b/README.md
@@ -1,6 +1,6 @@
 # Apache Flink Jira Bot
 
-The Flink Jira enforces some of the rules outlined in [the Apache Flink 
Confluence](https://cwiki.apache.org/confluence/display/FLINK/Flink+Jira+Process).
+The Flink Jira Bot partially enforces the Apache Flink Jira process. Please 
see [Apache Flink Jira 
Process](https://cwiki.apache.org/confluence/display/FLINK/Flink+Jira+Process) 
for all the guidlines and conventions that we try to follow.
 
 ## Usage
 
@@ -59,4 +59,5 @@ An unresolved Minor ticket without an update for 
{stale_minor.stale_days} is clo
 
 Apache Flink is an open source project of The Apache Software Foundation (ASF).
 
-Flink is distributed data processing framework with powerful stream and batch 
processing capabilities. Learn more about Flink at http://flink.apache.org/
\ No newline at end of file
+Flink is a distributed data processing framework with powerful stream and 
batch processing capabilities. Learn more about Flink at 
http://flink.apache.org/
+

[flink-jira-bot] 34/47: [hotfix] clarify intetion of stale_assigned comment

2021-05-19 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git

commit 723a958982add0cd6957463009ec0bbc7a3bb050
Author: Konstantin Knauf 
AuthorDate: Fri Apr 23 14:39:09 2021 +0200

[hotfix] clarify intetion of stale_assigned comment
---
 config.yaml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/config.yaml b/config.yaml
index 9428f9a..5f928b3 100644
--- a/config.yaml
+++ b/config.yaml
@@ -20,7 +20,7 @@ stale_assigned:
 stale_days: 14
 warning_days: 7
 warning_label: "stale-assigned"
-warning_comment: 'This issue is assigned but has not received an update in 
{stale_days} days so it has been labeled "{warning_label}". If you are still 
working on the issue, please give an update and remove the label. If you are no 
longer working on the issue, please unassign so someone else may work on it. In 
{warning_days} days the issue will be automatically unassigned.'
+warning_comment: 'This issue is assigned but has not received an update in 
{stale_days} days so it has been labeled "{warning_label}". If you are still 
working on the issue or are waiting for feedback from a Committer, please 
remove the label and optionally provide an update. If you are waiting for 
feedback, please consider this a reminder *to Committers/Reviewer* to get back 
to you. If you are no longer working on the issue, please unassign yourself so 
someone else may work on it. I [...]
 done_label: "auto-unassigned"
 done_comment: 'This issue was marked "{warning_label}" and has not 
received an update in {warning_days} days. It is now automatically unassigned. 
If you are still working on it, you can assign it to yourself again. Please 
also give an update about the status of the work.'

[flink-jira-bot] 27/47: [hotfix] move config parsing into FlinkJiraRule class

2021-05-19 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git

commit 836ee7d377f7b44a11e0bde9a8231de538772210
Author: Konstantin Knauf 
AuthorDate: Wed Apr 21 14:08:28 2021 +0200

[hotfix] move config parsing into FlinkJiraRule class
---
 flink_jira_bot.py| 12 +++-
 flink_jira_rule.py   |  7 ++-
 stale_assigned_rule.py   |  6 --
 stale_major_or_above_rule.py | 14 --
 stale_minor_rule.py  |  6 --
 5 files changed, 17 insertions(+), 28 deletions(-)

diff --git a/flink_jira_bot.py b/flink_jira_bot.py
index 80a58e9..aa1befa 100644
--- a/flink_jira_bot.py
+++ b/flink_jira_bot.py
@@ -62,16 +62,18 @@ if __name__ == "__main__":
 password=os.environ["JIRA_PASSWORD"],
 )
 
-stale_assigned_rule = StaleAssignedRule(jira, jira_bot_config, args.dryrun)
-stale_minor_rule = StaleMinorRule(jira, jira_bot_config, args.dryrun)
+stale_assigned_rule = StaleAssignedRule(
+jira, jira_bot_config["stale_assigned"], args.dryrun
+)
+stale_minor_rule = StaleMinorRule(jira, jira_bot_config["stale_minor"], 
args.dryrun)
 stale_major_rule = StaleMajorOrAboveRule(
-jira, jira_bot_config, args.dryrun, "Major"
+jira, jira_bot_config["stale_major"], args.dryrun, "Major"
 )
 stale_critical_rule = StaleMajorOrAboveRule(
-jira, jira_bot_config, args.dryrun, "Critical"
+jira, jira_bot_config["stale_critical"], args.dryrun, "Critical"
 )
 stale_blocker_rule = StaleMajorOrAboveRule(
-jira, jira_bot_config, args.dryrun, "Blocker"
+jira, jira_bot_config["stale_blocker"], args.dryrun, "Blocker"
 )
 stale_assigned_rule.run()
 stale_minor_rule.run()
diff --git a/flink_jira_rule.py b/flink_jira_rule.py
index 566fce7..c453562 100644
--- a/flink_jira_rule.py
+++ b/flink_jira_rule.py
@@ -25,8 +25,13 @@ class FlinkJiraRule:
 
 def __init__(self, jira_client, config, is_dry_run):
 self.jira_client = jira_client
-self.config = config
 self.is_dry_run = is_dry_run
+self.stale_days = config["stale_days"].get()
+self.warning_days = config["warning_days"].get()
+self.warning_label = config["warning_label"].get()
+self.done_label = config["done_label"].get()
+self.done_comment = config["done_comment"].get()
+self.warning_comment = config["warning_comment"].get()
 
 def get_issues(self, jql_query):
 """Queries the JIRA PI for all issues that match the given JQL Query
diff --git a/stale_assigned_rule.py b/stale_assigned_rule.py
index e781a9d..ddee747 100644
--- a/stale_assigned_rule.py
+++ b/stale_assigned_rule.py
@@ -30,12 +30,6 @@ class StaleAssignedRule(FlinkJiraRule):
 
 def __init__(self, jira_client, config, is_dry_run):
 super().__init__(jira_client, config, is_dry_run)
-self.stale_days = config["stale_assigned"]["stale_days"].get()
-self.warning_days = config["stale_assigned"]["warning_days"].get()
-self.warning_label = config["stale_assigned"]["warning_label"].get()
-self.done_label = config["stale_assigned"]["done_label"].get()
-self.done_comment = config["stale_assigned"]["done_comment"].get()
-self.warning_comment = 
config["stale_assigned"]["warning_comment"].get()
 
 def run(self):
 self.unassign_tickets_marked_stale()
diff --git a/stale_major_or_above_rule.py b/stale_major_or_above_rule.py
index de3cb17..aeda3f1 100644
--- a/stale_major_or_above_rule.py
+++ b/stale_major_or_above_rule.py
@@ -33,14 +33,6 @@ class StaleMajorOrAboveRule(FlinkJiraRule):
 
 def __init__(self, jira_client, config, is_dry_run, priority):
 super().__init__(jira_client, config, is_dry_run)
-self.stale_days = 
config[f"stale_{priority.lower()}"]["stale_days"].get()
-self.warning_days = 
config[f"stale_{priority.lower()}"]["warning_days"].get()
-self.warning_label = 
config[f"stale_{priority.lower()}"]["warning_label"].get()
-self.done_label = 
config[f"stale_{priority.lower()}"]["done_label"].get()
-self.done_comment = 
config[f"stale_{priority.lower()}"]["done_comment"].get()
-self.warning_comment = config[f"stale_{priority.lower()}"][
-"warning_comment"
-].get()
 self.priority = priority
 
 LOWER_PRIORITIES = {"Blocker": "Critical", "Critical": "Major"

[flink-jira-bot] 41/47: Merge pull request #12 from knaufk/hotfix-config-formatting

2021-05-19 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git

commit fe3c5db836bbfd7b8311b1d865fdf0b4d79c192f
Merge: 9e04944 1c4ab41
Author: Konstantin Knauf 
AuthorDate: Thu Apr 29 10:23:48 2021 +0200

Merge pull request #12 from knaufk/hotfix-config-formatting

[hotfix] fix indentation in config.yaml

 config.yaml | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

[flink-jira-bot] 38/47: Merge pull request #8 from knaufk/FLINK-22036

2021-05-19 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git

commit 67b61dc4dc756459d3e442f158516d32eec82c0e
Merge: 37190da c41f7fd
Author: Konstantin Knauf 
AuthorDate: Mon Apr 26 10:35:40 2021 +0200

Merge pull request #8 from knaufk/FLINK-22036

[FLINK-22036] clarify relationship between README and Confluence page

 README.md | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

[flink-jira-bot] 35/47: [FLINK-22429] exclude Sub-Tasks form stale-major+ and stale-minor rule

2021-05-19 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git

commit 0b403ff3b212008819f53ecfa995e34b58b9b95f
Author: Konstantin Knauf 
AuthorDate: Fri Apr 23 14:52:41 2021 +0200

[FLINK-22429] exclude Sub-Tasks form stale-major+ and stale-minor rule
---
 stale_major_or_above_rule.py | 4 ++--
 stale_minor_rule.py  | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/stale_major_or_above_rule.py b/stale_major_or_above_rule.py
index c5509a0..dd256b2 100644
--- a/stale_major_or_above_rule.py
+++ b/stale_major_or_above_rule.py
@@ -41,8 +41,8 @@ class StaleMajorOrAboveRule(FlinkJiraRule):
 f"AND updated < startOfDay(-{self.warning_days}d)"
 )
 self.mark_stale_tickets_stale(
-f"project=FLINK AND priority = {self.priority} AND resolution = 
Unresolved "
-f"AND assignee is empty AND updated < 
startOfDay(-{self.stale_days}d)"
+f'project=FLINK AND type != "Sub-Task" AND priority = 
{self.priority} AND resolution = Unresolved '
+f'AND assignee is empty AND updated < 
startOfDay(-{self.stale_days}d)'
 )
 
 def handle_stale_ticket(self, key):
diff --git a/stale_minor_rule.py b/stale_minor_rule.py
index 0bef5d9..ae54dac 100644
--- a/stale_minor_rule.py
+++ b/stale_minor_rule.py
@@ -38,8 +38,8 @@ class StaleMinorRule(FlinkJiraRule):
 f"AND updated < startOfDay(-{self.warning_days}d)"
 )
 self.mark_stale_tickets_stale(
-f"project = FLINK AND Priority = Minor AND resolution = Unresolved 
"
-f"AND updated < startOfDay(-{self.stale_days}d)"
+f'project = FLINK AND type != "Sub-Task" AND Priority = Minor AND 
resolution = Unresolved '
+f'AND updated < startOfDay(-{self.stale_days}d)'
 )
 
 def handle_stale_ticket(self, key):

[flink-jira-bot] 39/47: [hotfix] Make comment language friendly to contributors

2021-05-19 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git

commit 9e049443dedc71c381bb8628991e92a3b538dc5e
Author: Seth Wiesman 
AuthorDate: Fri Apr 23 11:10:07 2021 -0500

[hotfix] Make comment language friendly to contributors

Co-authored-by: Konstantin Knauf 

This closes #11
---
 config.yaml | 37 +++--
 1 file changed, 27 insertions(+), 10 deletions(-)

diff --git a/config.yaml b/config.yaml
index 5f928b3..b472cf2 100644
--- a/config.yaml
+++ b/config.yaml
@@ -20,38 +20,55 @@ stale_assigned:
 stale_days: 14
 warning_days: 7
 warning_label: "stale-assigned"
-warning_comment: 'This issue is assigned but has not received an update in 
{stale_days} days so it has been labeled "{warning_label}". If you are still 
working on the issue or are waiting for feedback from a Committer, please 
remove the label and optionally provide an update. If you are waiting for 
feedback, please consider this a reminder *to Committers/Reviewer* to get back 
to you. If you are no longer working on the issue, please unassign yourself so 
someone else may work on it. I [...]
 done_label: "auto-unassigned"
-done_comment: 'This issue was marked "{warning_label}" and has not 
received an update in {warning_days} days. It is now automatically unassigned. 
If you are still working on it, you can assign it to yourself again. Please 
also give an update about the status of the work.'
+warning_comment: |
+I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] 
and I help the community manage its development. I see this issue is assigned 
but has not received an update in {stale_days}, so it has been labeled 
"{warning_label}".
+If you are still working on the issue, please remove the label and add 
a comment updating the community on your progress.  If this issue is waiting on 
feedback, please consider this a reminder to the committer/reviewer. Flink is a 
very active project, and so we appreciate your patience.
+If you are no longer working on the issue, please unassign yourself so 
someone else may work on it. If the "warning_label" label is not removed in 
{warning_days} days, the issue will be automatically unassigned.
+
+done_comment: |
+This issue was marked "{warning_label}" {warning_days} ago and has not 
received an update. I have automatically removed the current assignee from the 
issue so others in the community may pick it up. If you are still working on 
this ticket, please ask a committer to reassign you and provide an update about 
your current status.
 
 stale_minor:
 stale_days: 180
 warning_days: 7
 warning_label: "stale-minor"
-warning_comment: 'This issue and all of its Sub-Tasks have not been 
updated for {stale_days} days. So, it has been labeled "{warning_label}". If 
you are still affected by this bug or are still interested in this issue, 
please give an update and remove the label. In {warning_days} days the issue 
will be closed automatically.'
 done_label: "auto-closed"
-done_comment: 'This issue has been labeled "{warning_label}" for 
{warning_days} days. It is closed now. If you are still affected by this or 
would like to raise the priority of this ticket please re-open, removing the 
label "{done_label}" and raise the ticket priority accordingly.'
+warning_comment: |
+I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] 
and I help the community manage its development. I noticed that neither this 
issue nor its subtasks had updates for {state_days} days, so I labeled it 
"{warning_label}".  If you are still affected by this bug or are still 
interested in this issue, please update and remove the label.
+
+done_comment: |
+This issue was labeled "{warning_label}" {warning_days} ago and has 
not received any updates so I have gone ahead and closed it.  If you are still 
affected by this or would like to raise the priority of this ticket please 
re-open, removing the label "{done_label}" and raise the ticket priority 
accordingly.
 
 stale_blocker:
 stale_days: 1
 warning_days: 7
 warning_label: "stale-blocker"
-warning_comment: 'This Blockers is unassigned and itself and all of its 
Sub-Tasks have not been updated for {stale_days} days. So, it has been labeled 
"{warning_label}". If this ticket is a Blocker, please either assign yourself 
or give an update. Afterwards, please remove the label. In {warning_days} days 
the issue will be deprioritized.'
 done_label: "auto-deprioritized-blocker"
-done_comment: 'This issue has been labeled "{warning_label}" for 
{warning_days} days. It is

[flink-jira-bot] 33/47: [FLINK-22340] set stale_assigned.stale_days to 14

2021-05-19 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git

commit 0b934ae3036d494f830d80db41bb639b6b25c41b
Author: Konstantin Knauf 
AuthorDate: Fri Apr 23 14:33:15 2021 +0200

[FLINK-22340] set stale_assigned.stale_days to 14
---
 config.yaml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/config.yaml b/config.yaml
index d0e7aff..9428f9a 100644
--- a/config.yaml
+++ b/config.yaml
@@ -17,7 +17,7 @@
 

 
 stale_assigned:
-stale_days: 7
+stale_days: 14
 warning_days: 7
 warning_label: "stale-assigned"
 warning_comment: 'This issue is assigned but has not received an update in 
{stale_days} days so it has been labeled "{warning_label}". If you are still 
working on the issue, please give an update and remove the label. If you are no 
longer working on the issue, please unassign so someone else may work on it. In 
{warning_days} days the issue will be automatically unassigned.'

[flink-jira-bot] 45/47: [hotfix] fix typo in one of the comments

2021-05-19 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git

commit 9c2998af4f06df151ab2b21252814c20a54a6edf
Author: Konstantin Knauf 
AuthorDate: Tue May 18 19:15:57 2021 +0200

[hotfix] fix typo in one of the comments
---
 config.yaml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/config.yaml b/config.yaml
index 2e48bb0..50091da 100644
--- a/config.yaml
+++ b/config.yaml
@@ -35,7 +35,7 @@ stale_minor:
 warning_label: "stale-minor"
 done_label: "auto-closed"
 warning_comment: |
-I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] 
and I help the community manage its development. I noticed that neither this 
issue nor its subtasks had updates for {state_days} days, so I labeled it 
"{warning_label}".  If you are still affected by this bug or are still 
interested in this issue, please update and remove the label.
+I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] 
and I help the community manage its development. I noticed that neither this 
issue nor its subtasks had updates for {stale_days} days, so I labeled it 
"{warning_label}".  If you are still affected by this bug or are still 
interested in this issue, please update and remove the label.
 
 done_comment: |
 This issue was labeled "{warning_label}" {warning_days} ago and has 
not received any updates so I have gone ahead and closed it.  If you are still 
affected by this or would like to raise the priority of this ticket please 
re-open, removing the label "{done_label}" and raise the ticket priority 
accordingly.

[flink-jira-bot] 43/47: [FLINK-22570] combine jira client calls and reduce number of notifications to one per ticket per rule

2021-05-19 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git

commit 7cccb045fb9a53d1e8d5b72a644099b0a90bc08d
Author: Konstantin Knauf 
AuthorDate: Tue May 18 19:03:50 2021 +0200

[FLINK-22570] combine jira client calls and reduce number of notifications 
to one per ticket per rule
---
 flink_jira_rule.py   | 65 +++-
 stale_assigned_rule.py   | 25 +++--
 stale_major_or_above_rule.py | 20 --
 stale_minor_rule.py  | 22 +--
 4 files changed, 69 insertions(+), 63 deletions(-)

diff --git a/flink_jira_rule.py b/flink_jira_rule.py
index a98ca71..3f784d7 100644
--- a/flink_jira_rule.py
+++ b/flink_jira_rule.py
@@ -60,58 +60,14 @@ class FlinkJiraRule:
 issues = self.get_issues(find_subtasks_updated_within)
 return len(issues) > 0
 
-def add_label(self, issue, label):
-labels = issue["fields"]["labels"] + [label]
-fields = {"labels": labels}
-key = issue["key"]
-
-if not self.is_dry_run:
-self.jira_client.update_issue_field(key, fields)
-else:
-logging.info(f'DRY RUN ({key}): Adding label "{label}".')
-
-def replace_label(self, issue, old_label, new_label):
-labels = issue["fields"]["labels"] + [new_label]
-labels.remove(old_label)
-fields = {"labels": labels}
-key = issue["key"]
-
-if not self.is_dry_run:
-self.jira_client.update_issue_field(key, fields)
-else:
-logging.info(
-f'DRY RUN ({key}): Replace label "{old_label}" for 
"{new_label}".'
-)
-
-def add_comment(self, key, comment):
+def add_label_with_comment(self, key, label, comment):
 if not self.is_dry_run:
-self.jira_client.issue_add_comment(key, comment)
-else:
-logging.info(f'DRY_RUN ({key}): Adding comment "{comment}".')
-
-def close_issue(self, key):
-if not self.is_dry_run:
-self.jira_client.set_issue_status(
-key, "Closed", fields={"resolution": {"name": "Auto Closed"}}
+self.jira_client.edit_issue(
+key,
+{"labels": [{"add": label}], "comment": [{"add": {"body": 
comment}}]},
 )
 else:
-logging.info(f"DRY_RUN (({key})): Closing.")
-
-def unassign(self, key):
-if not self.is_dry_run:
-if self.jira_client.get_issue_status(key) == "In Progress":
-self.jira_client.assign_issue(key, self.jira_client.username)
-self.jira_client.set_issue_status(key, "Open")
-self.jira_client.assign_issue(key, None)
-else:
-logging.info(f"DRY_RUN (({key})): Unassigning.")
-
-def set_priority(self, key, priority):
-if not self.is_dry_run:
-fields = {"priority": {"name": priority}}
-self.jira_client.update_issue_field(key, fields)
-else:
-logging.info(f"DRY_RUN (({key})): Setting to {priority}")
+logging.info(f'DRY RUN ({key}): Adding label "{label}".')
 
 @abc.abstractmethod
 def run(self):
@@ -140,12 +96,11 @@ class FlinkJiraRule:
 warning_label=self.warning_label,
 )
 
-self.add_label(issue, self.warning_label)
-self.add_comment(key, formatted_comment)
+self.add_label_with_comment(key, self.warning_label, 
formatted_comment)
 
 else:
 logging.info(
-f"Found https://issues.apache.org/jira/browse/{key}, but 
is has recently updated Subtasks. "
+f"Found https://issues.apache.org/jira/browse/{key}, but 
is has recently updated Subtasks."
 f"Ignoring for now."
 )
 
@@ -165,6 +120,6 @@ class FlinkJiraRule:
 done_label=self.done_label,
 )
 
-self.add_comment(key, formatted_comment)
-self.replace_label(issue, self.warning_label, self.done_label)
-self.handle_stale_ticket(key)
+self.handle_stale_ticket(
+key, self.warning_label, self.done_label, formatted_comment
+)
diff --git a/stale_assigned_rule.py b/stale_assigned_rule.py
index 26c7b00..d5cb41c 100644
--- a/stale_assigned_rule.py
+++ b/stale_assigned_rule.py
@@ -41,5 +41,26 @@ class StaleAssignedRule(FlinkJiraRule):
 f"AND updated < startOfDay(-{self.stale_

[flink-jira-bot] 40/47: [hotfix] fix indentation in config.yaml

2021-05-19 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git

commit 1c4ab41fce24bca9805bd8de405d87be1bddfaa3
Author: Konstantin Knauf 
AuthorDate: Thu Apr 29 10:16:26 2021 +0200

[hotfix] fix indentation in config.yaml
---
 config.yaml | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/config.yaml b/config.yaml
index b472cf2..2e48bb0 100644
--- a/config.yaml
+++ b/config.yaml
@@ -70,5 +70,5 @@ stale_major:
 warning_comment: |
 I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] 
and I help the community manage its development. I see this issues has been 
marked as Major but is unassigned and neither itself nor its Sub-Tasks have 
been updated for {stale_days} days. I have gone ahead and added a 
"{warning_label}" to the issue". If this ticket is a Major, please either 
assign yourself or give an update. Afterwards, please remove the label or in 
{warning_days} days the issue will be deprioritized.
 
-done_comment: |
-This issue was labeled "{warning_label}" {warning_days} ago and has not 
received any updates so it is being deprioritized. If this ticket is actually 
Major, please raise the priority and ask a committer to assign you the issue or 
revive the public discussion.
+done_comment: |
+This issue was labeled "{warning_label}" {warning_days} ago and has 
not received any updates so it is being deprioritized. If this ticket is 
actually Major, please raise the priority and ask a committer to assign you the 
issue or revive the public discussion.

[flink-jira-bot] 29/47: [hotfix] pull up logic to handle stale tickets

2021-05-19 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git

commit a6002490ef50be5f4b3c103ba80db0d90d307c97
Author: Konstantin Knauf 
AuthorDate: Wed Apr 21 14:42:06 2021 +0200

[hotfix] pull up logic to handle stale tickets
---
 flink_jira_rule.py   | 24 
 stale_assigned_rule.py   | 33 ++---
 stale_major_or_above_rule.py | 34 +++---
 stale_minor_rule.py  | 34 +++---
 4 files changed, 44 insertions(+), 81 deletions(-)

diff --git a/flink_jira_rule.py b/flink_jira_rule.py
index ff32a1e..f11f275 100644
--- a/flink_jira_rule.py
+++ b/flink_jira_rule.py
@@ -114,6 +114,10 @@ class FlinkJiraRule:
 def run(self):
 return
 
+@abc.abstractmethod
+def handle_stale_ticket(self, key):
+return
+
 def mark_stale_tickets_stale(self, jql_query):
 
 logging.info(f"Looking for stale tickets.")
@@ -141,3 +145,23 @@ class FlinkJiraRule:
 f"Found https://issues.apache.org/jira/browse/{key}, but 
is has recently updated Subtasks. "
 f"Ignoring for now."
 )
+
+def handle_tickets_marked_stale(self, jql_query):
+logging.info(f"Looking for ticket previously marked as 
{self.warning_label}.")
+issues = self.get_issues(jql_query)
+
+for issue in issues:
+key = issue["key"]
+logging.info(
+f"Found https://issues.apache.org/jira/browse/{key}. It is now 
processed as stale."
+)
+
+formatted_comment = self.done_comment.format(
+warning_days=self.warning_days,
+warning_label=self.warning_label,
+done_label=self.done_label,
+)
+
+self.add_comment(key, formatted_comment)
+self.replace_label(issue, self.warning_label, self.done_label)
+self.handle_stale_ticket(key)
diff --git a/stale_assigned_rule.py b/stale_assigned_rule.py
index cb672d4..26c7b00 100644
--- a/stale_assigned_rule.py
+++ b/stale_assigned_rule.py
@@ -32,35 +32,14 @@ class StaleAssignedRule(FlinkJiraRule):
 super().__init__(jira_client, config, is_dry_run)
 
 def run(self):
-self.unassign_tickets_marked_stale()
-self.mark_stale_tickets_stale(
-f"project = FLINK AND resolution = Unresolved AND assignee is not 
EMPTY "
-f"AND updated < startOfDay(-{self.stale_days}d)"
-)
-
-def unassign_tickets_marked_stale(self):
-
-assigned_tickets_marked_stale = (
+self.handle_tickets_marked_stale(
 f"project=FLINK AND resolution = Unresolved AND labels in "
 f'("{self.warning_label}") AND updated < 
startOfDay(-{self.warning_days}d)'
 )
-logging.info(
-f"Looking for assigned tickets, which were previously marked as 
{self.warning_label}."
+self.mark_stale_tickets_stale(
+f"project = FLINK AND resolution = Unresolved AND assignee is not 
EMPTY "
+f"AND updated < startOfDay(-{self.stale_days}d)"
 )
-issues = self.get_issues(assigned_tickets_marked_stale)
-
-for issue in issues:
-key = issue["key"]
-logging.info(
-f"Found https://issues.apache.org/jira/browse/{key}. It is now 
unassigned due to inactivity."
-)
-
-formatted_comment = self.done_comment.format(
-warning_days=self.warning_days,
-warning_label=self.warning_label,
-done_label=self.done_label,
-)
 
-self.add_comment(key, formatted_comment)
-self.replace_label(issue, self.warning_label, self.done_label)
-self.unassign(key)
+def handle_stale_ticket(self, key):
+self.unassign(key)
diff --git a/stale_major_or_above_rule.py b/stale_major_or_above_rule.py
index e37c9d1..d5e5663 100644
--- a/stale_major_or_above_rule.py
+++ b/stale_major_or_above_rule.py
@@ -38,35 +38,15 @@ class StaleMajorOrAboveRule(FlinkJiraRule):
 LOWER_PRIORITIES = {"Blocker": "Critical", "Critical": "Major", "Major": 
"Minor"}
 
 def run(self):
-self.close_tickets_marked_stale()
+self.handle_tickets_marked_stale(
+f"project=FLINK AND Priority = {self.priority} AND resolution = 
Unresolved "
+f'AND labels in ("{self.warning_label}") '
+f"AND updated < startOfDay(-{self.warning_days}d)"
+)
 self.mark_stale_tickets_stale(
 f"project=FLINK AND priori

[flink-jira-bot] 23/47: Merge pull request #6 from knaufk/FLINK-22394

2021-05-19 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git

commit 1bd0618237096e87cd08c827552e46f5325d5637
Merge: 8bf7d6a 5f209ae
Author: Konstantin Knauf 
AuthorDate: Wed Apr 21 13:01:32 2021 +0200

Merge pull request #6 from knaufk/FLINK-22394

[hotfix] Auto Close issues with resolution "Auto Closed" instead of "…

 flink_jira_bot.py | 6 --
 1 file changed, 4 insertions(+), 2 deletions(-)

[flink-jira-bot] 46/47: [FLINK-22569] limit number of tickets touched by the bot per run to 100

2021-05-19 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git

commit 59c16f595514c67983965d9580c7c0f45eebcaaf
Author: Konstantin Knauf 
AuthorDate: Tue May 18 19:16:33 2021 +0200

[FLINK-22569] limit number of tickets touched by the bot per run to 100
---
 config.yaml|  5 +
 flink_jira_rule.py | 17 +
 2 files changed, 14 insertions(+), 8 deletions(-)

diff --git a/config.yaml b/config.yaml
index 50091da..f8aa8cf 100644
--- a/config.yaml
+++ b/config.yaml
@@ -17,6 +17,7 @@
 

 
 stale_assigned:
+ticket_limit: 10
 stale_days: 14
 warning_days: 7
 warning_label: "stale-assigned"
@@ -30,6 +31,7 @@ stale_assigned:
 This issue was marked "{warning_label}" {warning_days} ago and has not 
received an update. I have automatically removed the current assignee from the 
issue so others in the community may pick it up. If you are still working on 
this ticket, please ask a committer to reassign you and provide an update about 
your current status.
 
 stale_minor:
+ticket_limit: 10
 stale_days: 180
 warning_days: 7
 warning_label: "stale-minor"
@@ -41,6 +43,7 @@ stale_minor:
 This issue was labeled "{warning_label}" {warning_days} ago and has 
not received any updates so I have gone ahead and closed it.  If you are still 
affected by this or would like to raise the priority of this ticket please 
re-open, removing the label "{done_label}" and raise the ticket priority 
accordingly.
 
 stale_blocker:
+ticket_limit: 5
 stale_days: 1
 warning_days: 7
 warning_label: "stale-blocker"
@@ -52,6 +55,7 @@ stale_blocker:
 This issue was labeled "{warning_label}" {warning_days} ago and has 
not received any updates so it is being deprioritized. If this ticket is 
actually a Blocker, please raise the priority and ask a committer to assign you 
the issue or revive the public discussion.
 
 stale_critical:
+ticket_limit: 10
 stale_days: 7
 warning_days: 7
 warning_label: "stale-critical"
@@ -63,6 +67,7 @@ stale_critical:
 This issue was labeled "{warning_label}" {warning_days} ago and has 
not received any updates so it is being deprioritized. If this ticket is 
actually Critical, please raise the priority and ask a committer to assign you 
the issue or revive the public discussion.
 
 stale_major:
+ticket_limit: 15
 stale_days: 30
 warning_days: 7
 warning_label: "stale-major"
diff --git a/flink_jira_rule.py b/flink_jira_rule.py
index 3f784d7..f70ca3d 100644
--- a/flink_jira_rule.py
+++ b/flink_jira_rule.py
@@ -32,8 +32,9 @@ class FlinkJiraRule:
 self.done_label = config["done_label"].get()
 self.done_comment = config["done_comment"].get()
 self.warning_comment = config["warning_comment"].get()
+self.ticket_limit = config["ticket_limit"].get()
 
-def get_issues(self, jql_query):
+def get_issues(self, jql_query, limit):
 """Queries the JIRA PI for all issues that match the given JQL Query
 
 This method is necessary as requests tend to time out if the number of 
results reaches a certain number.
@@ -41,23 +42,23 @@ class FlinkJiraRule:
 :param jql_query: the search query
 :return: a list of issues matching the query
 """
-limit = 200
+limit_per_api_request = min(100, limit)
 current = 0
 total = 1
 issues = []
-while current < total:
-response = self.jira_client.jql(jql_query, limit=limit, 
start=current)
+while current < min(total, limit):
+response = self.jira_client.jql(jql_query, 
limit=limit_per_api_request, start=current)
 total = response["total"]
 issues = issues + response["issues"]
 current = len(issues)
 logging.info(f'"{jql_query}" returned {len(issues)} issues')
-return issues
+return issues[:min(limit, len(issues))]
 
 def has_recently_updated_subtask(self, parent, updated_within_days):
 find_subtasks_updated_within = (
 f"parent = {parent}  AND updated > 
startOfDay(-{updated_within_days}d)"
 )
-issues = self.get_issues(find_subtasks_updated_within)
+issues = self.get_issues(find_subtasks_updated_within, 1)
 return len(issues) > 0
 
 def add_label_with_comment(self, key, label, comment):
@@ -80,7 +81,7 @@ class FlinkJiraRule:
 def mark_stale_tickets_stale(self, jql_query):
 
 logging.info(f"Looking for stale tickets.")
-issues = self.get_issues(jq

[flink-jira-bot] 20/47: [FLINK-22033] add docstring for rule classes

2021-05-19 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git

commit 77943a14746fbcdb8432863b07f0c8143d33f3fc
Author: Konstantin Knauf 
AuthorDate: Fri Apr 16 11:31:51 2021 +0200

[FLINK-22033] add docstring for rule classes
---
 flink_jira_bot.py | 12 
 1 file changed, 12 insertions(+)

diff --git a/flink_jira_bot.py b/flink_jira_bot.py
index e1cdc28..00ce80f 100644
--- a/flink_jira_bot.py
+++ b/flink_jira_bot.py
@@ -107,6 +107,12 @@ class FlinkJiraRule:
 
 
 class Rule3(FlinkJiraRule):
+"""
+An unresolved Minor ticket without an update for {stale_minor.stale_days} 
is closed after a warning period of
+{stale_minor.warning_days} with a comment that encourages users to watch, 
comment and simply reopen with a higher
+priority if the problem insists.
+"""
+
 def __init__(self, jira_client, config, is_dry_run):
 super().__init__(jira_client, config, is_dry_run)
 self.stale_days = config["stale_minor"]["stale_days"].get()
@@ -181,6 +187,12 @@ class Rule3(FlinkJiraRule):
 
 
 class Rule2(FlinkJiraRule):
+"""
+Assigned tickets without an update for {stale_assigned.stale_days} are 
unassigned after a warning period of
+{stale_assigned.warning_days}. Before this happens the assignee is 
notified that this is about to happen and
+asked for an update on the status of her contribution.
+"""
+
 def __init__(self, jira_client, config, is_dry_run):
 super().__init__(jira_client, config, is_dry_run)
 self.stale_days = config["stale_assigned"]["stale_days"].get()

[flink-jira-bot] 37/47: Merge pull request #9 from knaufk/FLINK-22340

2021-05-19 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git

commit 37190da20dd8586b277be0b13face6632706fdc1
Merge: 673419a 723a958
Author: Konstantin Knauf 
AuthorDate: Fri Apr 23 16:09:08 2021 +0200

Merge pull request #9 from knaufk/FLINK-22340

[FLINK-22340] adjust stale_assigned role

 config.yaml | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

[flink-jira-bot] 28/47: [hotfix] pull up logic for marking tickets stale

2021-05-19 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git

commit b342cb2168b941790ebefd36a780b80cd2c9dc96
Author: Konstantin Knauf 
AuthorDate: Wed Apr 21 14:18:09 2021 +0200

[hotfix] pull up logic for marking tickets stale
---
 flink_jira_rule.py   | 28 
 stale_assigned_rule.py   | 37 -
 stale_major_or_above_rule.py | 37 -
 stale_minor_rule.py  | 37 -
 4 files changed, 40 insertions(+), 99 deletions(-)

diff --git a/flink_jira_rule.py b/flink_jira_rule.py
index c453562..ff32a1e 100644
--- a/flink_jira_rule.py
+++ b/flink_jira_rule.py
@@ -113,3 +113,31 @@ class FlinkJiraRule:
 @abc.abstractmethod
 def run(self):
 return
+
+def mark_stale_tickets_stale(self, jql_query):
+
+logging.info(f"Looking for stale tickets.")
+issues = self.get_issues(jql_query)
+
+for issue in issues:
+key = issue["key"]
+issue = self.jira_client.get_issue(key)
+
+if not self.has_recently_updated_subtask(key, self.stale_days):
+logging.info(
+f"Found https://issues.apache.org/jira/browse/{key}. It is 
marked stale now."
+)
+formatted_comment = self.warning_comment.format(
+stale_days=self.stale_days,
+warning_days=self.warning_days,
+warning_label=self.warning_label,
+)
+
+self.add_label(issue, self.warning_label)
+self.add_comment(key, formatted_comment)
+
+else:
+logging.info(
+f"Found https://issues.apache.org/jira/browse/{key}, but 
is has recently updated Subtasks. "
+f"Ignoring for now."
+)
diff --git a/stale_assigned_rule.py b/stale_assigned_rule.py
index ddee747..cb672d4 100644
--- a/stale_assigned_rule.py
+++ b/stale_assigned_rule.py
@@ -33,7 +33,10 @@ class StaleAssignedRule(FlinkJiraRule):
 
 def run(self):
 self.unassign_tickets_marked_stale()
-self.mark_stale_tickets_stale()
+self.mark_stale_tickets_stale(
+f"project = FLINK AND resolution = Unresolved AND assignee is not 
EMPTY "
+f"AND updated < startOfDay(-{self.stale_days}d)"
+)
 
 def unassign_tickets_marked_stale(self):
 
@@ -61,35 +64,3 @@ class StaleAssignedRule(FlinkJiraRule):
 self.add_comment(key, formatted_comment)
 self.replace_label(issue, self.warning_label, self.done_label)
 self.unassign(key)
-
-def mark_stale_tickets_stale(self):
-
-stale_assigned_tickets = (
-f"project = FLINK AND resolution = Unresolved AND assignee is not 
EMPTY AND updated < "
-f"startOfDay(-{self.stale_days}d)"
-)
-logging.info(f"Looking for assigned tickets, which are stale.")
-issues = self.get_issues(stale_assigned_tickets)
-
-for issue in issues:
-key = issue["key"]
-issue = self.jira_client.get_issue(key)
-
-if not self.has_recently_updated_subtask(key, self.stale_days):
-logging.info(
-f"Found https://issues.apache.org/jira/browse/{key}. It is 
marked stale now."
-)
-formatted_comment = self.warning_comment.format(
-stale_days=self.stale_days,
-warning_days=self.warning_days,
-warning_label=self.warning_label,
-)
-
-self.add_label(issue, self.warning_label)
-self.add_comment(key, formatted_comment)
-
-else:
-logging.info(
-f"Found https://issues.apache.org/jira/browse/{key}, but 
is has recently updated Subtasks. "
-f"Ignoring for now."
-)
diff --git a/stale_major_or_above_rule.py b/stale_major_or_above_rule.py
index aeda3f1..e37c9d1 100644
--- a/stale_major_or_above_rule.py
+++ b/stale_major_or_above_rule.py
@@ -39,7 +39,10 @@ class StaleMajorOrAboveRule(FlinkJiraRule):
 
 def run(self):
 self.close_tickets_marked_stale()
-self.mark_stale_tickets_stale()
+self.mark_stale_tickets_stale(
+f"project=FLINK AND priority = {self.priority} AND resolution = 
Unresolved "
+f"AND assignee is empty AND updated < 
startOfDay(-{self.stale_days}d)"
+)
 
 def close_tickets_marked_stale(self):
 
@@ -67,35 +70,3 @@ class StaleMajorOrAboveRule(FlinkJiraRule):
 self.add_comment(ke

[flink-jira-bot] 18/47: [hotfix] fix tyop in Github Actions workflow

2021-05-19 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git

commit e575ac6695ea89176fb68e9526b5200be57afa2c
Author: Konstantin Knauf 
AuthorDate: Thu Apr 15 18:21:11 2021 +0200

[hotfix] fix tyop in Github Actions workflow
---
 .github/workflows/actions.yaml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/.github/workflows/actions.yaml b/.github/workflows/actions.yaml
index d9ef9fe..1cc051b 100644
--- a/.github/workflows/actions.yaml
+++ b/.github/workflows/actions.yaml
@@ -1,4 +1,4 @@
-name: Run Flink Jira Twice Daily
+name: Run Flink Jira Bot Twice Daily
 
 on:
   schedule:

[flink-jira-bot] 44/47: Merge pull request #14 from knaufk/FLINK-22570

2021-05-19 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git

commit a43b94fbe084d9e9a6ddab4bfc7feba1f447300c
Merge: f185d86 7cccb04
Author: Konstantin Knauf 
AuthorDate: Wed May 19 10:07:44 2021 +0200

Merge pull request #14 from knaufk/FLINK-22570

[FLINK-22570] combine jira client calls and reduce number of notifica…

 flink_jira_rule.py   | 65 +++-
 stale_assigned_rule.py   | 25 +++--
 stale_major_or_above_rule.py | 20 --
 stale_minor_rule.py  | 22 +--
 4 files changed, 69 insertions(+), 63 deletions(-)

[flink-jira-bot] 24/47: [FLIINK-22034] update README.md for Rule1

2021-05-19 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git

commit 5ad9bd36bf13078c8d2ad1b87ca02da3ab9eb6c2
Author: Konstantin Knauf 
AuthorDate: Wed Apr 21 11:14:53 2021 +0200

[FLIINK-22034] update README.md for Rule1
---
 README.md | 7 ++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/README.md b/README.md
index 503a762..a91e616 100644
--- a/README.md
+++ b/README.md
@@ -40,7 +40,12 @@ The configuration of the rules can be found in 
[config.yaml](config.yaml).
 
 ## About the Rules
 
-### Rule 1 (not implemented yet)
+### Rule 1 Major+ Need Assignee or Discussion
+
+Tickets major and above need an assignee, or an update within 
{stale_.stale_days}, otherwise the priority will be 
reduced after a warning period of {stale_.warning_days} 
days.
+An update of a Sub-Task counts as an update to the ticket. 
+Before this happens the assignee/reporter/watchers are notified that the 
ticket is about to become stale and will be deprioritized. 
+The time periods before warning differ based on the priority: 
 
 ### Rule 2: Unassign Stale Assigned Tickets

[flink-jira-bot] 17/47: Merge pull request #4 from knaufk/hotfix-jira

2021-05-19 Thread knaufk

This is an automated email from the ASF dual-hosted git repository.

knaufk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-jira-bot.git

commit 93679d9fdd56cc6c0fd2850f08637bf5d8299a5e
Merge: 4cc0b90 310b9cc
Author: Konstantin Knauf 
AuthorDate: Wed Apr 14 19:42:56 2021 +0200

Merge pull request #4 from knaufk/hotfix-jira

[hotfix] fix runtime errors in flink_jira_bot.py

 flink_jira_bot.py | 34 ++
 1 file changed, 18 insertions(+), 16 deletions(-)

1 2 3 >

1 - 100 of 270 matches

Mail list logo