You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ig...@apache.org on 2021/11/17 18:13:05 UTC
[flink-statefun] branch master updated (d1e750c -> 49f6166)
This is an automated email from the ASF dual-hosted git repository.
igal pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git.
from d1e750c [hotfix] Use JDK 8 Optional instead of shaded Optional class from Guava.
add 49f6166 [FLINK-24534] Use the async transport if transport is not specified.
No new revisions were added by this update.
Summary of changes:
.../src/main/go/SmokeE2EMain.go | 2 +-
.../smoke/golang/SmokeVerificationGolangE2E.java | 2 +
.../src/test/resources/Dockerfile | 5 ++
.../src/test/resources/Dockerfile.remote-function | 5 +-
.../src/test/resources/remote-module/module.yaml | 2 +-
.../src/test/resources/ssl/README.md | 11 +++
.../src/test/resources/ssl/cacerts | 0
.../src/test/resources/ssl/server.crt | 10 +++
.../src/test/resources/ssl/server.key | 9 +++
.../src/test/resources/Dockerfile.remote-function | 2 +-
.../src/test/resources/remote-module/module.yaml | 4 +-
.../src/test/resources/remote-module/module.yaml | 4 +-
.../src/test/resources/module.yaml | 2 +-
.../flink/core/StatefulFunctionsConfig.java | 2 +-
.../core/functions/PendingAsyncOperations.java | 89 +++++++++++----------
.../core/httpfn/HttpFunctionEndpointSpec.java | 2 +-
.../core/httpfn/TransportClientConstants.java | 3 +
.../flink/core/httpfn/TransportClientSpec.java | 8 +-
.../flink/core/nettyclient/NettyClient.java | 8 +-
.../core/nettyclient/NettyRequestReplySpec.java | 91 +++++++++++++++++++---
.../core/nettyclient/NettyTransportModule.java | 8 +-
21 files changed, 191 insertions(+), 78 deletions(-)
create mode 100644 statefun-e2e-tests/statefun-smoke-e2e-golang/src/test/resources/ssl/README.md
create mode 100644 statefun-e2e-tests/statefun-smoke-e2e-golang/src/test/resources/ssl/cacerts
create mode 100644 statefun-e2e-tests/statefun-smoke-e2e-golang/src/test/resources/ssl/server.crt
create mode 100644 statefun-e2e-tests/statefun-smoke-e2e-golang/src/test/resources/ssl/server.key