2018-06-28 08:10:35,599 ERROR org.apache.flink.runtime.jobmanager.JobManager                - Failed to run JobManager.
java.io.IOException: Could not create FileSystem for highly available storage (high-availability.storageDir)
	at org.apache.flink.runtime.blob.BlobUtils.createFileSystemBlobStore(BlobUtils.java:119)
	at org.apache.flink.runtime.blob.BlobUtils.createBlobStoreFromConfig(BlobUtils.java:92)
	at org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createHighAvailabilityServices(HighAvailabilityServicesUtils.java:103)
	at org.apache.flink.runtime.jobmanager.JobManager$.runJobManager(JobManager.scala:2010)
	at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$2.apply$mcV$sp(JobManager.scala:2115)
	at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$2.apply(JobManager.scala:2093)
	at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$2.apply(JobManager.scala:2093)
	at scala.util.Try$.apply(Try.scala:192)
	at org.apache.flink.runtime.akka.AkkaUtils$.retryOnBindException(AkkaUtils.scala:755)
	at org.apache.flink.runtime.jobmanager.JobManager$.runJobManager(JobManager.scala:2093)
	at org.apache.flink.runtime.jobmanager.JobManager$$anon$10.call(JobManager.scala:1955)
	at org.apache.flink.runtime.jobmanager.JobManager$$anon$10.call(JobManager.scala:1953)
	at java.security.AccessController.doPrivileged(Native Method)
	at javax.security.auth.Subject.doAs(Subject.java:422)
	at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1807)
	at org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)
	at org.apache.flink.runtime.jobmanager.JobManager$.main(JobManager.scala:1953)
	at org.apache.flink.runtime.jobmanager.JobManager.main(JobManager.scala)
Caused by: java.io.IOException: Cannot instantiate file system for URI: gs://kube-flink/flink/ha
	at org.apache.flink.runtime.fs.hdfs.HadoopFsFactory.create(HadoopFsFactory.java:187)
	at org.apache.flink.core.fs.FileSystem.getUnguardedFileSystem(FileSystem.java:401)
	at org.apache.flink.core.fs.FileSystem.get(FileSystem.java:320)
	at org.apache.flink.core.fs.Path.getFileSystem(Path.java:293)
	at org.apache.flink.runtime.blob.BlobUtils.createFileSystemBlobStore(BlobUtils.java:116)
	... 17 more
Caused by: java.lang.RuntimeException: java.lang.ClassNotFoundException: Class com.google.cloud.hadoop.fs.gcs.GoogleHadoopFileSystem not found
	at org.apache.hadoop.conf.Configuration.getClass(Configuration.java:2216)
	at org.apache.hadoop.fs.FileSystem.getFileSystemClass(FileSystem.java:2792)
	at org.apache.flink.runtime.fs.hdfs.HadoopFsFactory.create(HadoopFsFactory.java:99)
	... 21 more
Caused by: java.lang.ClassNotFoundException: Class com.google.cloud.hadoop.fs.gcs.GoogleHadoopFileSystem not found
	at org.apache.hadoop.conf.Configuration.getClassByName(Configuration.java:2122)
	at org.apache.hadoop.conf.Configuration.getClass(Configuration.java:2214)
	... 23 more
java.io.IOException: Could not create FileSystem for highly available storage (high-availability.storageDir)
	at org.apache.flink.runtime.blob.BlobUtils.createFileSystemBlobStore(BlobUtils.java:119)
	at org.apache.flink.runtime.blob.BlobUtils.createBlobStoreFromConfig(BlobUtils.java:92)
	at org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createHighAvailabilityServices(HighAvailabilityServicesUtils.java:103)
	at org.apache.flink.runtime.jobmanager.JobManager$.runJobManager(JobManager.scala:2010)
	at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$2.apply$mcV$sp(JobManager.scala:2115)
	at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$2.apply(JobManager.scala:2093)
	at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$2.apply(JobManager.scala:2093)
	at scala.util.Try$.apply(Try.scala:192)
	at org.apache.flink.runtime.akka.AkkaUtils$.retryOnBindException(AkkaUtils.scala:755)
	at org.apache.flink.runtime.jobmanager.JobManager$.runJobManager(JobManager.scala:2093)
	at org.apache.flink.runtime.jobmanager.JobManager$$anon$10.call(JobManager.scala:1955)
	at org.apache.flink.runtime.jobmanager.JobManager$$anon$10.call(JobManager.scala:1953)
	at java.security.AccessController.doPrivileged(Native Method)
	at javax.security.auth.Subject.doAs(Subject.java:422)
	at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1807)
	at org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)
	at org.apache.flink.runtime.jobmanager.JobManager$.main(JobManager.scala:1953)
	at org.apache.flink.runtime.jobmanager.JobManager.main(JobManager.scala)
Caused by: java.io.IOException: Cannot instantiate file system for URI: gs://kube-flink/flink/ha
	at org.apache.flink.runtime.fs.hdfs.HadoopFsFactory.create(HadoopFsFactory.java:187)
	at org.apache.flink.core.fs.FileSystem.getUnguardedFileSystem(FileSystem.java:401)
	at org.apache.flink.core.fs.FileSystem.get(FileSystem.java:320)
	at org.apache.flink.core.fs.Path.getFileSystem(Path.java:293)
	at org.apache.flink.runtime.blob.BlobUtils.createFileSystemBlobStore(BlobUtils.java:116)
	... 17 more
Caused by: java.lang.RuntimeException: java.lang.ClassNotFoundException: Class com.google.cloud.hadoop.fs.gcs.GoogleHadoopFileSystem not found
	at org.apache.hadoop.conf.Configuration.getClass(Configuration.java:2216)
	at org.apache.hadoop.fs.FileSystem.getFileSystemClass(FileSystem.java:2792)
	at org.apache.flink.runtime.fs.hdfs.HadoopFsFactory.create(HadoopFsFactory.java:99)
	... 21 more
Caused by: java.lang.ClassNotFoundException: Class com.google.cloud.hadoop.fs.gcs.GoogleHadoopFileSystem not found
	at org.apache.hadoop.conf.Configuration.getClassByName(Configuration.java:2122)
	at org.apache.hadoop.conf.Configuration.getClass(Configuration.java:2214)
	... 23 more