You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2022/02/01 11:00:18 UTC
[flink-statefun-playground] branch release-3.2 updated: [release] Update to v3.2.0
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 66cbd1f [release] Update to v3.2.0
66cbd1f is described below
commit 66cbd1f6f0c9f60a18791f270273944da0433f5c
Author: Till Rohrmann <tr...@apache.org>
AuthorDate: Fri Jan 28 09:45:18 2022 +0100
[release] Update to v3.2.0
This closes #18.
---
deployments/aws-lambda/README.md | 4 ++--
deployments/aws-lambda/pom.xml | 4 ++--
deployments/k8s/04-statefun/01-statefun-runtime.yaml | 17 ++++++++---------
go/greeter/docker-compose.yml | 4 ++--
go/greeter/go.mod | 2 +-
go/showcase/docker-compose.yml | 6 +++---
go/showcase/go.mod | 2 +-
java/greeter/README.md | 4 ++--
java/greeter/docker-compose.yml | 4 ++--
java/greeter/pom.xml | 4 ++--
java/shopping-cart/README.md | 9 +++------
java/shopping-cart/docker-compose.yml | 4 ++--
java/shopping-cart/pom.xml | 4 ++--
java/showcase/pom.xml | 4 ++--
.../serving/StatefulFunctionsRuntimeProcesses.java | 4 ++--
javascript/greeter/Dockerfile | 3 +--
.../greeter/apache-flink-statefun-3.2-SNAPSHOT.tgz | Bin 49694 -> 0 bytes
javascript/greeter/docker-compose.yml | 4 ++--
javascript/greeter/package.json | 2 +-
javascript/showcase/docker-compose.yml | 6 +++---
python/greeter/docker-compose.yml | 4 ++--
python/greeter/requirements.txt | 2 +-
python/showcase/docker-compose.yml | 6 +++---
python/showcase/setup.py | 4 ++--
24 files changed, 51 insertions(+), 56 deletions(-)
diff --git a/deployments/aws-lambda/README.md b/deployments/aws-lambda/README.md
index 6036edf..73396a3 100644
--- a/deployments/aws-lambda/README.md
+++ b/deployments/aws-lambda/README.md
@@ -38,9 +38,9 @@ for invoking your StateFun functions.
### Configure StateFun Module Specification
-The AWS Lambda endpoint URL should be configured as a function endpoint in your [Module Specification](https://ci.apache.org/projects/flink/flink-statefun-docs-release-3.0/docs/deployment/module/).
+The AWS Lambda endpoint URL should be configured as a function endpoint in your [Module Specification](https://ci.apache.org/projects/flink/flink-statefun-docs-release-3.2/docs/deployment/module/).
-Note how you may use [templating](https://ci.apache.org/projects/flink/flink-statefun-docs-release-3.0/docs/deployment/module/#url-template)
+Note how you may use [templating](https://ci.apache.org/projects/flink/flink-statefun-docs-release-3.2/docs/deployment/module/#url-template)
in the endpoint URL for multiple functions under the same namespace This allows you to add new AWS Lambda functions,
potentially individually serving different StateFun functions, under separate paths of the same AWS API Gateway endpoint.
This provides flexibility to upgrade your StateFun application by dynamically adding new functions without having to restart the StateFun runtime.
diff --git a/deployments/aws-lambda/pom.xml b/deployments/aws-lambda/pom.xml
index 69e2526..5bb8756 100644
--- a/deployments/aws-lambda/pom.xml
+++ b/deployments/aws-lambda/pom.xml
@@ -22,11 +22,11 @@ under the License.
<groupId>org.apache.flink</groupId>
<artifactId>aws-lambda-example</artifactId>
- <version>3.1.0</version>
+ <version>3.2.0</version>
<packaging>jar</packaging>
<properties>
- <statefun.version>3.1.0</statefun.version>
+ <statefun.version>3.2.0</statefun.version>
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
</properties>
diff --git a/deployments/k8s/04-statefun/01-statefun-runtime.yaml b/deployments/k8s/04-statefun/01-statefun-runtime.yaml
index 4503e6f..789d1f4 100644
--- a/deployments/k8s/04-statefun/01-statefun-runtime.yaml
+++ b/deployments/k8s/04-statefun/01-statefun-runtime.yaml
@@ -17,15 +17,15 @@ data:
state.backend: rocksdb
state.backend.rocksdb.timer-service.factory: ROCKSDB
state.backend.incremental: true
- parallelism.default: 1
+ parallelism.default: 1
s3.access-key: minioadmin
s3.secret-key: minioadmin
state.checkpoints.dir: s3://checkpoints/subscriptions
s3.endpoint: http://minio.statefun.svc.cluster.local:9000
s3.path-style-access: true
- jobmanager.memory.process.size: 1g
+ jobmanager.memory.process.size: 1g
taskmanager.memory.process.size: 1g
-
+
log4j-console.properties: |+
monitorInterval=30
rootLogger.level = INFO
@@ -43,7 +43,7 @@ data:
appender.console.layout.type = PatternLayout
appender.console.layout.pattern = %d{yyyy-MM-dd HH:mm:ss,SSS} %-5p %-60c %x - %m%n
logger.netty.name = org.apache.flink.shaded.akka.org.jboss.netty.channel.DefaultChannelPipeline
- logger.netty.level = OFF
+ logger.netty.level = OFF
---
apiVersion: v1
@@ -98,7 +98,7 @@ spec:
spec:
containers:
- name: master
- image: apache/flink-statefun:3.1.0
+ image: apache/flink-statefun:3.2.0
imagePullPolicy: IfNotPresent
env:
- name: ROLE
@@ -144,7 +144,7 @@ metadata:
name: statefun-worker
namespace: statefun
spec:
- replicas: 1
+ replicas: 1
selector:
matchLabels:
app: statefun
@@ -157,13 +157,13 @@ spec:
spec:
containers:
- name: worker
- image: apache/flink-statefun:3.1.0
+ image: apache/flink-statefun:3.2.0
imagePullPolicy: IfNotPresent
env:
- name: ROLE
value: worker
- name: MASTER_HOST
- value: statefun-master
+ value: statefun-master
resources:
requests:
memory: "1Gi"
@@ -199,4 +199,3 @@ spec:
items:
- key: module.yaml
path: module.yaml
-
diff --git a/go/greeter/docker-compose.yml b/go/greeter/docker-compose.yml
index 9a07833..dc86400 100644
--- a/go/greeter/docker-compose.yml
+++ b/go/greeter/docker-compose.yml
@@ -34,7 +34,7 @@ services:
###############################################################
statefun-manager:
- image: apache/flink-statefun:3.1.0
+ image: apache/flink-statefun:3.2.0
expose:
- "6123"
ports:
@@ -46,7 +46,7 @@ services:
- ./module.yaml:/opt/statefun/modules/greeter/module.yaml
statefun-worker:
- image: apache/flink-statefun:3.1.0
+ image: apache/flink-statefun:3.2.0
expose:
- "6121"
- "6122"
diff --git a/go/greeter/go.mod b/go/greeter/go.mod
index f4d5657..c6b1228 100644
--- a/go/greeter/go.mod
+++ b/go/greeter/go.mod
@@ -18,4 +18,4 @@ module statefun.io/greeter
go 1.16
-require github.com/apache/flink-statefun/statefun-sdk-go/v3 v3.1.0
+require github.com/apache/flink-statefun/statefun-sdk-go/v3 v3.2.0
diff --git a/go/showcase/docker-compose.yml b/go/showcase/docker-compose.yml
index f20cc53..eb5c6c9 100644
--- a/go/showcase/docker-compose.yml
+++ b/go/showcase/docker-compose.yml
@@ -24,7 +24,7 @@ services:
###############################################################
statefun-manager:
- image: apache/flink-statefun:3.1.0
+ image: apache/flink-statefun:3.2.0
expose:
- "6123"
ports:
@@ -36,7 +36,7 @@ services:
- ./module.yaml:/opt/statefun/modules/greeter/module.yaml
statefun-worker:
- image: apache/flink-statefun:3.1.0
+ image: apache/flink-statefun:3.2.0
expose:
- "6121"
- "6122"
@@ -72,7 +72,7 @@ services:
###############################################################
# Forward a port 8000 from the host's machine
###############################################################
-
+
host-machine:
image: qoomon/docker-host@sha256:e0f021dd77c7c26d37b825ab2cbf73cd0a77ca993417da80a14192cb041937b0
cap_add: [ 'NET_ADMIN', 'NET_RAW' ]
diff --git a/go/showcase/go.mod b/go/showcase/go.mod
index dc342a0..049afaf 100644
--- a/go/showcase/go.mod
+++ b/go/showcase/go.mod
@@ -18,4 +18,4 @@ module statefun.io/showcase
go 1.16
-require github.com/apache/flink-statefun/statefun-sdk-go/v3 v3.1.0
+require github.com/apache/flink-statefun/statefun-sdk-go/v3 v3.2.0
diff --git a/java/greeter/README.md b/java/greeter/README.md
index 2e739b5..315b278 100644
--- a/java/greeter/README.md
+++ b/java/greeter/README.md
@@ -22,9 +22,9 @@ that accepts user information to generate personalized greeting messages that ar
our functions service, hosting the `UserFn` and `UserLogin` 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.
- `user-logins.txt`: A file with multiple JSON objects per line; this is used as test events produced to our application ingress.
-- `module.yaml`: The [Module Specification](https://ci.apache.org/projects/flink/flink-statefun-docs-release-3.0/docs/deployment/module/) file to be mounted to the StateFun runtime process containers. This
+- `module.yaml`: The [Module Specification](https://ci.apache.org/projects/flink/flink-statefun-docs-release-3.2/docs/deployment/module/) file to be mounted to the StateFun runtime process containers. This
configures a few things for a StateFun application, such as the service endpoints of the application's functions, as
- well as definitions of [Ingresses and Egresses](https://ci.apache.org/projects/flink/flink-statefun-docs-release-3.0/docs/io-module/overview/) which the application will use.
+ well as definitions of [Ingresses and Egresses](https://ci.apache.org/projects/flink/flink-statefun-docs-release-3.2/docs/io-module/overview/) which the application will use.
- `docker-compose.yml`: Docker Compose file to spin up everything.
## Prerequisites
diff --git a/java/greeter/docker-compose.yml b/java/greeter/docker-compose.yml
index e4d2f21..c863641 100644
--- a/java/greeter/docker-compose.yml
+++ b/java/greeter/docker-compose.yml
@@ -35,7 +35,7 @@ services:
###############################################################
statefun-manager:
- image: apache/flink-statefun:3.1.0-java11
+ image: apache/flink-statefun:3.2.0-java11
expose:
- "6123"
ports:
@@ -47,7 +47,7 @@ services:
- ./module.yaml:/opt/statefun/modules/greeter/module.yaml
statefun-worker:
- image: apache/flink-statefun:3.1.0-java11
+ image: apache/flink-statefun:3.2.0-java11
expose:
- "6121"
- "6122"
diff --git a/java/greeter/pom.xml b/java/greeter/pom.xml
index 6d18dd0..05ebd2b 100644
--- a/java/greeter/pom.xml
+++ b/java/greeter/pom.xml
@@ -22,11 +22,11 @@ under the License.
<groupId>org.apache.flink</groupId>
<artifactId>greeter-functions-app</artifactId>
- <version>3.1.0</version>
+ <version>3.2.0</version>
<packaging>jar</packaging>
<properties>
- <statefun.version>3.1.0</statefun.version>
+ <statefun.version>3.2.0</statefun.version>
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
</properties>
diff --git a/java/shopping-cart/README.md b/java/shopping-cart/README.md
index 75233ad..1d8b539 100644
--- a/java/shopping-cart/README.md
+++ b/java/shopping-cart/README.md
@@ -9,9 +9,9 @@ If you are new to stateful functions, we recommend you to first look at a more s
- `src/`, `pom.xml` and `Dockerfile`: These files and directories are the contents of a Java Maven project which builds
our functions service, hosting the `UserShoppingCartFn` and `StockFn` 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.
-- `module.yaml`: The [Module Specification](https://ci.apache.org/projects/flink/flink-statefun-docs-release-3.0/docs/deployment/module/) file to be mounted to the StateFun runtime process containers. This
+- `module.yaml`: The [Module Specification](https://ci.apache.org/projects/flink/flink-statefun-docs-release-3.2/docs/deployment/module/) file to be mounted to the StateFun runtime process containers. This
configures a few things for a StateFun application, such as the service endpoints of the application's functions, as
- well as definitions of [Ingresses and Egresses](https://ci.apache.org/projects/flink/flink-statefun-docs-release-3.0/docs/io-module/overview/) which the application will use.
+ well as definitions of [Ingresses and Egresses](https://ci.apache.org/projects/flink/flink-statefun-docs-release-3.2/docs/io-module/overview/) which the application will use.
- `docker-compose.yml`: Docker Compose file to spin up everything.
- `playthrough`: utilities for automatically playing through the interactions scenarios.
@@ -59,7 +59,7 @@ It will send a series of messages, results of which you can observe in the logs
```
docker-compose logs -f shopping-cart-functions
```
-Note: `Caller: Optional.empty` in the logs corresponds to the messages that came via an ingress rather than from another stateful function.
+Note: `Caller: Optional.empty` in the logs corresponds to the messages that came via an ingress rather than from another stateful function.
To see the results produced to the egress:
```
@@ -71,6 +71,3 @@ If you want to modify the code, you can do a hot redeploy of your functions serv
docker-compose up -d --build shopping-cart-functions
```
This rebuilds the functions service image with the updated code, and restarts the service with the new image.
-
-
-
diff --git a/java/shopping-cart/docker-compose.yml b/java/shopping-cart/docker-compose.yml
index 2be9b39..090f09e 100644
--- a/java/shopping-cart/docker-compose.yml
+++ b/java/shopping-cart/docker-compose.yml
@@ -35,7 +35,7 @@ services:
###############################################################
statefun-manager:
- image: apache/flink-statefun:3.1.0-java11
+ image: apache/flink-statefun:3.2.0-java11
expose:
- "6123"
ports:
@@ -47,7 +47,7 @@ services:
- ./module.yaml:/opt/statefun/modules/shopping-cart/module.yaml
statefun-worker:
- image: apache/flink-statefun:3.1.0-java11
+ image: apache/flink-statefun:3.2.0-java11
expose:
- "6121"
- "6122"
diff --git a/java/shopping-cart/pom.xml b/java/shopping-cart/pom.xml
index 35471a2..1a20282 100644
--- a/java/shopping-cart/pom.xml
+++ b/java/shopping-cart/pom.xml
@@ -22,11 +22,11 @@ under the License.
<artifactId>shopping-cart</artifactId>
<groupId>org.apache.flink</groupId>
- <version>3.1.0</version>
+ <version>3.2.0</version>
<packaging>jar</packaging>
<properties>
- <statefun.version>3.1.0</statefun.version>
+ <statefun.version>3.2.0</statefun.version>
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
<untertow.version>1.4.18.Final</untertow.version>
diff --git a/java/showcase/pom.xml b/java/showcase/pom.xml
index 9b56543..5c2b951 100644
--- a/java/showcase/pom.xml
+++ b/java/showcase/pom.xml
@@ -22,11 +22,11 @@ under the License.
<groupId>org.apache.flink</groupId>
<artifactId>statefun-java-showcase</artifactId>
- <version>3.1.0</version>
+ <version>3.2.0</version>
<packaging>jar</packaging>
<properties>
- <statefun.version>3.1.0</statefun.version>
+ <statefun.version>3.2.0</statefun.version>
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
</properties>
diff --git a/java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part6/serving/StatefulFunctionsRuntimeProcesses.java b/java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part6/serving/StatefulFunctionsRuntimeProcesses.java
index efc12c5..d391916 100644
--- a/java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part6/serving/StatefulFunctionsRuntimeProcesses.java
+++ b/java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part6/serving/StatefulFunctionsRuntimeProcesses.java
@@ -86,7 +86,7 @@ public final class StatefulFunctionsRuntimeProcesses {
}
private static GenericContainer<?> managerContainer(Network network) {
- return new GenericContainer<>(DockerImageName.parse("apache/flink-statefun:3.0.0"))
+ return new GenericContainer<>(DockerImageName.parse("apache/flink-statefun:3.2.0"))
.withNetwork(network)
.withNetworkAliases("statefun-manager")
.withEnv("ROLE", "master")
@@ -98,7 +98,7 @@ public final class StatefulFunctionsRuntimeProcesses {
}
private static GenericContainer<?> workerContainer(Network network) {
- return new GenericContainer<>(DockerImageName.parse("apache/flink-statefun:3.0.0"))
+ return new GenericContainer<>(DockerImageName.parse("apache/flink-statefun:3.2.0"))
.withNetwork(network)
.withNetworkAliases("statefun-worker")
.withEnv("ROLE", "worker")
diff --git a/javascript/greeter/Dockerfile b/javascript/greeter/Dockerfile
index b342462..fdfcf72 100644
--- a/javascript/greeter/Dockerfile
+++ b/javascript/greeter/Dockerfile
@@ -18,9 +18,8 @@ FROM node:16
WORKDIR /usr/src/app
-COPY apache-flink-statefun-3.2-SNAPSHOT.tgz ./
COPY package.json ./
-RUN npm install -s apache-flink-statefun-3.2-SNAPSHOT.tgz
+RUN npm install apache-flink-statefun@3.2.0
COPY functions.js ./
diff --git a/javascript/greeter/apache-flink-statefun-3.2-SNAPSHOT.tgz b/javascript/greeter/apache-flink-statefun-3.2-SNAPSHOT.tgz
deleted file mode 100644
index 8dd9c31..0000000
Binary files a/javascript/greeter/apache-flink-statefun-3.2-SNAPSHOT.tgz and /dev/null differ
diff --git a/javascript/greeter/docker-compose.yml b/javascript/greeter/docker-compose.yml
index 57c8be4..583a35c 100644
--- a/javascript/greeter/docker-compose.yml
+++ b/javascript/greeter/docker-compose.yml
@@ -34,7 +34,7 @@ services:
###############################################################
statefun-manager:
- image: apache/flink-statefun:3.1.0-java11
+ image: apache/flink-statefun:3.2.0-java11
expose:
- "6123"
ports:
@@ -46,7 +46,7 @@ services:
- ./module.yaml:/opt/statefun/modules/greeter/module.yaml
statefun-worker:
- image: apache/flink-statefun:3.1.0-java11
+ image: apache/flink-statefun:3.2.0-java11
expose:
- "6121"
- "6122"
diff --git a/javascript/greeter/package.json b/javascript/greeter/package.json
index abc2d78..a7128d5 100644
--- a/javascript/greeter/package.json
+++ b/javascript/greeter/package.json
@@ -7,6 +7,6 @@
"start": "node functions.js"
},
"dependencies": {
- "apache-flink-statefun": "3.2-SNAPSHOT"
+ "apache-flink-statefun": "3.2.0"
}
}
diff --git a/javascript/showcase/docker-compose.yml b/javascript/showcase/docker-compose.yml
index 4b6a001..09b43a4 100644
--- a/javascript/showcase/docker-compose.yml
+++ b/javascript/showcase/docker-compose.yml
@@ -24,7 +24,7 @@ services:
###############################################################
statefun-manager:
- image: apache/flink-statefun:3.1.0-java11
+ image: apache/flink-statefun:3.2.0-java11
expose:
- "6123"
ports:
@@ -36,7 +36,7 @@ services:
- ./module.yaml:/opt/statefun/modules/greeter/module.yaml
statefun-worker:
- image: apache/flink-statefun:3.1.0-java11
+ image: apache/flink-statefun:3.2.0-java11
expose:
- "6121"
- "6122"
@@ -72,7 +72,7 @@ services:
###############################################################
# Forward a port 8000 from the host's machine
###############################################################
-
+
host-machine:
image: qoomon/docker-host@sha256:e0f021dd77c7c26d37b825ab2cbf73cd0a77ca993417da80a14192cb041937b0
cap_add: [ 'NET_ADMIN', 'NET_RAW' ]
diff --git a/python/greeter/docker-compose.yml b/python/greeter/docker-compose.yml
index 57c8be4..583a35c 100644
--- a/python/greeter/docker-compose.yml
+++ b/python/greeter/docker-compose.yml
@@ -34,7 +34,7 @@ services:
###############################################################
statefun-manager:
- image: apache/flink-statefun:3.1.0-java11
+ image: apache/flink-statefun:3.2.0-java11
expose:
- "6123"
ports:
@@ -46,7 +46,7 @@ services:
- ./module.yaml:/opt/statefun/modules/greeter/module.yaml
statefun-worker:
- image: apache/flink-statefun:3.1.0-java11
+ image: apache/flink-statefun:3.2.0-java11
expose:
- "6121"
- "6122"
diff --git a/python/greeter/requirements.txt b/python/greeter/requirements.txt
index cafef02..6ca24c5 100644
--- a/python/greeter/requirements.txt
+++ b/python/greeter/requirements.txt
@@ -15,4 +15,4 @@
# limitations under the License.
aiohttp
-apache-flink-statefun==3.1.0
+apache-flink-statefun==3.2.0
diff --git a/python/showcase/docker-compose.yml b/python/showcase/docker-compose.yml
index 4b6a001..09b43a4 100644
--- a/python/showcase/docker-compose.yml
+++ b/python/showcase/docker-compose.yml
@@ -24,7 +24,7 @@ services:
###############################################################
statefun-manager:
- image: apache/flink-statefun:3.1.0-java11
+ image: apache/flink-statefun:3.2.0-java11
expose:
- "6123"
ports:
@@ -36,7 +36,7 @@ services:
- ./module.yaml:/opt/statefun/modules/greeter/module.yaml
statefun-worker:
- image: apache/flink-statefun:3.1.0-java11
+ image: apache/flink-statefun:3.2.0-java11
expose:
- "6121"
- "6122"
@@ -72,7 +72,7 @@ services:
###############################################################
# Forward a port 8000 from the host's machine
###############################################################
-
+
host-machine:
image: qoomon/docker-host@sha256:e0f021dd77c7c26d37b825ab2cbf73cd0a77ca993417da80a14192cb041937b0
cap_add: [ 'NET_ADMIN', 'NET_RAW' ]
diff --git a/python/showcase/setup.py b/python/showcase/setup.py
index 737a34e..f93fb1e 100644
--- a/python/showcase/setup.py
+++ b/python/showcase/setup.py
@@ -27,7 +27,7 @@ with io.open(os.path.join(this_directory, 'README.md'), 'r', encoding='utf-8') a
setup(
name='showcase',
- version='3.1.0',
+ version='3.2.0',
packages=["showcase"],
url='https://github.com/apache/flink-statefun-playground',
license='https://www.apache.org/licenses/LICENSE-2.0',
@@ -38,7 +38,7 @@ setup(
long_description=long_description,
long_description_content_type='text/markdown',
install_requires=['protobuf>=3.11.3,<4.0.0',
- 'apache-flink-statefun==3.1.0',
+ 'apache-flink-statefun==3.2.0',
'aiohttp'],
tests_require=['pytest'],
python_requires='>=3.8',