发布于: Nov 20, 2020
现在，您可以在适用于 Apache Flink 的 Amazon Kinesis Data Analytics 中使用 Apache Flink 版本 1.11 来构建和运行流式处理应用程序。Apache Flink v1.11 改进了 Table and SQL API，它是用于流和批处理的统一关系 API，并且是专门为与 Apache Flink 一起使用而设计的 SQL 语言的超集。Apache Flink v1.11 功能还包括改进的内存模型和 RocksDB 优化，可提高应用程序的稳定性，并支持 Apache 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、自定义集成以及更多正在使用的内置连接器。
您可以在我们的文档中了解有关 Amazon Kinesis Data Analytics for Apache Flink 的更多信息。您可以通过访问官方网站来了解有关 Flink 1.11 功能的更多信息。
请参阅 AWS 区域列表，了解 Amazon Kinesis Data Analytics 的区域可用性。