This is an automated email from the ASF dual-hosted git repository.
sjwiesman 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 dffc594 [FLINK-24301] use Async transport on all statefun playground
examples
dffc594 is described below
commit dffc59428a91853332a038e9d13970108d2302e9
Author: sjwiesman <[email protected]>
AuthorDate: Wed Sep 15 11:39:33 2021 -0500
[FLINK-24301] use Async transport on all statefun playground examples
This closes #14
---
go/greeter/module.yaml | 3 ++-
go/showcase/module.yaml | 3 ++-
java/greeter/module.yaml | 2 ++
java/shopping-cart/module.yaml | 4 +++-
java/showcase/src/main/resources/module.yaml | 8 ++++----
python/greeter/module.yaml | 5 ++---
python/showcase/module.yaml | 5 ++---
7 files changed, 17 insertions(+), 13 deletions(-)
diff --git a/go/greeter/module.yaml b/go/greeter/module.yaml
index 19a6efe..1273125 100644
--- a/go/greeter/module.yaml
+++ b/go/greeter/module.yaml
@@ -16,7 +16,8 @@ kind: io.statefun.endpoints.v2/http
spec:
functions: example/*
urlPathTemplate: http://functions:8000/statefun
- maxNumBatchRequests: 10000
+ transport:
+ type: io.statefun.transports.v1/async
---
kind: io.statefun.kafka.v1/ingress
spec:
diff --git a/go/showcase/module.yaml b/go/showcase/module.yaml
index 10ac7fd..e9355fe 100644
--- a/go/showcase/module.yaml
+++ b/go/showcase/module.yaml
@@ -17,7 +17,8 @@ kind: io.statefun.endpoints.v2/http
spec:
functions: showcase.fns/*
urlPathTemplate: http://host-machine:8000/statefun
- maxNumBatchRequests: 10000
+ transport:
+ type: io.statefun.transports.v1/async
---
kind: io.statefun.kafka.v1/ingress
spec:
diff --git a/java/greeter/module.yaml b/java/greeter/module.yaml
index 44e9aff..f424c0c 100644
--- a/java/greeter/module.yaml
+++ b/java/greeter/module.yaml
@@ -17,6 +17,8 @@ kind: io.statefun.endpoints.v2/http
spec:
functions: greeter.fns/*
urlPathTemplate: http://greeter-functions:1108/
+ transport:
+ type: io.statefun.transports.v1/async
---
kind: io.statefun.kafka.v1/ingress
spec:
diff --git a/java/shopping-cart/module.yaml b/java/shopping-cart/module.yaml
index 1825751..2f5ba9c 100644
--- a/java/shopping-cart/module.yaml
+++ b/java/shopping-cart/module.yaml
@@ -17,6 +17,8 @@ kind: io.statefun.endpoints.v2/http
spec:
functions: com.example/*
urlPathTemplate: http://shopping-cart-functions:1108/
+ transport:
+ type: io.statefun.transports.v1/async
---
kind: io.statefun.kafka.v1/ingress
spec:
@@ -68,4 +70,4 @@ spec:
address: kafka:9092
deliverySemantic:
type: exactly-once
- transactionTimeoutMillis: 100000
+ transactionTimeout: 15min
diff --git a/java/showcase/src/main/resources/module.yaml
b/java/showcase/src/main/resources/module.yaml
index beb1064..0bd279c 100644
--- a/java/showcase/src/main/resources/module.yaml
+++ b/java/showcase/src/main/resources/module.yaml
@@ -18,10 +18,10 @@ spec:
functions: java.showcase.fns/*
urlPathTemplate: http://host.testcontainers.internal:1108/
transport:
- timeouts:
- call: 1day # setting a very high timeout here facilitates the user
- # to set breakpoints in the function Java code and explore
- # around in the IDE, without StateFun failing an ongoing
invocation
+ type: io.statefun.transports.v1/async
+ call: 1day # setting a very high timeout here facilitates the user
+ # to set breakpoints in the function Java code and explore
+ # around in the IDE, without StateFun failing an ongoing
invocation
---
kind: io.statefun.kafka.v1/ingress
spec:
diff --git a/python/greeter/module.yaml b/python/greeter/module.yaml
index 9db500f..461b17f 100644
--- a/python/greeter/module.yaml
+++ b/python/greeter/module.yaml
@@ -18,8 +18,7 @@ spec:
functions: example/*
urlPathTemplate: http://functions:8000/statefun
transport:
- timeouts:
- call: 2min
+ type: io.statefun.transports.v1/async
---
kind: io.statefun.kafka.v1/ingress
spec:
@@ -38,4 +37,4 @@ spec:
address: kafka:9092
deliverySemantic:
type: exactly-once
- transactionTimeoutMillis: 100000
+ transactionTimeout: 15min
diff --git a/python/showcase/module.yaml b/python/showcase/module.yaml
index 30a5b1c..1ac251e 100644
--- a/python/showcase/module.yaml
+++ b/python/showcase/module.yaml
@@ -18,8 +18,7 @@ spec:
functions: showcase/*
urlPathTemplate: http://host-machine:8000/statefun
transport:
- timeouts:
- call: 2min
+ type: io.statefun.transports.v1/async
---
kind: io.statefun.kafka.v1/ingress
spec:
@@ -38,4 +37,4 @@ spec:
address: kafka:9092
deliverySemantic:
type: exactly-once
- transactionTimeoutMillis: 100000
+ transactionTimeout: 15min
