logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

【异常】Spark写入HBase时写入DataNode失败:dfs.client.block.write.replace-datanode-on-failure.policy

问题描述:在SparkStreaming长时间写入HBase的时候,会下面的异常问题:2017-12-24 23:20:34[ SparkListenerBus:540107357 ] - [ ERROR ]Listener EventLoggingListener threw an exceptionjava.io.IOException: Failed to replace

#spark#hbase#hadoop
【异常】elasticsearch的RestClientAPI请求超时问题:java.lang.RuntimeException: error while performing request

问题描述:在Spark中使用elasticsearch的RestClient API在读取es中数据时,出现TimeoutException,在之前的优化的中做下面的超时设置,这个只能解决request retries exceeded max retry timeout [30000]这种超时:RestClient build = RestClient.builder(httpHosts

#elasticsearch
图数据库之neo4j-jdbc的使用

使用JDBC连接neo4j,并对数据库进行操作。与常规数据库的JDBC 连接类似。

#neo4j
图数据库之Cypher语言

1、什么是Cypher2、写(create、merge、set、delete、remove、foreach、import)3、读(match、optionalmatch、where、start、聚合)4、常规(return、orderby、limit、skip、with、unwind、union)5、函数(谓词、标准函数、集合函数、数学函数、字符串函数)

#数据库
图数据库之Cypher语言

1、什么是Cypher2、写(create、merge、set、delete、remove、foreach、import)3、读(match、optionalmatch、where、start、聚合)4、常规(return、orderby、limit、skip、with、unwind、union)5、函数(谓词、标准函数、集合函数、数学函数、字符串函数)

#数据库
到底了