各位好,

    The program finished with the following exception:

    java.lang.IllegalArgumentException: The given host:port ('yarn-cluster') 
doesn't contain a valid port

    at org.apache.flink.util.NetUtils.validateHostPortString(NetUtils.java:108)

    at org.apache.flink.util.NetUtils.parseHostPortAddress(NetUtils.java:88)


祝好!

回复