这是我的密码：
def saveToOpenTSDB(rows: Iterator[String], url: String) {
val requestConfig: RequestConfig = RequestConfig.custom().setSocketTimeout(2000).setConnectTimeout(2000).setConnectionRequestTimeout(2000).build()
val httpClient: CloseableHttpClient = HttpClients.createDefault() }错误堆栈跟踪：
2018-10-25 12:40:39323 info org.apache.flink.client.clifrontend
2条答案
按热度按时间qeeaahzv1#
-2018-10-25 12:40:39324 info org.apache.flink.client.clifrontend-启动命令行客户端（版本：1.6.1，rev:23e2636, date:14.09.2018 @ 19:56:46 utc）2018-10-25 12:40:39，324 info org.apache.flink.client.cli.clifrontend-操作系统当前用户：root 2018-10-25 12:40:39676 info org.apache.flink.client.clifrontend-当前hadoop/kerberos用户：root 2018-10-25 12:40:39676 info org.apache.flink.client.clifrontend-jvm:java hotspot（tm）64位服务器vm-oracle corporation-1.8/25.172-b11 2018-10-25 12:40:39，676 info org.apache.flink.client.cli.clifrontend-最大堆大小：7136兆字节2018-10-25 12:40:39676 info org.apache.flink.client.cli.clifrontend-java\u home:/usr/java/jdk1.8.0\u 172 2018-10-25 12:40:39678 info org.apache.flink.client.clifrontend-hadoop版本：2.6.5 2018-10-25 12:40:39，678 info org.apache.flink.client.cli.clifrontend-jvm选项：2018-10-25 12:40:39678 info org.apache.flink.client.cli.clifrontend-
-dlog.file=/root/flink-1.6.1/log/flink-root-client-cuiyk-cdn-test-10.log 2018-10-25 12:40:39678 info org.apache.flink.client.cli.clifrontend--dlog4j.configuration=file:/root/flink-1.6.1/conf/log4j-cli.properties 2018-10-25 12:40:39，678 info org.apache.flink.client.cli.clifrontend--dlogback.configurationfile=file:/root/flink-1.6.1/conf/logback.xml 2018-10-25 12:40:39678 info org.apache.flink.client.clifrontend-程序参数：2018-10-25 12:40:39678 info org.apache.flink.client.clifrontend-
运行2018-10-25 12:40:39678 info org.apache.flink.client.clifrontend--c 2018-10-25 12:40:39678 info org.apache.flink.client.clifrontend-dataclean.flinkdatacleandemo 2018-10-25 12:40:39678 info org.apache.flink.client.clifrontend-
--parallelism 2018-10-25 12:40:39678 info org.apache.flink.client.clifrontend-4 2018-10-25 12:40:39678 info org.apache.flink.client.clifrontend---jobmanager 2018-10-25 12:40:39679 info org.apache.flink.client.clifrontend-
cuiyk-cdn-test-4:42115 2018-10-25 12:40:39679信息org.apache.flink.client.clifrontend-
./flinkkafka2tsdb.jar 2018-10-25 12:40:39，679 info org.apache.flink.client.clifrontend-类路径：/1.6.1.1/lib/flink/flink/flink-pyn-pyn 2.11-1.6.1.1.jar.jar：/root/flink-1.6.1/lib/lib/flink/flink-1.6.1/lib/flink/flink-pyk-pypy-py2.11-1.6.1.1.1.jar.jar：/root/flink-1.6.1/lib/flink/flink-hadik-hadodok-2.6.1.1.1.1.1.1.1.1.1.1.1.1.jar。jar：/jar：/jar：/root/根///flink/flk/flk-1.1.1.6.6.6.6.6.6.1.1.1.1.1.1.1.1.1.1.1.视频/hadoop:2018-10-25 12:40:39，679 info org.apache.flink.client.cli.clifrontend
1mrurvl12#
-2018-10-25 12:40:39682 info org.apache.flink.configuration.globalconfiguration-加载配置属性：classloader.resolve-order，父级优先2018-10-25 12:40:39，682 info org.apache.flink.configuration.globalconfiguration-加载配置属性：jobmanager.rpc.address，localhost 2018-10-25 12:40:39682 info org.apache.flink.configuration.globalconfiguration-加载配置属性：jobmanager.rpc.port，6123 2018-10-25 12:40:39，682 info org.apache.flink.configuration.globalconfiguration-加载配置属性：jobmanager.heap.size，1024m 2018-10-25 12:40:39682 info org.apache.flink.configuration.globalconfiguration-加载配置属性：taskmanager.heap.size，1024m 2018-10-25 12:40:39，683 info org.apache.flink.configuration.globalconfiguration-加载配置属性：taskmanager.numberoftaskslots，1 2018-10-25 12:40:39683 info org.apache.flink.configuration.globalconfiguration-加载配置属性：parallelism.default，1 2018-10-25 12:40:39，683 info org.apache.flink.configuration.globalconfiguration-加载配置属性：rest.port，8081 2018-10-25 12:40:39696 info org.apache.flink.yarn.cli.flinkyarnsessioncli
-在/tmp/.yarn properties根目录下找到了Yarn特性文件。2018-10-25 12:40:39914 info org.apache.flink.runtime.security.modules.hadoopmodule-hadoop用户设置为root(auth:simple)2018-10-25 12:40:39936 info org.apache.flink.client.cli.clifrontend-运行“run”命令。2018-10-25 12:40:39940 info org.apache.flink.client.cli frontend-从jar文件2018-10-25 12:40:40314 info org.apache.flink.runtime.rest.restclient-rest客户端终结点开始生成程序。2018-10-25 12:40:40316 info org.apache.flink.client.clifrontend-开始执行程序2018-10-25 12:40:40316 info org.apache.flink.client.program.rest.restclusterclient-以交互模式启动程序（分离：false）2018-10-25 12:40:40，346 warn org.apache.flink.streaming.connectors.kafka.flinkkafcumer09-忽略配置的密钥反序列化器（key.deserializer）2018-10-25 12:40:40346 warn org.apache.flink.streaming.connectors.kafka.flinkkafcumer09-忽略配置的值反序列化器（value.deserializer）2018-10-25 12:40:40，532 info org.apache.flink.configuration.globalconfiguration-加载配置属性：classloader.resolve-order，parent first 2018-10-25 12:40:40532 info org.apache.flink.configuration.globalconfiguration-加载配置属性：jobmanager.rpc.address，localhost 2018-10-25 12:40:40，532 info org.apache.flink.configuration.globalconfiguration-加载配置属性：jobmanager.rpc.port，6123 2018-10-25 12:40:40532 info org.apache.flink.configuration.globalconfiguration-加载配置属性：jobmanager.heap.size，1024m 2018-10-25 12:40:40，532 info org.apache.flink.configuration.globalconfiguration-加载配置属性：taskmanager.heap.size，1024m 2018-10-25 12:40:40532 info org.apache.flink.configuration.globalconfiguration-加载配置属性：taskmanager.numberoftaskslots，1 2018-10-25 12:40:40，532 info org.apache.flink.configuration.globalconfiguration-加载配置属性：parallelism.default，1 2018-10-25 12:40:40533 info org.apache.flink.configuration.globalconfiguration-加载配置属性：rest.port，8081 2018-10-25 12:40:40，540 info org.apache.flink.client.program.rest.restclusterclient-提交作业1b45b5780e7067fae20be1db8e7c2f（分离：false）。2018-10-25 12:41:38177 info org.apache.flink.runtime.rest.restclient-正在关闭rest端点。2018-10-25 12:41:38179 info org.apache.flink.runtime.rest.restclient-rest端点关闭完成。2018-10-25 12:41:38180 error org.apache.flink.client.clifrontend-运行命令时出错。org.apache.flink.client.program.programinvocationexception:作业失败(jobid:1b45b5780e0e7067fae20be1db8e7c2f）位于org.apache.flink.client.program.rest.restclusterclient.submitjob（restclusterclient）。java:267)在org.apache.flink.client.program.clusterclient.run（clusterclient。java:486)位于org.apache.flink.streaming.api.environment.streamcontextenvironment.execute（streamcontextenvironment）。java:66)在org.apache.flink.streaming.api.scala.streamexecutionenvironment.execute（streamexecutionenvironment。scala:654)在dataclean.flinkdatacleandemo$.main（flinkdatacleandemo。scala:162)位于sun.reflect.nativemethodaccessorimpl.invoke0（本机方法）的dataclean.flinkdatacleandemo.main（flinkdatacleandemo.scala）sun.reflect.nativemethodaccessorimpl.invoke（nativemethodaccessorimpl。java:62)在sun.reflect.delegatingmethodaccessorimpl.invoke（delegatingmethodaccessorimpl。java:43)在java.lang.reflect.method.invoke（方法。java:498)在org.apache.flink.client.program.packagedprogram.callmain方法（packagedprogram。java:529)在org.apache.flink.client.program.packagedprogram.invokeinteractivemodeforexecution（packagedprogram。java:421)在org.apache.flink.client.program.clusterclient.run（clusterclient。java:426)在org.apache.flink.client.cli.clifrontend.executeprogram（clifrontend。java:804)在org.apache.flink.client.cli.clifrontend.runprogram（clifrontend。java:280)在org.apache.flink.client.cli.clifrontend.run（clifrontend。java:215)在org.apache.flink.client.cli.clifrontend.parseparameters（clifrontend。java:1044)在org.apache.flink.client.cli.clifrontend.lambda$main$11（clifrontend。java:1120)位于javax.security.auth.subject.doas（subject）的java.security.accesscontroller.doprivileged（本机方法）。java:422)在org.apache.hadoop.security.usergroupinformation.doas（用户组信息。java:1692)位于org.apache.flink.runtime.security.hadoopsecuritycontext.runsecuried（hadoopsecuritycontext）。java:41)位于org.apache.flink.client.cli.clifrontend.main（clifrontend。java:1120)原因：java.lang.noclassdeffounderror:无法初始化类org.apache.http.conn.ssl.sslconnectionsocketfactory位于org.apache.http.impl.client.httpclientbuilder.build（httpclientbuilder）。java:912)在org.apache.http.impl.client.httpclients.createdefault（httpclients。java:58)在dataclean.commondeploy$.savetoopentsdb（commondeploy。scala:21)在dataclean.flinkdatacleandemo$$anonfun$main$1.apply（flinkdatacleandemo。scala:152)在dataclean.flinkdatacleandemo$$anonfun$main$1.apply（flinkdatacleandemo。scala:150)在org.apache.flink.streaming.api.scala.datastream$$anon$4.map（datastream。scala:607)在org.apache.flink.streaming.api.operators.streammap.processelement（streammap。java:41)在org.apache.flink.streaming.runtime.tasks.operatorchain$copyingchainingoutput.pushtooperator（operatorchain。java:579)在org.apache.flink.streaming.runtime.tasks.operatorchain$copyingchainingoutput.collect（operatorchain。java:554)在org.apache.flink.streaming.runtime.tasks.operatorchain$copyingchainingoutput.collect（operatorchain。java:534)在org.apache.flink.streaming.api.operators.abstractstreamoperator$countingoutput.collect（abstractstreamoperator）。java:689)位于org.apache.flink.streaming.api.operators.abstractstreamoperator$countingoutput.collect（abstractstreamoperator）。java:667)在org.apache.flink.streaming.api.operators.timestampedcollector.collect（timestampedcollector。java:51)在org.apache.flink.streaming.api.scala.da