[
https://issues.apache.org/jira/browse/FLINK-23945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17404311#comment-17404311
]
钟洋洋 commented on FLINK-23945:
-----------------------------
*when I specifying the host of your s3 service like
{{s3://21.96.18.197:8082/flink/recovery,the following error was reported}}*
org.apache.flink.runtime.entrypoint.ClusterEntrypointException: Failed to
initialize the cluster entrypoint KubernetesSessionClusterEntrypoint.
at
org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:201)
~[flink-dist_2.12-1.12.3.jar:1.12.3]
at
org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runClusterEntrypoint(ClusterEntrypoint.java:585)
[flink-dist_2.12-1.12.3.jar:1.12.3]
at
org.apache.flink.kubernetes.entrypoint.KubernetesSessionClusterEntrypoint.main(KubernetesSessionClusterEntrypoint.java:61)
[flink-dist_2.12-1.12.3.jar:1.12.3]
Caused by: java.io.IOException: Could not create FileSystem for highly
available storage path
(s3://21.96.18.197:8082/flink/rocovery/flink-native-k8s-session-11)
at
org.apache.flink.runtime.blob.BlobUtils.createFileSystemBlobStore(BlobUtils.java:92)
~[flink-dist_2.12-1.12.3.jar:1.12.3]
at
org.apache.flink.runtime.blob.BlobUtils.createBlobStoreFromConfig(BlobUtils.java:76)
~[flink-dist_2.12-1.12.3.jar:1.12.3]
at
org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createHighAvailabilityServices(HighAvailabilityServicesUtils.java:115)
~[flink-dist_2.12-1.12.3.jar:1.12.3]
at
org.apache.flink.runtime.entrypoint.ClusterEntrypoint.createHaServices(ClusterEntrypoint.java:338)
~[flink-dist_2.12-1.12.3.jar:1.12.3]
at
org.apache.flink.runtime.entrypoint.ClusterEntrypoint.initializeServices(ClusterEntrypoint.java:296)
~[flink-dist_2.12-1.12.3.jar:1.12.3]
at
org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runCluster(ClusterEntrypoint.java:224)
~[flink-dist_2.12-1.12.3.jar:1.12.3]
at
org.apache.flink.runtime.entrypoint.ClusterEntrypoint.lambda$startCluster$1(ClusterEntrypoint.java:178)
~[flink-dist_2.12-1.12.3.jar:1.12.3]
at java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_292]
at javax.security.auth.Subject.doAs(Subject.java:422) ~[?:1.8.0_292]
at
org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1836)
~[flink-shaded-hadoop-2-uber-2.8.3-10.0.jar:2.8.3-10.0]
at
org.apache.flink.runtime.security.contexts.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)
~[flink-dist_2.12-1.12.3.jar:1.12.3]
at
org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:175)
~[flink-dist_2.12-1.12.3.jar:1.12.3]
... 2 more
Caused by: java.io.FileNotFoundException: Bucket 21.96.18.197 does not exist
at
org.apache.hadoop.fs.s3a.S3AFileSystem.verifyBucketExists(S3AFileSystem.java:374)
~[?:?]
at org.apache.hadoop.fs.s3a.S3AFileSystem.initialize(S3AFileSystem.java:308)
~[?:?]
at
org.apache.flink.fs.s3.common.AbstractS3FileSystemFactory.create(AbstractS3FileSystemFactory.java:123)
~[?:?]
at
org.apache.flink.core.fs.PluginFileSystemFactory.create(PluginFileSystemFactory.java:62)
~[flink-dist_2.12-1.12.3.jar:1.12.3]
at
org.apache.flink.core.fs.FileSystem.getUnguardedFileSystem(FileSystem.java:507)
~[flink-dist_2.12-1.12.3.jar:1.12.3]
at org.apache.flink.core.fs.FileSystem.get(FileSystem.java:408)
~[flink-dist_2.12-1.12.3.jar:1.12.3]
at org.apache.flink.core.fs.Path.getFileSystem(Path.java:274)
~[flink-dist_2.12-1.12.3.jar:1.12.3]
at
org.apache.flink.runtime.blob.BlobUtils.createFileSystemBlobStore(BlobUtils.java:89)
~[flink-dist_2.12-1.12.3.jar:1.12.3]
at
org.apache.flink.runtime.blob.BlobUtils.createBlobStoreFromConfig(BlobUtils.java:76)
~[flink-dist_2.12-1.12.3.jar:1.12.3]
at
org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createHighAvailabilityServices(HighAvailabilityServicesUtils.java:115)
~[flink-dist_2.12-1.12.3.jar:1.12.3]
at
org.apache.flink.runtime.entrypoint.ClusterEntrypoint.createHaServices(ClusterEntrypoint.java:338)
~[flink-dist_2.12-1.12.3.jar:1.12.3]
at
org.apache.flink.runtime.entrypoint.ClusterEntrypoint.initializeServices(ClusterEntrypoint.java:296)
~[flink-dist_2.12-1.12.3.jar:1.12.3]
at
org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runCluster(ClusterEntrypoint.java:224)
~[flink-dist_2.12-1.12.3.jar:1.12.3]
at
org.apache.flink.runtime.entrypoint.ClusterEntrypoint.lambda$startCluster$1(ClusterEntrypoint.java:178)
~[flink-dist_2.12-1.12.3.jar:1.12.3]
at java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_292]
at javax.security.auth.Subject.doAs(Subject.java:422) ~[?:1.8.0_292]
at
org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1836)
~[flink-shaded-hadoop-2-uber-2.8.3-10.0.jar:2.8.3-10.0]
at
org.apache.flink.runtime.security.contexts.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)
~[flink-dist_2.12-1.12.3.jar:1.12.3]
at
org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:175)
~[flink-dist_2.12-1.12.3.jar:1.12.3]
... 2 more
*I feel flink treats {{*21.96.18.197*}} as a bucket*
when I configure like *{{s3://flink/recovery}}*, I can successfully start my
cluster,
I don’t understand why it fails to start when configured according to the
official website *{{s3:///flink/recovery}}*, but it can start successfully when
configured according to *{{s3://flink/recovery}}*
> can not open dashboard
> -----------------------
>
> Key: FLINK-23945
> URL: https://issues.apache.org/jira/browse/FLINK-23945
> Project: Flink
> Issue Type: Bug
> Components: Connectors / FileSystem, Deployment / Kubernetes
> Affects Versions: 1.12.3
> Reporter: 钟洋洋
> Priority: Minor
>
> Cannot deploy normally using k8s native session mode, but no error log is
> found
>
> Details are in the comments section
>
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
