Max created FLINK-18000:
--------------------------- Summary: 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 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._ -- This message was sent by Atlassian Jira (v8.3.4#803005) |
Free forum by Nabble | Edit this page |