[
https://issues.apache.org/jira/browse/FLINK-18000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121509#comment-17121509
]
Max commented on FLINK-18000:
-----------------------------
Thanks for your quickly response. After read the document that you post. I
think there is some wrong with my k8s cluster. so Please close it at first.
> 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)
