<?xml version="1.0"?>
<feed xmlns="http://www.w3.org/2005/Atom" xml:lang="zh">
	<id>https://arolstar52-zhtest.hf.space/index.php?action=history&amp;feed=atom&amp;title=Apache_Flink</id>
	<title>Apache Flink - 版本历史</title>
	<link rel="self" type="application/atom+xml" href="https://arolstar52-zhtest.hf.space/index.php?action=history&amp;feed=atom&amp;title=Apache_Flink"/>
	<link rel="alternate" type="text/html" href="https://arolstar52-zhtest.hf.space/index.php?title=Apache_Flink&amp;action=history"/>
	<updated>2026-07-15T18:34:48Z</updated>
	<subtitle>在这个wiki上该页的修订历史</subtitle>
	<generator>MediaWiki 1.43.9</generator>
	<entry>
		<id>https://arolstar52-zhtest.hf.space/index.php?title=Apache_Flink&amp;diff=3156489&amp;oldid=prev</id>
		<title>imported&gt;Kcx36：​Cat-a-lot：从分类移除：Category:使用过时图像语法的页面 using Cat-a-lot</title>
		<link rel="alternate" type="text/html" href="https://arolstar52-zhtest.hf.space/index.php?title=Apache_Flink&amp;diff=3156489&amp;oldid=prev"/>
		<updated>2024-11-26T09:56:59Z</updated>

		<summary type="html">&lt;p&gt;&lt;a href=&quot;/wiki/Help:Cat-a-lot&quot; class=&quot;mw-redirect&quot; title=&quot;Help:Cat-a-lot&quot;&gt;Cat-a-lot&lt;/a&gt;：从分类移除：&lt;a href=&quot;/wiki/Category:%E4%BD%BF%E7%94%A8%E8%BF%87%E6%97%B6%E5%9B%BE%E5%83%8F%E8%AF%AD%E6%B3%95%E7%9A%84%E9%A1%B5%E9%9D%A2&quot; title=&quot;Category:使用过时图像语法的页面&quot;&gt;Category:使用过时图像语法的页面&lt;/a&gt; using &lt;a href=&quot;/index.php?title=C:Help:Cat-a-lot&amp;amp;action=edit&amp;amp;redlink=1&quot; class=&quot;new&quot; title=&quot;C:Help:Cat-a-lot（页面不存在）&quot;&gt;Cat-a-lot&lt;/a&gt;&lt;/p&gt;
