AI 助理
备案控制台
开发者社区 大数据与机器学习 实时计算 Flink 正文

在richMapFunction中的open方法中，使用多线程读取外部hive的数据，有问题吗？

在richMapFunction中的open方法中，使用多线程读取外部hive的数据，这种方式有什么问题没？

展开
收起
wenti 2023-03-15 10:56:15 306 分享 版权

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

1 条回答
写回答
取消 提交回答
  • 665661

    有lookupjoin，为啥要在map里补数据？——该回答整理自钉群“【③群】Apache Flink China社区”

    2023-03-15 13:46:18
    赞同 展开评论
问答分类：
SQL HIVE 实时计算 Flink版
问答标签：
线程数据 方法线程 Hive数据 方法Hive open方法线程
问答地址：
开发者社区 > 大数据与机器学习 > 实时计算 Flink > 问答
相关问答
实时计算 Flink版
在Flink CDC中这种方式必须是hive的用户创建的表，创建的hdfs文件才能挂载没有其他方法?
58
0
0
在例子中，线程A和线程B更新同一数据导致的不一致问题具体是如何发生的？
53
1
0
MDL_wait::set_status()方法的作用是什么？如何确保线程安全？
25
1
0
在timed_wait方法中，如何确保线程安全地等待和检查状态？
35
1
0
PTS如何实现不同线程独立读取数据文件
51
1
0
在Android开发中，如果当前在子线程，想要调用主线程的方法，有哪些常见的做法？
301
1
0
用Hologres做数据插入时，在这一步遇到了线程阻塞导致程序卡死，有什么好的解决方案吗？
40
0
0
RocketMQ使用线程池，进行异步入库，入库的方法不执行是什么问题？
44
1
0
在同步调用模式下，业务线程是如何拿到结果数据的?
41
1
0
如何在C/C++中创建异步线程来调用Dart方法？
81
1
0
大数据与机器学习

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。

我要提问
收录在圈子:
阿里云实时计算Flink
199210
+ 订阅
实时计算 Flink 版（Alibaba Cloud Realtime Compute for Apache Flink，Powered by Ververica）是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统，由 Apache Flink 创始团队官方出品，拥有全球统一商业化品牌，完全兼容开源 Flink API，提供丰富的企业级增值功能。

相关文章

  • Apache Doris 3.0.4 版本正式发布
  • 从湖仓分离到湖仓一体，四川航空基于 SelectDB 的多源数据联邦分析实践
  • 双11安全保卫战｜阿里云特别活动+阿里集团情报特别活动
  • 中国报表工具的前世今生
  • StarRocks 在爱奇艺大数据场景的实践

    • 热门讨论

    热门文章

  • Flink CDC任务从savepoint/checkpoints状态中恢复作业错误问题
  • flink cdc 有没得官方介绍文档？
  • web-ui 加载会非常慢是什么原因呢？
  • FlinkCDC MySQL 中 scan.startup.mode 用的是什么模式啊？
  • "flink-cdc-connector-mysql，这个报错怎么解决的？
  • Flink1.17为什么需要JDK 11呢？JDK8我试了也能运行
  • Slot request bulk is not fulfillable，20以上job同时部署失败
  • Apache Flink未授权访问上传导致的RCE漏洞，这个漏洞目前方案解决吗？
  • Flink sql将数组炸开，实现hive的explode函数的效果，还有什么其他好的方式？
  • FlinkKafkaConsumer 1.11的clientId什么的看不到这个怎么解决吗？
    • 展开全部
  • 数据仓库介绍与实时数仓案例
  • OPPO数据中台之基石：基于Flink SQL构建实数据仓库
  • 分布式Snapshot和Flink Checkpointing简介
  • Flink SQL 功能解密系列 —— 维表 JOIN 与异步优化
  • 流计算StreamCompute
  • Flume+Kafka+Flink+Redis构建大数据实时处理系统：实时统计网站PV、UV展示
  • 阿里云实时计算产品案例&解决方案汇总
  • 流计算精品翻译: The Dataflow Model
  • Flink SQL 功能解密系列 —— 流式 TopN 挑战与实现
  • 为什么说流处理即未来？
    • 展开全部
    还有其他疑问?
    咨询AI助理