回答情况：
提问时间：
问题标签：
1回答
我想对批处理数据执行Flink SQL。(S3中的CSV)例如，我的查询包括对两个表进行筛选和加入筛选的结果。我希望Flink不要以阻塞批处理的方式实现这两个表，然后通过join传递结果，而是使用流哈希连接操作符，就像datastream中的那样。
我怎样才能做到这一点？我正在使用PyFlink。
浏览 6提问于2022-04-02得票数 1
我尝试使用flink api：Table result1 = tableEnv.sql"GROUP BY TUMBLE(rowtime(), INTERVAL '1' DAY
浏览 4提问于2017-06-08得票数 0
回答已采纳
亲爱的所有人，Flink SQL>从table1选择*，其中dt=‘1609739880002’；Flink SQL>从table1中选择计数(*)，其中dt
浏览 2修改于2021-01-17得票数 0
回答已采纳
我正在尝试使用Flink的SQL API从映射中访问键。DataStream<EventHolder> mapEventStream = env.fromCollection(getMaps());
Table alerts = tableE
浏览 34修改于2020-02-09得票数 1
我使用的是Flink v1.7.1。当我使用tableSource、SQL和tableSink完成Flink流作业时，我不知道如何为它添加单元测试。
浏览 21修改于2019-02-28得票数 2
回答已采纳
问题描述:我想通过sql查询mysql中的数据，或者通过sql将其写入es集群。该程序可以成功运行，但es没有数据。.build();
<artifactId>flink-java</artifactId>
<vers
浏览 1修改于2020-12-10得票数 0
我正在创建2个flink sql表，1个用于CSV文件系统，另一个用于kafka。其目标是持续监视文件系统文件夹，并将新的csv文件记录推送到kafka主题。但是我在下面写的查询，推送csv文件记录一次，flink作业进入“完成”模式，任何新的文件都不会被处理。请有人告诉我如何创建flink sql连续流与源和csv文件系统和目标为Kafka。创建源表的Flink SQL
浏览 1提问于2021-03-24得票数 0
回答已采纳
我想在flink SQL中执行count(0)，但它给出的异常如下"number"}}}'
我没有发现任何错误，但它就是不工作，如果我不从模式中计数和删除计数，它会工作得很好，所以我确信sql我检查了fl
浏览 36提问于2019-11-05得票数 0
我在flink sql数据处理中有一个场景，其中有许多kafka消息(json格式)，消息内容的.All相似但不相同。我创建了许多flink表，与消息一一对应，我意识到很难维护kafka主题。1635116133089, }{ "status":"login",
"type":"i
浏览 23提问于2021-11-07得票数 0
回答已采纳
我正在使用Flink SQL客户端(Flink version 1.13.1)提交我的工作，但是，如doc()中提到的SET语句给了我分析错误，也尝试了使用-i文件选项。错误：SET 'sql-client.verbose' = 'tr
浏览 2提问于2021-11-01得票数 0
通过观察输出，我可以看到Flink SQL作业触发器/emitts记录只在扫描完整个主题(并因此读取到内存中？)之后，但我希望一旦找到ingle匹配，作业就会触发记录。我在Flink SQL源表上还有5秒的水印。
我如何指示Flink发送/触发记录，一旦它与连接进行了一次“匹配”？由于当前的工作是在发出任何记录之前扫描整个表，这在我的数据卷中是不可行的。
浏览 3修改于2022-05-31得票数 0
我正在使用Flink SQL来处理批处理情况。如何使用FLINK SQL获取每个组的top-n记录？
浏览 13提问于2019-02-01得票数 0
回答已采纳
我对Flink比较陌生，今天我在Flink 1.11.3会话集群上使用Flink SQL时遇到了一个问题。我注册了一个使用jdbc驱动程序的源表。我的观察CREATE TABLE source_transactions (
txid ST
浏览 7修改于2020-12-22得票数 3
回答已采纳
我想对Flink SQL表执行一个查询，该查询由安全的kafka集群的kafka主题支持。我能够以编程方式执行查询，但无法通过Flink SQL客户端执行。通过SQL client进行的SQL Flink查询
运行此操作将产生以下错误。Flink SQL> CREATE TABLE test_flink11 (`keyid` STRING,`id` STRING,`name` STRING,`address`
浏览 1修改于2021-02-23得票数 1
早些时候，我问Flink是否可以，答案是肯定的。现在，我将更多地研究Flink SQL的功能。在SQL中，这种类型的挑战有时很容易(例如，SELECT 1在常规引擎(如MySQL)中工作)，但有时也是不可能的，例如。对于Flink SQL，我不太确定，当然，如果您想要运行一个快速测试或构建一个可移植的示例，那么它可以消除对其他解决方案的任何硬依赖。除了窗口之外，我在Flink SQL中看不到有时间概念的任何东西，因此在外部，我怀疑这是不可能的。
我不是
浏览 0提问于2021-03-27得票数 1
我在一个应用程序上工作，我想在实时事件和过去的事件上运行Flink SQL。我尝试了一个POC，其中Flink在Kafka等流源上运行SQL，SQL查询只返回新的事件/更改。但是，我想在整个数据上运行SQL，一些数据可能会随着时间的推移而变化。基本上，我的要求是连续查询整个数据。如何使用Flink或任何其他流媒体解决方案来实现这一点？
浏览 0修改于2020-01-01得票数 2
我可以了解一下如何使用Flink SQL解析更改日志事件吗？下面是我尝试通过Flink SQL客户端解析该流的尝试> city_id INT,[ERROR] Could not execute SQL statement
浏览 23提问于2021-02-23得票数 0
回答已采纳
我正在为使用match_recognize的Flink SQL语句编写单元测试。FLINK版本: 1.11
浏览 2修改于2020-09-24得票数 0
回答已采纳
当我使用pyflink hive sql read data insert into es时，抛出以下异常:环境: flink 1.11.2 flink-sql-connector-hive-3.1.2(HiveVectorizedOrcSplitReader.java:99) ~[flink-sql-connector-hive-3.1.2_2.11-1.11.2.jar:1.11.2]
at.nextBatch(OrcShimV210.java:35) ~[flink
浏览 338提问于2020-12-17得票数 0
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号