flink1.19和hive3.1.3,cdc从mysql同步数据到hive,插入时报错?
使用的是flink sql处理流程是从mysql进kafka之后,通过kafka插入hive,在插入数据时会报错,选了upsert-kafka,sql没有更新或者删除操作 Flink SQL> [ERROR] Could not execute SQL statement. Reason: org.apache.flink.table.api.TableException: Table si...
DataWorks通过脚本模式配置离线同步任务,从Hive同步数据到HBase,是参数位置不对吗?
DataWorks通过脚本模式配置离线同步任务,从Hive同步数据到HBase,读取hive时设置了参数,运行报错,是参数位置不对吗?
实时计算 Flink版产品使用问题之kafka2hive同步数据时,如何回溯历史数据
问题一:flink中,join如果不指定窗口,会把join结果一直存储下来吗? flink中,join如果不指定窗口,会把join结果一直存储下来吗? 参考答案: Apache Flink 中,如果不指定窗口进行 join,join 结果不会无限期地存储下来。在无窗口的情况下进行 join,Flink 会根据数据流的到达顺序和关联键进行即时 join。...

DataWorks 从hive 同步数据到Starrcoks 这个写入端的参数文档嘛?
DataWorks 从hive 同步数据到Starrcoks 这个写入端的参数文档嘛?我源端读取都很快 但是我写入这一段超级慢 每次只能写5mb文件进去
请教下,kafka2hive采用flinksql同步数据,如果想要回溯历史数据,应该怎么做呢?
请教下,kafka2hive采用flinksql同步数据,如果想要回溯历史数据,应该怎么做呢?是跑批任务一个小时一个小时回溯呢?还是跑一个流任务从指定offset一直运行呢?
FTP同步数据到HIVE报错您尝试读取的列越界
问题描述用户从FTP同步数据到HIVE报错“您尝试读取的列越界,源文件该行有 [1] 列,您尝试读取第 [2] 列”。问题原因文件编码格式错误。解决方案检查文件编码格式,需要保持和选择的格式一样。适用于Dataphin列越界
请问hdfs同步hive表的时候会发生同步数据部分丢失,这种情况怎么解决呀?已经尝试了好几遍,丢了十
请问hdfs同步hive表的时候会发生同步数据部分丢失,这种情况怎么解决呀?已经尝试了好几遍,丢了十几万的数据
当我使用flink cdc+ iceberg+hive同步数据,启用upsert时,提交sql jo
当我使用flink cdc+ iceberg+hive同步数据,启用upsert时,提交sql job报以下错误提示Equality field columns shouldn't be empty 已经设置了主键,使用了iceberg 的v2,请问是要在哪里设置一下吗
集成任务同步数据到Hive时报错GSSinitiatefailed
问题描述Dataphin集成任务同步数据到Hive报错“GSS initiate failed”。问题原因Hive数据源kerberos认证没有成功。解决方案检查Hive数据源的连通性以及集群认证的相关票证是否正常。适用于Dataphin
本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。