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 2022/03/07 12:46:24 UTC
[flink-statefun] branch master updated (547554a -> f4dc3e9)
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 547554a [FLINK-26378][sdk][py] Set caller to None for ingress messages.
add f4dc3e9 [FLINK-25866][statefun] Support additional TLS configuration
No new revisions were added by this update.
Summary of changes:
docs/content/docs/modules/http-endpoint.md | 9 +
statefun-e2e-tests/statefun-smoke-e2e-java/pom.xml | 15 +-
.../smoke/java/CommandInterpreterAppServer.java | 129 ++++++++--
.../e2e/smoke/java/UndertowHttpHandler.java | 62 -----
.../src/main/resources/certs/README.md | 1 +
.../src/main/resources/certs/a_ca.pem | 21 ++
.../src/main/resources/certs/a_server.crt | 22 ++
.../src/main/resources/certs/a_server.key.p8 | 29 +++
.../e2e/smoke/java/SmokeVerificationJavaE2E.java | 1 +
.../src/test/resources/Dockerfile | 1 +
.../src/test/resources/certs/README.md | 1 +
.../src/test/resources/certs/a_ca.pem | 21 ++
.../src/test/resources/certs/a_client.crt | 19 ++
.../src/test/resources/certs/a_client.key.p8 | 29 +++
.../src/test/resources/certs/key_password.txt | 1 +
.../src/test/resources/remote-module/module.yaml | 10 +-
.../nettyclient/HttpConnectionPoolManager.java | 12 +-
.../flink/core/nettyclient/NettyClient.java | 110 +++++++-
.../core/nettyclient/NettyRequestReplySpec.java | 34 ++-
.../core/nettyclient/NettySharedResources.java | 19 --
.../flink/statefun/flink/core/TestUtils.java | 17 ++
.../flink/core/httpfn/TransportClientTest.java | 260 +++++++++++++++++++
.../flink/core/nettyclient/NettyClientTest.java | 280 +++++++++++++++++++++
.../src/test/resources/certs/README.md | 176 +++++++++++++
.../src/test/resources/certs/a_ca.key | 30 +++
.../src/test/resources/certs/a_ca.pem | 21 ++
.../src/test/resources/certs/a_caCerts.pem | 42 ++++
.../src/test/resources/certs/a_client.crt | 19 ++
.../src/test/resources/certs/a_client.key.p8 | 29 +++
.../src/test/resources/certs/a_server.crt | 22 ++
.../src/test/resources/certs/a_server.key.p8 | 29 +++
.../src/test/resources/certs/b_ca.key | 30 +++
.../src/test/resources/certs/b_ca.pem | 21 ++
.../src/test/resources/certs/b_caCerts.pem | 42 ++++
.../src/test/resources/certs/b_client.crt | 19 ++
.../src/test/resources/certs/b_client.key.p8 | 29 +++
.../src/test/resources/certs/c_ca.key | 30 +++
.../src/test/resources/certs/c_ca.pem | 21 ++
.../src/test/resources/certs/c_client.crt | 19 ++
.../src/test/resources/certs/c_client.key.p8 | 28 +++
.../src/test/resources/certs/key_password.txt | 1 +
.../src/test/resources/certs/server.ext | 8 +
42 files changed, 1603 insertions(+), 116 deletions(-)
delete mode 100644 statefun-e2e-tests/statefun-smoke-e2e-java/src/main/java/org/apache/flink/statefun/e2e/smoke/java/UndertowHttpHandler.java
create mode 100644 statefun-e2e-tests/statefun-smoke-e2e-java/src/main/resources/certs/README.md
create mode 100644 statefun-e2e-tests/statefun-smoke-e2e-java/src/main/resources/certs/a_ca.pem
create mode 100644 statefun-e2e-tests/statefun-smoke-e2e-java/src/main/resources/certs/a_server.crt
create mode 100644 statefun-e2e-tests/statefun-smoke-e2e-java/src/main/resources/certs/a_server.key.p8
create mode 100644 statefun-e2e-tests/statefun-smoke-e2e-java/src/test/resources/certs/README.md
create mode 100644 statefun-e2e-tests/statefun-smoke-e2e-java/src/test/resources/certs/a_ca.pem
create mode 100644 statefun-e2e-tests/statefun-smoke-e2e-java/src/test/resources/certs/a_client.crt
create mode 100644 statefun-e2e-tests/statefun-smoke-e2e-java/src/test/resources/certs/a_client.key.p8
create mode 100644 statefun-e2e-tests/statefun-smoke-e2e-java/src/test/resources/certs/key_password.txt
create mode 100644 statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/httpfn/TransportClientTest.java
create mode 100644 statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/nettyclient/NettyClientTest.java
create mode 100644 statefun-flink/statefun-flink-core/src/test/resources/certs/README.md
create mode 100644 statefun-flink/statefun-flink-core/src/test/resources/certs/a_ca.key
create mode 100644 statefun-flink/statefun-flink-core/src/test/resources/certs/a_ca.pem
create mode 100644 statefun-flink/statefun-flink-core/src/test/resources/certs/a_caCerts.pem
create mode 100644 statefun-flink/statefun-flink-core/src/test/resources/certs/a_client.crt
create mode 100644 statefun-flink/statefun-flink-core/src/test/resources/certs/a_client.key.p8
create mode 100644 statefun-flink/statefun-flink-core/src/test/resources/certs/a_server.crt
create mode 100644 statefun-flink/statefun-flink-core/src/test/resources/certs/a_server.key.p8
create mode 100644 statefun-flink/statefun-flink-core/src/test/resources/certs/b_ca.key
create mode 100644 statefun-flink/statefun-flink-core/src/test/resources/certs/b_ca.pem
create mode 100644 statefun-flink/statefun-flink-core/src/test/resources/certs/b_caCerts.pem
create mode 100644 statefun-flink/statefun-flink-core/src/test/resources/certs/b_client.crt
create mode 100644 statefun-flink/statefun-flink-core/src/test/resources/certs/b_client.key.p8
create mode 100644 statefun-flink/statefun-flink-core/src/test/resources/certs/c_ca.key
create mode 100644 statefun-flink/statefun-flink-core/src/test/resources/certs/c_ca.pem
create mode 100644 statefun-flink/statefun-flink-core/src/test/resources/certs/c_client.crt
create mode 100644 statefun-flink/statefun-flink-core/src/test/resources/certs/c_client.key.p8
create mode 100644 statefun-flink/statefun-flink-core/src/test/resources/certs/key_password.txt
create mode 100644 statefun-flink/statefun-flink-core/src/test/resources/certs/server.ext