官方文档 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