[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

[jira] [Created] (FLINK-11204) flink do not work in security mode with kerberos authentication.

kelun wang created FLINK-11204:

             Summary: flink do not work in security mode with kerberos authentication.
                 Key: FLINK-11204
             Project: Flink
          Issue Type: Bug
          Components: Scala Shell
    Affects Versions: 1.7.0, 1.6.2, 1.5.5, 1.4.2, 1.3.3
            Reporter: kelun wang


When using flink in a cluster with kerberos credential, the script do not supports Kerberos authentication, errors like below will occur:

1) Fail to deploy Yarn cluster.

{code:java} yarn -n 3
Exception in thread "main" java.lang.RuntimeException: Error deploying the YARN cluster
at org.apache.flink.yarn.cli.FlinkYarnSessionCli.createCluster(
at org.apache.flink.yarn.cli.FlinkYarnSessionCli.createCluster(
at org.apache.flink.api.scala.FlinkShell$.deployNewYarnCluster(FlinkShell.scala:256)
at org.apache.flink.api.scala.FlinkShell$.fetchConnectionInfo(FlinkShell.scala:165)
at org.apache.flink.api.scala.FlinkShell$.liftedTree1$1(FlinkShell.scala:189)
at org.apache.flink.api.scala.FlinkShell$.startShell(FlinkShell.scala:188)
at org.apache.flink.api.scala.FlinkShell$.main(FlinkShell.scala:137)
at org.apache.flink.api.scala.FlinkShell.main(FlinkShell.scala)
Caused by: java.lang.IllegalArgumentException: Can't get Kerberos realm
at org.apache.flink.yarn.AbstractYarnClusterDescriptor.deployInternal(
at org.apache.flink.yarn.AbstractYarnClusterDescriptor.deploySessionCluster(
... 8 more

2)Fail to fetch deployed a Flink cluster, when using the following command :

bin/ yarn

def fetchDeployedYarnClusterInfo(
configuration: Configuration,
configurationDirectory: String) = {

val args = ArrayBuffer[String](
"-m", "yarn-cluster"
when fething deployed yarn cluster, with param "-m yarn-cluster" it will create new one, but has no "-n", still fail.


This message was sent by Atlassian JIRA