@羲凡——只为了更好的活着Flink 批处理——多文件写入hdfs(Java)0.本文解决哪种问题假如你有5000个门店甚至更多，产品需要你将每个门店的数据都写成一个文件且以门店命名，这意味着你要写5000或更多的文件，如果你直接用flink批处理writeAsText算子要么报错，要么特别慢，如果报错 Cannot currently handle nodes with more tha...

@羲凡——只为了更好的活着Clickhouse 监控运维常用SQL小结1、查看磁盘空间SELECTname,path,formatReadableSize(free_space) AS free_space,formatReadableSize(total_space) AS total_space,typeFROM system.disks2、查看表大小SELECTtable,formatRea

@羲凡——只为了更好的活着踩坑——Sqoop报错ERROR tool.ExportTool: Error during export控制台打印的报错是19/04/19 20:17:09 ERROR mapreduce.ExportJobBase: Export job failed!19/04/19 20:17:09 ERROR tool.ExportTool: Error during ...

@羲凡——只为了更好的活着踩坑——Flink报错 找不到org.apache.flink.streaming.api.scala.StreamExecutionEnvironment的类文件一.问题背景新建一个项目，准备用java写flinktable，发现报错如下Error:(20, 58) java: 无法访问org.apache.flink.streaming.api.scala.S...