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