[
https://issues.apache.org/jira/browse/FLINK-23945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17403791#comment-17403791
]
钟洋洋 commented on FLINK-23945:
-----------------------------
{{high-availability.storageDir: s3:///flink/recovery}}
*When I performed the above configuration, the following error was reported*
Could not start cluster entrypoint KubernetesSessionClusterEntrypoint.
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:/flink/recovery/flink-native-k8s-session-1)
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.IOException: null uri host.
at
org.apache.flink.fs.s3.common.AbstractS3FileSystemFactory.create(AbstractS3FileSystemFactory.java:162)
~[?:?]
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
Caused by: java.lang.NullPointerException: null uri host.
at java.util.Objects.requireNonNull(Objects.java:228) ~[?:1.8.0_292]
at
org.apache.hadoop.fs.s3native.S3xLoginHelper.buildFSURI(S3xLoginHelper.java:72)
~[?:?]
at org.apache.hadoop.fs.s3a.S3AFileSystem.setUri(S3AFileSystem.java:467) ~[?:?]
at org.apache.hadoop.fs.s3a.S3AFileSystem.initialize(S3AFileSystem.java:234)
~[?:?]
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.
> can not open dashboard
> -----------------------
>
> Key: FLINK-23945
> URL: https://issues.apache.org/jira/browse/FLINK-23945
> Project: Flink
> Issue Type: Bug
> Components: Deployment / Kubernetes
> Affects Versions: 1.12.3
> Reporter: 钟洋洋
> Priority: Blocker
>
> 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)
