You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Max (Jira)" <ji...@apache.org> on 2020/05/28 10:21:00 UTC

[jira] [Updated] (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:all-tabpanel ]

Max updated FLINK-18000:
------------------------
    Description: 
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._

 

  was:
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/]_

    _and docker build the flink docker images and change the Dockfile like this._

_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 -Dlogback.configurationFile=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 -Dlogback.configurationFile=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._

 


> 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)