无法使用Flink-nifi连接器从Nifi输出端口读取数据

"我在具有暴露端口的虚拟机上的docker中有一个Nifi实例：8080和10000.在瘦实例上，我创建了一个带有输出端口名为“flink”的简单管道，我想使用flink-nifi连接器读取这些数据：

SiteToSiteClientConfig clientConfig = new SiteToSiteClient.Builder()

            .url(""http://vm-address:8080/nifi"")
            .portName(""flink"")
            .requestBatchCount(100)
            .buildConfig();
    DataStream<NiFiDataPacket> nifi = environment.addSource(new NiFiSource(clientConfig));

    nifi.map(new MapFunction<NiFiDataPacket, JsonNode>() {
        @Override
        public JsonNode map(NiFiDataPacket value) throws Exception {
            return DataConverter.byte2Json(value.getContent());
        }
    }).print();

在这种情况下我得到错误： Exception in thread ""main"" org.apache.flink.runtime.client.JobExecutionException: java.net.UnknownHostException 如果我在配置中添加localAddress：

SiteToSiteClientConfig clientConfig = new SiteToSiteClient.Builder()

            .url(""http://vm-address:8080/nifi"")
            .localAddress(InetAddress.getByName(""vm-address""))
            .portName(""flink"")
            .requestBatchCount(100)
            .buildConfig();

我收到了这个错误： Exception in thread ""main"" org.apache.flink.runtime.client.JobExecutionException: java.net.BindException: Cannot assign requested address: JVM_Bind

我从Windows上的本地PC运行此代码，flink以独立模式启动。此外，我试图直接在虚拟机上运行它，但我得到了同样的错误。

在日志中有很多重试：

execchain.RetryExec：处理/ vm-address请求时捕获的I / O异常（java.net.BindException） - > {} - > http：// vm-address：8080：无法分配请求的地址：JVM_Bind
"