&lt;p&gt;&lt;b&gt;新页面&lt;/b&gt;&lt;/p&gt;&lt;div&gt;{{NoteTA|G1=IT|G2=FL}}&lt;br /&gt;
{{Infobox software&lt;br /&gt;
| title = Apache Flink&lt;br /&gt;
| name = Apache Flink&lt;br /&gt;
| logo = Apache Flink logo.svg&lt;br /&gt;
| screenshot = &lt;br /&gt;
| caption = &lt;br /&gt;
| developer = [[Apache软件基金会]]&lt;br /&gt;
| released = {{Start date and age|2011|05|df=yes}}&lt;br /&gt;
| programming language = [[Java]]和[[Scala]]&lt;br /&gt;
| operating system = [[跨平台]]&lt;br /&gt;
| genre = {{hlist|数据分析|[[机器学习]]算法}}&lt;br /&gt;
| license = [[Apache许可证]] 2.0&lt;br /&gt;
}}&lt;br /&gt;
&lt;br /&gt;
&amp;#039;&amp;#039;&amp;#039;Apache Flink&amp;#039;&amp;#039;&amp;#039;是由[[Apache软件基金会]]开发的[[开源]]流处理[[软件框架|框架]]，其核心是用[[Java]]和[[Scala]]编写的分布式流数据流引擎。&amp;lt;ref&amp;gt;{{Cite web|url=https://flink.apache.org/|title=Apache Flink: Scalable Batch and Stream Data Processing|work=apache.org|accessdate=2018-12-17|archive-date=2018-12-26|archive-url=https://web.archive.org/web/20181226025402/https://flink.apache.org/|dead-url=no}}&amp;lt;/ref&amp;gt;&amp;lt;ref&amp;gt;{{Cite web|url=https://github.com/apache/flink|title=apache/flink|work=GitHub|accessdate=2018-12-17|archive-date=2019-01-28|archive-url=https://web.archive.org/web/20190128124611/https://github.com/apache/flink|dead-url=no}}&amp;lt;/ref&amp;gt;Flink以[[数据并行]]和[[管道 (软件)|管道]]方式执行任意流数据程序&amp;lt;ref&amp;gt;Alexander Alexandrov, Rico Bergmann, Stephan Ewen, Johann-Christoph Freytag, Fabian Hueske, Arvid Heise, Odej Kao, Marcus Leich, Ulf Leser, Volker Markl, Felix Naumann, Mathias Peters, Astrid Rheinländer, Matthias J. Sax, Sebastian Schelter, Mareike Höger, Kostas Tzoumas, and Daniel Warneke. 2014. &amp;#039;&amp;#039;The Stratosphere platform for big data analytics&amp;#039;&amp;#039;. The VLDB Journal 23, 6 (December 2014), 939-964. [https://dx.doi.org/10.1007/s00778-014-0357-y DOI]&amp;lt;/ref&amp;gt;，Flink的流水线运行时系统可以执行[[批处理任务|批处理]]和流处理程序。&amp;lt;ref&amp;gt;{{Cite web|url=http://www.infoworld.com/article/2919602/hadoop/flink-hadoops-new-contender-for-mapreduce-spark.html|title=Apache Flink: New Hadoop contender squares off against Spark|author=Ian Pointer|date=2015-05-07|work=InfoWorld|accessdate=2018-12-17|archive-date=2018-10-23|archive-url=https://web.archive.org/web/20181023160745/https://www.infoworld.com/article/2919602/hadoop/flink-hadoops-new-contender-for-mapreduce-spark.html|dead-url=no}}&amp;lt;/ref&amp;gt;&amp;lt;ref&amp;gt;{{Cite web|url=http://www.odbms.org/blog/2015/06/on-apache-flink-interview-with-volker-markl/|title=On Apache Flink. Interview with Volker Markl.|work=odbms.org|accessdate=2018-12-17|archive-date=2018-10-23|archive-url=https://web.archive.org/web/20181023120357/http://www.odbms.org/blog/2015/06/on-apache-flink-interview-with-volker-markl/|dead-url=no}}&amp;lt;/ref&amp;gt;此外，Flink的运行时本身也支持[[迭代法|迭代算法]]的执行。&amp;lt;ref&amp;gt;Stephan Ewen, Kostas Tzoumas, Moritz Kaufmann, and Volker Markl. 2012. &amp;#039;&amp;#039;Spinning fast iterative data flows&amp;#039;&amp;#039;. Proc. VLDB Endow. 5, 11 (July 2012), 1268-1279. [https://dx.doi.org/10.14778/2350229.2350245 DOI]&amp;lt;/ref&amp;gt;&lt;br /&gt;
&lt;br /&gt;
Flink提供高吞吐量、低延迟的流数据引擎&amp;lt;ref&amp;gt;{{Cite news|url=https://yahooeng.tumblr.com/post/135321837876/benchmarking-streaming-computation-engines-at|title=Benchmarking Streaming Computation Engines at Yahoo!|work=Yahoo Engineering|accessdate=2017-02-23|archive-date=2017-05-01|archive-url=https://web.archive.org/web/20170501180320/https://yahooeng.tumblr.com/post/135321837876/benchmarking-streaming-computation-engines-at|dead-url=no}}&amp;lt;/ref&amp;gt;以及对事件-时间处理和状态管理的支持。Flink应用程序在发生机器故障时具有容错能力，并且支持exactly-once语义。&amp;lt;ref name=&amp;quot;:2&amp;quot;&amp;gt;{{Cite arXiv |title=Lightweight Asynchronous Snapshots for Distributed Dataflows |author1=Paris Carbone |author2=Gyula Fóra |author3=Stephan Ewen |author4=Seif Haridi |author5=Kostas Tzoumas |year=2015 |arxiv=1506.08603 |version=v1}}&amp;lt;/ref&amp;gt;程序可以用Java、Scala&amp;lt;ref&amp;gt;{{Cite web|url=https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/datastream_api.html|title=Apache Flink 1.2.0 Documentation: Flink DataStream API Programming Guide|accessdate=2017-02-23|work=ci.apache.org|language=en|archive-date=2017-02-23|archive-url=https://web.archive.org/web/20170223213110/https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/datastream_api.html|dead-url=no}}&amp;lt;/ref&amp;gt;、[[Python]]&amp;lt;ref&amp;gt;{{Cite web|url=https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/batch/python.html|title=Apache Flink 1.2.0 Documentation: Python Programming Guide|accessdate=2017-02-23|work=ci.apache.org|language=en|archive-date=2017-02-21|archive-url=https://web.archive.org/web/20170221101948/https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/batch/python.html|dead-url=no}}&amp;lt;/ref&amp;gt;和[[SQL]]&amp;lt;ref&amp;gt;{{Cite web|url=https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/table_api.html|title=Apache Flink 1.2.0 Documentation: Table and SQL|accessdate=2017-02-23|work=ci.apache.org|language=en|archive-date=2017-02-23|archive-url=https://web.archive.org/web/20170223212855/https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/table_api.html|dead-url=no}}&amp;lt;/ref&amp;gt;等语言编写，并自动编译和优化&amp;lt;ref&amp;gt;Fabian Hueske, Mathias Peters, Matthias J. Sax, Astrid Rheinländer, Rico Bergmann, Aljoscha Krettek, and Kostas Tzoumas. 2012. &amp;#039;&amp;#039;Opening the black boxes in data flow optimization&amp;#039;&amp;#039;. Proc. VLDB Endow. 5, 11 (July 2012), 1256-1267. [https://dx.doi.org/10.14778/2350229.2350244 DOI]&amp;lt;/ref&amp;gt;到在集群或云环境中运行的数据流程序。&amp;lt;ref&amp;gt;Daniel Warneke and Odej Kao. 2009. &amp;#039;&amp;#039;Nephele: efficient parallel data processing in the cloud&amp;#039;&amp;#039;. In Proceedings of the 2nd Workshop on Many-Task Computing on Grids and Supercomputers (MTAGS &amp;#039;09). ACM, New York, NY, USA, Article 8, 10 pages. [http://doi.acm.org/10.1145/1646468.1646476 DOI]&amp;lt;/ref&amp;gt;&lt;br /&gt;
&lt;br /&gt;
Flink并不提供自己的数据存储系统，但为[[Amazon Web Services#Analytics|Amazon Kinesis]]、[[Apache Kafka]]、[[Alluxio]]、[[HDFS]]、[[Apache Cassandra]]和[[Elasticsearch]]等系统提供了数据源和接收器。&amp;lt;ref name=&amp;quot;:0&amp;quot;&amp;gt;{{Cite web|url=https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/connectors/index.html|title=Apache Flink 1.2.0 Documentation: Streaming Connectors|accessdate=2017-02-23|work=ci.apache.org|language=en|archive-date=2017-02-21|archive-url=https://web.archive.org/web/20170221103402/https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/connectors/index.html|dead-url=no}}&amp;lt;/ref&amp;gt;&lt;br /&gt;
&lt;br /&gt;
== 开发 ==&lt;br /&gt;
Apache Flink是由Apache软件基金会内的Apache Flink社区基于[[Apache许可证]]2.0&amp;lt;ref&amp;gt;{{Cite web|url=https://git1-us-west.apache.org/repos/asf?p=flink.git;a=blob;f=LICENSE;hb=HEAD|title=ASF Git Repos - flink.git/blob - LICENSE|work=apache.org|access-date=2018-12-17|archive-url=https://web.archive.org/web/20171023175448/https://git1-us-west.apache.org/repos/asf?p=flink.git;a=blob;f=LICENSE;hb=HEAD|archive-date=2017-10-23|dead-url=yes}}&amp;lt;/ref&amp;gt;开发的，该项目已有超过100位代码提交者和超过[https://github.com/apache/flink 460贡献者。]{{Wayback|url=https://github.com/apache/flink |date=20190128124611 }}&lt;br /&gt;
&lt;br /&gt;
[http://www.data-artisans.com/ data Artisans]{{Wayback|url=http://www.data-artisans.com/ |date=20181218011022 }}是由Apache Flink的创始人创建的公司。&amp;lt;ref&amp;gt;{{Cite web|url=http://data-artisans.com/about/team/|title=Team – data Artisans|accessdate=2017-02-23|work=data-artisans.com|language=en-US|archive-url=https://web.archive.org/web/20170223212401/http://data-artisans.com/about/team/|archive-date=2017-02-23|dead-url=yes}}&amp;lt;/ref&amp;gt;目前，该公司已聘用了12个Apache Flink的代码提交者。&amp;lt;ref&amp;gt;{{Cite web|url=http://flink.apache.org/community.html#people|title=Apache Flink: Community &amp;amp; Project Info|accessdate=2017-02-23|work=flink.apache.org|language=en|archive-date=2017-02-21|archive-url=https://web.archive.org/web/20170221121010/http://flink.apache.org/community.html#people|dead-url=no}}&amp;lt;/ref&amp;gt;&lt;br /&gt;
&lt;br /&gt;
== 概述 ==&lt;br /&gt;
Apache Flink的数据流编程模型在有限和无限数据集上提供单次事件（event-at-a-time）处理。在基础层面，Flink程序由流和转换组成。 “从概念上讲，流是一种（可能永无止境的）数据流记录，转换是一种将一个或多个流作为输入并因此产生一个或多个输出流的操作”。&amp;lt;ref name=&amp;quot;:1&amp;quot;&amp;gt;{{Cite web|url=https://ci.apache.org/projects/flink/flink-docs-release-1.2/concepts/programming-model.html#programs-and-dataflows|title=Apache Flink 1.2.0 Documentation: Dataflow Programming Model|accessdate=2017-02-23|work=ci.apache.org|language=en|archive-date=2017-02-21|archive-url=https://web.archive.org/web/20170221104945/https://ci.apache.org/projects/flink/flink-docs-release-1.2/concepts/programming-model.html#programs-and-dataflows|dead-url=no}}&amp;lt;/ref&amp;gt;&lt;br /&gt;
&lt;br /&gt;
Apache Flink包括两个核心API：用于有界或无界数据流的数据流API和用于有界数据集的数据集API。Flink还提供了一个表API，它是一种类似SQL的表达式语言，用于关系流和批处理，可以很容易地嵌入到Flink的数据流和数据集API中。Flink支持的最高级语言是SQL，它在语义上类似于表API，并将程序表示为SQL查询表达式。&lt;br /&gt;
&lt;br /&gt;
=== 编程模型和分布式运行时 ===&lt;br /&gt;
Flink程序在执行后被映射到流数据流&amp;lt;ref name=&amp;quot;:1&amp;quot; /&amp;gt;，每个Flink数据流以一个或多个源（数据输入，例如消息队列或文件系统）开始，并以一个或多个接收器（数据输出，如消息队列、文件系统或数据库等）结束。Flink可以对流执行任意数量的变换，这些流可以被编排为有向无环数据流图，允许应用程序分支和合并数据流。&lt;br /&gt;
&lt;br /&gt;
Flink提供现成的源和接收连接器，包括[[Kafka|Apache Kafka]]、Amazon Kinesis、[[HDFS]]和[[Apache Cassandra]]等&amp;lt;ref name=&amp;quot;:0&amp;quot; /&amp;gt;。&lt;br /&gt;
&lt;br /&gt;
Flink程序可以作为集群内的分布式系统运行，也可以以独立模式或在YARN、Mesos、基于Docker的环境和其他资源管理框架下进行部署&amp;lt;ref&amp;gt;{{Cite web|url=https://ci.apache.org/projects/flink/flink-docs-release-1.2/concepts/runtime.html|title=Apache Flink 1.2.0 Documentation: Distributed Runtime Environment|accessdate=2017-02-24|work=ci.apache.org|language=en|archive-date=2017-02-21|archive-url=https://web.archive.org/web/20170221102045/https://ci.apache.org/projects/flink/flink-docs-release-1.2/concepts/runtime.html|dead-url=no}}&amp;lt;/ref&amp;gt;。&lt;br /&gt;
&lt;br /&gt;
=== 状态：检查点、保存点和容错 ===&lt;br /&gt;
Apache Flink具有一种基于分布式检查点的轻量级容错机制。&amp;lt;ref name=&amp;quot;:2&amp;quot; /&amp;gt; 检查点是应用程序状态和源流中位置的自动异步快照。在发生故障的情况下，启用了检查点的Flink程序将在恢复时从上一个完成的检查点恢复处理，确保Flink在应用程序中保持一次性（exactly-once）状态语义。检查点机制暴露应用程序代码的接口，以便将外部系统包括在检查点机制中（如打开和提交数据库系统的事务）。&lt;br /&gt;
&lt;br /&gt;
Flink还包括一种名为保存点的机制，它是一种手动触发的检查点。&amp;lt;ref&amp;gt;{{Cite web|url=https://ci.apache.org/projects/flink/flink-docs-release-1.2/concepts/runtime.html#savepoints|title=Apache Flink 1.2.0 Documentation: Distributed Runtime Environment - Savepoints|accessdate=2017-02-24|author=|date=|first=|work=ci.apache.org|language=en|archiveurl=https://web.archive.org/web/20170221102045/https://ci.apache.org/projects/flink/flink-docs-release-1.2/concepts/runtime.html#savepoints|archivedate=2017-02-21|dead-url=no}}&amp;lt;/ref&amp;gt;用户可以生成保存点，停止正在运行的Flink程序，然后从流中的相同应用程序状态和位置恢复程序。 保存点可以在不丢失应用程序状态的情况下对Flink程序或Flink群集进行更新。从Flink 1.2开始，保存点还允许以不同的并行性重新启动应用程序，这使得用户可以适应不断变化的工作负载。&lt;br /&gt;
&lt;br /&gt;
=== 数据流API ===&lt;br /&gt;
Flink的[https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/datastream_api.html 数据流API]{{Wayback|url=https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/datastream_api.html |date=20190121071307 }}支持有界或无界数据流上的转换（如过滤器、聚合和窗口函数），包含了20多种不同类型的转换，可以在Java和Scala中使用。&amp;lt;ref&amp;gt;{{Cite web|url=https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/datastream_api.html|title=Apache Flink 1.2.0 Documentation: Flink DataStream API Programming Guide|accessdate=2017-02-24|work=ci.apache.org|language=en|archive-date=2017-02-23|archive-url=https://web.archive.org/web/20170223213110/https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/datastream_api.html|dead-url=no}}&amp;lt;/ref&amp;gt;&lt;br /&gt;
&lt;br /&gt;
有状态流处理程序的一个简单Scala示例是从连续输入流发出字数并在5秒窗口中对数据进行分组的应用：&amp;lt;syntaxhighlight lang=&amp;quot;scala&amp;quot;&amp;gt;&lt;br /&gt;
import org.apache.flink.streaming.api.scala._&lt;br /&gt;
import org.apache.flink.streaming.api.windowing.time.Time&lt;br /&gt;
&lt;br /&gt;
case class WordCount(word: String, count: Int)&lt;br /&gt;
&lt;br /&gt;
object WindowWordCount {&lt;br /&gt;
  def main(args: Array[String]) {&lt;br /&gt;
&lt;br /&gt;
    val env = StreamExecutionEnvironment.getExecutionEnvironment&lt;br /&gt;
    val text = env.socketTextStream(&amp;quot;localhost&amp;quot;, 9999)&lt;br /&gt;
&lt;br /&gt;
    val counts = text.flatMap { _.toLowerCase.split(&amp;quot;\\W+&amp;quot;) filter { _.nonEmpty } }&lt;br /&gt;
      .map { WordCount(_, 1) }&lt;br /&gt;
      .keyBy(&amp;quot;word&amp;quot;)&lt;br /&gt;
      .timeWindow(Time.seconds(5))&lt;br /&gt;
      .sum(&amp;quot;count&amp;quot;)&lt;br /&gt;
&lt;br /&gt;
    counts.print&lt;br /&gt;
&lt;br /&gt;
    env.execute(&amp;quot;Window Stream WordCount&amp;quot;)&lt;br /&gt;
  }&lt;br /&gt;
}&lt;br /&gt;
&amp;lt;/syntaxhighlight&amp;gt;&lt;br /&gt;
&lt;br /&gt;
==== Apache Beam - Flink Runner ====&lt;br /&gt;
Apache Beam“提供了一种高级统一编程模型，允许（开发人员）实现可在在任何执行引擎上运行批处理和流数据处理作业”。&amp;lt;ref&amp;gt;{{Cite web|url=https://beam.apache.org/|title=Apache Beam|accessdate=2017-02-24|work=beam.apache.org|language=en|archive-date=2017-02-25|archive-url=https://web.archive.org/web/20170225163516/https://beam.apache.org/|dead-url=no}}&amp;lt;/ref&amp;gt;Apache Flink-on-Beam运行器是功能最丰富的、由Beam社区维护的能力矩阵。&amp;lt;ref&amp;gt;{{Cite web|url=https://beam.apache.org/documentation/runners/capability-matrix/|title=Apache Beam Capability Matrix|accessdate=2017-02-24|work=beam.apache.org|language=en|archive-date=2017-02-25|archive-url=https://web.archive.org/web/20170225130229/https://beam.apache.org/documentation/runners/capability-matrix/|dead-url=no}}&amp;lt;/ref&amp;gt;&lt;br /&gt;
&lt;br /&gt;
data Artisans与Apache Flink社区一起，与Beam社区密切合作，开发了一个强大的Flink runner。&amp;lt;ref&amp;gt;{{Cite web|url=https://cloud.google.com/blog/big-data/2016/05/why-apache-beam-a-google-perspective|title=Why Apache Beam? A Google Perspective {{!}} Google Cloud Big Data and Machine Learning Blog  {{!}}  Google Cloud Platform|accessdate=2017-02-24|work=Google Cloud Platform|language=en|archive-date=2017-02-25|archive-url=https://web.archive.org/web/20170225052603/https://cloud.google.com/blog/big-data/2016/05/why-apache-beam-a-google-perspective|dead-url=no}}&amp;lt;/ref&amp;gt;&lt;br /&gt;
&lt;br /&gt;
=== 数据集API ===&lt;br /&gt;
Flink的[https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/batch/index.html 数据集API]{{Wayback|url=https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/batch/index.html |date=20190121080926 }}支持对有界数据集进行转换（如过滤、映射、连接和分组），包含了20多种不同类型的转换。&amp;lt;ref&amp;gt;{{Cite web|url=https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/batch/index.html|title=Apache Flink 1.2.0 Documentation: Flink DataSet API Programming Guide|accessdate=2017-02-24|work=ci.apache.org|language=en|archive-date=2017-02-21|archive-url=https://web.archive.org/web/20170221102200/https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/batch/index.html|dead-url=no}}&amp;lt;/ref&amp;gt; 该API可用于Java、Scala和实验性的Python API。Flink的数据集API在概念上与数据流API类似。&lt;br /&gt;
&lt;br /&gt;
=== 表API和SQL ===&lt;br /&gt;
Flink的[https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/table_api.html 表API]{{Wayback|url=https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/table_api.html |date=20190518171941 }}是一种类似SQL的表达式语言，用于关系流和批处理，可以嵌入Flink的Java和Scala数据集和数据流API中。表API和SQL接口在关系表抽象上运行，可以从外部数据源或现有数据流和数据集创建表。表API支持关系运算符，如表上的选择、聚合和连接等。&lt;br /&gt;
&lt;br /&gt;
也可以使用常规SQL查询表。表API提供了和SQL相同的功能，可以在同一程序中混合使用。将表转换回数据集或数据流时，由关系运算符和SQL查询定义的逻辑计划将使用Apache Calcite进行优化，并转换为数据集或数据流程序。&lt;br /&gt;
&lt;br /&gt;
== Flink Forward ==&lt;br /&gt;
[http://flink-forward.org/ Flink Forward]{{Wayback|url=http://flink-forward.org/ |date=20181218193358 }}是一个关于Apache Flink的年度会议。第一届Flink Forward于2015年在柏林举行。为期两天的会议有来自16个国家的250多名与会者。 会议分为两个部分，Flink开发人员提供30多个技术演示，另外还有一个Flink培训实践。&lt;br /&gt;
&lt;br /&gt;
2016年，350名与会者参加了会议，40多位发言人在3个平行轨道上进行了技术讲座。第三天，与会者被邀请参加实践培训课程。&lt;br /&gt;
&lt;br /&gt;
2017年，该活动也将扩展到旧金山。 会议致力于Flink如何在企业中使用、Flink系统内部、与Flink的生态系统集成以及平台的未来进行技术会谈。它包含主题演讲Flink用户在工业和学术界的讲座以及关于Apache Flink的实践培训课程。&lt;br /&gt;
&lt;br /&gt;
来自以下组织的发言人在Flink Forward会议上发表了演讲：[[阿里巴巴集团]]、{{tsl|en|Amadeus IT Group|Amadeus}}、{{tsl|en|Bouygues Telecom}}、[[第一资本]]、[[Cloudera]]、data Artisans、[[Dell EMC|EMC]]、[[爱立信]]、[[Hortonworks]]、[[华为]]、[[IBM]]、[[Google]]、[[MapR]]、[[MongoDB]]、[[Netflix]]、{{tsl|en|New Relic}}、{{tsl|en|Otto GmbH|Otto Group}}，[[Red Hat]]、[[ResearchGate]]、[[Uber]]和[[Zalando]]。&amp;lt;ref&amp;gt;{{cite web|url=http://2016.flink-forward.org/program/sessions/|title=Sessions {{!}}             FlinkForward {{!}}                             12-14 Sep 2016                         {{!}} Berlin|website=2016.flink-forward.org|language=en-US|access-date=2017-02-24|archive-date=2017-02-25|archive-url=https://web.archive.org/web/20170225051139/http://2016.flink-forward.org/program/sessions/|dead-url=no}}&amp;lt;/ref&amp;gt;&amp;lt;ref&amp;gt;{{cite web|url=http://2015.flink-forward.org/|title=Flink Forward » Flink Forward 2015|website=2015.flink-forward.org|language=en-US|access-date=2017-02-24|archive-date=2017-01-27|archive-url=https://web.archive.org/web/20170127100919/http://2015.flink-forward.org/|dead-url=no}}&amp;lt;/ref&amp;gt;&lt;br /&gt;
&lt;br /&gt;
== 历史 ==&lt;br /&gt;
2010年，研究项目“Stratosphere：云上的信息管理”&amp;lt;ref name=&amp;quot;stratosphere&amp;quot;&amp;gt;{{Cite web|url=http://stratosphere.eu/|title=Stratosphere|work=stratosphere.eu|accessdate=2018-12-18|archive-date=2018-12-24|archive-url=https://web.archive.org/web/20181224102132/http://stratosphere.eu/|dead-url=no}}&amp;lt;/ref&amp;gt;（由德国研究基金会（DFG）资助&amp;lt;ref&amp;gt;{{Cite web|url=http://dfg.de/foerderung/programme/listen/projektdetails/index.jsp?id=132320961|title=DFG - Deutsche Forschungsgemeinschaft -|work=dfg.de|accessdate=2018-12-18|archive-date=2017-02-27|archive-url=https://web.archive.org/web/20170227182145/http://www.dfg.de/foerderung/programme/listen/projektdetails/index.jsp?id=132320961|dead-url=no}}&amp;lt;/ref&amp;gt;）由[[柏林工业大学]]、[[柏林洪堡大學|柏林洪堡大学]]和[[哈索·普拉特纳研究院]]合作启动。Flink从Stratosphere的分布式执行引擎的一个分支开始，于2014年3月成为[[Apache孵化|Apache孵化器]]项目。&amp;lt;ref&amp;gt;{{Cite web|url=https://wiki.apache.org/incubator/StratosphereProposal|title=Stratosphere|work=apache.org|accessdate=2018-12-18|archive-date=2017-10-16|archive-url=https://web.archive.org/web/20171016024041/https://wiki.apache.org/incubator/StratosphereProposal|dead-url=no}}&amp;lt;/ref&amp;gt;2014年12月，Flink成为Apache顶级项目。&amp;lt;ref&amp;gt;{{Cite web|url=https://projects.apache.org/project.html?flink|title=Project Details for Apache Flink|work=apache.org|accessdate=2018-12-18|archive-date=2017-02-08|archive-url=https://web.archive.org/web/20170208033716/https://projects.apache.org/project.html?flink|dead-url=no}}&amp;lt;/ref&amp;gt;&amp;lt;ref&amp;gt;{{Cite web|url=https://blogs.apache.org/foundation/entry/the_apache_software_foundation_announces69|title=The Apache Software Foundation Announces Apache™ Flink™ as a Top-Level Project : The Apache Software Foundation Blog|work=apache.org|accessdate=2018-12-18|archive-date=2018-12-18|archive-url=https://web.archive.org/web/20181218145608/https://blogs.apache.org/foundation/entry/the_apache_software_foundation_announces69|dead-url=no}}&amp;lt;/ref&amp;gt;&amp;lt;ref&amp;gt;{{Cite web|url=http://siliconangle.com/blog/2015/02/09/will-the-mysterious-apache-flink-find-its-sweet-spot-in-the-enterprise|title=Will the mysterious Apache Flink find a sweet spot in the enterprise?|work=siliconangle.com|accessdate=2018-12-18|archive-date=2016-12-28|archive-url=https://web.archive.org/web/20161228053852/http://siliconangle.com/blog/2015/02/09/will-the-mysterious-apache-flink-find-its-sweet-spot-in-the-enterprise/|dead-url=no}}&amp;lt;/ref&amp;gt;&amp;lt;ref&amp;gt;&amp;lt;div&amp;gt;[http://www.heise.de/developer/meldung/Big-Data-Apache-Flink-wird-Top-Level-Projekt-2516177.html (德语)] {{Wayback|url=http://www.heise.de/developer/meldung/Big-Data-Apache-Flink-wird-Top-Level-Projekt-2516177.html |date=20181218193442 }}&amp;lt;/div&amp;gt;&amp;lt;/ref&amp;gt;&lt;br /&gt;
{| class=&amp;quot;wikitable&amp;quot;&lt;br /&gt;
!版本&lt;br /&gt;
!原始发布的日期&lt;br /&gt;
!最新版本&lt;br /&gt;
!发布日期&lt;br /&gt;
|-&lt;br /&gt;
| {{Version|o|0.9}}&lt;br /&gt;
|2015-06-24&lt;br /&gt;
|0.9.1&lt;br /&gt;
|2015-09-01&lt;br /&gt;
|-&lt;br /&gt;
| {{Version|o|0.10}}&lt;br /&gt;
|2015-11-16&lt;br /&gt;
|0.10.2&lt;br /&gt;
|2016-02-11&lt;br /&gt;
|-&lt;br /&gt;
| {{Version|o|1.0}}&lt;br /&gt;
|2016-03-08&lt;br /&gt;
|1.0.3版&lt;br /&gt;
|2016-05-11&lt;br /&gt;
|-&lt;br /&gt;
| {{Version|o|1.1}}&lt;br /&gt;
|2016-08-08&lt;br /&gt;
|1.1.5&lt;br /&gt;
|2017-03-22&lt;br /&gt;
|-&lt;br /&gt;
| {{Version|o|1.2}}&lt;br /&gt;
|2017-02-06&lt;br /&gt;
|1.2.1&lt;br /&gt;
|2017-04-26&lt;br /&gt;
|-&lt;br /&gt;
| {{Version|o|1.3}}&lt;br /&gt;
|2017-06-01&lt;br /&gt;
|1.3.3&lt;br /&gt;
|2018-03-15&lt;br /&gt;
|-&lt;br /&gt;
| {{Version|o|1.4}}&lt;br /&gt;
|2017-12-12&lt;br /&gt;
|1.4.2&lt;br /&gt;
|2018-03-08&lt;br /&gt;
|-&lt;br /&gt;
| {{Version|o|1.5}}&lt;br /&gt;
|2018-05-25&lt;br /&gt;
|1.5.5&lt;br /&gt;
|2018-10-29&lt;br /&gt;
|-&lt;br /&gt;
| {{Version|co|1.6}}&lt;br /&gt;
|2018-08-08&lt;br /&gt;
|1.6.2&lt;br /&gt;
|2018-10-29&lt;br /&gt;
|-&lt;br /&gt;
| {{Version|c|1.7}}&lt;br /&gt;
|2018-11-30&lt;br /&gt;
|1.7.2&lt;br /&gt;
|2019-02-15&lt;br /&gt;
|-&lt;br /&gt;
| colspan=&amp;quot;5&amp;quot; |{{Version|l}}&lt;br /&gt;
|}&lt;br /&gt;
&amp;#039;&amp;#039;发布日期&amp;#039;&amp;#039;&lt;br /&gt;
&lt;br /&gt;
* 08/2018: [https://flink.apache.org/news/2018/08/09/release-1.6.0.html Apache Flink1.6]{{Wayback|url=https://flink.apache.org/news/2018/08/09/release-1.6.0.html |date=20190326201458 }} (09/2018: [https://flink.apache.org/news/2018/09/20/release-1.6.1.html 1.6.1]{{Wayback|url=https://flink.apache.org/news/2018/09/20/release-1.6.1.html |date=20190215130006 }};10/2018: [https://flink.apache.org/news/2018/10/29/release-1.6.2.html 1.6.2]{{Wayback|url=https://flink.apache.org/news/2018/10/29/release-1.6.2.html |date=20181030035750 }})&lt;br /&gt;
* 05/2018: [https://flink.apache.org/news/2018/05/25/release-1.5.0.html Apache Flink1.5]{{Wayback|url=https://flink.apache.org/news/2018/05/25/release-1.5.0.html |date=20180720110112 }} (07/2018: [https://flink.apache.org/news/2018/07/12/release-1.5.1.html 1.5.1]{{Wayback|url=https://flink.apache.org/news/2018/07/12/release-1.5.1.html |date=20180725143546 }};07/2018: [https://flink.apache.org/news/2018/07/31/release-1.5.2.html 1.5.2]{{Wayback|url=https://flink.apache.org/news/2018/07/31/release-1.5.2.html |date=20180801095741 }};08/2018: [https://flink.apache.org/news/2018/08/21/release-1.5.3.html 1.5.3]{{Wayback|url=https://flink.apache.org/news/2018/08/21/release-1.5.3.html |date=20190215130006 }};09/2018: [https://flink.apache.org/news/2018/09/20/release-1.5.4.html 1.5.4]{{Wayback|url=https://flink.apache.org/news/2018/09/20/release-1.5.4.html |date=20190215130006 }};10/2018: [https://flink.apache.org/news/2018/10/29/release-1.5.5.html 1.5.5]{{Wayback|url=https://flink.apache.org/news/2018/10/29/release-1.5.5.html |date=20190215130006 }})&lt;br /&gt;
* 12/2017年: [https://flink.apache.org/news/2017/12/12/release-1.4.0.html Apache Flink1.4]{{Wayback|url=https://flink.apache.org/news/2017/12/12/release-1.4.0.html |date=20181030035821 }} (02/2018: [https://flink.apache.org/news/2018/02/15/release-1.4.1.html 1.4.1]{{Wayback|url=https://flink.apache.org/news/2018/02/15/release-1.4.1.html |date=20180727134930 }};03/2018: [https://flink.apache.org/news/2018/03/08/release-1.4.2.html 1.4.2]{{Wayback|url=https://flink.apache.org/news/2018/03/08/release-1.4.2.html |date=20181030035602 }})&lt;br /&gt;
* 06/2017: [https://flink.apache.org/news/2017/06/01/release-1.3.0.html Apache Flink1.3]{{Wayback|url=https://flink.apache.org/news/2017/06/01/release-1.3.0.html |date=20180724055403 }} (06/2017: [https://flink.apache.org/news/2017/06/23/release-1.3.1.html 1.3.1]{{Wayback|url=https://flink.apache.org/news/2017/06/23/release-1.3.1.html |date=20180303140700 }};08/2017: [https://flink.apache.org/news/2017/08/05/release-1.3.2.html 1.3.2]{{Wayback|url=https://flink.apache.org/news/2017/08/05/release-1.3.2.html |date=20181030035447 }};03/2018: [https://flink.apache.org/news/2018/03/15/release-1.3.3.html 1.3.3]{{Wayback|url=https://flink.apache.org/news/2018/03/15/release-1.3.3.html |date=20181030090531 }})&lt;br /&gt;
* 02/2017: [https://flink.apache.org/news/2017/02/06/release-1.2.0.html Apache Flink1.2]{{Wayback|url=https://flink.apache.org/news/2017/02/06/release-1.2.0.html |date=20180725114221 }} (04/2017: [https://flink.apache.org/news/2017/04/26/release-1.2.1.html 1.2.1]{{Wayback|url=https://flink.apache.org/news/2017/04/26/release-1.2.1.html |date=20181030035817 }})&lt;br /&gt;
* 08/2016: [http://flink.apache.org/news/2016/08/08/release-1.1.0.html Apache Flink1.1]{{Wayback|url=http://flink.apache.org/news/2016/08/08/release-1.1.0.html |date=20180809151930 }} (08/2016: [https://flink.apache.org/news/2016/08/11/release-1.1.1.html 1.1.1]{{Wayback|url=https://flink.apache.org/news/2016/08/11/release-1.1.1.html |date=20181020095016 }};09/2016 [https://flink.apache.org/news/2016/09/05/release-1.1.2.html v1。1.2]{{Wayback|url=https://flink.apache.org/news/2016/09/05/release-1.1.2.html |date=20181020095020 }};10/2016 [https://flink.apache.org/news/2016/10/12/release-1.1.3.html v1。1.3]{{Wayback|url=https://flink.apache.org/news/2016/10/12/release-1.1.3.html |date=20171203215853 }};12/2016 [https://flink.apache.org/news/2016/12/21/release-1.1.4.html v1。1.4]{{Wayback|url=https://flink.apache.org/news/2016/12/21/release-1.1.4.html |date=20181020095007 }};03/2017 [https://flink.apache.org/news/2017/03/23/release-1.1.5.html v1。1.5]{{Wayback|url=https://flink.apache.org/news/2017/03/23/release-1.1.5.html |date=20171203175825 }})&lt;br /&gt;
* 03/2016: [https://flink.apache.org/news/2016/03/08/release-1.0.0.html Apache Flink1.0]{{Wayback|url=https://flink.apache.org/news/2016/03/08/release-1.0.0.html |date=20180613134440 }} (04/2016: [https://flink.apache.org/news/2016/04/06/release-1.0.1.html 1.0.1]{{Wayback|url=https://flink.apache.org/news/2016/04/06/release-1.0.1.html |date=20181218102032 }};04/2016: [https://flink.apache.org/news/2016/04/22/release-1.0.2.html 1.0.2]{{Wayback|url=https://flink.apache.org/news/2016/04/22/release-1.0.2.html |date=20181218102136 }};05/2016 [http://flink.apache.org/news/2016/05/11/release-1.0.3.html v1。0.3]{{Wayback|url=http://flink.apache.org/news/2016/05/11/release-1.0.3.html |date=20171203213858 }})&lt;br /&gt;
* 11/2015: [https://flink.apache.org/news/2015/11/16/release-0.10.0.html Apache Flink0.10]{{Wayback|url=https://flink.apache.org/news/2015/11/16/release-0.10.0.html |date=20181218145620 }} (11/2015: [https://flink.apache.org/news/2015/11/27/release-0.10.1.html 0.10.1]{{Wayback|url=https://flink.apache.org/news/2015/11/27/release-0.10.1.html |date=20171203213227 }};02/2016: [https://flink.apache.org/news/2016/02/11/release-0.10.2.html 0.10.2]{{Wayback|url=https://flink.apache.org/news/2016/02/11/release-0.10.2.html |date=20171203213622 }})&lt;br /&gt;
* 06/2015: [https://flink.apache.org/news/2015/06/24/announcing-apache-flink-0.9.0-release.html Apache Flink0.9]{{Wayback|url=https://flink.apache.org/news/2015/06/24/announcing-apache-flink-0.9.0-release.html |date=20171203213612 }} (09/2015: [https://flink.apache.org/news/2015/09/01/release-0.9.1.html 0.9.1]{{Wayback|url=https://flink.apache.org/news/2015/09/01/release-0.9.1.html |date=20171203212916 }})&lt;br /&gt;
** 04/2015: [https://flink.apache.org/news/2015/04/13/release-0.9.0-milestone1.html Apache Flink0.9-里程碑-1]{{Wayback|url=https://flink.apache.org/news/2015/04/13/release-0.9.0-milestone1.html |date=20181218102201 }}&lt;br /&gt;
&lt;br /&gt;
&amp;#039;&amp;#039;Apache孵化器发布日期&amp;#039;&amp;#039;&lt;br /&gt;
&lt;br /&gt;
* 01/2015: [https://flink.apache.org/news/2015/01/21/release-0.8.html Apache Flink0.8-孵化]{{Wayback|url=https://flink.apache.org/news/2015/01/21/release-0.8.html |date=20181218102138 }}&lt;br /&gt;
* 11/2014: [https://flink.apache.org/news/2014/11/04/release-0.7.0.html Apache Flink0.7-孵化]{{Wayback|url=https://flink.apache.org/news/2014/11/04/release-0.7.0.html |date=20181218102023 }}&lt;br /&gt;
* 08/2014: [https://flink.apache.org/news/2014/08/26/release-0.6.html Apache Flink0.6-孵化]{{Wayback|url=https://flink.apache.org/news/2014/08/26/release-0.6.html |date=20171203215833 }} (09/2014: [https://flink.apache.org/news/2014/09/26/release-0.6.1.html 0.6.1-孵化]{{Wayback|url=https://flink.apache.org/news/2014/09/26/release-0.6.1.html |date=20181218102022 }})&lt;br /&gt;
* 05/2014: Stratosphere 0.5(06/2014:0.5.1;07/2014:0.5.2)&lt;br /&gt;
&lt;br /&gt;
&amp;#039;&amp;#039;Pre-Apache Stratosphere 发布日期&amp;#039;&amp;#039;&lt;br /&gt;
&lt;br /&gt;
* 01/2014: Stratosphere 0.4（0.3版本被跳过）&lt;br /&gt;
* 08/2012: Stratosphere 0.2&lt;br /&gt;
* 05/2011: Stratosphere 0.1（08/2011:0.1.1）&lt;br /&gt;
&lt;br /&gt;
== 参见 ==&lt;br /&gt;
&lt;br /&gt;
* {{tsl|en|List of Apache Software Foundation projects|Apache软件基金会项目列表}}&lt;br /&gt;
* 其他类似的数据处理引擎，如Storm和Spark。&amp;lt;ref&amp;gt;{{Cite web|url=http://ieeexplore.ieee.org/xpl/articleDetails.jsp?arnumber=7530084|title=Benchmarking Streaming Computation Engines: Storm, Flink and Spark Streaming|date=May 2016|format=PDF|publisher=IEEE|accessdate=2018-12-18|archive-date=2020-03-05|archive-url=https://web.archive.org/web/20200305114452/https://ieeexplore.ieee.org/document/7530084/?arnumber=7530084|dead-url=no}}&amp;lt;/ref&amp;gt;&lt;br /&gt;
* [[Apache Beam]]，一种共享编程模型，Flink是其创始后端。&lt;br /&gt;
&lt;br /&gt;
== 参考文献 ==&lt;br /&gt;
&amp;lt;references group=&amp;quot;&amp;quot;&amp;gt;&amp;lt;/references&amp;gt;&lt;br /&gt;
&lt;br /&gt;
== 外部链接 ==&lt;br /&gt;
*{{Official website}}&lt;br /&gt;
&lt;br /&gt;
{{Apache Software Foundation}}&lt;br /&gt;
&lt;br /&gt;
[[Category:自由系統軟體]]&lt;br /&gt;
[[Category:使用Apache许可证的软件]]&lt;br /&gt;
[[Category:Apache软件基金会]]&lt;br /&gt;
[[Category:用Java編程的自由軟體]]&lt;br /&gt;
[[Category:Apache软件基金会项目]]&lt;br /&gt;
[[Category:有未审阅翻译的页面]]&lt;br /&gt;
[[Category:串流處理]]&lt;/div&gt;</summary>
		<author><name>imported&gt;Kcx36</name></author>
	</entry>
</feed>