我使用的是 Flink 1.12。我想读取一个 csv，并根据处理时间滚动窗口组。
代码如下，但是没有输出查
我的用例是
<ol>
<li>使用 flink 数据流 api 从 AWS Kinesis 数据流中获取数据并过滤/映射</li>
<li>使用 StreamTa
我正在使用 flink 1.11 并尝试使用 match_recognize 的嵌套查询，如下所示：
<pre><code>select * from events where id
有没有办法从 match_recognize MEASURES 子句中输出所有列？
我尝试了以下方法：
<br/>1.
<pre><code>SELECT * FROM
<strong>我已经成功地将亚马逊 s3 中的 csv 文件数据加载到 FlinkSql 本地机器</strong>
<pre><code>CREATE TABLE fs_
我想实现以下案例：
<pre><code> 1. select count(1) from user;
2. select count(distinct uid) from user;
</code></pre>
Apache Flink/Ververica 社区版 - 问题
我正在尝试向 ververica 社区版添加自定义连接器，但一直出现以下
我创建了一个包含数据类型字段的flink表，错误类型不匹配。
我想知道如何在flink表中创建一个包含数组
当我使用<strong>Flink SQL</strong>执行如下语句时，报错如下：
<strong>请求</strong>
根据<code>user_id</
我有一个 Flink 流程序，它在经过长时间的转换逻辑后具有分支处理逻辑。长的转换逻辑会被执行多次吗
我有一个 Flink 作业，它从数据库更改日志流创建一个动态表。表定义如下所示：
<pre class="lang-scala pre
我正在尝试运行 Flink 客户端应用程序，我正在从文件中读取数据。
应使用 <strong>ProcessFunction</strong> 运
我一直在尝试在 Flink sql-client 中 <code>SOURCE</code> 一个包含 SQL 语句的文件。来自文档：
<块引用>
SOUR
我目前正在尝试在独立的 Flink 环境中调试 IDEA 上的教程项目“table-walkthrough”。我根据教程安装了所需
启动Flink SQL进行数据处理时，发现checkpoint异常：
<pre><code>2021-06-16 14:27:57,484 INFO org.apache.flink.runtime.ch
我收到了一个 ValidationException
功能：使用Flink-SQL消费Kafka
Flink 版本：1.10
Avro :1.10.0
<pre><code>
我目前正在使用 Flink 为防欺诈算法实现数据准备系统。目前，我们面临着能够在特定时间范围后对事件
<pre><code>Flink SQL> INSERT INTO es_sink SELECT 'hello';
[INFO] Submitting SQL update statement to the cluster...
Exception in
我正在将一些为 Flink 1.5 版编写的遗留 Java 代码转换为 Flink 1.13.1 版。具体来说，我正在使用 Table API。我
我正在使用链接中的数据：<a href="https://github.com/ververica/sql-training/wiki/Setting-up-the-Training-Environment" rel="nof
