这是我的Flink SQL
<pre class="lang-sql prettyprint-override"><code>SELECT t.reportCode FROM query_record_info as t LEFT JOIN cre
我们有一个来自数据库表的文件路径列表，其中包含创建时的时间戳。试图弄清楚我们如何使用db中的文
我正在将Flink SQL流作业写入磁盘，并希望按年，月和日对数据进行分区。
给出以下表格定义：
<
如何使用独立应用程序（本地执行环境或小型集群）实现flink保存点。
我在flink-config.yaml文件中配置了保
我们有一个关于检查点的问题，那就是如何继续从引导服务器使用kafka。我们设置了flink zookeeper ha，它可
我正在尝试连接两个连续的查询，但始终遇到以下错误：
<code>Rowtime attributes must not be in the input row
我们确实有一个应用程序，它从多个服务中获取SQL请求，并使用Flink的<code>TableEnvironment</code>执行它们。
未得到预期的行为，我的flink应用程序遇到了实时事件，而触发条件则取决于两个事件ABC和XYZ。当两个事
我对flink感到陌生，并试图达到以下要求。
<strong>我的要求</strong>：
我的应用程序正在监听来自事
我需要有关在K8上部署Flink应用程序的帮助
我们有3个源将以SQL查询的形式发送触发条件。总查询量
我在DataStream API上有一项工作，它运行良好，但是我需要使用计算所得的<code>DataStream<Event></code>并将
我正在阅读<a href="https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/sql/" rel="nofollow noreferrer">Flink SQL<
我正在尝试在简单的Flink作业下运行以使用TableAPI计数单词。使用DataStream API读取数据流，并使用StreamTable
我的要求是基于2个事件（EVT_A和EVT_B与顺序无关）生成触发器。这是期望
<pre><code>1. EVT_A arrived. --> N
我想测试Flink作业的配置单元集成。因此测试看起来像
<ol>
<li>设置表环境并初始化HiveCatalog。</li>
<li>
Flink中的KeyBy和GroupBy有何异同？如果仅在Table程序中使用Table / SQL API，GroupBy是否等效于KeyBy？
我有以下任务：
<ol>
<li>使用对Hive表的SQL请求创建作业； </li>
<li>在远程Flink群集上运行此作业； </li>
这是我的Flink CEP MATCH_RECOGNIZE sql。
<pre><code>SELECT E.*
FROM MyEvents
MATCH_RECOGNIZE (
ORDER BY procTime
MEASURES
如何从frilk table API中提取日期时间和时间
<pre><code>final Table select = transactions
.window(Tumble.ov
我想问一下我何时使用<code>JdbcUpsertTableSink</code>将数据写入MySQL，数据没有更新，我设置了MySQL的主键，
