Hi Xuyang,
The input records are balanced across subtasks, with debloating buffers
enabled, the records this subtask receives is less as compared to other
subtasks.
If the differences among all subtasks are not significant, we might be
> encountering an IO bottleneck. In this case, we could try
退订真的很麻烦，，，退订了好几次没搞懂
回复的原邮件
| 发件人 | ha.fen...@aisino.com |
| 日期 | 2024年06月25日 17:25 |
| 收件人 | user-zh |
| 抄送至 | |
| 主题 | Re: 回复：cdc读取oracle数据如何解析 |
数据没问题
"ID" "NAME" "ADDTIME""PRICE"
1 "aa" 2024-6-25 14:21:33 12.22
发件人： 15868861416
发送时间： 2024-06-25 17:19
收件人：
检查一下oracle中的DEBEZIUM.PRODUCTS这个表的数据，看你解析中有字符串
| |
博星
|
|
15868861...@163.com
|
回复的原邮件
| 发件人 | ha.fen...@aisino.com |
| 发送日期 | 2024年06月25日 15:54 |
| 收件人 | user-zh |
| 主题 | cdc读取oracle数据如何解析 |
根据文档的代码
JdbcIncrementalSource oracleChangeEventSource =
new OracleSourceBuilder()
Thanks,Rion.I roughly understand.And I still want to know whether the
deployment ofAdaptive Schedulerrelies on Kubernetes? Are
there any cases of deploying FlinkAdaptive Scheduleron bare metal
machine?
Appreciated again.
----
??:
Flink 1.16.0
搜索到社区有相关文章，其中的实例如下：
https://flink.apache.org/2022/11/25/optimising-the-throughput-of-async-sinks-using-a-custom-ratelimitingstrategy/#rationale-behind-the-ratelimitingstrategy-interface
public class TokenBucketRateLimitingStrategy implements RateLimitingStrategy {
