Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
java.io.FileNotFoundException: File does not exist: hdfs://xxx
一 产生问题背景 我们公司正在准备从cdh迁回社区版hadoop集群 启动flink任务的时候 还未运行就直接报错 Caused by org apache flink yarn YarnClusterDescriptor YarnDepl
Hadoop
Flink生产实战!
flink
Flink任务日志写到kafka【最新1.12,1.13】
这篇文章如果对你有帮助 记得点赞哦 有问题也可以给我评论 一 背景 公司的日志希望能够同一到一个Kibana去做一个同一的展示 那就需要将任务的日志写到kafka Flink1 12开始默认的日志框架就是log4j2 那么配置的方式跟之前l
Flink生产实战!
运维
大数据
Log4j
flink
Flink Sql on Hive 的生产遇到的坑以及优化(持续更新 ...)
1 HiveSource xxxx xxxx s parallelism 200 is higher than the max parallelism 128 Please lower the parallelism or increase
Flink生产实战!
flink
hive
实时大数据
解决flink消费kafka过期数据和目前存量数据的计算(未来的方向)
背景 目前公司业务需要统计超过7天以上的特征统计 但是kafka只存7天的数据 如果只想通过flink sql去计算30天的用户特征要求当天生效 这是完不成的 但是看到下面的分享 感觉未来的方向有了 一 2021 Apache Flink
Flink生产实战!
Iceberg
大数据
flink