You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Yang Wang (Jira)" <ji...@apache.org> on 2020/05/28 11:02:00 UTC
[jira] [Commented] (FLINK-18000) Flink-job-manger Get a X509 error, when I try to delpoy flink on kubelet 1.18.2

    [ https://issues.apache.org/jira/browse/FLINK-18000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118546#comment-17118546 ] 

Yang Wang commented on FLINK-18000:
-----------------------------------

Do you have set the RBAC[1] according to the document[1]? It seems that the jobmanager has been created successfully, however failed to talk to K8s apiserver. Also set the logging will help you to debug[2].

 

[1]. [https://ci.apache.org/projects/flink/flink-docs-master/ops/deployment/native_kubernetes.html#rbac]

[2]. [https://ci.apache.org/projects/flink/flink-docs-master/ops/deployment/native_kubernetes.html#log-files]

> Flink-job-manger Get a X509 error, when I try to  delpoy flink on kubelet 1.18.2
> --------------------------------------------------------------------------------
>
>                 Key: FLINK-18000
>                 URL: https://issues.apache.org/jira/browse/FLINK-18000
>             Project: Flink
>          Issue Type: Bug
>          Components: Deployment / Kubernetes
>    Affects Versions: 1.10.1
>            Reporter: Max
>            Priority: Major
>
> Hi all
>     I try to delpoy the kubernetes-session.sh on my kubernetes 1.18, but it failed. I got a message like this. Get [https://192.168.88.132:10250/containerLogs/default/flink-cluster-c421e366-e9ea-4bd4-8f65-3424cf107860-7f86cdfrbsfq/flink-job-manager?tailLines=5000]×tamps=true: x509: certificate signed by unknown authority
>      
>     _Following is what I do, please fell free to correct me._
>    _step 1 , I have setup a kubernetes cluster 1.18 with 3 nodes._
> _Test it, it seem it is ok._   
> _kubectl get nodes_
> _NAME STATUS ROLES AGE VERSION_
>  _192.168.88.130 Ready <none> 61m v1.18.2_
>  _192.168.88.131 Ready <none> 55m v1.18.2_
>  _192.168.88.132 Ready <none> 45m v1.18.2_
>    _step 2.  git clone the [https://github.com/apache/flink-docker/]_
>      _change the Dockfile like this_  _and build it._
> _git diff_
>  _diff --git a/1.10/scala_2.12-debian/Dockerfile b/1.10/scala_2.12-debian/Dockerfile_
>  _index 6a3e535..c7b5d18 100644_
>  _--- a/1.10/scala_2.12-debian/Dockerfile_
>  _+++ b/1.10/scala_2.12-debian/Dockerfile_
>  _@@ -16,7 +16,7 @@_
>  _# limitations under the License._
>  _###############################################################################_
> _-FROM openjdk:8-jre_
>  _+FROM openjdk:8u242-jre_
> _# Install dependencies_
>  _RUN set -ex; _
>    _docker builder run smooth. I got the image, and tag it as  flink:1.10.2_
>   _step 3._ 
>    _download the flink-1.10.1 package, and run the command like this_
>    _./bin/kubernetes-session.sh _
>  _-Dtaskmanager.memory.process.size=1024m _
>  _-Dkubernetes.taskmanager.cpu=1 _
>  _-Dtaskmanager.numberOfTaskSlots=1 _
>  _-Dresourcemanager.taskmanager-timeout=3600000 _
>  _-Dkubernetes.container.image=flink:1.10.2_
>    _also I changed the kubernetes-session.sh. so I can debug this shell if I need. follow is what I get_
>  
> _++ dirname ./bin/kubernetes-session.sh_
>  _+ bin=./bin_
>  _++ cd ./bin_
>  _++ pwd_
>  _+ bin=/home/aaa/flink/flink-1.10.1/bin_
>  _+ . /home/aaa/flink/flink-1.10.1/bin/config.sh_
>  _++ DEFAULT_ENV_PID_DIR=/tmp_
>  _++ DEFAULT_ENV_LOG_MAX=5_
>  _++ DEFAULT_ENV_JAVA_OPTS=_
>  _++ DEFAULT_ENV_JAVA_OPTS_JM=_
>  _++ DEFAULT_ENV_JAVA_OPTS_TM=_
>  _++ DEFAULT_ENV_JAVA_OPTS_HS=_
>  _++ DEFAULT_ENV_JAVA_OPTS_CLI=_
>  _++ DEFAULT_ENV_SSH_OPTS=_
>  _++ DEFAULT_YARN_CONF_DIR=_
>  _++ DEFAULT_HADOOP_CONF_DIR=_
>  _++ KEY_JOBM_MEM_SIZE=jobmanager.heap.size_
>  _++ KEY_JOBM_MEM_MB=jobmanager.heap.mb_
>  _++ KEY_TASKM_COMPUTE_NUMA=taskmanager.compute.numa_
>  _++ KEY_ENV_PID_DIR=env.pid.dir_
>  _++ KEY_ENV_LOG_DIR=env.log.dir_
>  _++ KEY_ENV_LOG_MAX=env.log.max_
>  _++ KEY_ENV_YARN_CONF_DIR=env.yarn.conf.dir_
>  _++ KEY_ENV_HADOOP_CONF_DIR=env.hadoop.conf.dir_
>  _++ KEY_ENV_JAVA_HOME=env.java.home_
>  _++ KEY_ENV_JAVA_OPTS=env.java.opts_
>  _++ KEY_ENV_JAVA_OPTS_JM=env.java.opts.jobmanager_
>  _++ KEY_ENV_JAVA_OPTS_TM=env.java.opts.taskmanager_
>  _++ KEY_ENV_JAVA_OPTS_HS=env.java.opts.historyserver_
>  _++ KEY_ENV_JAVA_OPTS_CLI=env.java.opts.client_
>  _++ KEY_ENV_SSH_OPTS=env.ssh.opts_
>  _++ KEY_HIGH_AVAILABILITY=high-availability_
>  _++ KEY_ZK_HEAP_MB=zookeeper.heap.mb_
>  _++ BYTES_UNITS=("b" "bytes")_
>  _++ KILO_BYTES_UNITS=("k" "kb" "kibibytes")_
>  _++ MEGA_BYTES_UNITS=("m" "mb" "mebibytes")_
>  _++ GIGA_BYTES_UNITS=("g" "gb" "gibibytes")_
>  _++ TERA_BYTES_UNITS=("t" "tb" "tebibytes")_
>  _++ target=./bin/kubernetes-session.sh_
>  _++ iteration=0_
>  _++ '[' -L ./bin/kubernetes-session.sh ']'_
>  _+++ dirname ./bin/kubernetes-session.sh_
>  _++ bin=./bin_
>  _+++ cd ./bin_
>  _+++ pwd -P_
>  _++ SYMLINK_RESOLVED_BIN=/home/aaa/flink/flink-1.10.1/bin_
>  _++ '[' -z '' ']'_
>  _+++ dirname /home/aaa/flink/flink-1.10.1/bin_
>  _++ FLINK_HOME=/home/aaa/flink/flink-1.10.1_
>  _++ FLINK_LIB_DIR=/home/aaa/flink/flink-1.10.1/lib_
>  _++ FLINK_PLUGINS_DIR=/home/aaa/flink/flink-1.10.1/plugins_
>  _++ FLINK_OPT_DIR=/home/aaa/flink/flink-1.10.1/opt_
>  _+++ manglePath /home/aaa/flink/flink-1.10.1_
>  _++++ uname -s_
>  _+++ UNAME=Linux_
>  _+++ '[' Linux == CYGWIN ']'_
>  _+++ echo /home/aaa/flink/flink-1.10.1_
>  _++ FLINK_HOME_DIR_MANGLED=/home/aaa/flink/flink-1.10.1_
>  _++ '[' -z '' ']'_
>  _++ FLINK_CONF_DIR=/home/aaa/flink/flink-1.10.1/conf_
>  _++ FLINK_BIN_DIR=/home/aaa/flink/flink-1.10.1/bin_
>  _++ DEFAULT_FLINK_LOG_DIR=/home/aaa/flink/flink-1.10.1/log_
>  _++ FLINK_CONF_FILE=flink-conf.yaml_
>  _++ YAML_CONF=/home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _++ export FLINK_CONF_DIR_
>  _++ export FLINK_BIN_DIR_
>  _++ export FLINK_PLUGINS_DIR_
>  _++ export FLINK_LIB_DIR_
>  _++ export FLINK_OPT_DIR_
>  _+++ readFromConfig env.java.home '' /home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _+++ local key=env.java.home_
>  _+++ local defaultValue=_
>  _+++ local configFile=/home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _++++ sed -n 's/^[ ]*env.java.home[ ]*: ([^#]*).*$/\1/p' /home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _++++ sed 's/^ *//;s/ *$//'_
>  _++++ tail -n 1_
>  _+++ local value=_
>  _+++ '[' -z '' ']'_
>  _+++ echo ''_
>  _++ MY_JAVA_HOME=_
>  _++ '[' -z '' ']'_
>  _++ MY_JAVA_HOME=/home/aaa/jdk/jdk1.8.0_211_
>  _++ '[' -z /home/aaa/jdk/jdk1.8.0_211 ']'_
>  _++ JAVA_HOME=/home/aaa/jdk/jdk1.8.0_211_
>  _+++ uname -s_
>  _++ UNAME=Linux_
>  _++ '[' Linux == CYGWIN ']'_
>  _++ [[ -d /home/aaa/jdk/jdk1.8.0_211 ]]_
>  _++ JAVA_RUN=/home/aaa/jdk/jdk1.8.0_211/bin/java_
>  _++ '[' -z kube19216888130 ']'_
>  _++ IS_NUMBER='^[0-9]+$'_
>  _++ '[' -z '' ']'_
>  _+++ readFromConfig jobmanager.heap.size 0 /home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _+++ local key=jobmanager.heap.size_
>  _+++ local defaultValue=0_
>  _+++ local configFile=/home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _++++ sed -n 's/^[ ]*jobmanager.heap.size[ ]*: ([^#]*).*$/\1/p' /home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _++++ sed 's/^ *//;s/ *$//'_
>  _++++ tail -n 1_
>  _+++ local value=1024m_
>  _+++ '[' -z 1024m ']'_
>  _+++ echo 1024m_
>  _++ FLINK_JM_HEAP=1024m_
>  _++ '[' 1024m == 0 ']'_
>  _++ command -v numactl_
>  _++ [[ 1 -ne 0 ]]_
>  _++ FLINK_TM_COMPUTE_NUMA=false_
>  _++ '[' -z '' ']'_
>  _+++ readFromConfig env.log.max 5 /home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _+++ local key=env.log.max_
>  _+++ local defaultValue=5_
>  _+++ local configFile=/home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _++++ sed -n 's/^[ ]*env.log.max[ ]*: ([^#]*).*$/\1/p' /home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _++++ sed 's/^ *//;s/ *$//'_
>  _++++ tail -n 1_
>  _+++ local value=_
>  _+++ '[' -z '' ']'_
>  _+++ echo 5_
>  _++ MAX_LOG_FILE_NUMBER=5_
>  _++ '[' -z '' ']'_
>  _+++ readFromConfig env.log.dir /home/aaa/flink/flink-1.10.1/log /home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _+++ local key=env.log.dir_
>  _+++ local defaultValue=/home/aaa/flink/flink-1.10.1/log_
>  _+++ local configFile=/home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _++++ sed -n 's/^[ ]*env.log.dir[ ]*: ([^#]*).*$/\1/p' /home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _++++ sed 's/^ *//;s/ *$//'_
>  _++++ tail -n 1_
>  _+++ local value=_
>  _+++ '[' -z '' ']'_
>  _+++ echo /home/aaa/flink/flink-1.10.1/log_
>  _++ FLINK_LOG_DIR=/home/aaa/flink/flink-1.10.1/log_
>  _++ '[' -z '' ']'_
>  _+++ readFromConfig env.yarn.conf.dir '' /home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _+++ local key=env.yarn.conf.dir_
>  _+++ local defaultValue=_
>  _+++ local configFile=/home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _++++ sed 's/^ *//;s/ *$//'_
>  _++++ sed -n 's/^[ ]*env.yarn.conf.dir[ ]*: ([^#]*).*$/\1/p' /home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _++++ tail -n 1_
>  _+++ local value=_
>  _+++ '[' -z '' ']'_
>  _+++ echo ''_
>  _++ YARN_CONF_DIR=_
>  _++ '[' -z '' ']'_
>  _+++ readFromConfig env.hadoop.conf.dir '' /home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _+++ local key=env.hadoop.conf.dir_
>  _+++ local defaultValue=_
>  _+++ local configFile=/home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _++++ sed 's/^ *//;s/ *$//'_
>  _++++ sed -n 's/^[ ]*env.hadoop.conf.dir[ ]*: ([^#]*).*$/\1/p' /home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _++++ tail -n 1_
>  _+++ local value=_
>  _+++ '[' -z '' ']'_
>  _+++ echo ''_
>  _++ HADOOP_CONF_DIR=_
>  _++ '[' -z '' ']'_
>  _+++ readFromConfig env.pid.dir /tmp /home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _+++ local key=env.pid.dir_
>  _+++ local defaultValue=/tmp_
>  _+++ local configFile=/home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _++++ sed -n 's/^[ ]*env.pid.dir[ ]*: ([^#]*).*$/\1/p' /home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _++++ sed 's/^ *//;s/ *$//'_
>  _++++ tail -n 1_
>  _+++ local value=_
>  _+++ '[' -z '' ']'_
>  _+++ echo /tmp_
>  _++ FLINK_PID_DIR=/tmp_
>  _++ '[' -z '' ']'_
>  _+++ readFromConfig env.java.opts '' /home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _+++ local key=env.java.opts_
>  _+++ local defaultValue=_
>  _+++ local configFile=/home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _++++ sed -n 's/^[ ]*env.java.opts[ ]*: ([^#]*).*$/\1/p' /home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _++++ tail -n 1_
>  _++++ sed 's/^ *//;s/ *$//'_
>  _+++ local value=_
>  _+++ '[' -z '' ']'_
>  _+++ echo ''_
>  _++ FLINK_ENV_JAVA_OPTS=_
>  _+++ echo ''_
>  _+++ sed -e 's/^"//' -e 's/"$//'_
>  _++ FLINK_ENV_JAVA_OPTS=_
>  _++ '[' -z '' ']'_
>  _+++ readFromConfig env.java.opts.jobmanager '' /home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _+++ local key=env.java.opts.jobmanager_
>  _+++ local defaultValue=_
>  _+++ local configFile=/home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _++++ sed -n 's/^[ ]*env.java.opts.jobmanager[ ]*: ([^#]*).*$/\1/p' /home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _++++ tail -n 1_
>  _++++ sed 's/^ *//;s/ *$//'_
>  _+++ local value=_
>  _+++ '[' -z '' ']'_
>  _+++ echo ''_
>  _++ FLINK_ENV_JAVA_OPTS_JM=_
>  _+++ echo ''_
>  _+++ sed -e 's/^"//' -e 's/"$//'_
>  _++ FLINK_ENV_JAVA_OPTS_JM=_
>  _++ '[' -z '' ']'_
>  _+++ readFromConfig env.java.opts.taskmanager '' /home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _+++ local key=env.java.opts.taskmanager_
>  _+++ local defaultValue=_
>  _+++ local configFile=/home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _++++ sed -n 's/^[ ]*env.java.opts.taskmanager[ ]*: ([^#]*).*$/\1/p' /home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _++++ tail -n 1_
>  _++++ sed 's/^ *//;s/ *$//'_
>  _+++ local value=_
>  _+++ '[' -z '' ']'_
>  _+++ echo ''_
>  _++ FLINK_ENV_JAVA_OPTS_TM=_
>  _+++ sed -e 's/^"//' -e 's/"$//'_
>  _+++ echo ''_
>  _++ FLINK_ENV_JAVA_OPTS_TM=_
>  _++ '[' -z '' ']'_
>  _+++ readFromConfig env.java.opts.historyserver '' /home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _+++ local key=env.java.opts.historyserver_
>  _+++ local defaultValue=_
>  _+++ local configFile=/home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _++++ sed 's/^ *//;s/ *$//'_
>  _++++ tail -n 1_
>  _++++ sed -n 's/^[ ]*env.java.opts.historyserver[ ]*: ([^#]*).*$/\1/p' /home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _+++ local value=_
>  _+++ '[' -z '' ']'_
>  _+++ echo ''_
>  _++ FLINK_ENV_JAVA_OPTS_HS=_
>  _+++ echo ''_
>  _+++ sed -e 's/^"//' -e 's/"$//'_
>  _++ FLINK_ENV_JAVA_OPTS_HS=_
>  _++ '[' -z '' ']'_
>  _+++ readFromConfig env.java.opts.client '' /home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _+++ local key=env.java.opts.client_
>  _+++ local defaultValue=_
>  _+++ local configFile=/home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _++++ sed -n 's/^[ ]*env.java.opts.client[ ]*: ([^#]*).*$/\1/p' /home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _++++ tail -n 1_
>  _++++ sed 's/^ *//;s/ *$//'_
>  _+++ local value=_
>  _+++ '[' -z '' ']'_
>  _+++ echo ''_
>  _++ FLINK_ENV_JAVA_OPTS_CLI=_
>  _+++ echo ''_
>  _+++ sed -e 's/^"//' -e 's/"$//'_
>  _++ FLINK_ENV_JAVA_OPTS_CLI=_
>  _++ '[' -z '' ']'_
>  _+++ readFromConfig env.ssh.opts '' /home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _+++ local key=env.ssh.opts_
>  _+++ local defaultValue=_
>  _+++ local configFile=/home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _++++ sed 's/^ *//;s/ *$//'_
>  _++++ tail -n 1_
>  _++++ sed -n 's/^[ ]*env.ssh.opts[ ]*: ([^#]*).*$/\1/p' /home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _+++ local value=_
>  _+++ '[' -z '' ']'_
>  _+++ echo ''_
>  _++ FLINK_SSH_OPTS=_
>  _++ '[' -z '' ']'_
>  _+++ readFromConfig zookeeper.heap.mb 0 /home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _+++ local key=zookeeper.heap.mb_
>  _+++ local defaultValue=0_
>  _+++ local configFile=/home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _++++ sed -n 's/^[ ]*zookeeper.heap.mb[ ]*: ([^#]*).*$/\1/p' /home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _++++ sed 's/^ *//;s/ *$//'_
>  _++++ tail -n 1_
>  _+++ local value=_
>  _+++ '[' -z '' ']'_
>  _+++ echo 0_
>  _++ ZK_HEAP=0_
>  _++ '[' -z '' ']'_
>  _+++ readFromConfig high-availability '' /home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _+++ local key=high-availability_
>  _+++ local defaultValue=_
>  _+++ local configFile=/home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _++++ sed -n 's/^[ ]*high-availability[ ]*: ([^#]*).*$/\1/p' /home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _++++ tail -n 1_
>  _++++ sed 's/^ *//;s/ *$//'_
>  _+++ local value=_
>  _+++ '[' -z '' ']'_
>  _+++ echo ''_
>  _++ HIGH_AVAILABILITY=_
>  _++ '[' -z '' ']'_
>  _+++ readFromConfig recovery.mode '' /home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _+++ local key=recovery.mode_
>  _+++ local defaultValue=_
>  _+++ local configFile=/home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _++++ sed -n 's/^[ ]*recovery.mode[ ]*: ([^#]*).*$/\1/p' /home/aaa/flink/flink-1.10.1/conf/flink-conf.yaml_
>  _++++ sed 's/^ *//;s/ *$//'_
>  _++++ tail -n 1_
>  _+++ local value=_
>  _+++ '[' -z '' ']'_
>  _+++ echo ''_
>  _++ DEPRECATED_HA=_
>  _++ '[' -z '' ']'_
>  _++ HIGH_AVAILABILITY=none_
>  _++ '[' -z '' ']'_
>  _++ JVM_ARGS=_
>  _++ '[' -z '' ']'_
>  _++ '[' -n /home/aaa/hadoop-2.10.0 ']'_
>  _++ '[' -d /home/aaa/hadoop-2.10.0/conf ']'_
>  _++ '[' -d /home/aaa/hadoop-2.10.0/etc/hadoop ']'_
>  _++ HADOOP_CONF_DIR=/home/aaa/hadoop-2.10.0/etc/hadoop_
>  _++ '[' -z /home/aaa/hadoop-2.10.0/etc/hadoop ']'_
>  _++ INTERNAL_HADOOP_CLASSPATHS=:/home/aaa/hadoop-2.10.0/etc/hadoop:_
>  _++ '[' -n '' ']'_
>  _+ '[' '' = '' ']'_
>  _+ FLINK_IDENT_STRING=aaa_
>  _+ JVM_ARGS=' -Xmx512m'_
>  _+++ constructFlinkClassPath_
>  _+++ local FLINK_DIST_
>  _+++ local FLINK_CLASSPATH_
>  _++++ find /home/aaa/flink/flink-1.10.1/lib '!' -type d -name '*.jar' -print0_
>  _++++ sort -z_
>  _+++ read -d '' -r jarfile_
>  _+++ [[ /home/aaa/flink/flink-1.10.1/lib/flink-dist_2.11-1.10.1.jar =~ .*/flink-dist[^/]*.jar$ ]]_
>  _+++ FLINK_DIST=:/home/aaa/flink/flink-1.10.1/lib/flink-dist_2.11-1.10.1.jar_
>  _+++ read -d '' -r jarfile_
>  _+++ [[ /home/aaa/flink/flink-1.10.1/lib/flink-table_2.11-1.10.1.jar =~ .*/flink-dist[^/]*.jar$ ]]_
>  _+++ [[ '' == '' ]]_
>  _+++ FLINK_CLASSPATH=/home/aaa/flink/flink-1.10.1/lib/flink-table_2.11-1.10.1.jar_
>  _+++ read -d '' -r jarfile_
>  _+++ [[ /home/aaa/flink/flink-1.10.1/lib/flink-table-blink_2.11-1.10.1.jar =~ .*/flink-dist[^/]*.jar$ ]]_
>  _+++ [[ /home/aaa/flink/flink-1.10.1/lib/flink-table_2.11-1.10.1.jar == '' ]]_
>  _+++ FLINK_CLASSPATH=/home/aaa/flink/flink-1.10.1/lib/flink-table_2.11-1.10.1.jar:/home/aaa/flink/flink-1.10.1/lib/flink-table-blink_2.11-1.10.1.jar_
>  _+++ read -d '' -r jarfile_
>  _+++ [[ /home/aaa/flink/flink-1.10.1/lib/log4j-1.2.17.jar =~ .*/flink-dist[^/]*.jar$ ]]_
>  _+++ [[ /home/aaa/flink/flink-1.10.1/lib/flink-table_2.11-1.10.1.jar:/home/aaa/flink/flink-1.10.1/lib/flink-table-blink_2.11-1.10.1.jar == '' ]]_
>  _+++ FLINK_CLASSPATH=/home/aaa/flink/flink-1.10.1/lib/flink-table_2.11-1.10.1.jar:/home/aaa/flink/flink-1.10.1/lib/flink-table-blink_2.11-1.10.1.jar:/home/aaa/flink/flink-1.10.1/lib/log4j-1.2.17.jar_
>  _+++ read -d '' -r jarfile_
>  _+++ [[ /home/aaa/flink/flink-1.10.1/lib/slf4j-log4j12-1.7.15.jar =~ .*/flink-dist[^/]*.jar$ ]]_
>  _+++ [[ /home/aaa/flink/flink-1.10.1/lib/flink-table_2.11-1.10.1.jar:/home/aaa/flink/flink-1.10.1/lib/flink-table-blink_2.11-1.10.1.jar:/home/aaa/flink/flink-1.10.1/lib/log4j-1.2.17.jar == '' ]]_
>  _+++ FLINK_CLASSPATH=/home/aaa/flink/flink-1.10.1/lib/flink-table_2.11-1.10.1.jar:/home/aaa/flink/flink-1.10.1/lib/flink-table-blink_2.11-1.10.1.jar:/home/aaa/flink/flink-1.10.1/lib/log4j-1.2.17.jar:/home/aaa/flink/flink-1.10.1/lib/slf4j-log4j12-1.7.15.jar_
>  _+++ read -d '' -r jarfile_
>  _+++ [[ :/home/aaa/flink/flink-1.10.1/lib/flink-dist_2.11-1.10.1.jar == '' ]]_
>  _+++ echo /home/aaa/flink/flink-1.10.1/lib/flink-table_2.11-1.10.1.jar:/home/aaa/flink/flink-1.10.1/lib/flink-table-blink_2.11-1.10.1.jar:/home/aaa/flink/flink-1.10.1/lib/log4j-1.2.17.jar:/home/aaa/flink/flink-1.10.1/lib/slf4j-log4j12-1.7.15.jar:/home/aaa/flink/flink-1.10.1/lib/flink-dist_2.11-1.10.1.jar_
>  _++ manglePathList /home/aaa/flink/flink-1.10.1/lib/flink-table_2.11-1.10.1.jar:/home/aaa/flink/flink-1.10.1/lib/flink-table-blink_2.11-1.10.1.jar:/home/aaa/flink/flink-1.10.1/lib/log4j-1.2.17.jar:/home/aaa/flink/flink-1.10.1/lib/slf4j-log4j12-1.7.15.jar:/home/aaa/flink/flink-1.10.1/lib/flink-dist_2.11-1.10.1.jar::/home/aaa/hadoop-2.10.0/etc/hadoop:_
>  _+++ uname -s_
>  _++ UNAME=Linux_
>  _++ '[' Linux == CYGWIN ']'_
>  _++ echo /home/aaa/flink/flink-1.10.1/lib/flink-table_2.11-1.10.1.jar:/home/aaa/flink/flink-1.10.1/lib/flink-table-blink_2.11-1.10.1.jar:/home/aaa/flink/flink-1.10.1/lib/log4j-1.2.17.jar:/home/aaa/flink/flink-1.10.1/lib/slf4j-log4j12-1.7.15.jar:/home/aaa/flink/flink-1.10.1/lib/flink-dist_2.11-1.10.1.jar::/home/aaa/hadoop-2.10.0/etc/hadoop:_
>  _+ CC_CLASSPATH=/home/aaa/flink/flink-1.10.1/lib/flink-table_2.11-1.10.1.jar:/home/aaa/flink/flink-1.10.1/lib/flink-table-blink_2.11-1.10.1.jar:/home/aaa/flink/flink-1.10.1/lib/log4j-1.2.17.jar:/home/aaa/flink/flink-1.10.1/lib/slf4j-log4j12-1.7.15.jar:/home/aaa/flink/flink-1.10.1/lib/flink-dist_2.11-1.10.1.jar::/home/aaa/hadoop-2.10.0/etc/hadoop:_
>  _+ log=/home/aaa/flink/flink-1.10.1/log/flink-aaa-k8s-session-kube19216888130.log_
>  _+ log_setting='-Dlog.file=/home/aaa/flink/flink-1.10.1/log/flink-aaa-k8s-session-kube19216888130.log -Dlog4j.configuration=[file:/home/aaa/flink/flink-1.10.1/conf/log4j-console.properties|file://home/aaa/flink/flink-1.10.1/conf/log4j-console.properties] -Dlogback.configurationFile=[file:/home/aaa/flink/flink-1.10.1/conf/logback-console.xml'_|file://home/aaa/flink/flink-1.10.1/conf/logback-console.xml'_]
>  _+ export FLINK_CONF_DIR_
>  _+ /home/aaa/jdk/jdk1.8.0_211/bin/java -Xmx512m -classpath /home/aaa/flink/flink-1.10.1/lib/flink-table_2.11-1.10.1.jar:/home/aaa/flink/flink-1.10.1/lib/flink-table-blink_2.11-1.10.1.jar:/home/aaa/flink/flink-1.10.1/lib/log4j-1.2.17.jar:/home/aaa/flink/flink-1.10.1/lib/slf4j-log4j12-1.7.15.jar:/home/aaa/flink/flink-1.10.1/lib/flink-dist_2.11-1.10.1.jar::/home/aaa/hadoop-2.10.0/etc/hadoop: -Dlog.file=/home/aaa/flink/flink-1.10.1/log/flink-aaa-k8s-session-kube19216888130.log -Dlog4j.configuration=[file:/home/aaa/flink/flink-1.10.1/conf/log4j-console.properties|file://home/aaa/flink/flink-1.10.1/conf/log4j-console.properties] -Dlogback.configurationFile=[file:/home/aaa/flink/flink-1.10.1/conf/logback-console.xml|file://home/aaa/flink/flink-1.10.1/conf/logback-console.xml] org.apache.flink.kubernetes.cli.KubernetesSessionCli -Dtaskmanager.memory.process.size=1024m -Dkubernetes.taskmanager.cpu=1 -Dtaskmanager.numberOfTaskSlots=1 -Dresourcemanager.taskmanager-timeout=3600000 -Dkubernetes.container.image=flink:1.10.2_
>  _2020-05-28 17:27:58,498 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: jobmanager.rpc.address, localhost_
>  _2020-05-28 17:27:58,500 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: jobmanager.rpc.port, 6123_
>  _2020-05-28 17:27:58,500 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: jobmanager.heap.size, 1024m_
>  _2020-05-28 17:27:58,500 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: taskmanager.memory.process.size, 1728m_
>  _2020-05-28 17:27:58,500 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: taskmanager.numberOfTaskSlots, 1_
>  _2020-05-28 17:27:58,500 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: parallelism.default, 1_
>  _2020-05-28 17:27:58,501 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: jobmanager.execution.failover-strategy, region_
>  _2020-05-28 17:27:58,595 INFO org.apache.flink.client.deployment.DefaultClusterClientServiceLoader - Could not load factory due to missing dependencies._
>  _2020-05-28 17:27:59,395 INFO org.apache.flink.runtime.clusterframework.TaskExecutorProcessUtils - The derived from fraction jvm overhead memory (102.400mb (107374184 bytes)) is less than its min value 192.000mb (201326592 bytes), min value will be used instead_
>  _2020-05-28 17:27:59,396 INFO org.apache.flink.runtime.clusterframework.TaskExecutorProcessUtils - The derived from fraction network memory (57.600mb (60397978 bytes)) is less than its min value 64.000mb (67108864 bytes), min value will be used instead_
>  _2020-05-28 17:27:59,403 INFO org.apache.flink.kubernetes.utils.KubernetesUtils - Kubernetes deployment requires a fixed port. Configuration blob.server.port will be set to 6124_
>  _2020-05-28 17:27:59,403 INFO org.apache.flink.kubernetes.utils.KubernetesUtils - Kubernetes deployment requires a fixed port. Configuration taskmanager.rpc.port will be set to 6122_
>  _2020-05-28 17:28:00,626 INFO org.apache.flink.kubernetes.KubernetesClusterDescriptor - Create flink session cluster flink-cluster-c421e366-e9ea-4bd4-8f65-3424cf107860 successfully, JobManager Web Interface: [http://api.k8seasy.com:10935|http://api.k8seasy.com:10935/]_
>    _I think all the steps are success. But I catch some error on the kubernetes-dashboard._
> _log of_ flink-job-manager _in_
>  flink-cluster-c421e366-e9ea-4bd4-8f65-3424cf107860-7f86cdfrbsfq
>   
>     _Get [https://192.168.88.132:10250/containerLogs/default/flink-cluster-c421e366-e9ea-4bd4-8f65-3424cf107860-7f86cdfrbsfq/flink-job-manager?tailLines=5000]×tamps=true: x509: certificate signed by unknown authority_
>     _Would you please tell me how to resolve it?  Thanks._
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)