"这是我的代码:
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:39,323 INFO org.apache.flink.client.cli.CliFrontend - --------------------------- -------------------------------------------------- --- 2018-10-25 12:40:39,324 INFO org.apache.flink.client.cli.CliFrontend - 启动命令行客户端(版本:1.6.1,Rev:23e2636,日期: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:39,676 INFO org.apache.flink.client .cli.CliFrontend - 当前Hadoop / Kerberos用户:root 2018-10-25 12:40:39,676 INFO org.apache.flink.client.cli.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个MiBytes 2018年10月25日12:40:39676 INFO org.apache.flink.client.cli.CliFrontend - JAVA_HOME:/usr/java/jdk1.8.0_172 2018年10月25日12:40 :39,678 INFO org.apache.flink.client.cli.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:39,678 INFO org.apache.flink.client.cli.CliFrontend - 5 2018-10-25 12:40:39,678 INFO org.apache.flink.client.cli.CliFrontend - JVM选项:2018-10-25 12:40:39,678 INFO org.apache.flink.client.cli.CliFrontend - 5 2018-10-25 12:40:39,678 INFO org.apache.flink.client.cli.CliFrontend - JVM选项:2018-10-25 12:40:39,678 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:39,678 INFO org.apache.flink.client。 cli.CliFrontend - -Dlog4j.configuration =文件:2018年10月25日/root/flink-1.6.1/conf/log4j-cli.properties 12:40:39678 INFO org.apache.flink.client.cli.CliFrontend - -Dlogback.configurationFile = file:/root/flink-1.6.1/conf/logback.xml 2018-10-25 12:40:39,678 INFO org.apache.flink.client.cli.CliFrontend - Program Arguments:2018-10 -25 12:40:39,678 INFO org.apache.flink.client.cli.CliFrontend -
运行2018-10-25 12:40:39,678 INFO org.apache.flink.client.cli.CliFrontend - -c 2018-10-25 12:40:39,678 INFO org.apache.flink.client.cli.CliFrontend - dataclean .FlinkDataCleanDemo 2018-10-25 12:40:39,678 INFO org.apache.flink.client.cli.CliFrontend -
--parallelism 2018-10-25 12:40:39,678 INFO org.apache.flink.client.cli.CliFrontend - 4 2018-10-25 12:40:39,678 INFO org.apache.flink.client.cli.CliFrontend - --jobmanager 2018-10-25 12:40:39,679 INFO org.apache.flink.client.cli.CliFrontend -
cuiyk-cdn-test-4:42115 2018-10-25 12:40:39,679 INFO org.apache.flink.client.cli.CliFrontend -
./flinkkafka2tsdb.jar 2018-10-25 12:40:39,679 INFO org.apache.flink.client.cli.CliFrontend - Classpath:/root/flink-1.6.1/lib/flink-python_2.11-1.6.1的.jar:/root/flink-1.6.1/lib/flink-shaded-hadoop2-uber-1.6.1.jar:/root/flink-1.6.1/lib/log4j-1.2.17.jar:/根/弗林克-1.6.1 / lib目录/ SLF4J-log4j12-1.7.7.jar:/root/flink-1.6.1/lib/flink-dist_2.11-1.6.1.jar :: /选择/ Cloudera公司/包裹/ CDH -5.13.3-1.cdh5.13.3.p0.2 / lib / hadoop / etc / hadoop:2018-10-25 12:40:39,679 INFO org.apache.flink.client.cli.CliFrontend - ---- -------------------------------------------------- -------------------------- 2018-10-25 12:40:39,682 INFO org.apache.flink.configuration.GlobalConfiguration - 加载配置属性:classloader.resolve-order,parent-first 2018-10-25 12:40:39,682 INFO org.apache.flink。configuration.GlobalConfiguration - 加载配置属性:jobmanager.rpc.address,localhost 2018-10-25 12:40:39,682 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:39,682 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: 39,683 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: 39,696 INFO org.apache.flink.yarn.cli.FlinkYarnSessionCli
//related dependecies:
<dependency>
<groupId>commons-httpclient</groupId>
<artifactId>commons-httpclient</artifactId>
<version>3.0</version>
</dependency>
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
<version>4.4</version>
</dependency>"
"我刚刚解决了这个问题,在'配置'标签中添加了maven shade插件,如下所示:
<relocations>
<relocation>
<pattern>org.apache.http</pattern>
<shadedPattern>shade.org.apache.http</shadedPattern>
</relocation>
</relocations>"
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。