flink写入Es报Limit of total fields [1000]


ElasticsearchSinkFunction class StringData { private String data; } StringData data = new StringData(jsonData); IndexRequest indexRequest = R

ObjectMapper(Jackson)解析Json对象


ObjectMapper mapper = new ObjectMapper(); // 忽略大小写 mapper.configure(MapperFeature.ACCEPT_CASE_INSENSITIVE_PROPERTIES, true); // 下划线 与 驼峰转化 mapper.

Flink异步读取外部数据(Mysql、Redis)


使用 SingleOutputStreamOperator<String> sream = AsyncDataStream.unorderedWait(stream, new AsyncMySQLRequest() , 20000, T

Python调用jdbcDriver连接其他数据源


Python调用jdbcDriver连接其他数据源 原因 使用python的pyhive pyhs2之类的库,在windows上一直无法正常运行 sasl的库依赖问题 采用折中的方式实现与远端hive的通信 连接hive 下载hive-jdbc-1.1.0-cdh5.12.1-standalone.

mac下安装scrapy


直接执行 pip3 install scrapy error: command ‘/usr/bin/clang’ failed with exit status 1 对应clang的包不正确 解决方案 直接去Apple 官网下载最新版本的Command Line Tools安装即可 安装Comman

如何获取全国省市的经纬点坐标信息


https://lbs.amap.com/api/webservice/guide/api/district/ 登陆高德lbs官网 查询行政区划 =》 中国 2 base 查询中国的两级行政区的坐标点位置 打开控制台 (chrome F12)点击运行 =》 保存请求响应为 js对象 var data

读书笔记-专有名词


边际效用递减原则 合理伤害权 论资排辈制(源于北魏)

wordpress修改目录


移动目录文件夹 如 从 /var/www/html 移动到 /var/www/html/wordpress 选中wordpress的database USE wordpress 查看wp_options表单(数据库的URL存在这里。) mysql> select * from wp_options

HIVE FIRST_VALUE和LAST_VALUE


FIRST_VALUE, 返回序列中第一个值 LAST_VALUE,用于返回序列中最后一个值。 last_value返回异常 hive on spark 中可能存在 oracle相同的问题 order by 时 取的值为当前行之前的最后一个值。 解决方案 使用first_value 逆序排列取值 参

JVM调优-命令大全(转)


JVM调优-命令大全(jps jstat jmap jhat jstack jinfo 常用命令导航 Arnold_zhao:Jps -v 【查看当前进程启动时显示指定的参数】 Jinfo:【查看所有非显示指定的参数】 jinfo -flags 17996 【显示JVM参数等信息】 jinfo -s