[flink-statefun-playground] branch dev updated: [FLINK-25899] Add connected components example
This is an automated email from the ASF dual-hosted git repository. trohrmann pushed a commit to branch dev in repository https://gitbox.apache.org/repos/asf/flink-statefun-playground.git The following commit(s) were added to refs/heads/dev by this push: new c28e68c [FLINK-25899] Add connected components example c28e68c is described below commit c28e68cc34c94eeaf2475d1b376a01b70004400a Author: Till Rohrmann AuthorDate: Fri Jan 28 10:45:10 2022 +0100 [FLINK-25899] Add connected components example --- java/connected-components/Dockerfile | 27 + java/connected-components/README.md| 74 java/connected-components/docker-compose.yml | 110 + java/connected-components/module.yaml | 41 +++ java/connected-components/pom.xml | 111 + .../ConnectedComponentsAppServer.java | 48 .../connectedcomponents/ConnectedComponentsFn.java | 134 + .../java/connectedcomponents/types/Types.java | 41 +++ .../java/connectedcomponents/types/Vertex.java | 24 .../types/VertexComponentChange.java | 41 +++ .../undertow/UndertowHttpHandler.java | 62 ++ java/connected-components/vertices.txt | 12 ++ 12 files changed, 725 insertions(+) diff --git a/java/connected-components/Dockerfile b/java/connected-components/Dockerfile new file mode 100644 index 000..76f3feb --- /dev/null +++ b/java/connected-components/Dockerfile @@ -0,0 +1,27 @@ +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See the NOTICE file distributed with +# this work for additional information regarding copyright ownership. +# The ASF licenses this file to You under the Apache License, Version 2.0 +# (the "License"); you may not use this file except in compliance with +# the License. You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. + +# Build the functions code ... +FROM maven:3.6.3-jdk-11 AS builder +COPY src /usr/src/app/src +COPY pom.xml /usr/src/app +RUN mvn -f /usr/src/app/pom.xml clean package + +# ... and run the web server! +FROM openjdk:8 +WORKDIR / +COPY --from=builder /usr/src/app/target/connected-components-functions-app*jar-with-dependencies.jar connected-components-functions-app.jar +EXPOSE 1108 +CMD java -jar connected-components-functions-app.jar diff --git a/java/connected-components/README.md b/java/connected-components/README.md new file mode 100644 index 000..981a754 --- /dev/null +++ b/java/connected-components/README.md @@ -0,0 +1,74 @@ +# Connected Components Example with Docker Compose + +This example is intended as a follow-up after completion of the [Java SDK Showcase Tutorial](../showcase). If you're +already familiar with the Java SDK fundamentals and would like to get a better understanding of how a realistic StateFun +application looks like, then you're in the right place! Otherwise, we highly suggest taking a look at the Showcase +tutorial first. + +This example works with Docker Compose, and runs a few services that build up an end-to-end StateFun application: +- Functions service that runs your functions and expose them through an HTTP endpoint. +- StateFun runtime processes (a manager plus workers) that will handle ingress, egress, and inter-function messages as + well as function state storage in a consistent and fault-tolerant manner. +- Apache Kafka broker for the application ingress and egress. StateFun currently natively supports AWS Kinesis as well, + and you can also extend to connect with other systems. + +To motivate this example, we'll implement a [connected components](https://en.wikipedia.org/wiki/Component_(graph_theory) algorithm on top of Stateful Functions. +The program has one function - a `ConnectedComponentsFn` that consumes `Vertex` JSON events from an ingress and communicates with its neighbours to find the minimal component id. +Changes of the component id of a vertex are being output via an egress. + +## Directory structure + +- `src/`, `pom.xml` and `Dockerfile`: These files and directories are the contents of a Java Maven project which builds + our functions service, hosting the `ConnectedComponentsFn` behind a HTTP endpoint. Check out the source code under + `src/main/java`. The `Dockerfile` is used to build a Docker image for our functions service. +- `vertices.txt`: A file with multiple JSON objects per line; this is used as test events produced to our application ingress. +- `module.yaml`: The [Module Spe
[flink-statefun-playground] branch release-3.2 updated: [FLINK-25899] Add connected components example
This is an automated email from the ASF dual-hosted git repository. trohrmann pushed a commit to branch release-3.2 in repository https://gitbox.apache.org/repos/asf/flink-statefun-playground.git The following commit(s) were added to refs/heads/release-3.2 by this push: new dc40776 [FLINK-25899] Add connected components example dc40776 is described below commit dc40776d380540094fa721bfe734c1ca926be9f9 Author: Till Rohrmann AuthorDate: Fri Jan 28 10:45:10 2022 +0100 [FLINK-25899] Add connected components example --- java/connected-components/Dockerfile | 27 + java/connected-components/README.md| 74 java/connected-components/docker-compose.yml | 110 + java/connected-components/module.yaml | 41 +++ java/connected-components/pom.xml | 111 + .../ConnectedComponentsAppServer.java | 48 .../connectedcomponents/ConnectedComponentsFn.java | 134 + .../java/connectedcomponents/types/Types.java | 41 +++ .../java/connectedcomponents/types/Vertex.java | 24 .../types/VertexComponentChange.java | 41 +++ .../undertow/UndertowHttpHandler.java | 62 ++ java/connected-components/vertices.txt | 12 ++ 12 files changed, 725 insertions(+) diff --git a/java/connected-components/Dockerfile b/java/connected-components/Dockerfile new file mode 100644 index 000..76f3feb --- /dev/null +++ b/java/connected-components/Dockerfile @@ -0,0 +1,27 @@ +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See the NOTICE file distributed with +# this work for additional information regarding copyright ownership. +# The ASF licenses this file to You under the Apache License, Version 2.0 +# (the "License"); you may not use this file except in compliance with +# the License. You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. + +# Build the functions code ... +FROM maven:3.6.3-jdk-11 AS builder +COPY src /usr/src/app/src +COPY pom.xml /usr/src/app +RUN mvn -f /usr/src/app/pom.xml clean package + +# ... and run the web server! +FROM openjdk:8 +WORKDIR / +COPY --from=builder /usr/src/app/target/connected-components-functions-app*jar-with-dependencies.jar connected-components-functions-app.jar +EXPOSE 1108 +CMD java -jar connected-components-functions-app.jar diff --git a/java/connected-components/README.md b/java/connected-components/README.md new file mode 100644 index 000..981a754 --- /dev/null +++ b/java/connected-components/README.md @@ -0,0 +1,74 @@ +# Connected Components Example with Docker Compose + +This example is intended as a follow-up after completion of the [Java SDK Showcase Tutorial](../showcase). If you're +already familiar with the Java SDK fundamentals and would like to get a better understanding of how a realistic StateFun +application looks like, then you're in the right place! Otherwise, we highly suggest taking a look at the Showcase +tutorial first. + +This example works with Docker Compose, and runs a few services that build up an end-to-end StateFun application: +- Functions service that runs your functions and expose them through an HTTP endpoint. +- StateFun runtime processes (a manager plus workers) that will handle ingress, egress, and inter-function messages as + well as function state storage in a consistent and fault-tolerant manner. +- Apache Kafka broker for the application ingress and egress. StateFun currently natively supports AWS Kinesis as well, + and you can also extend to connect with other systems. + +To motivate this example, we'll implement a [connected components](https://en.wikipedia.org/wiki/Component_(graph_theory) algorithm on top of Stateful Functions. +The program has one function - a `ConnectedComponentsFn` that consumes `Vertex` JSON events from an ingress and communicates with its neighbours to find the minimal component id. +Changes of the component id of a vertex are being output via an egress. + +## Directory structure + +- `src/`, `pom.xml` and `Dockerfile`: These files and directories are the contents of a Java Maven project which builds + our functions service, hosting the `ConnectedComponentsFn` behind a HTTP endpoint. Check out the source code under + `src/main/java`. The `Dockerfile` is used to build a Docker image for our functions service. +- `vertices.txt`: A file with multiple JSON objects per line; this is used as test events produced to our application ingress. +- `module.yaml`:
[flink-statefun-playground] branch release-3.1 updated (ebc83ab -> 9c666fd)
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch release-3.1
in repository https://gitbox.apache.org/repos/asf/flink-statefun-playground.git.
from ebc83ab Change the version to 3.1.1
add 9c666fd [FLINK-25899] Add connected components example
No new revisions were added by this update.
Summary of changes:
java/{greeter => connected-components}/Dockerfile | 4 +-
java/{greeter => connected-components}/README.md | 20 +--
.../docker-compose.yml | 20 +--
java/{greeter => connected-components}/module.yaml | 16 +--
.../pom.xml| 43 ++-
.../ConnectedComponentsAppServer.java} | 11 +-
.../connectedcomponents/ConnectedComponentsFn.java | 134 +
.../java/connectedcomponents/types/Types.java | 41 +++
.../java/connectedcomponents/types/Vertex.java | 24
.../types/VertexComponentChange.java | 41 +++
.../undertow/UndertowHttpHandler.java | 2 +-
java/connected-components/vertices.txt | 12 ++
12 files changed, 299 insertions(+), 69 deletions(-)
copy java/{greeter => connected-components}/Dockerfile (84%)
copy java/{greeter => connected-components}/README.md (74%)
copy java/{greeter => connected-components}/docker-compose.yml (86%)
copy java/{greeter => connected-components}/module.yaml (75%)
copy java/{shopping-cart => connected-components}/pom.xml (77%)
copy
java/{greeter/src/main/java/org/apache/flink/statefun/playground/java/greeter/GreeterAppServer.java
=>
connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/ConnectedComponentsAppServer.java}
(83%)
create mode 100644
java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/ConnectedComponentsFn.java
create mode 100644
java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/types/Types.java
create mode 100644
java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/types/Vertex.java
create mode 100644
java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/types/VertexComponentChange.java
copy
java/{greeter/src/main/java/org/apache/flink/statefun/playground/java/greeter
=>
connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents}/undertow/UndertowHttpHandler.java
(96%)
create mode 100644 java/connected-components/vertices.txt
[flink] branch master updated (bb92bc0 -> d9d72ef)
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from bb92bc0 [FLINK-25575][streaming] Switch the implementation of Sink operator to V2. new 05eecb0d [FLINK-25387][FLINK-25388][FLINK-25389][table-planner] Introduce ExecNodeMetadata new d9d72ef [hotfix][table-planner] Remove org.reflections usage and dependency 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: .../flink/table/planner/loader/PlannerModule.java | 4 +- flink-table/flink-table-planner/pom.xml| 26 -- .../table/planner/plan/nodes/exec/ExecNode.java| 15 +- .../planner/plan/nodes/exec/ExecNodeBase.java | 52 ++-- .../planner/plan/nodes/exec/ExecNodeContext.java | 163 +++ .../planner/plan/nodes/exec/ExecNodeMetadata.java | 132 + .../plan/nodes/exec/ExecNodeTypeIdResolver.java| 67 + .../planner/plan/nodes/exec/InputProperty.java | 4 - .../plan/nodes/exec/MultipleExecNodeMetadata.java | 20 +- .../exec/batch/BatchExecBoundedStreamScan.java | 8 +- .../plan/nodes/exec/batch/BatchExecCalc.java | 4 +- .../plan/nodes/exec/batch/BatchExecCorrelate.java | 4 +- .../plan/nodes/exec/batch/BatchExecExchange.java | 8 +- .../plan/nodes/exec/batch/BatchExecExpand.java | 4 +- .../nodes/exec/batch/BatchExecHashAggregate.java | 8 +- .../plan/nodes/exec/batch/BatchExecHashJoin.java | 8 +- .../exec/batch/BatchExecHashWindowAggregate.java | 8 +- .../plan/nodes/exec/batch/BatchExecLegacySink.java | 3 + .../exec/batch/BatchExecLegacyTableSourceScan.java | 9 +- .../plan/nodes/exec/batch/BatchExecLimit.java | 8 +- .../plan/nodes/exec/batch/BatchExecLookupJoin.java | 4 +- .../nodes/exec/batch/BatchExecMultipleInput.java | 8 +- .../nodes/exec/batch/BatchExecNestedLoopJoin.java | 8 +- .../nodes/exec/batch/BatchExecOverAggregate.java | 9 +- .../exec/batch/BatchExecOverAggregateBase.java | 5 +- .../plan/nodes/exec/batch/BatchExecPythonCalc.java | 21 +- .../nodes/exec/batch/BatchExecPythonCorrelate.java | 4 +- .../exec/batch/BatchExecPythonGroupAggregate.java | 8 +- .../batch/BatchExecPythonGroupWindowAggregate.java | 8 +- .../exec/batch/BatchExecPythonOverAggregate.java | 9 +- .../plan/nodes/exec/batch/BatchExecRank.java | 8 +- .../plan/nodes/exec/batch/BatchExecSink.java | 4 +- .../plan/nodes/exec/batch/BatchExecSort.java | 8 +- .../nodes/exec/batch/BatchExecSortAggregate.java | 8 +- .../plan/nodes/exec/batch/BatchExecSortLimit.java | 8 +- .../nodes/exec/batch/BatchExecSortMergeJoin.java | 8 +- .../exec/batch/BatchExecSortWindowAggregate.java | 8 +- .../nodes/exec/batch/BatchExecTableSourceScan.java | 8 +- .../plan/nodes/exec/batch/BatchExecUnion.java | 8 +- .../plan/nodes/exec/batch/BatchExecValues.java | 8 +- .../exec/batch/BatchExecWindowTableFunction.java | 4 +- .../plan/nodes/exec/common/CommonExecCalc.java | 13 +- .../nodes/exec/common/CommonExecCorrelate.java | 13 +- .../plan/nodes/exec/common/CommonExecExchange.java | 9 +- .../plan/nodes/exec/common/CommonExecExpand.java | 9 +- .../nodes/exec/common/CommonExecLegacySink.java| 5 +- .../common/CommonExecLegacyTableSourceScan.java| 5 +- .../nodes/exec/common/CommonExecLookupJoin.java| 14 +- .../nodes/exec/common/CommonExecPythonCalc.java| 8 +- .../exec/common/CommonExecPythonCorrelate.java | 8 +- .../plan/nodes/exec/common/CommonExecSink.java | 11 +- .../exec/common/CommonExecTableSourceScan.java | 6 +- .../plan/nodes/exec/common/CommonExecUnion.java| 9 +- .../plan/nodes/exec/common/CommonExecValues.java | 12 +- .../exec/common/CommonExecWindowTableFunction.java | 8 +- .../exec/serde/ExecNodeGraphJsonPlanGenerator.java | 15 +- .../plan/nodes/exec/serde/JsonSerdeUtil.java | 6 +- .../nodes/exec/stream/StreamExecAggregateBase.java | 4 +- .../plan/nodes/exec/stream/StreamExecCalc.java | 19 +- .../exec/stream/StreamExecChangelogNormalize.java | 18 +- .../nodes/exec/stream/StreamExecCorrelate.java | 19 +- .../exec/stream/StreamExecDataStreamScan.java | 8 +- .../nodes/exec/stream/StreamExecDeduplicate.java | 18 +- .../exec/stream/StreamExecDropUpdateBefore.java| 20 +- .../plan/nodes/exec/stream/StreamExecExchange.java | 20 +- .../plan/nodes/exec/stream/StreamExecExpand.java | 19 +- .../stream/StreamExecGlobalGroupAggregate.java | 16 +- .../stream/StreamExecGlobalWindowAggregate.java| 16 +- .../exec/stream/StreamExecGroupAggregate.java | 18 +- .../exec/stream/StreamExecGroupTableAggregate.java | 8 +- .
[flink] 02/02: [hotfix][table-planner] Remove org.reflections usage and dependency
This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit d9d72ef142a2343f37b8b10ca6e04dc7f6ca086e
Author: Marios Trivyzas
AuthorDate: Mon Jan 31 12:55:58 2022 +0200
[hotfix][table-planner] Remove org.reflections usage and dependency
---
.../flink/table/planner/loader/PlannerModule.java | 4 +-
flink-table/flink-table-planner/pom.xml| 26 --
.../table/planner/plan/utils/ReflectionsUtil.java | 56 -
.../nodes/exec/stream/JsonSerdeCoverageTest.java | 93 --
.../plan/utils/ExecNodeMetadataUtilTest.java | 44 +-
.../planner/plan/utils/ReflectionsUtilTest.java| 87
.../metadata/MetadataHandlerConsistencyTest.scala | 36 +
7 files changed, 65 insertions(+), 281 deletions(-)
diff --git
a/flink-table/flink-table-planner-loader/src/main/java/org/apache/flink/table/planner/loader/PlannerModule.java
b/flink-table/flink-table-planner-loader/src/main/java/org/apache/flink/table/planner/loader/PlannerModule.java
index 7d72fdc..0a698b2 100644
---
a/flink-table/flink-table-planner-loader/src/main/java/org/apache/flink/table/planner/loader/PlannerModule.java
+++
b/flink-table/flink-table-planner-loader/src/main/java/org/apache/flink/table/planner/loader/PlannerModule.java
@@ -68,9 +68,7 @@ class PlannerModule {
// flink-table-runtime or flink-dist itself
"org.codehaus.janino",
"org.codehaus.commons",
-"org.apache.commons.lang3",
-// Used by org.reflections
-"javassist"))
+"org.apache.commons.lang3"))
.toArray(String[]::new);
private static final String[] COMPONENT_CLASSPATH = new String[]
{"org.apache.flink"};
diff --git a/flink-table/flink-table-planner/pom.xml
b/flink-table/flink-table-planner/pom.xml
index 3d986ef..ce559ac 100644
--- a/flink-table/flink-table-planner/pom.xml
+++ b/flink-table/flink-table-planner/pom.xml
@@ -189,24 +189,6 @@ under the License.
scala-parser-combinators_${scala.binary.version}
-
-
- org.reflections
- reflections
- 0.9.10
- compile
-
-
-
com.google.code.findbugs
- annotations
-
-
- com.google.guava
- guava
-
-
-
-
@@ -372,9 +354,6 @@ under the License.
org.scala-lang.modules:scala-parser-combinators_${scala.binary.version}
-
-
-
org.reflections:reflections
@@ -410,11 +389,6 @@ under the License.
org.apache.flink.table.shaded.com.jayway
-
-
-
org.reflections
-
org.apache.flink.table.shaded.org.reflections
-
com.ibm.icu
diff --git
a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/utils/ReflectionsUtil.java
b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/utils/ReflectionsUtil.java
deleted file mode 100644
index 7ea1409..000
---
a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/utils/ReflectionsUtil.java
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file exc
[flink-statefun] branch master updated (66b2fc5 -> 2c57b91)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink-statefun.git. from 66b2fc5 [hotfix][doc] Remove invalid link in README new 8b12bd2 [FLINK-25915][docs] Remove Google Analytics implementation new 2c57b91 [FLINK-25915][docs] Add Matomo tracking code to base layout 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/layouts/_default/baseof.html | 30 +++--- 1 file changed, 19 insertions(+), 11 deletions(-)
[flink-statefun] 02/02: [FLINK-25915][docs] Add Matomo tracking code to base layout
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git
commit 2c57b91b88fef4e5600c7990c01ea1c47d8155c2
Author: martijnvisser
AuthorDate: Tue Feb 1 19:30:05 2022 +0100
[FLINK-25915][docs] Add Matomo tracking code to base layout
---
docs/layouts/_default/baseof.html | 19 +++
1 file changed, 19 insertions(+)
diff --git a/docs/layouts/_default/baseof.html
b/docs/layouts/_default/baseof.html
index b5c8149..733bf1b 100644
--- a/docs/layouts/_default/baseof.html
+++ b/docs/layouts/_default/baseof.html
@@ -23,6 +23,25 @@ under the License.
{{ hugo.Generator }}
{{ partial "docs/html-head" . }}
{{ partial "docs/inject/head" . }}
+
+
+var _paq = window._paq = window._paq || [];
+/* 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() {
+ var u="//matomo.privacy.apache.org/";
+ _paq.push(['setTrackerUrl', u+'matomo.php']);
+ _paq.push(['setSiteId', '1']);
+ var d=document, g=d.createElement('script'),
s=d.getElementsByTagName('script')[0];
+ g.async=true; g.src=u+'matomo.js'; s.parentNode.insertBefore(g,s);
+})();
+
+
[flink-statefun] 01/02: [FLINK-25915][docs] Remove Google Analytics implementation
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git
commit 8b12bd29f93e5dd2548f34d06e19be34d4e4bd49
Author: martijnvisser
AuthorDate: Tue Feb 1 19:29:06 2022 +0100
[FLINK-25915][docs] Remove Google Analytics implementation
---
docs/layouts/_default/baseof.html | 11 ---
1 file changed, 11 deletions(-)
diff --git a/docs/layouts/_default/baseof.html
b/docs/layouts/_default/baseof.html
index ea45bd8..b5c8149 100644
--- a/docs/layouts/_default/baseof.html
+++ b/docs/layouts/_default/baseof.html
@@ -65,17 +65,6 @@ under the License.
{{ partial "docs/inject/body" . }}
-
-
-
-
(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');
-
[flink-statefun] 02/02: [FLINK-25915][docs] Add Matomo tracking code to base layout
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-3.2
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git
commit c45cf00cf26e77add6fec7e6526b0bbf3df323c6
Author: martijnvisser
AuthorDate: Tue Feb 1 19:30:05 2022 +0100
[FLINK-25915][docs] Add Matomo tracking code to base layout
---
docs/layouts/_default/baseof.html | 19 +++
1 file changed, 19 insertions(+)
diff --git a/docs/layouts/_default/baseof.html
b/docs/layouts/_default/baseof.html
index b5c8149..733bf1b 100644
--- a/docs/layouts/_default/baseof.html
+++ b/docs/layouts/_default/baseof.html
@@ -23,6 +23,25 @@ under the License.
{{ hugo.Generator }}
{{ partial "docs/html-head" . }}
{{ partial "docs/inject/head" . }}
+
+
+var _paq = window._paq = window._paq || [];
+/* 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() {
+ var u="//matomo.privacy.apache.org/";
+ _paq.push(['setTrackerUrl', u+'matomo.php']);
+ _paq.push(['setSiteId', '1']);
+ var d=document, g=d.createElement('script'),
s=d.getElementsByTagName('script')[0];
+ g.async=true; g.src=u+'matomo.js'; s.parentNode.insertBefore(g,s);
+})();
+
+
[flink-statefun] branch release-3.2 updated (581c0cd -> c45cf00)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch release-3.2 in repository https://gitbox.apache.org/repos/asf/flink-statefun.git. from 581c0cd [FLINK-25829] Skip deployment of statefun-sdk-js new 9d535da [FLINK-25915][docs] Remove Google Analytics implementation new c45cf00 [FLINK-25915][docs] Add Matomo tracking code to base layout 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/layouts/_default/baseof.html | 30 +++--- 1 file changed, 19 insertions(+), 11 deletions(-)
[flink-statefun] 01/02: [FLINK-25915][docs] Remove Google Analytics implementation
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-3.2
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git
commit 9d535da46d45a09aa00e904b41685ed9753f8677
Author: martijnvisser
AuthorDate: Tue Feb 1 19:29:06 2022 +0100
[FLINK-25915][docs] Remove Google Analytics implementation
---
docs/layouts/_default/baseof.html | 11 ---
1 file changed, 11 deletions(-)
diff --git a/docs/layouts/_default/baseof.html
b/docs/layouts/_default/baseof.html
index ea45bd8..b5c8149 100644
--- a/docs/layouts/_default/baseof.html
+++ b/docs/layouts/_default/baseof.html
@@ -65,17 +65,6 @@ under the License.
{{ partial "docs/inject/body" . }}
-
-
-
-
(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');
-
[flink-statefun] 02/02: [FLINK-25915][docs] Add Matomo tracking code to base layout
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-3.1
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git
commit fce37735e9290ca43592f79e9d30293787745379
Author: martijnvisser
AuthorDate: Tue Feb 1 19:30:05 2022 +0100
[FLINK-25915][docs] Add Matomo tracking code to base layout
---
docs/layouts/_default/baseof.html | 19 +++
1 file changed, 19 insertions(+)
diff --git a/docs/layouts/_default/baseof.html
b/docs/layouts/_default/baseof.html
index b5c8149..733bf1b 100644
--- a/docs/layouts/_default/baseof.html
+++ b/docs/layouts/_default/baseof.html
@@ -23,6 +23,25 @@ under the License.
{{ hugo.Generator }}
{{ partial "docs/html-head" . }}
{{ partial "docs/inject/head" . }}
+
+
+var _paq = window._paq = window._paq || [];
+/* 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() {
+ var u="//matomo.privacy.apache.org/";
+ _paq.push(['setTrackerUrl', u+'matomo.php']);
+ _paq.push(['setSiteId', '1']);
+ var d=document, g=d.createElement('script'),
s=d.getElementsByTagName('script')[0];
+ g.async=true; g.src=u+'matomo.js'; s.parentNode.insertBefore(g,s);
+})();
+
+
[flink-statefun] branch release-3.1 updated (56786b1 -> fce3773)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch release-3.1 in repository https://gitbox.apache.org/repos/asf/flink-statefun.git. from 56786b1 [FLINK-25197] Fix serialization issue in RequestReplyFunctionBuilder new 205fc85 [FLINK-25915][docs] Remove Google Analytics implementation new fce3773 [FLINK-25915][docs] Add Matomo tracking code to base layout 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/layouts/_default/baseof.html | 30 +++--- 1 file changed, 19 insertions(+), 11 deletions(-)
[flink-statefun] 01/02: [FLINK-25915][docs] Remove Google Analytics implementation
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-3.1
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git
commit 205fc85d394af604f7f3cd14810f551807df5d67
Author: martijnvisser
AuthorDate: Tue Feb 1 19:29:06 2022 +0100
[FLINK-25915][docs] Remove Google Analytics implementation
---
docs/layouts/_default/baseof.html | 11 ---
1 file changed, 11 deletions(-)
diff --git a/docs/layouts/_default/baseof.html
b/docs/layouts/_default/baseof.html
index ea45bd8..b5c8149 100644
--- a/docs/layouts/_default/baseof.html
+++ b/docs/layouts/_default/baseof.html
@@ -65,17 +65,6 @@ under the License.
{{ partial "docs/inject/body" . }}
-
-
-
-
(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');
-
[flink-statefun] 01/02: [FLINK-25915][docs] Remove Google Analytics implementation
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-3.0
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git
commit bf9c19c98f86fd2ffaed3cece4e298a087551703
Author: martijnvisser
AuthorDate: Tue Feb 1 19:29:06 2022 +0100
[FLINK-25915][docs] Remove Google Analytics implementation
---
docs/layouts/_default/baseof.html | 11 ---
1 file changed, 11 deletions(-)
diff --git a/docs/layouts/_default/baseof.html
b/docs/layouts/_default/baseof.html
index ea45bd8..b5c8149 100644
--- a/docs/layouts/_default/baseof.html
+++ b/docs/layouts/_default/baseof.html
@@ -65,17 +65,6 @@ under the License.
{{ partial "docs/inject/body" . }}
-
-
-
-
(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');
-
[flink-statefun] 02/02: [FLINK-25915][docs] Add Matomo tracking code to base layout
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-3.0
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git
commit b1d4047eef098ab55a42adffc493eeefd6c11721
Author: martijnvisser
AuthorDate: Tue Feb 1 19:30:05 2022 +0100
[FLINK-25915][docs] Add Matomo tracking code to base layout
---
docs/layouts/_default/baseof.html | 19 +++
1 file changed, 19 insertions(+)
diff --git a/docs/layouts/_default/baseof.html
b/docs/layouts/_default/baseof.html
index b5c8149..733bf1b 100644
--- a/docs/layouts/_default/baseof.html
+++ b/docs/layouts/_default/baseof.html
@@ -23,6 +23,25 @@ under the License.
{{ hugo.Generator }}
{{ partial "docs/html-head" . }}
{{ partial "docs/inject/head" . }}
+
+
+var _paq = window._paq = window._paq || [];
+/* 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() {
+ var u="//matomo.privacy.apache.org/";
+ _paq.push(['setTrackerUrl', u+'matomo.php']);
+ _paq.push(['setSiteId', '1']);
+ var d=document, g=d.createElement('script'),
s=d.getElementsByTagName('script')[0];
+ g.async=true; g.src=u+'matomo.js'; s.parentNode.insertBefore(g,s);
+})();
+
+
[flink-statefun] branch release-3.0 updated (8ca76a0 -> b1d4047)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch release-3.0 in repository https://gitbox.apache.org/repos/asf/flink-statefun.git. from 8ca76a0 [hotfix][docs] Fix typo new bf9c19c [FLINK-25915][docs] Remove Google Analytics implementation new b1d4047 [FLINK-25915][docs] Add Matomo tracking code to base layout 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/layouts/_default/baseof.html | 30 +++--- 1 file changed, 19 insertions(+), 11 deletions(-)
[flink-statefun] branch release-2.2 updated (5965af8 -> 3dd24de)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch release-2.2 in repository https://gitbox.apache.org/repos/asf/flink-statefun.git. from 5965af8 [docs] Pre-generate downloads/walkthrough.zip new afd723f [FLINK-25915][docs] Remove Google Analytics implementation new 3dd24de [FLINK-25915][docs] Add Matomo tracking code to base layout 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/_layouts/base.html | 30 +++--- 1 file changed, 19 insertions(+), 11 deletions(-)
[flink-statefun] 01/02: [FLINK-25915][docs] Remove Google Analytics implementation
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-2.2
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git
commit afd723f2ac1e10d02f46cebf36fc8524b94823db
Author: martijnvisser
AuthorDate: Tue Feb 1 19:38:17 2022 +0100
[FLINK-25915][docs] Remove Google Analytics implementation
---
docs/_layouts/base.html | 11 ---
1 file changed, 11 deletions(-)
diff --git a/docs/_layouts/base.html b/docs/_layouts/base.html
index e85db9a..aaca380 100644
--- a/docs/_layouts/base.html
+++ b/docs/_layouts/base.html
@@ -75,17 +75,6 @@ under the License.
https://cdnjs.cloudflare.com/ajax/libs/anchor-js/3.1.0/anchor.min.js";>
-
-
-
(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');
-
-
{% comment %}
[flink-statefun] 02/02: [FLINK-25915][docs] Add Matomo tracking code to base layout
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-2.2 in repository https://gitbox.apache.org/repos/asf/flink-statefun.git commit 3dd24de2926ef7e068c71a1ab3f35a110b927173 Author: martijnvisser AuthorDate: Tue Feb 1 19:39:01 2022 +0100 [FLINK-25915][docs] Add Matomo tracking code to base layout --- docs/_layouts/base.html | 19 +++ 1 file changed, 19 insertions(+) diff --git a/docs/_layouts/base.html b/docs/_layouts/base.html index aaca380..9f1bee8 100644 --- a/docs/_layouts/base.html +++ b/docs/_layouts/base.html @@ -40,6 +40,25 @@ under the License. https://oss.maxcdn.com/html5shiv/3.7.2/html5shiv.min.js";> https://oss.maxcdn.com/respond/1.4.2/respond.min.js";>
[flink-statefun] 02/02: [FLINK-25915][docs] Add Matomo tracking code to base layout
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-2.1 in repository https://gitbox.apache.org/repos/asf/flink-statefun.git commit c37bd5a70829a0c02cf2417e80f7cf77df22351f Author: martijnvisser AuthorDate: Tue Feb 1 19:39:01 2022 +0100 [FLINK-25915][docs] Add Matomo tracking code to base layout --- docs/_layouts/base.html | 19 +++ 1 file changed, 19 insertions(+) diff --git a/docs/_layouts/base.html b/docs/_layouts/base.html index aaca380..9f1bee8 100644 --- a/docs/_layouts/base.html +++ b/docs/_layouts/base.html @@ -40,6 +40,25 @@ under the License. https://oss.maxcdn.com/html5shiv/3.7.2/html5shiv.min.js";> https://oss.maxcdn.com/respond/1.4.2/respond.min.js";>
[flink-statefun] branch release-2.1 updated (ad5dc24 -> c37bd5a)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch release-2.1 in repository https://gitbox.apache.org/repos/asf/flink-statefun.git. from ad5dc24 [docs] Pre-generate downloads/walkthrough.zip new 59f5433 [FLINK-25915][docs] Remove Google Analytics implementation new c37bd5a [FLINK-25915][docs] Add Matomo tracking code to base layout 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/_layouts/base.html | 30 +++--- 1 file changed, 19 insertions(+), 11 deletions(-)
[flink-statefun] 01/02: [FLINK-25915][docs] Remove Google Analytics implementation
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-2.1
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git
commit 59f5433aebaa632d99b7be6deed3032975908eb6
Author: martijnvisser
AuthorDate: Tue Feb 1 19:38:17 2022 +0100
[FLINK-25915][docs] Remove Google Analytics implementation
---
docs/_layouts/base.html | 11 ---
1 file changed, 11 deletions(-)
diff --git a/docs/_layouts/base.html b/docs/_layouts/base.html
index e85db9a..aaca380 100644
--- a/docs/_layouts/base.html
+++ b/docs/_layouts/base.html
@@ -75,17 +75,6 @@ under the License.
https://cdnjs.cloudflare.com/ajax/libs/anchor-js/3.1.0/anchor.min.js";>
-
-
-
(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');
-
-
{% comment %}
[flink-statefun] branch release-2.0 updated (749746b -> cfe19d8)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch release-2.0 in repository https://gitbox.apache.org/repos/asf/flink-statefun.git. from 749746b [docs] Pre-generate downloads/walkthrough.zip new 84c4c09 [FLINK-25915][docs] Remove Google Analytics implementation new cfe19d8 [FLINK-25915][docs] Add Matomo tracking code to base layout 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/_layouts/base.html | 30 +++--- 1 file changed, 19 insertions(+), 11 deletions(-)
[flink-statefun] 02/02: [FLINK-25915][docs] Add Matomo tracking code to base layout
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-2.0 in repository https://gitbox.apache.org/repos/asf/flink-statefun.git commit cfe19d8826d2b3ef44d5bd2c3e8fca67410c0ef9 Author: martijnvisser AuthorDate: Tue Feb 1 19:39:01 2022 +0100 [FLINK-25915][docs] Add Matomo tracking code to base layout --- docs/_layouts/base.html | 19 +++ 1 file changed, 19 insertions(+) diff --git a/docs/_layouts/base.html b/docs/_layouts/base.html index aaca380..9f1bee8 100644 --- a/docs/_layouts/base.html +++ b/docs/_layouts/base.html @@ -40,6 +40,25 @@ under the License. https://oss.maxcdn.com/html5shiv/3.7.2/html5shiv.min.js";> https://oss.maxcdn.com/respond/1.4.2/respond.min.js";>
[flink-statefun] 01/02: [FLINK-25915][docs] Remove Google Analytics implementation
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-2.0
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git
commit 84c4c094f710c9afc721456eb5e01af6286d36ae
Author: martijnvisser
AuthorDate: Tue Feb 1 19:38:17 2022 +0100
[FLINK-25915][docs] Remove Google Analytics implementation
---
docs/_layouts/base.html | 11 ---
1 file changed, 11 deletions(-)
diff --git a/docs/_layouts/base.html b/docs/_layouts/base.html
index e85db9a..aaca380 100644
--- a/docs/_layouts/base.html
+++ b/docs/_layouts/base.html
@@ -75,17 +75,6 @@ under the License.
https://cdnjs.cloudflare.com/ajax/libs/anchor-js/3.1.0/anchor.min.js";>
-
-
-
(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');
-
-
{% comment %}
[flink] branch master updated (8069a0f -> bb92bc0)
This is an automated email from the ASF dual-hosted git repository.
fpaul pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 8069a0f [FLINK-25423][state-processor-api] Enable loading state
backend via configuration in DataSet API
add 4d32070 [FLINK-25575][streaming] Add data structure to collect
CommittableMessages.
add 107390f [FLINK-25575][streaming] Expose transformations currently
held by the StreamExecutionEnvironment
add ee8a795 [FLINK-25575][streaming] Scope batch exchanges in
PartitionTransformation to batch mode.
add 4a01b4d [FLINK-25575][streaming] Add SinkV1Adapter that simulates
Sink V1 in V2 interfaces.
add 053088d [FLINK-25575][table][test] Ignore CompactManagedTableITCase
because it requires the GlobalCommitter
add bb92bc0 [FLINK-25575][streaming] Switch the implementation of Sink
operator to V2.
No new revisions were added by this update.
Summary of changes:
.../7602816f-5c01-4b7a-9e3e-235dfedec245 | 1 -
.../table/UpsertKafkaDynamicTableFactoryTest.java | 12 +-
...st_stream_execution_environment_completeness.py | 2 +-
.../connector/sink2/StandardSinkTopologies.java} | 37 +-
.../flink/streaming/api/datastream/DataStream.java | 27 +-
.../streaming/api/datastream/DataStreamSink.java | 69 ++-
.../environment/StreamExecutionEnvironment.java| 10 +-
.../streaming/api/graph/StreamGraphGenerator.java | 5 +
.../api/graph/TransformationTranslator.java| 4 +
.../api/operators/collect/CollectStreamSink.java | 52 +--
.../api/transformations/SinkTransformation.java| 63 +--
.../api/transformations/SinkV1Adapter.java | 446 ++
.../operators/sink/AbstractCommitterHandler.java | 88
.../sink/AbstractStreamingCommitterHandler.java| 152 --
.../operators/sink/BatchCommitterHandler.java | 87
.../runtime/operators/sink/CommitRetrier.java | 84
.../runtime/operators/sink/CommitterHandler.java | 78
.../runtime/operators/sink/CommitterOperator.java | 162 +--
.../operators/sink/CommitterOperatorFactory.java | 84 +---
.../operators/sink/ForwardCommittingHandler.java | 42 --
.../sink/GlobalBatchCommitterHandler.java | 76 ---
.../sink/GlobalStreamingCommitterHandler.java | 101
.../operators/sink/NoopCommitterHandler.java | 48 --
.../operators/sink/SinkOperatorFactory.java| 123 -
.../{SinkOperator.java => SinkWriterOperator.java} | 185 +++-
.../operators/sink/SinkWriterOperatorFactory.java | 80
.../operators/sink/SinkWriterStateHandler.java | 27 +-
.../sink/StatefulSinkWriterStateHandler.java | 76 +--
.../sink/StatelessSinkWriterStateHandler.java | 28 +-
.../operators/sink/StreamingCommitterHandler.java | 68 ---
.../operators/sink/StreamingCommitterState.java| 70 ---
.../sink/StreamingCommitterStateSerializer.java| 105 -
.../committables/CheckpointCommittableManager.java | 36 ++
.../CheckpointCommittableManagerImpl.java | 158 +++
.../sink/committables/CommitRequestImpl.java | 112 +
.../sink/committables/CommitRequestState.java} | 33 +-
.../sink/committables/CommittableCollector.java| 242 ++
.../CommittableCollectorSerializer.java| 236 ++
.../sink/committables/CommittableManager.java | 52 +++
.../committables/SubtaskCommittableManager.java| 194
.../PartitionTransformationTranslator.java | 21 +-
.../translators/SinkTransformationTranslator.java | 430 -
.../connector/sink2/CommittableSummaryAssert.java | 62 +++
.../sink2/CommittableWithLinageAssert.java | 67 +++
.../api/connector/sink2/IntegerSerializer.java | 3 +-
...ntegerSerializer.java => SinkV2Assertions.java} | 27 +-
.../api/datastream/DataStreamSinkTest.java | 4 +-
.../graph/SinkTransformationTranslatorTest.java| 81 +++-
.../api/graph/StreamGraphGeneratorTest.java| 25 +
.../api/graph/StreamingJobGraphGeneratorTest.java | 12 +-
.../transformations/SinkTransformationTest.java| 84
.../api/transformations/SinkV1AdapterTest.java | 171 +++
.../operators/sink/BatchCommitterHandlerTest.java | 104 -
.../runtime/operators/sink/CommitRetrierTest.java | 122 -
.../operators/sink/CommitterOperatorTest.java | 298
.../sink/GlobalBatchCommitterHandlerTest.java | 116 -
.../sink/GlobalStreamingCommitterHandlerTest.java | 256 ---
.../runtime/operators/sink/SinkTestUtil.java | 20 +-
.../operators/sink/SinkWriterOperatorTest.java | 509 ++---
.../sink/StreamingCommitterHandlerTest.java| 208 -
.../StreamingCommitterStateSerializerTest.java | 70 ---
.../sink/StreamingCommitterStateTest.java | 49 --
.../streaming/runtime/operators/sink/TestSink.java | 5 +
..
[flink] branch master updated (0d77a1a -> 8069a0f)
This is an automated email from the ASF dual-hosted git repository. sjwiesman pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 0d77a1a [FLINK-25597][conf][docs] Clarify options for local directories add 8bed8bf [FLINK-25423][state-processor-api] Enable loading state backend via configuration in SavepointWriter add 77adfb9 [refactor][state-processor-api] Move state backend loading and restoration into utility add cefdfc1 [refactor][state-processor-api] Remove usages of deprecated class add 846ce04 [FLINK-25423][state-processor-api] Enable loading state backend via configuration in SavepointReader add 8069a0f [FLINK-25423][state-processor-api] Enable loading state backend via configuration in DataSet API No new revisions were added by this update. Summary of changes: .../flink/state/api/BootstrapTransformation.java | 8 +- .../flink/state/api/EvictingWindowReader.java | 7 +- .../state/api/EvictingWindowSavepointReader.java | 17 +-- .../apache/flink/state/api/ExistingSavepoint.java | 29 ++-- .../java/org/apache/flink/state/api/Savepoint.java | 53 .../apache/flink/state/api/SavepointReader.java| 91 ++--- .../apache/flink/state/api/SavepointWriter.java| 63 - .../state/api/StateBootstrapTransformation.java| 3 +- .../org/apache/flink/state/api/WindowReader.java | 7 +- .../flink/state/api/WindowSavepointReader.java | 17 +-- .../apache/flink/state/api/WritableSavepoint.java | 7 +- .../state/api/input/BroadcastStateInputFormat.java | 13 +- .../state/api/input/KeyedStateInputFormat.java | 60 - .../state/api/input/ListStateInputFormat.java | 14 +- .../state/api/input/OperatorStateInputFormat.java | 69 +- .../api/input/StreamOperatorContextBuilder.java| 146 + .../state/api/input/UnionStateInputFormat.java | 14 +- .../api/input/splits/KeyGroupRangeInputSplit.java | 4 +- .../api/input/splits/OperatorStateInputSplit.java | 22 +++- .../PrioritizedOperatorSubtaskStateInputSplit.java | 15 +-- .../api/runtime/metadata/SavepointMetadataV2.java | 8 +- .../flink/state/api/SavepointWriterITCase.java | 30 - .../flink/state/api/SavepointWriterTest.java | 64 + .../api/input/BroadcastStateInputFormatTest.java | 3 +- .../state/api/input/ListStateInputFormatTest.java | 4 +- .../input/StreamOperatorContextBuilderTest.java| 70 ++ .../state/api/input/UnionStateInputFormatTest.java | 4 +- .../state/api/utils/CustomStateBackendFactory.java | 22 ++-- 28 files changed, 685 insertions(+), 179 deletions(-) create mode 100644 flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/input/StreamOperatorContextBuilder.java copy flink-clients/src/main/java/org/apache/flink/client/program/ClusterClientProvider.java => flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/input/splits/PrioritizedOperatorSubtaskStateInputSplit.java (68%) create mode 100644 flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/SavepointWriterTest.java create mode 100644 flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/input/StreamOperatorContextBuilderTest.java copy flink-runtime/src/main/java/org/apache/flink/runtime/state/hashmap/HashMapStateBackendFactory.java => flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/utils/CustomStateBackendFactory.java (58%)
[flink] branch master updated (e55a42b -> 0d77a1a)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from e55a42b [FLINK-25880][Docs] Implement Matomo in Flink documentation (#18577) add 0d77a1a [FLINK-25597][conf][docs] Clarify options for local directories No new revisions were added by this update. Summary of changes: docs/content/docs/deployment/filesystems/s3.md | 2 +- .../shortcodes/generated/blob_server_configuration.html | 2 +- .../layouts/shortcodes/generated/cluster_configuration.html | 2 +- .../shortcodes/generated/expert_cluster_section.html| 2 +- .../shortcodes/generated/history_server_configuration.html | 2 +- .../generated/kubernetes_config_configuration.html | 12 ++-- docs/layouts/shortcodes/generated/web_configuration.html| 4 ++-- .../org/apache/flink/configuration/BlobServerOptions.java | 2 +- .../java/org/apache/flink/configuration/ClusterOptions.java | 2 +- .../apache/flink/configuration/HistoryServerOptions.java| 3 +-- .../java/org/apache/flink/configuration/WebOptions.java | 13 ++--- 11 files changed, 26 insertions(+), 20 deletions(-)
[flink] branch release-1.12 updated: [hotfix][docs] Fix links
This is an automated email from the ASF dual-hosted git repository.
chesnay 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 ef26166 [hotfix][docs] Fix links
ef26166 is described below
commit ef261661b4cbd875bed2e7e8df959f3ae571563c
Author: Chesnay Schepler
AuthorDate: Wed Feb 2 13:43:05 2022 +0100
[hotfix][docs] Fix links
---
docs/deployment/filesystems/gcs.zh.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/docs/deployment/filesystems/gcs.zh.md
b/docs/deployment/filesystems/gcs.zh.md
index a95eb56..cc68c2d 100644
--- a/docs/deployment/filesystems/gcs.zh.md
+++ b/docs/deployment/filesystems/gcs.zh.md
@@ -25,7 +25,7 @@ under the License.
# Google Cloud Storage
-[Google Cloud storage](https://cloud.google.com/storage) (GCS) provides cloud
storage for a variety of use cases. You can use it for **reading** and
**writing data**, and for checkpoint storage when using
[`FileSystemCheckpointStorage`]({% link ops/state/checkpoints.md
%}#the-filesystemcheckpointstorage)) with the [streaming **state backends**]({%
link ops/state/state_backends.md %}).
+[Google Cloud storage](https://cloud.google.com/storage) (GCS) provides cloud
storage for a variety of use cases. You can use it for **reading** and
**writing data**, and for checkpoint storage when using
[`FileSystemCheckpointStorage`]({% link ops/state/checkpoints.zh.md
%}#the-filesystemcheckpointstorage)) with the [streaming **state backends**]({%
link ops/state/state_backends.zh.md %}).
[flink] 02/02: [FLINK-25880][docs] Add Matomo tracking code to base layout
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.12 in repository https://gitbox.apache.org/repos/asf/flink.git commit 75eb2de685ae959b05b960005c4f68030e6466ab Author: martijnvisser AuthorDate: Tue Feb 1 16:23:34 2022 +0100 [FLINK-25880][docs] Add Matomo tracking code to base layout --- docs/_layouts/base.html | 19 +++ 1 file changed, 19 insertions(+) diff --git a/docs/_layouts/base.html b/docs/_layouts/base.html index 75b2778..3794d04 100644 --- a/docs/_layouts/base.html +++ b/docs/_layouts/base.html @@ -53,6 +53,25 @@ under the License. https://oss.maxcdn.com/html5shiv/3.7.2/html5shiv.min.js";> https://oss.maxcdn.com/respond/1.4.2/respond.min.js";>
[flink] branch release-1.12 updated (9be6974 -> 75eb2de)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch release-1.12 in repository https://gitbox.apache.org/repos/asf/flink.git. from 9be6974 [FLINK-25472][core] Update to Log4j 2.17.1 new 59ba66e [FLINK-25880][docs] Remove Google Analytics implementation new 75eb2de [FLINK-25880][docs] Add Matomo tracking code to base layout 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/_layouts/base.html | 30 +++--- 1 file changed, 19 insertions(+), 11 deletions(-)
[flink] 01/02: [FLINK-25880][docs] Remove Google Analytics implementation
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.12
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 59ba66ed674857ae47fba0c06a3933eaa78c552a
Author: martijnvisser
AuthorDate: Mon Jan 31 13:39:12 2022 +0100
[FLINK-25880][docs] Remove Google Analytics implementation
---
docs/_layouts/base.html | 11 ---
1 file changed, 11 deletions(-)
diff --git a/docs/_layouts/base.html b/docs/_layouts/base.html
index c21cd8d9..75b2778 100644
--- a/docs/_layouts/base.html
+++ b/docs/_layouts/base.html
@@ -95,17 +95,6 @@ under the License.
-
-
-
(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');
-
-
{% comment %}
[flink] 01/02: [FLINK-25880][docs] Remove Google Analytics implementation
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 0191401e502766cb7b30c53d0b6fd398b71e01b2
Author: martijnvisser
AuthorDate: Mon Jan 31 13:39:12 2022 +0100
[FLINK-25880][docs] Remove Google Analytics implementation
---
docs/layouts/_default/baseof.html | 11 ---
1 file changed, 11 deletions(-)
diff --git a/docs/layouts/_default/baseof.html
b/docs/layouts/_default/baseof.html
index ea45bd8..b5c8149 100644
--- a/docs/layouts/_default/baseof.html
+++ b/docs/layouts/_default/baseof.html
@@ -65,17 +65,6 @@ under the License.
{{ partial "docs/inject/body" . }}
-
-
-
-
(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');
-
[flink] 02/02: [FLINK-25880][docs] Add Matomo tracking code to base layout
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 8ed95244fe820c9a69db3beb47cbd816314cdcdd
Author: martijnvisser
AuthorDate: Mon Jan 31 13:40:12 2022 +0100
[FLINK-25880][docs] Add Matomo tracking code to base layout
---
docs/layouts/_default/baseof.html | 19 +++
1 file changed, 19 insertions(+)
diff --git a/docs/layouts/_default/baseof.html
b/docs/layouts/_default/baseof.html
index b5c8149..f9b7600 100644
--- a/docs/layouts/_default/baseof.html
+++ b/docs/layouts/_default/baseof.html
@@ -23,6 +23,25 @@ under the License.
{{ hugo.Generator }}
{{ partial "docs/html-head" . }}
{{ partial "docs/inject/head" . }}
+
+
+ var _paq = window._paq = window._paq || [];
+ /* 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() {
+var u="//matomo.privacy.apache.org/";
+_paq.push(['setTrackerUrl', u+'matomo.php']);
+_paq.push(['setSiteId', '1']);
+var d=document, g=d.createElement('script'),
s=d.getElementsByTagName('script')[0];
+g.async=true; g.src=u+'matomo.js'; s.parentNode.insertBefore(g,s);
+ })();
+
+
[flink] branch release-1.13 updated (10a30f6 -> 8ed9524)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git. from 10a30f6 [FLINK-25771][connectors][Cassandra][test] Add a test that raiseCassandraRequestsTimeouts indeed changes the configuration inside the container. new 0191401 [FLINK-25880][docs] Remove Google Analytics implementation new 8ed9524 [FLINK-25880][docs] Add Matomo tracking code to base layout 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/layouts/_default/baseof.html | 30 +++--- 1 file changed, 19 insertions(+), 11 deletions(-)
[flink] 02/02: [FLINK-25880][docs] Add Matomo tracking code to base layout
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 790484281e0b67341f97317fa90e81beb68d7d73
Author: martijnvisser
AuthorDate: Mon Jan 31 13:40:12 2022 +0100
[FLINK-25880][docs] Add Matomo tracking code to base layout
---
docs/layouts/_default/baseof.html | 19 +++
1 file changed, 19 insertions(+)
diff --git a/docs/layouts/_default/baseof.html
b/docs/layouts/_default/baseof.html
index b5c8149..f9b7600 100644
--- a/docs/layouts/_default/baseof.html
+++ b/docs/layouts/_default/baseof.html
@@ -23,6 +23,25 @@ under the License.
{{ hugo.Generator }}
{{ partial "docs/html-head" . }}
{{ partial "docs/inject/head" . }}
+
+
+ var _paq = window._paq = window._paq || [];
+ /* 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() {
+var u="//matomo.privacy.apache.org/";
+_paq.push(['setTrackerUrl', u+'matomo.php']);
+_paq.push(['setSiteId', '1']);
+var d=document, g=d.createElement('script'),
s=d.getElementsByTagName('script')[0];
+g.async=true; g.src=u+'matomo.js'; s.parentNode.insertBefore(g,s);
+ })();
+
+
[flink] 01/02: [FLINK-25880][docs] Remove Google Analytics implementation
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git
commit f1819dd1feab577359f75dce5e53235ddefe0ae0
Author: martijnvisser
AuthorDate: Mon Jan 31 13:39:12 2022 +0100
[FLINK-25880][docs] Remove Google Analytics implementation
---
docs/layouts/_default/baseof.html | 11 ---
1 file changed, 11 deletions(-)
diff --git a/docs/layouts/_default/baseof.html
b/docs/layouts/_default/baseof.html
index ea45bd8..b5c8149 100644
--- a/docs/layouts/_default/baseof.html
+++ b/docs/layouts/_default/baseof.html
@@ -65,17 +65,6 @@ under the License.
{{ partial "docs/inject/body" . }}
-
-
-
-
(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');
-
[flink] branch release-1.14 updated (498ee85 -> 7904842)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git. from 498ee85 [FLINK-25771][connectors][Cassandra][test] Add a test that raiseCassandraRequestsTimeouts indeed changes the configuration inside the container. new f1819dd [FLINK-25880][docs] Remove Google Analytics implementation new 7904842 [FLINK-25880][docs] Add Matomo tracking code to base layout 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/layouts/_default/baseof.html | 30 +++--- 1 file changed, 19 insertions(+), 11 deletions(-)
[flink] 02/02: [FLINK-25880][docs] Add Matomo tracking code to base layout
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit 67dedfbc5bf91dfe3103e29265ed8370fac5895a Author: martijnvisser AuthorDate: Tue Feb 1 16:23:34 2022 +0100 [FLINK-25880][docs] Add Matomo tracking code to base layout --- docs/_layouts/base.html | 19 +++ 1 file changed, 19 insertions(+) diff --git a/docs/_layouts/base.html b/docs/_layouts/base.html index b91fc7c..953c8f4 100644 --- a/docs/_layouts/base.html +++ b/docs/_layouts/base.html @@ -53,6 +53,25 @@ under the License. https://oss.maxcdn.com/html5shiv/3.7.2/html5shiv.min.js";> https://oss.maxcdn.com/respond/1.4.2/respond.min.js";>
[flink] 01/02: [FLINK-25880][docs] Remove Google Analytics implementation
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 1b79987ba9ef417d624a7869f1dc330da8aa8f94
Author: martijnvisser
AuthorDate: Mon Jan 31 13:39:12 2022 +0100
[FLINK-25880][docs] Remove Google Analytics implementation
---
docs/_layouts/base.html | 11 ---
1 file changed, 11 deletions(-)
diff --git a/docs/_layouts/base.html b/docs/_layouts/base.html
index 79abdc3..b91fc7c 100644
--- a/docs/_layouts/base.html
+++ b/docs/_layouts/base.html
@@ -95,17 +95,6 @@ under the License.
-
-
-
(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');
-
-
{% comment %}
[flink] branch release-1.11 updated (8efa0d1 -> 67dedfb)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git. from 8efa0d1 Update for 1.11.6 new 1b79987 [FLINK-25880][docs] Remove Google Analytics implementation new 67dedfb [FLINK-25880][docs] Add Matomo tracking code to base layout 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/_layouts/base.html | 30 +++--- 1 file changed, 19 insertions(+), 11 deletions(-)
[flink] 02/02: [FLINK-25880][docs] Add Matomo tracking code to base layout
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.10 in repository https://gitbox.apache.org/repos/asf/flink.git commit e4ef133b1687fe8d091549844d32850241128c71 Author: martijnvisser AuthorDate: Tue Feb 1 16:23:34 2022 +0100 [FLINK-25880][docs] Add Matomo tracking code to base layout --- docs/_layouts/base.html | 19 +++ 1 file changed, 19 insertions(+) diff --git a/docs/_layouts/base.html b/docs/_layouts/base.html index baea240..be0e770 100644 --- a/docs/_layouts/base.html +++ b/docs/_layouts/base.html @@ -53,6 +53,25 @@ under the License. https://oss.maxcdn.com/html5shiv/3.7.2/html5shiv.min.js";> https://oss.maxcdn.com/respond/1.4.2/respond.min.js";>
[flink] 01/02: [FLINK-25880][docs] Remove Google Analytics implementation
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 4b390465335bfb37425cfe8004dfa53937ea8396
Author: martijnvisser
AuthorDate: Mon Jan 31 13:39:12 2022 +0100
[FLINK-25880][docs] Remove Google Analytics implementation
---
docs/_layouts/base.html | 11 ---
1 file changed, 11 deletions(-)
diff --git a/docs/_layouts/base.html b/docs/_layouts/base.html
index 512838a..baea240 100644
--- a/docs/_layouts/base.html
+++ b/docs/_layouts/base.html
@@ -92,17 +92,6 @@ under the License.
https://cdnjs.cloudflare.com/ajax/libs/anchor-js/3.1.0/anchor.min.js";>
-
-
-
(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');
-
-
{% comment %}
[flink] branch release-1.10 updated (cb26a2a -> e4ef133)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch release-1.10 in repository https://gitbox.apache.org/repos/asf/flink.git. from cb26a2a [FLINK-24260][python] Limit requests to 2.26.0 or above only for python 3.6+ new 4b39046 [FLINK-25880][docs] Remove Google Analytics implementation new e4ef133 [FLINK-25880][docs] Add Matomo tracking code to base layout 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/_layouts/base.html | 30 +++--- 1 file changed, 19 insertions(+), 11 deletions(-)
[flink] 01/02: [FLINK-25880][docs] Remove Google Analytics implementation
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 6d763dc4cb79fa9cfbff5391d9e728ef2fd33e37
Author: martijnvisser
AuthorDate: Mon Jan 31 13:39:12 2022 +0100
[FLINK-25880][docs] Remove Google Analytics implementation
---
docs/_layouts/base.html | 11 ---
1 file changed, 11 deletions(-)
diff --git a/docs/_layouts/base.html b/docs/_layouts/base.html
index 512838a..baea240 100644
--- a/docs/_layouts/base.html
+++ b/docs/_layouts/base.html
@@ -92,17 +92,6 @@ under the License.
https://cdnjs.cloudflare.com/ajax/libs/anchor-js/3.1.0/anchor.min.js";>
-
-
-
(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');
-
-
{% comment %}
[flink] branch release-1.9 updated (5125b11 -> 5babbde)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch release-1.9 in repository https://gitbox.apache.org/repos/asf/flink.git. from 5125b11 [hotfix][docs] Mark 1.9 as outdated new 6d763dc [FLINK-25880][docs] Remove Google Analytics implementation new 5babbde [FLINK-25880][docs] Add Matomo tracking code to base layout 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/_layouts/base.html | 30 +++--- 1 file changed, 19 insertions(+), 11 deletions(-)
[flink] 02/02: [FLINK-25880][docs] Add Matomo tracking code to base layout
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.9 in repository https://gitbox.apache.org/repos/asf/flink.git commit 5babbdee575e6539b4c58654cc5b1625675f8b86 Author: martijnvisser AuthorDate: Tue Feb 1 16:23:34 2022 +0100 [FLINK-25880][docs] Add Matomo tracking code to base layout --- docs/_layouts/base.html | 19 +++ 1 file changed, 19 insertions(+) diff --git a/docs/_layouts/base.html b/docs/_layouts/base.html index baea240..be0e770 100644 --- a/docs/_layouts/base.html +++ b/docs/_layouts/base.html @@ -53,6 +53,25 @@ under the License. https://oss.maxcdn.com/html5shiv/3.7.2/html5shiv.min.js";> https://oss.maxcdn.com/respond/1.4.2/respond.min.js";>
[flink] 02/02: [FLINK-25880][docs] Add Matomo tracking code to base layout
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.7 in repository https://gitbox.apache.org/repos/asf/flink.git commit 4fde279439e41cc1da348dae30c89b8e72a22ad4 Author: martijnvisser AuthorDate: Tue Feb 1 16:23:34 2022 +0100 [FLINK-25880][docs] Add Matomo tracking code to base layout --- docs/_layouts/base.html | 19 +++ 1 file changed, 19 insertions(+) diff --git a/docs/_layouts/base.html b/docs/_layouts/base.html index a94b93b..0b8eb86 100644 --- a/docs/_layouts/base.html +++ b/docs/_layouts/base.html @@ -53,6 +53,25 @@ under the License. https://oss.maxcdn.com/html5shiv/3.7.2/html5shiv.min.js";> https://oss.maxcdn.com/respond/1.4.2/respond.min.js";>
[flink] branch release-1.7 updated (5e0b797 -> 4fde279)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch release-1.7 in repository https://gitbox.apache.org/repos/asf/flink.git. from 5e0b797 [FLINK-16697][metrics][jmx] Disable rebinding new cd9c418 [FLINK-25880][docs] Remove Google Analytics implementation new 4fde279 [FLINK-25880][docs] Add Matomo tracking code to base layout 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/_layouts/base.html | 30 +++--- 1 file changed, 19 insertions(+), 11 deletions(-)
[flink] 01/02: [FLINK-25880][docs] Remove Google Analytics implementation
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.7
in repository https://gitbox.apache.org/repos/asf/flink.git
commit cd9c418aad26a33713828d13f406242f1e8557f0
Author: martijnvisser
AuthorDate: Mon Jan 31 13:39:12 2022 +0100
[FLINK-25880][docs] Remove Google Analytics implementation
---
docs/_layouts/base.html | 11 ---
1 file changed, 11 deletions(-)
diff --git a/docs/_layouts/base.html b/docs/_layouts/base.html
index 1dbaa76..a94b93b 100644
--- a/docs/_layouts/base.html
+++ b/docs/_layouts/base.html
@@ -88,17 +88,6 @@ under the License.
https://cdnjs.cloudflare.com/ajax/libs/anchor-js/3.1.0/anchor.min.js";>
-
-
-
(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');
-
-
{% comment %}
[flink] 02/02: [FLINK-25880][docs] Add Matomo tracking code to base layout
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.8 in repository https://gitbox.apache.org/repos/asf/flink.git commit f9ac8bccad348753954466c81b58d91b1a86a49e Author: martijnvisser AuthorDate: Tue Feb 1 16:23:34 2022 +0100 [FLINK-25880][docs] Add Matomo tracking code to base layout --- docs/_layouts/base.html | 19 +++ 1 file changed, 19 insertions(+) diff --git a/docs/_layouts/base.html b/docs/_layouts/base.html index 9bce7fe..ebd15f5 100644 --- a/docs/_layouts/base.html +++ b/docs/_layouts/base.html @@ -53,6 +53,25 @@ under the License. https://oss.maxcdn.com/html5shiv/3.7.2/html5shiv.min.js";> https://oss.maxcdn.com/respond/1.4.2/respond.min.js";>
[flink] 01/02: [FLINK-25880][docs] Remove Google Analytics implementation
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.8
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 35f37421315a39d9760de15c00d0aeef1985a735
Author: martijnvisser
AuthorDate: Mon Jan 31 13:39:12 2022 +0100
[FLINK-25880][docs] Remove Google Analytics implementation
---
docs/_layouts/base.html | 11 ---
1 file changed, 11 deletions(-)
diff --git a/docs/_layouts/base.html b/docs/_layouts/base.html
index 8be5cc7..9bce7fe 100644
--- a/docs/_layouts/base.html
+++ b/docs/_layouts/base.html
@@ -88,17 +88,6 @@ under the License.
https://cdnjs.cloudflare.com/ajax/libs/anchor-js/3.1.0/anchor.min.js";>
-
-
-
(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');
-
-
{% comment %}
[flink] branch release-1.8 updated (0e8e806 -> f9ac8bc)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch release-1.8 in repository https://gitbox.apache.org/repos/asf/flink.git. from 0e8e806 [FLINK-16697][metrics][jmx] Disable rebinding new 35f3742 [FLINK-25880][docs] Remove Google Analytics implementation new f9ac8bc [FLINK-25880][docs] Add Matomo tracking code to base layout 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/_layouts/base.html | 30 +++--- 1 file changed, 19 insertions(+), 11 deletions(-)
[flink] 01/02: [FLINK-25880][docs] Remove Google Analytics implementation
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.6
in repository https://gitbox.apache.org/repos/asf/flink.git
commit aa26f5cc1f2dc0548bd85aefdad5a9fbce1c9404
Author: martijnvisser
AuthorDate: Mon Jan 31 13:39:12 2022 +0100
[FLINK-25880][docs] Remove Google Analytics implementation
---
docs/_layouts/base.html | 11 ---
1 file changed, 11 deletions(-)
diff --git a/docs/_layouts/base.html b/docs/_layouts/base.html
index 1dbaa76..a94b93b 100644
--- a/docs/_layouts/base.html
+++ b/docs/_layouts/base.html
@@ -88,17 +88,6 @@ under the License.
https://cdnjs.cloudflare.com/ajax/libs/anchor-js/3.1.0/anchor.min.js";>
-
-
-
(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');
-
-
{% comment %}
[flink] 02/02: [FLINK-25880][docs] Add Matomo tracking code to base layout
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.6 in repository https://gitbox.apache.org/repos/asf/flink.git commit 74d5f1eefb8158cfc316de72c1b31b9438e1d2d2 Author: martijnvisser AuthorDate: Tue Feb 1 16:23:34 2022 +0100 [FLINK-25880][docs] Add Matomo tracking code to base layout --- docs/_layouts/base.html | 19 +++ 1 file changed, 19 insertions(+) diff --git a/docs/_layouts/base.html b/docs/_layouts/base.html index a94b93b..0b8eb86 100644 --- a/docs/_layouts/base.html +++ b/docs/_layouts/base.html @@ -53,6 +53,25 @@ under the License. https://oss.maxcdn.com/html5shiv/3.7.2/html5shiv.min.js";> https://oss.maxcdn.com/respond/1.4.2/respond.min.js";>
[flink] branch release-1.6 updated (b8647b1 -> 74d5f1e)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch release-1.6 in repository https://gitbox.apache.org/repos/asf/flink.git. from b8647b1 [FLINK-16697][metrics][jmx] Disable rebinding new aa26f5c [FLINK-25880][docs] Remove Google Analytics implementation new 74d5f1e [FLINK-25880][docs] Add Matomo tracking code to base layout 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/_layouts/base.html | 30 +++--- 1 file changed, 19 insertions(+), 11 deletions(-)
[flink] 01/02: [FLINK-25880][docs] Remove Google Analytics implementation
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.5
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 823710251f0b72ac8ee55b177789d4ff23fc07bd
Author: martijnvisser
AuthorDate: Mon Jan 31 13:39:12 2022 +0100
[FLINK-25880][docs] Remove Google Analytics implementation
---
docs/_layouts/base.html | 11 ---
1 file changed, 11 deletions(-)
diff --git a/docs/_layouts/base.html b/docs/_layouts/base.html
index 1dbaa76..a94b93b 100644
--- a/docs/_layouts/base.html
+++ b/docs/_layouts/base.html
@@ -88,17 +88,6 @@ under the License.
https://cdnjs.cloudflare.com/ajax/libs/anchor-js/3.1.0/anchor.min.js";>
-
-
-
(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');
-
-
{% comment %}
[flink] 02/02: [FLINK-25880][docs] Add Matomo tracking code to base layout
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.5 in repository https://gitbox.apache.org/repos/asf/flink.git commit 9cae51f584d9099ab9b439972f4963445dabc6eb Author: martijnvisser AuthorDate: Tue Feb 1 16:23:34 2022 +0100 [FLINK-25880][docs] Add Matomo tracking code to base layout --- docs/_layouts/base.html | 19 +++ 1 file changed, 19 insertions(+) diff --git a/docs/_layouts/base.html b/docs/_layouts/base.html index a94b93b..0b8eb86 100644 --- a/docs/_layouts/base.html +++ b/docs/_layouts/base.html @@ -53,6 +53,25 @@ under the License. https://oss.maxcdn.com/html5shiv/3.7.2/html5shiv.min.js";> https://oss.maxcdn.com/respond/1.4.2/respond.min.js";>
[flink] branch release-1.5 updated (f9b4e0d -> 9cae51f)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch release-1.5 in repository https://gitbox.apache.org/repos/asf/flink.git. from f9b4e0d [FLINK-16697][metrics][jmx] Disable rebinding new 8237102 [FLINK-25880][docs] Remove Google Analytics implementation new 9cae51f [FLINK-25880][docs] Add Matomo tracking code to base layout 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/_layouts/base.html | 30 +++--- 1 file changed, 19 insertions(+), 11 deletions(-)
[flink] 02/02: [FLINK-25880][docs] Add Matomo tracking code to base layout
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.4 in repository https://gitbox.apache.org/repos/asf/flink.git commit 27b9064e1acfe7117b204f1196388c0ded8b357a Author: martijnvisser AuthorDate: Tue Feb 1 16:23:34 2022 +0100 [FLINK-25880][docs] Add Matomo tracking code to base layout --- docs/_layouts/base.html | 19 +++ 1 file changed, 19 insertions(+) diff --git a/docs/_layouts/base.html b/docs/_layouts/base.html index 5165581..0291153 100644 --- a/docs/_layouts/base.html +++ b/docs/_layouts/base.html @@ -53,6 +53,25 @@ under the License. https://oss.maxcdn.com/html5shiv/3.7.2/html5shiv.min.js";> https://oss.maxcdn.com/respond/1.4.2/respond.min.js";>
[flink] 01/02: [FLINK-25880][docs] Remove Google Analytics implementation
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.4
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 39f48f96d9330c6e70cc96d07ff6c8c3f1a65a08
Author: martijnvisser
AuthorDate: Mon Jan 31 13:39:12 2022 +0100
[FLINK-25880][docs] Remove Google Analytics implementation
---
docs/_layouts/base.html | 11 ---
1 file changed, 11 deletions(-)
diff --git a/docs/_layouts/base.html b/docs/_layouts/base.html
index fdb199b..5165581 100644
--- a/docs/_layouts/base.html
+++ b/docs/_layouts/base.html
@@ -88,17 +88,6 @@ under the License.
https://cdnjs.cloudflare.com/ajax/libs/anchor-js/3.1.0/anchor.min.js";>
-
-
-
(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');
-
-
{% comment %}
[flink] branch release-1.4 updated (12787ec -> 27b9064)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch release-1.4 in repository https://gitbox.apache.org/repos/asf/flink.git. from 12787ec [FLINK-16697][metrics][jmx] Disable rebinding new 39f48f9 [FLINK-25880][docs] Remove Google Analytics implementation new 27b9064 [FLINK-25880][docs] Add Matomo tracking code to base layout 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/_layouts/base.html | 30 +++--- 1 file changed, 19 insertions(+), 11 deletions(-)
[flink] 02/02: [FLINK-25880][docs] Add Matomo tracking code to base layout
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.3 in repository https://gitbox.apache.org/repos/asf/flink.git commit 006273fac7f51433568e320d5700a823a51b1b9a Author: martijnvisser AuthorDate: Tue Feb 1 16:23:34 2022 +0100 [FLINK-25880][docs] Add Matomo tracking code to base layout --- docs/_layouts/base.html | 19 +++ 1 file changed, 19 insertions(+) diff --git a/docs/_layouts/base.html b/docs/_layouts/base.html index e4b222e..cc5e8c6 100644 --- a/docs/_layouts/base.html +++ b/docs/_layouts/base.html @@ -53,6 +53,25 @@ under the License. https://oss.maxcdn.com/html5shiv/3.7.2/html5shiv.min.js";> https://oss.maxcdn.com/respond/1.4.2/respond.min.js";>
[flink] branch release-1.3 updated (4f06bb7 -> 006273f)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch release-1.3 in repository https://gitbox.apache.org/repos/asf/flink.git. from 4f06bb7 [FLINK-16697][metrics][jmx] Disable rebinding new bc634d3 [FLINK-25880][docs] Remove Google Analytics implementation new 006273f [FLINK-25880][docs] Add Matomo tracking code to base layout 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/_layouts/base.html | 30 +++--- 1 file changed, 19 insertions(+), 11 deletions(-)
[flink] 01/02: [FLINK-25880][docs] Remove Google Analytics implementation
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.3
in repository https://gitbox.apache.org/repos/asf/flink.git
commit bc634d3017a27289df52a5970f04eccc94fe601b
Author: martijnvisser
AuthorDate: Mon Jan 31 13:39:12 2022 +0100
[FLINK-25880][docs] Remove Google Analytics implementation
---
docs/_layouts/base.html | 11 ---
1 file changed, 11 deletions(-)
diff --git a/docs/_layouts/base.html b/docs/_layouts/base.html
index 43441e8..e4b222e 100644
--- a/docs/_layouts/base.html
+++ b/docs/_layouts/base.html
@@ -88,17 +88,6 @@ under the License.
https://cdnjs.cloudflare.com/ajax/libs/anchor-js/3.1.0/anchor.min.js";>
-
-
-
(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');
-
-
{% comment %}
[flink] 01/02: [FLINK-25880][docs] Remove Google Analytics implementation
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.2
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 22ae3b8776461028da07cc212914f026ffe4e3af
Author: martijnvisser
AuthorDate: Mon Jan 31 13:39:12 2022 +0100
[FLINK-25880][docs] Remove Google Analytics implementation
---
docs/_layouts/base.html | 11 ---
1 file changed, 11 deletions(-)
diff --git a/docs/_layouts/base.html b/docs/_layouts/base.html
index 439427a..15cf75f 100644
--- a/docs/_layouts/base.html
+++ b/docs/_layouts/base.html
@@ -88,17 +88,6 @@ under the License.
https://cdnjs.cloudflare.com/ajax/libs/anchor-js/3.1.0/anchor.min.js";>
-
-
-
(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');
-
-
{% comment %}
[flink] branch release-1.2 updated (d2a0512 -> 328115d)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch release-1.2 in repository https://gitbox.apache.org/repos/asf/flink.git. from d2a0512 [FLINK-16697][metrics][jmx] Disable rebinding new 22ae3b8 [FLINK-25880][docs] Remove Google Analytics implementation new 328115d [FLINK-25880][docs] Add Matomo tracking code to base layout 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/_layouts/base.html | 30 +++--- 1 file changed, 19 insertions(+), 11 deletions(-)
[flink] 02/02: [FLINK-25880][docs] Add Matomo tracking code to base layout
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.2 in repository https://gitbox.apache.org/repos/asf/flink.git commit 328115d5a14bcc93b33120c959c79efc22146eec Author: martijnvisser AuthorDate: Tue Feb 1 16:23:34 2022 +0100 [FLINK-25880][docs] Add Matomo tracking code to base layout --- docs/_layouts/base.html | 19 +++ 1 file changed, 19 insertions(+) diff --git a/docs/_layouts/base.html b/docs/_layouts/base.html index 15cf75f..955da5d 100644 --- a/docs/_layouts/base.html +++ b/docs/_layouts/base.html @@ -53,6 +53,25 @@ under the License. https://oss.maxcdn.com/html5shiv/3.7.2/html5shiv.min.js";> https://oss.maxcdn.com/respond/1.4.2/respond.min.js";>
[flink] 02/02: [FLINK-25880][docs] Add Matomo tracking code to base layout
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.1 in repository https://gitbox.apache.org/repos/asf/flink.git commit 4c3cd0ed34969a46e7a89d42395972c71ebb33ae Author: martijnvisser AuthorDate: Tue Feb 1 16:23:34 2022 +0100 [FLINK-25880][docs] Add Matomo tracking code to base layout --- docs/_layouts/base.html | 19 +++ 1 file changed, 19 insertions(+) diff --git a/docs/_layouts/base.html b/docs/_layouts/base.html index 40f7094..a17612d 100644 --- a/docs/_layouts/base.html +++ b/docs/_layouts/base.html @@ -52,6 +52,25 @@ under the License. https://oss.maxcdn.com/html5shiv/3.7.2/html5shiv.min.js";> https://oss.maxcdn.com/respond/1.4.2/respond.min.js";>
[flink] branch release-1.1 updated (a61b5d2 -> 4c3cd0e)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch release-1.1 in repository https://gitbox.apache.org/repos/asf/flink.git. from a61b5d2 [FLINK-16697][metrics][jmx] Disable rebinding new c0bbdb3 [FLINK-25880][docs] Remove Google Analytics implementation new 4c3cd0e [FLINK-25880][docs] Add Matomo tracking code to base layout 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/_layouts/base.html | 30 +++--- 1 file changed, 19 insertions(+), 11 deletions(-)
[flink] 01/02: [FLINK-25880][docs] Remove Google Analytics implementation
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.1
in repository https://gitbox.apache.org/repos/asf/flink.git
commit c0bbdb35edbbb0b2df42f5b0edd7f4b25e02da22
Author: martijnvisser
AuthorDate: Mon Jan 31 13:39:12 2022 +0100
[FLINK-25880][docs] Remove Google Analytics implementation
---
docs/_layouts/base.html | 11 ---
1 file changed, 11 deletions(-)
diff --git a/docs/_layouts/base.html b/docs/_layouts/base.html
index 14336d1..40f7094 100644
--- a/docs/_layouts/base.html
+++ b/docs/_layouts/base.html
@@ -83,17 +83,6 @@ under the License.
https://cdnjs.cloudflare.com/ajax/libs/anchor-js/3.1.0/anchor.min.js";>
-
-
-
(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');
-
-
{% comment %}
[flink] 01/02: [FLINK-25880][docs] Remove Google Analytics implementation
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.0
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 109973152be0b9c235f88d6a4d04b3a1244b7ab0
Author: martijnvisser
AuthorDate: Mon Jan 31 13:39:12 2022 +0100
[FLINK-25880][docs] Remove Google Analytics implementation
---
docs/_layouts/base.html | 11 ---
1 file changed, 11 deletions(-)
diff --git a/docs/_layouts/base.html b/docs/_layouts/base.html
index 94dd111..5600c91 100644
--- a/docs/_layouts/base.html
+++ b/docs/_layouts/base.html
@@ -82,17 +82,6 @@ under the License.
https://maxcdn.bootstrapcdn.com/bootstrap/3.3.4/js/bootstrap.min.js";>
-
-
-
(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');
-
-
[flink] 02/02: [FLINK-25880][docs] Add Matomo tracking code to base layout
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.0 in repository https://gitbox.apache.org/repos/asf/flink.git commit 101cc03f357ee4ace6fd7d88bab20818d2870570 Author: martijnvisser AuthorDate: Tue Feb 1 16:23:34 2022 +0100 [FLINK-25880][docs] Add Matomo tracking code to base layout --- docs/_layouts/base.html | 19 +++ 1 file changed, 19 insertions(+) diff --git a/docs/_layouts/base.html b/docs/_layouts/base.html index 5600c91..f5b3c4b 100644 --- a/docs/_layouts/base.html +++ b/docs/_layouts/base.html @@ -52,6 +52,25 @@ under the License. https://oss.maxcdn.com/html5shiv/3.7.2/html5shiv.min.js";> https://oss.maxcdn.com/respond/1.4.2/respond.min.js";>
[flink] branch release-1.0 updated (4b4e9ae -> 101cc03)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch release-1.0 in repository https://gitbox.apache.org/repos/asf/flink.git. from 4b4e9ae [FLINK-9806][docs] Add canonical link new 1099731 [FLINK-25880][docs] Remove Google Analytics implementation new 101cc03 [FLINK-25880][docs] Add Matomo tracking code to base layout 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/_layouts/base.html | 30 +++--- 1 file changed, 19 insertions(+), 11 deletions(-)
[flink] branch master updated (18db2f2 -> e55a42b)
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
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)
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 + .../2017/07/04/flink-rescalab
[flink-web] 02/03: [FLINK-25878] Update privacy policy to reflect change from Google Analytics to Matomo
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&action=optOut&language=en&backgroundColor=&fontColor=&fontSize=14px&fontFamily=%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 coll
[flink] branch master updated (90a824c -> 18db2f2)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 90a824c [FLINK-25819][tests] Improve error reporting add 18db2f2 [FLINK-25564][tests] Leave cleanup to rule No new revisions were added by this update. Summary of changes: ...TaskManagerProcessFailureStreamingRecoveryITCase.java | 16 ++-- 1 file changed, 2 insertions(+), 14 deletions(-)
[flink] branch master updated (e5956c4 -> 90a824c)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from e5956c4 [FLINK-25894][build] Explicitly set streaming-java oldVersion add 90a824c [FLINK-25819][tests] Improve error reporting No new revisions were added by this update. Summary of changes: .../flink/runtime/io/network/buffer/NetworkBufferPoolTest.java | 7 ++- 1 file changed, 2 insertions(+), 5 deletions(-)
[flink] 01/02: [FLINK-25905][build] Add Experimental to japicmp exclude list
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 8566d9b11ce010441bf25766c60d9b06998ba09e Author: Chesnay Schepler AuthorDate: Tue Feb 1 10:11:59 2022 +0100 [FLINK-25905][build] Add Experimental to japicmp exclude list --- pom.xml | 1 + 1 file changed, 1 insertion(+) diff --git a/pom.xml b/pom.xml index 00771eb..c74661b 100644 --- a/pom.xml +++ b/pom.xml @@ -2109,6 +2109,7 @@ under the License. + @org.apache.flink.annotation.Experimental @org.apache.flink.annotation.PublicEvolving @org.apache.flink.annotation.Internal org.apache.flink.streaming.api.datastream.DataStream#DataStream(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment,org.apache.flink.streaming.api.transformations.StreamTransformation)
[flink] 02/02: [FLINK-25894][build] Explicitly set streaming-java oldVersion
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit e5956c4981f0ea923cb9c3421c586ad9e2bb3943
Author: Chesnay Schepler
AuthorDate: Mon Jan 31 22:13:07 2022 +0100
[FLINK-25894][build] Explicitly set streaming-java oldVersion
---
flink-streaming-java/pom.xml | 12
1 file changed, 12 insertions(+)
diff --git a/flink-streaming-java/pom.xml b/flink-streaming-java/pom.xml
index 952ce28..bc87e1d 100644
--- a/flink-streaming-java/pom.xml
+++ b/flink-streaming-java/pom.xml
@@ -104,6 +104,18 @@ under the License.
com.github.siom79.japicmp
japicmp-maven-plugin
+
+
+
+
+
+
${project.groupId}
+
${project.artifactId}_2.11
+
${japicmp.referenceVersion}
+ jar
+
+
+
[flink] branch master updated (9f61e12 -> e5956c4)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 9f61e12 [FLINK-25445] No need to create local recovery dirs when disabled local-recovery in TaskExecutorLocalStateStoresManager new 8566d9b [FLINK-25905][build] Add Experimental to japicmp exclude list new e5956c4 [FLINK-25894][build] Explicitly set streaming-java oldVersion 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: flink-streaming-java/pom.xml | 12 pom.xml | 1 + 2 files changed, 13 insertions(+)
