发布于: Mar 5, 2021
现在，您可以在适用于 Apache Flink 的 Amazon Kinesis Data Analytics 中使用 Apache Flink 版本 1.11 构建和运行流应用程序。Apache Flink v1.11 改进了 Table API 和 SQL API。Table API 是一种统一的关系 API，适用于流式处理和批处理，并且是专门为与 Apache Flink 配合使用而设计的 SQL 语言的超集。
Flink v1.11 功能包括改进的内存模型和 RocksDB 优化，以提高应用程序的稳定性，并支持 Flink 控制面板中的任务管理器堆栈跟踪。Kinesis Data Analytics 现在支持 JDK 11 和 Scala 2.12，很快还将支持 Python。
Amazon Kinesis Data Analytics 可让您轻松地使用 Apache Flink 实时转换和分析流数据。Apache Flink 是一个用于处理数据流的开源框架和引擎。Amazon Kinesis Data Analytics 降低了构建和管理 Apache Flink 应用程序的复杂性。适用于 Apache Flink 的 Amazon Kinesis Data Analytics 使用内置连接器集成了 Amazon Managed Streaming for Apache Kafka (Amazon MSK)、Amazon Kinesis Data Streams、Amazon Elasticsearch Service、Amazon DynamoDB Streams、Amazon S3 以及自定义集成等。
您可以在我们的文档中了解有关适用于 Apache Flink 的 Amazon Kinesis Data Analytics 的更多信息。您可以访问官方网站，了解有关 Flink 1.11 的更多信息。