Hi,
just tried to launch flink app in flink-1.6.2 and get
2018-10-30 11:07:19,961 ERROR
org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Cluster
initialization failed.
java.lang.AbstractMethodError:
org.apache.flink.runtime.entrypoint.ClusterEntrypoint.createResourceManager(Lorg/apache/flink/configuration/Configuration;Lorg/apache/flink/runtime/clusterframework/types/ResourceID;Lorg/apache/flink/runtime/rpc/RpcService;Lorg/apache/flink/runtime/highavailability/HighAvailabilityServices;Lorg/apache/flink/runtime/heartbeat/HeartbeatServices;Lorg/apache/flink/runtime/metrics/MetricRegistry;Lorg/apache/flink/runtime/rpc/FatalErrorHandler;Lorg/apache/flink/runtime/entrypoint/ClusterInformation;Ljava/lang/String;)Lorg/apache/flink/runtime/resourcemanager/ResourceManager;
at
org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startClusterComponents(ClusterEntrypoint.java:338)
at
org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runCluster(ClusterEntrypoint.java:232)
at
org.apache.flink.runtime.entrypoint.ClusterEntrypoint.lambda$startCluster$0(ClusterEntrypoint.java:190)
at
org.apache.flink.runtime.security.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:30)
at
org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:189)
at
org.apache.flink.container.entrypoint.StandaloneJobClusterEntryPoint.main(StandaloneJobClusterEntryPoint.java:176)
complete log is here:
https://gist.github.com/zavalit/4dba49cdea45c6f56f947a7dcec1a666job manager is started with:
./bin/standalone-job.sh start-foreground --configDir conf --job-classname
MyEntryClass
the same app runs as it is in flink-1.6.1, the only thing that have changed
is a flink version
thx in advance, for any insides
--
Sent from:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/