请问这个是需要修改那个端口 flink-conf中我改了 但是不行
Exception in thread "main" java.lang.RuntimeException: Couldn't retrieve standalone cluster
at org.apache.flink.client.deployment.StandaloneClusterDescriptor.lambda$retrieve$0(StandaloneClusterDescriptor.java:53)
at com.dtstack.chunjun.client.standalone.StandaloneClusterClientHelper.submit(StandaloneClusterClientHelper.java:59)
at com.dtstack.chunjun.client.Launcher.main(Launcher.java:119)
Caused by: java.lang.NullPointerException: rest.address must be set
at org.apache.flink.util.Preconditions.checkNotNull(Preconditions.java:104)
at org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.getWebMonitorAddress(HighAvailabilityServicesUtils.java:196)
at org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createClientHAService(HighAvailabilityServicesUtils.java:138)
at org.apache.flink.client.program.rest.RestClusterClient.<init>(RestClusterClient.java:171)
at org.apache.flink.client.deployment.StandaloneClusterDescriptor.lambda$retrieve$0(StandaloneClusterDescriptor.java:51)
... 2 more
需要配置flink_home
export FLINK_HOME=/opt/app/flink-1.17.2
export PATH=$FLINK_HOME/bin:$PATH
standalone模式需要配置FLINK_HOME:
export FLINK_HOME=/opt/app/flink-1.17.2
export PATH=$FLINK_HOME/bin:$PATH