t; +
" where r.apply_id = 61558439941351 and t.route_goods_id is not null and
t.is_change = 2 " );
在 2023-12-25 20:46:36，"Jiabao Sun" 写道：
>Hi,
>
>邮件中的图片没显示出来，麻烦把 SQL 贴出来一下。
>
>Best,
>Jiabao
>
>
>On 2023/12/25 1
我的sql如下：
、
t_purch_apply_sent_route 是通过flink cdc创建的
t_purch_apply_sent_route_goods 是普通的jdbc
我期望的结果是返回符合过滤条件的；但现在执行的结果，会返回t_purch_apply_sent_route表所有数据
这显然不符合我的预期，原因应该是因为过滤条件进行了过早的下推
这应该算是bug吧，或者要满足我的预期，该怎么写sql?
退订
| |
杨光跃
|
|
yangguangyuem...@163.com
|
;
view_case3_TOPIC_B 是一个版本视图，现在的问题是如果view_case3_TOPIC_B 的数据不更新，
case3_TOPIC_A 即使有新数据，也不往外输出。
怎么才能做到 case3_TOPIC_A 有数据就会立马触发呢
| |
杨光跃
|
|
yangguangyuem...@163.com
|
签名由网易邮箱大师定制
for sink table when query contains update/delete
record.
我这个只需要追加就可以了吧，该怎么处理呢？
| |
杨光跃
|
|
yangguangyuem...@163.com
|
签名由网易邮箱大师定制
for sink table when query contains update/delete
record.
我这个只需要追加就可以了吧，该怎么处理呢？
| |
杨光跃
|
|
yangguangyuem...@163.com
|
签名由网易邮箱大师定制
在2021年6月30日 15:44，杨光跃 写道：
收到了，谢谢。
在sql-client里面执行 ： set table.exec.source.idle-timeout = 10s;
| |
杨光跃
|
|
yangguangyuem...@163.com
|
签名由网易邮箱大师定制
在2021年6月30日
收到了，谢谢。
在sql-client里面执行 ： set table.exec.source.idle-timeout = 10s;
| |
杨光跃
|
|
yangguangyuem...@163.com
|
签名由网易邮箱大师定制
在2021年6月30日 15:36，silence 写道：
可参考
https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/config/#table-exec-source-idle-timeout
在代码中可以通过 .withIdleness(Duration.ofMinutes(1)); 指定空闲数据源也触发水印，那么sql中怎么表示呢
| |
杨光跃
|
|
yangguangyuem...@163.com
|
签名由网易邮箱大师定制
言问 ： SET table.sql-dialect=hive;
然后在查询试试。
| |
杨光跃
|
|
yangguangyuem...@163.com
|
签名由网易邮箱大师定制
在2021年6月24日 18:00，Geoff nie 写道：
非常感谢！我是在sql-client上提交的，修改配置文件已经成功提交了。hive表下分区文件名如下：
part-f3fa374b-c563-49c8-bd7a-b3bd7a5fb66d-0-2
还有两个问题请教下：
1.我通过如下创建了kafka流表，通过flink-sql查
kafka_table 是有数据的，
但是
检查点，checkpoint ，如果是jar包发布，直接在代码里写就可以。 如果用的sql-client提交sql ，可以在配置文件：
sql-client-defaults.yaml 中加入如下配置：
configuration:
execution.checkpointing.interval: 1000
| |
杨光跃
|
|
yangguangyuem...@163.com
|
签名由网易邮箱大师定制
在2021年6月24日 16:09，Geoff nie 写道：
非常感谢答复，不过我仔细考虑了下也没想明白，能具体说下在哪里配置参数吗。感谢
分区的提交需要开启checkpoint，要配置下
| |
杨光跃
|
|
yangguangyuem...@163.com
|
签名由网易邮箱大师定制
在2021年6月24日 14:44，Geoff nie 写道：
您好！我也遇到这个问题了，跟以下问题类似，请问，这个问题解决了吗？非常感谢。
在 2021-02-14 10:43:33，"潘永克" <13311533...@163.com> 写道：
转发邮件信息
发件人："潘永克"
rownum <= 5
| |
杨光跃
|
|
yangguangyuem...@163.com
|
签名由网易邮箱大师定制
在2021年6月23日 10:58，casel.chen 写道：
你指的是TopN吗？https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/sql/queries.html#top-n
但我想知道window topN写法，跟这个还不一样。
我的需求是：
cdc场景同一个主键数据变更频繁，我想定义一个5秒处理时间窗口，在该窗口内取同一主键最新变更记录。用flink sql 1.12如
Apache Flink 1.12 Documentation: Queries
| |
杨光跃
|
|
yangguangyuem...@163.com
|
签名由网易邮箱大师定制
在2021年6月23日 10:09，casel.chen 写道：
请不要截图哦
在 2021-06-23 09:47:46，"杨光跃" 写道：
1.12也支持的
| |
杨光跃
|
|
yangguangyuem...@163.com
|
签名由网易邮箱大师定制
在2021年6月23日 09:45，casel.chen 写道：
官网文档上显示fl
1.12也支持的
| |
杨光跃
|
|
yangguangyuem...@163.com
|
签名由网易邮箱大师定制
在2021年6月23日 09:45，casel.chen 写道：
官网文档上显示flink 1.13支持window topN，但flink 1.12没看到相关文档，请问有什么work around方法吗？
14 matches
Mail list logo
