[漏洞预警]Apache Flink 高危漏洞预警(CVE-2020-17518 CVE-2020-17519)

Jan 07,2021 in Flink read (2036)

2021年1月5日，Apache Flink官方发布安全更新，修复了由蚂蚁安全非攻实验室发现提交的2个高危漏洞： CVE-2020-17519：攻击者可通过REST API使用../跳目录实现系统任意文件读取； CVE-2020-17518：通过构造恶意的http hea...

Hive 2.3.7 安装

Apr 27,2020 in Hive,大数据 read (2143)

1. 下载Hive http://mirror.bit.edu.cn/apache/hive/ 2. 解压配置解压后进入conf目录 cp hive-default.xml.template hive-site.xml 编辑hive-site.xml,增加下面内容,mys...

Jul 26,2017 in Hadoop,Flink read (1461)

Bucketing File Sink 创建一个默认的bucketing sink,sink到一个由时间作为切分的滚动的文件 DataStream<String> input = ...; //只需要一个文件存储的路径 input.addSink(new Buc...

Jul 26,2017 in Kafka read (999)

http://kafka.apache.org/0101/javadoc/index.html?org/apache/kafka/clients/producer/KafkaProducer.html

Jul 26,2017 in Flink,Kafka read (4131)

设置从指定offset开始读取在Flink 1.3.0及以上可以使用setStartFromSpecificOffsets设置从指定offset开始读取 Fault Tolerance 开启checkpoint即可 offset提交行为如果checkpoint被禁用,F...

Jul 24,2017 in Hadoop read (1034)

1. 如何查看Linux系统当前状态 cpu, io, memory, network 进程列表，查找特定进程pid，进程的cpu, io, memory使用情况，系统的打开文件句柄数，线程数，当前用户的打开文件句柄数，线程数 java进程进程pid，内存使用情况，JV...

Jul 13,2017 in Flink,Kafka read (1321)

使Flink输出的数据在多个partition中均匀分布 FlinkKafkaProducerBase的子类可以使用默认的KafkaPartitioner FixedPartitioner(只向partition 0中写数据)也可以使用自己定义的Partitioner(继承...

May 01,2017 in HBase read (1322)

拆分表 help 'split' Split entire table or pass a region to split individual region. With the second parameter, you can specify an explicit ...