[ https://issues.apache.org/jira/browse/FLINK-21555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Flink Jira Bot updated FLINK-21555: ----------------------------------- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community manage its development. I see this issues has been marked as Major but is unassigned and neither itself nor its Sub-Tasks have been updated for 30 days. I have gone ahead and added a "stale-major" to the issue". If this ticket is a Major, please either assign yourself or give an update. Afterwards, please remove the label or in 7 days the issue will be deprioritized. > HA does not work when using mesos scheduler > ------------------------------------------- > > Key: FLINK-21555 > URL: https://issues.apache.org/jira/browse/FLINK-21555 > Project: Flink > Issue Type: Bug > Components: Deployment / Mesos > Affects Versions: 1.12.0 > Reporter: Qinghui Xu > Priority: Major > Labels: auto-unassigned, stale-major > > When trying to start a flink session cluster in mesos, it's crashing because > of jackson dependency issue: > {code:java} > org.apache.flink.runtime.entrypoint.ClusterEntrypointException: Failed to > initialize the cluster entrypoint MesosSessionClusterEntrypoint. at > org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:191) > ~[flink-dist_2.11-1.12-criteo-1605205002.jar:1.12-criteo-1605205002] at > org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runClusterEntrypoint(ClusterEntrypoint.java:529) > [flink-dist_2.11-1.12-criteo-1605205002.jar:1.12-criteo-1605205002] at > org.apache.flink.mesos.entrypoint.MesosSessionClusterEntrypoint.main(MesosSessionClusterEntrypoint.java:103) > [flink-dist_2.11-1.12-criteo-1605205002.jar:1.12-criteo-1605205002]Caused > by: java.lang.NoSuchMethodError: > com.fasterxml.jackson.databind.ObjectMapper.enable([Lcom/fasterxml/jackson/core/JsonParser$Feature;)Lcom/fasterxml/jackson/databind/ObjectMapper; > at > com.amazonaws.partitions.PartitionsLoader.<clinit>(PartitionsLoader.java:54) > ~[flink-s3-fs-presto-1.12-criteo-1605205002.jar:1.12-criteo-1605205002] at > com.amazonaws.regions.RegionMetadataFactory.create(RegionMetadataFactory.java:30) > ~[flink-s3-fs-presto-1.12-criteo-1605205002.jar:1.12-criteo-1605205002] at > com.amazonaws.regions.RegionUtils.initialize(RegionUtils.java:64) > ~[flink-s3-fs-presto-1.12-criteo-1605205002.jar:1.12-criteo-1605205002] at > com.amazonaws.regions.RegionUtils.getRegionMetadata(RegionUtils.java:52) > ~[flink-s3-fs-presto-1.12-criteo-1605205002.jar:1.12-criteo-1605205002] at > com.amazonaws.regions.EndpointToRegion.guessRegionOrRegionNameForEndpoint(EndpointToRegion.java:101) > ~[flink-s3-fs-presto-1.12-criteo-1605205002.jar:1.12-criteo-1605205002] at > com.amazonaws.regions.EndpointToRegion.guessRegionNameForEndpoint(EndpointToRegion.java:41) > ~[flink-s3-fs-presto-1.12-criteo-1605205002.jar:1.12-criteo-1605205002] at > com.amazonaws.regions.EndpointToRegion.guessRegionNameForEndpointWithDefault(EndpointToRegion.java:48) > ~[flink-s3-fs-presto-1.12-criteo-1605205002.jar:1.12-criteo-1605205002] at > com.amazonaws.AmazonWebServiceClient.computeSignerByURI(AmazonWebServiceClient.java:429) > ~[flink-s3-fs-presto-1.12-criteo-1605205002.jar:1.12-criteo-1605205002] at > com.amazonaws.AmazonWebServiceClient.setEndpoint(AmazonWebServiceClient.java:318) > ~[flink-s3-fs-presto-1.12-criteo-1605205002.jar:1.12-criteo-1605205002] at > com.amazonaws.services.s3.AmazonS3Client.setEndpoint(AmazonS3Client.java:728) > ~[flink-s3-fs-presto-1.12-criteo-1605205002.jar:1.12-criteo-1605205002] at > com.facebook.presto.hive.s3.PrestoS3FileSystem.createAmazonS3Client(PrestoS3FileSystem.java:661) > ~[flink-s3-fs-presto-1.12-criteo-1605205002.jar:1.12-criteo-1605205002] at > com.facebook.presto.hive.s3.PrestoS3FileSystem.initialize(PrestoS3FileSystem.java:216) > ~[flink-s3-fs-presto-1.12-criteo-1605205002.jar:1.12-criteo-1605205002] at > org.apache.flink.fs.s3.common.AbstractS3FileSystemFactory.create(AbstractS3FileSystemFactory.java:126) > ~[flink-s3-fs-presto-1.12-criteo-1605205002.jar:1.12-criteo-1605205002] at > org.apache.flink.core.fs.FileSystem.getUnguardedFileSystem(FileSystem.java:468) > ~[flink-dist_2.11-1.12-criteo-1605205002.jar:1.12-criteo-1605205002] at > org.apache.flink.core.fs.FileSystem.get(FileSystem.java:389) > ~[flink-dist_2.11-1.12-criteo-1605205002.jar:1.12-criteo-1605205002] at > org.apache.flink.core.fs.Path.getFileSystem(Path.java:292) > ~[flink-dist_2.11-1.12-criteo-1605205002.jar:1.12-criteo-1605205002] at > org.apache.flink.runtime.blob.BlobUtils.createFileSystemBlobStore(BlobUtils.java:100) > ~[flink-dist_2.11-1.12-criteo-1605205002.jar:1.12-criteo-1605205002] at > org.apache.flink.runtime.blob.BlobUtils.createBlobStoreFromConfig(BlobUtils.java:89) > ~[flink-dist_2.11-1.12-criteo-1605205002.jar:1.12-criteo-1605205002] at > org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createHighAvailabilityServices(HighAvailabilityServicesUtils.java:117) > ~[flink-dist_2.11-1.12-criteo-1605205002.jar:1.12-criteo-1605205002] at > org.apache.flink.runtime.entrypoint.ClusterEntrypoint.createHaServices(ClusterEntrypoint.java:309) > ~[flink-dist_2.11-1.12-criteo-1605205002.jar:1.12-criteo-1605205002] at > org.apache.flink.runtime.entrypoint.ClusterEntrypoint.initializeServices(ClusterEntrypoint.java:272) > ~[flink-dist_2.11-1.12-criteo-1605205002.jar:1.12-criteo-1605205002] at > org.apache.flink.mesos.entrypoint.MesosSessionClusterEntrypoint.initializeServices(MesosSessionClusterEntrypoint.java:56) > ~[flink-dist_2.11-1.12-criteo-1605205002.jar:1.12-criteo-1605205002] at > org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runCluster(ClusterEntrypoint.java:212) > ~[flink-dist_2.11-1.12-criteo-1605205002.jar:1.12-criteo-1605205002] at > org.apache.flink.runtime.entrypoint.ClusterEntrypoint.lambda$startCluster$0(ClusterEntrypoint.java:173) > ~[flink-dist_2.11-1.12-criteo-1605205002.jar:1.12-criteo-1605205002] at > java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_275] at > javax.security.auth.Subject.doAs(Subject.java:422) ~[?:1.8.0_275] at > org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1682) > ~[flink-s3-fs-presto-1.12-criteo-1605205002.jar:1.12-criteo-1605205002] at > org.apache.flink.runtime.security.contexts.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41) > ~[flink-dist_2.11-1.12-criteo-1605205002.jar:1.12-criteo-1605205002] at > org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:172) > ~[flink-dist_2.11-1.12-criteo-1605205002.jar:1.12-criteo-1605205002] ... 2 > more > {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)