[hotfix] Add v1 to OkHttp transport's typename
diff --git a/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/TransportClientConstants.java b/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/TransportClientConstants.java
index d5f8a35..281f235 100644
--- a/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/TransportClientConstants.java
+++ b/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/TransportClientConstants.java
@@ -23,5 +23,5 @@
public final class TransportClientConstants {
public static final TypeName OKHTTP_CLIENT_FACTORY_TYPE =
- TypeName.parseFrom("io.statefun.transports/okhttp");
+ TypeName.parseFrom("io.statefun.transports.v1/okhttp");
}
diff --git a/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/binders/v2/HttpEndpointBinderV2.java b/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/binders/v2/HttpEndpointBinderV2.java
index f94404c..0a3abba 100644
--- a/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/binders/v2/HttpEndpointBinderV2.java
+++ b/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/binders/v2/HttpEndpointBinderV2.java
@@ -47,7 +47,7 @@
* urlPathTemplate: https://bar.foo.com:8080/{function.name} (string)
* maxNumBatchRequests: 10000 (int, optional)
* transports: (object, optional)
- * type: io.statefun.transports/okhttp (typename, optional)
+ * type: io.statefun.transports.v1/okhttp (typename, optional)
* ... (remaining fields treated directly as properties)
* </pre>
*/
diff --git a/statefun-flink/statefun-flink-core/src/test/resources/http-endpoint-binders/v2.yaml b/statefun-flink/statefun-flink-core/src/test/resources/http-endpoint-binders/v2.yaml
index 3243a5b..54c2531 100644
--- a/statefun-flink/statefun-flink-core/src/test/resources/http-endpoint-binders/v2.yaml
+++ b/statefun-flink/statefun-flink-core/src/test/resources/http-endpoint-binders/v2.yaml
@@ -19,7 +19,7 @@
urlPathTemplate: http://bar.foo.com:8080/functions/{function.name}
maxNumBatchRequests: 10000
transport:
- type: io.statefun.transports/okhttp
+ type: io.statefun.transports.v1/okhttp
timeouts:
call: 1minute
connect: 30seconds
