You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Max (Jira)" <ji...@apache.org> on 2020/05/28 10:19:00 UTC
[jira] [Created] (FLINK-18000) Flink-job-manger Get a X509 error,
when I try to delpoy flink on kubelet 1.18.2
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)