背景 有一个经过Flink处理数据然后输出到kafka的任务。在运行了一段时间后，突然开始报错，然后任务频繁重启，具体的报错信息如下： 问题定位...

问题 hive表在原有的schema上新增一列后，重新计算历史分区的数据进行覆盖更新后，会发现以下现象： 用hive的select操作从老分区取...

最近在执行Hive SQL的时候遇到一个类型转换异常的错误，无法将Text类型转换为Long。由于异常信息栈比较多，只贴出一些核心异常信息，具体...

背景 常见hive修改字段类型操作 但是有时候修改字段类型会出现以下异常： 其中可能是string类型无法转换为int等强转类型的限制 可以进行...

如果使用trino查询过程中报错跑出以下异常 那么很有可能是以为查询的SQL语句中没有指定对应表的数据库名称。

转载自 https://blog.csdn.net/valada/article/details/104367378 实时去重，一直都是实时领域...

转载自 http://kane-xie.github.io/2017/07/12/2017-07-12_Flink%E4%BD%BF%E7%94...

随着发布机器上maven local repo下第三方包的积累，占据了发布机器上的大部分磁盘，所以将maven local repo的路径切换大...