1.12也支持的
| |
杨光跃
|
|
yangguangyuem...@163.com
|
签名由网易邮箱大师定制
在2021年6月23日 09:45,casel.chen 写道:
官网文档上显示flink 1.13支持window topN,但flink 1.12没看到相关文档,请问有什么work around方法吗?
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
from 上一步的虚拟表) where 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秒处理时间窗口,在该窗口内取同一主键最新变
分区的提交需要开启checkpoint,要配置下
| |
杨光跃
|
|
yangguangyuem...@163.com
|
签名由网易邮箱大师定制
在2021年6月24日 14:44,Geoff nie 写道:
您好!我也遇到这个问题了,跟以下问题类似,请问,这个问题解决了吗?非常感谢。
在 2021-02-14 10:43:33,"潘永克" <13311533...@163.com> 写道:
转发邮件信息
发件人:"潘永克"
检查点,checkpoint ,如果是jar包发布,直接在代码里写就可以。 如果用的sql-client提交sql ,可以在配置文件:
sql-client-defaults.yaml 中加入如下配置:
configuration:
execution.checkpointing.interval: 1000
| |
杨光跃
|
|
yangguangyuem...@163.com
|
签名由网易邮箱大师定制
在2021年6月24日 16:09,Geoff nie 写道:
非常感谢答复,不过我仔细考虑了下也没想明白,能具体说下在哪里配置参数吗。感谢
我们本地部署设置的slot都是1,你可能是在跑着写入任务,没有资源跑读取任务?
你可以设置把写入任务停了,或者设置方言问 : 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
还有两
在代码中可以通过 .withIdleness(Duration.ofMinutes(1)); 指定空闲数据源也触发水印,那么sql中怎么表示呢
| |
杨光跃
|
|
yangguangyuem...@163.com
|
签名由网易邮箱大师定制
收到了,谢谢。
在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
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日
sink table when query contains update/delete
record.
我这个只需要追加就可以了吧,该怎么处理呢?
| |
杨光跃
|
|
yangguangyuem...@163.com
|
签名由网易邮箱大师定制
;
view_case3_TOPIC_B 是一个版本视图,现在的问题是如果view_case3_TOPIC_B 的数据不更新,
case3_TOPIC_A 即使有新数据,也不往外输出。
怎么才能做到 case3_TOPIC_A 有数据就会立马触发呢
| |
杨光跃
|
|
yangguangyuem...@163.com
|
签名由网易邮箱大师定制
退订
| |
杨光跃
|
|
yangguangyuem...@163.com
|
我的sql如下:
、
t_purch_apply_sent_route 是通过flink cdc创建的
t_purch_apply_sent_route_goods 是普通的jdbc
我期望的结果是返回符合过滤条件的;但现在执行的结果,会返回t_purch_apply_sent_route表所有数据
这显然不符合我的预期,原因应该是因为过滤条件进行了过早的下推
这应该算是bug吧,或者要满足我的预期,该怎么写sql?
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
14 matches
Mail list logo