在流系统中，数据顺序是个大问题。 我们知道在flink中，使用窗口和水印会乱序处理数据。

嗨，我正在尝试在我的flink模块之一中执行检查点操作，如果我注释掉CoFlatMapFunction检查点是否在取消注

我正在尝试使用Apache Flink 1.11创建一个源表，在这里我可以访问JSON消息中的嵌套属性。我可以从根属性

我正在为使用match_recognize的Flink SQL语句编写单元测试。我正在像这样设置测试数据 <pre><code>Table data =

遵循最新的历史记录服务器文档<a href="https://ci.apache.org/projects/flink/flink-docs-stable/monitoring/historyserver.html"

我编写了一种在本地解析JSON的方法，该方法可以在IDEA中执行，但是当我将其编译为jar包并通过flink run执

我的flink应用程序具有作为sql查询的规则，并且具有一个输入事件源。 sql查询在传入事件上运行/评估，

这可能是一个简单的问题，但我在文档中找不到明确说明的内容：使用<code>StreamExecutionEnvironment.setStreamTi

我想创建一个包含<code>MATCH_RECOGNIZE</code>语句的视图。这会遇到以下错误： <pre><code>org.apache.flink.table.a

我正在使用Flink CEP识别某些事件模式，查询看起来像 <pre><code>select * from $TABLE MATCH_RECOGNIZE( pa

在Flink作业中，多个StatementSet是否起作用？如果是这样，用例是什么？幕后情况如何？看来可以实施这些

有什么方法可以将sql行映射器映射到java数组对象 示例： <pre><code>tableEnvironment.toRetractStream(table,

使用kafka主题作为源和目标的Flink应用程序。 使用 <blockquote> javaVersion ='1.11' flinkVersion ='1.11.1'<br/> sc

<ol> <li>软件版本：</li> </ol> <ul> <li> flink 1.11 </li> <li> hive1.2.1 </li> <li> hadoop2.7.1 </li> </ul> <ol start =“ 2”> <li>

我要为实时数据仓库构建沿袭系统，如何从flink sql中提取表和列沿袭？

示例代码： <pre class="lang-py prettyprint-override"><code>from pyflink.table import EnvironmentSettings, StreamTableEnvironment

我正在使用Flink CEP来检测来自Kafka的事件的模式。为了简单起见，事件只有一种类型。我正在尝试检测连

在Flink SQL中，看来=，==和===都是相同的相等运算符。这是一个示例： <pre><code>from pyflink.table import Envir

我希望将Flink SQL用作对多个不同服务的物化视图。例如，从MySQL＆Redis＆RPC服务读取数据，将它们连接在

我很难理解Flink中的流表。我能理解Hive，将固定的静态数据文件映射到“表”，但是如何体现基于流数