Apache Flinkはクラスタ上でUnknownHostExceptionをスローします

Question

私はデータを引き出すためにnifiに接続しているflinkプロジェクトを持っています。ローカルに実行しているときに、データストリームを取得する設定はうまく動作します。

.url("http://1.2.3.4:8080/nifi") 
      .portName("MyPortName") 
      .requestBatchCount(5) 
      .buildConfig(); 

しかし、私はリモートクラスタに.jarファイルを追加し、ジョブを実行するときには、このスロー：

java.net.UnknownHostException 
at sun.nio.ch.Net.translateException(Net.java:177) 
at sun.nio.ch.SocketAdaptor.connect(SocketAdaptor.java:127) 
at org.apache.nifi.remote.client.socket.EndpointConnectionPool.establishSiteToSiteConnection(EndpointConnectionPool.java:712) 
at org.apache.nifi.remote.client.socket.EndpointConnectionPool.establishSiteToSiteConnection(EndpointConnectionPool.java:685) 
at org.apache.nifi.remote.client.socket.EndpointConnectionPool.getEndpointConnection(EndpointConnectionPool.java:301) 
at org.apache.nifi.remote.client.socket.SocketClient.createTransaction(SocketClient.java:129) 
at org.apache.flink.streaming.connectors.nifi.NiFiSource.run(NiFiSource.java:90) 
at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:78) 
at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:55) 
at org.apache.flink.streaming.runtime.tasks.SourceStreamTask.run(SourceStreamTask.java:56) 
at org.apache.flink.streaming.runtime.tasks.StoppableSourceStreamTask.run(StoppableSourceStreamTask.java:39) 
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:272) 
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:655) 
at java.lang.Thread.run(Thread.java:745) 

私はUnknownHostExceptionがために見つけることができる唯一の理由は、それがあるということですのIP理由ホスト名を解決することはできませんが、私はすでにIPを与えています。 IPがnifiインスタンスにアクセスするために許可されるものを設定する必要があるため、nifiに接続できないという問題が以前にありました。 AWSサーバーを許可して追加しましたが、それは修正されましたが、明らかにこれがあります。

ご協力いただきありがとうございます。

Answer 1

問題が発生しました。私は、nifiクラスターとflinkクラスターを別々の地域に持っていました。 Flinkクラスタを同じ地域に移動し、クラスタの公開URLまたは非公開URLのいずれかを使用しても正常に動作します。