本文主要是介绍flink1.15 用于外部数据访问的异步 I/O scala版本,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
官方文档 Asynchronous I/O for External Data Access
异步 I/O | Apache Flink
核心问题
问什么有官方文档,我还要写个博客,因为scala Future这块有坑.
1 为什么我的算子显示反压100%
2 为什么我的任务不报错,也没有输出
3 Future对象我该怎么构建,有哪些注意事项.
pom
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>org.example</groupId><artifactId>FlinkLocalDemo</artifactId><version>1.0-SNAPSHOT</version><packaging>jar</packaging><name>FlinkLocalDemo</name><url>h
这篇关于flink1.15 用于外部数据访问的异步 I/O scala版本的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!