java - 如何创建一个 flink https 请求

Question

我正在运行以下命令以在 flink 中创建一个可与 HTTP 正常工作的作业。我还在作业管理器服务前设置了 Nginx 入口并启用了 SSL。当我通过入口发送请求时，我收到错误“HTTP 请求已发送到 HTTPS 端口”。有没有办法将我的请求包装在 SSL 包装器中。

sudo mvn clean compile exec:java -Dexec.mainClass=pathtodataflow.GenericFileArchivePipeline -Pflink-runner -Dexec.args=" \
    --runner=FlinkRunner \
    --project=project-name \
    --flinkMaster=http://flinkurl:80 \ #for HTTPS i change it to https://flinkurl:443
    --streaming=true \
    --bucketId=some-bucket-for-data \
    --inputTopic=projects/project-name/topics/file-digest \
    --checkpointingInterval=15000 \
    --checkpointTimeoutMillis=300000000" 

标签： javasslapache-flinknginx-ingress